Struct WasmDbmsDatabase 

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

The main DBMS database struct, generic over MemoryProvider and AccessControl.

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

Implementations

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

where M: MemoryProvider, A: AccessControl,

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

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

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

Creates a transactional database instance.

pub fn granted( &self, id: &A::Id, table: TableFingerprint, required: TablePerms, ) -> bool

Returns whether id is granted required on table.

pub fn granted_admin(&self, id: &A::Id) -> bool

Returns whether id carries the admin bypass flag.

pub fn granted_manage_acl(&self, id: &A::Id) -> bool

Returns whether id carries the manage_acl flag.

pub fn granted_migrate(&self, id: &A::Id) -> bool

Returns whether id carries the migrate flag.

pub fn grant( &self, caller: &A::Id, target: A::Id, grant: PermGrant, ) -> DbmsResult<()>

Applies a grant on behalf of caller. Self-enforces manage_acl.

pub fn revoke( &self, caller: &A::Id, target: &A::Id, revoke: PermRevoke, ) -> DbmsResult<()>

Applies a revoke on behalf of caller. Self-enforces manage_acl.

pub fn remove_identity(&self, caller: &A::Id, target: &A::Id) -> DbmsResult<()>

Removes target from the ACL on behalf of caller. Self-enforces manage_acl.

pub fn identities( &self, caller: &A::Id, ) -> DbmsResult<Vec<(A::Id, IdentityPerms)>>

Returns every identity in the ACL together with its perms, on behalf of caller. Self-enforces manage_acl.

Trait Implementations

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

where M: MemoryProvider, A: AccessControl,

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<Vec<Vec<(JoinColumnDef, Value)>>>

Runs a join query starting from table, returning rows with JoinColumnDef entries that carry the source table name.

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.