Struct WasmDbmsDatabase 

pub struct WasmDbmsDatabase<'ctx, M>
where
    M: MemoryProvider,
{ /* private fields */ }

The main DBMS database struct, generic over MemoryProvider.

This struct borrows from a DbmsContext and provides all CRUD operations, transaction management, and query execution.

Implementations

impl<'ctx, M> WasmDbmsDatabase<'ctx, M>

where M: MemoryProvider,

pub fn oneshot( ctx: &'ctx DbmsContext<M>, schema: impl DatabaseSchema<M> + 'ctx, ) -> Self

Creates a one-shot (non-transactional) database instance.

pub fn from_transaction( ctx: &'ctx DbmsContext<M>, schema: impl DatabaseSchema<M> + 'ctx, transaction_id: TransactionId, ) -> Self

Creates a transactional database instance.

Trait Implementations

impl<M> Database for WasmDbmsDatabase<'_, M>

where M: MemoryProvider,

fn select<T>(&self, query: Query) -> DbmsResult<Vec<T::Record>>

where T: TableSchema,

Runs a typed SELECT for table T and decodes each row into T::Record.

fn select_raw( &self, table: &str, query: Query, ) -> DbmsResult<Vec<Vec<(ColumnDef, Value)>>>

Runs a SELECT against a table identified by name, returning raw column-value pairs instead of typed records.

fn select_join(&self, table: &str, query: Query) -> DbmsResult<JoinResultSet>

Runs a join query starting from table.

fn aggregate<T>( &self, query: Query, aggregates: &[AggregateFunction], ) -> DbmsResult<Vec<AggregatedRow>>

where T: TableSchema,

Runs an aggregate query for table T, computing the requested aggregate functions per group.

fn insert<T>(&self, record: T::Insert) -> DbmsResult<()>

where T: TableSchema, T::Insert: InsertRecord<Schema = T>,

Inserts a single record into table T.

fn update<T>(&self, patch: T::Update) -> DbmsResult<u64>

where T: TableSchema, T::Update: UpdateRecord<Schema = T>,

Updates rows of table T matching the patch’s where_clause.

fn delete<T>( &self, behaviour: DeleteBehavior, filter: Option<Filter>, ) -> DbmsResult<u64>

where T: TableSchema,

Deletes rows of table T matching filter.

fn commit(&mut self) -> DbmsResult<()>

Commits the active transaction, replaying its operations against stable storage under a single write-ahead journal.

fn rollback(&mut self) -> DbmsResult<()>

Discards every staged operation in the active transaction without touching stable storage, and consumes the transaction handle.

fn has_drift(&self) -> DbmsResult<bool>

Returns true iff the compiled schema differs from the snapshots persisted in stable memory.

fn pending_migrations(&self) -> DbmsResult<Vec<MigrationOp>>

Returns the migration ops needed to bring the on-disk schema in line with the compiled schema, without applying anything.

fn migrate(&mut self, policy: MigrationPolicy) -> DbmsResult<()>

Applies a planned migration under policy.