Struct RuntimeSession 

pub struct RuntimeSession<P>
where
    P: Pager<Blob = EntryHandle> + Send + Sync + 'static,
{ /* private fields */ }

A session for executing operations with optional transaction support.

This is a high-level wrapper around the transaction machinery that provides a clean API for users. Operations can be executed directly or within a transaction.

Implementations

impl<P> RuntimeSession<P>

where P: Pager<Blob = EntryHandle> + Send + Sync + 'static,

pub fn begin_transaction(&self) -> Result<RuntimeStatementResult<P>>

Begin a transaction in this session. Creates an isolated staging context automatically.

pub fn abort_transaction(&self)

Mark the current transaction as aborted due to an error. This should be called when any error occurs during a transaction.

pub fn has_active_transaction(&self) -> bool

Check if this session has an active transaction.

pub fn is_aborted(&self) -> bool

Check if the current transaction has been aborted due to an error.

pub fn commit_transaction(&self) -> Result<RuntimeStatementResult<P>>

Commit the current transaction and apply changes to the base context. If the transaction was aborted, this acts as a ROLLBACK instead.

pub fn rollback_transaction(&self) -> Result<RuntimeStatementResult<P>>

Rollback the current transaction, discarding all changes.

pub fn create_table_plan( &self, plan: CreateTablePlan, ) -> Result<RuntimeStatementResult<P>>

Create a table (outside or inside transaction).

pub fn insert(&self, plan: InsertPlan) -> Result<RuntimeStatementResult<P>>

Insert rows (outside or inside transaction).

pub fn select(&self, plan: SelectPlan) -> Result<RuntimeStatementResult<P>>

Select rows (outside or inside transaction).

pub fn table_rows(&self, table: &str) -> Result<Vec<Vec<PlanValue>>>

Convenience helper to fetch all rows from a table within this session.

pub fn update(&self, plan: UpdatePlan) -> Result<RuntimeStatementResult<P>>

Update rows (outside or inside transaction).

pub fn delete(&self, plan: DeletePlan) -> Result<RuntimeStatementResult<P>>

Delete rows (outside or inside transaction).