Struct TransactionSession 

pub struct TransactionSession<BaseCtx, StagingCtx>
where
    BaseCtx: TransactionContext + 'static,
    StagingCtx: TransactionContext + 'static,
{ /* private fields */ }

A session handle for transaction management.

When dropped, automatically rolls back any active transaction.

Implementations

impl<BaseCtx, StagingCtx> TransactionSession<BaseCtx, StagingCtx>

where BaseCtx: TransactionContext + 'static, StagingCtx: TransactionContext + 'static,

pub fn new( context: Arc<BaseCtx>, session_id: u64, transactions: Arc<Mutex<HashMap<u64, SessionTransaction<BaseCtx, StagingCtx>>>>, txn_manager: Arc<TxnIdManager>, ) -> TransactionSession<BaseCtx, StagingCtx>

pub fn clone_session(&self) -> TransactionSession<BaseCtx, StagingCtx>

Clone this session (reuses the same session_id and shared transaction map). This is necessary to maintain transaction state across Engine clones.

pub fn session_id(&self) -> u64

Get the session ID.

pub fn context(&self) -> &Arc<BaseCtx>

Get the underlying context (for advanced use).

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 is_table_created_in_transaction(&self, table_name: &str) -> bool

Check if a table was created in the current active transaction. Returns true if there’s an active transaction and the table exists in its new_tables set.

pub fn table_column_specs_from_transaction( &self, table_name: &str, ) -> Option<Vec<PlanColumnSpec>>

Get column specifications for a table created in the current transaction. Returns None if there’s no active transaction or the table wasn’t created in it.

pub fn tables_referencing_in_transaction( &self, referenced_table: &str, ) -> Vec<String>

Get tables that reference the given table via foreign keys created in the current transaction. Returns an empty vector if there’s no active transaction or no transactional FKs reference this table.

pub fn has_table_locked_by_other_session(&self, table_name: &str) -> bool

Check if a table is locked by another active session’s transaction. Returns true if ANY other session has this table in their locked_table_names.

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 begin_transaction( &self, staging: Arc<StagingCtx>, ) -> Result<TransactionResult<<BaseCtx as TransactionContext>::Pager>, Error>

Begin a transaction in this session.

pub fn commit_transaction( &self, ) -> Result<(TransactionResult<<BaseCtx as TransactionContext>::Pager>, Vec<PlanOperation>), Error>

Commit the transaction in this session. If the transaction is aborted, this acts as a ROLLBACK instead.

pub fn rollback_transaction( &self, ) -> Result<TransactionResult<<BaseCtx as TransactionContext>::Pager>, Error>

Rollback the transaction in this session.

pub fn execute_operation( &self, operation: PlanOperation, ) -> Result<TransactionResult<<StagingCtx as TransactionContext>::Pager>, Error>

Execute an operation in this session’s transaction, or directly if no transaction is active.

Trait Implementations

impl<BaseCtx, StagingCtx> Drop for TransactionSession<BaseCtx, StagingCtx>

where BaseCtx: TransactionContext, StagingCtx: TransactionContext,

fn drop(&mut self)

Executes the destructor for this type.