Struct SqlTransaction 

pub struct SqlTransaction<'a, S: KVStore + 'a> { /* private fields */ }

SQL transaction wrapping a KV transaction.

Provides SQL-friendly access to table and index storage, with explicit commit/rollback control.

Implementations

impl<'a, S: KVStore + 'a> SqlTransaction<'a, S>

pub fn mode(&self) -> TxnMode

Returns the transaction mode.

pub fn table_storage<'b>( &'b mut self, table_meta: &TableMetadata, ) -> TableStorage<'b, 'a, S::Transaction<'a>>

Get a table storage handle.

Returns a TableStorage instance that borrows this transaction. The returned storage is valid for the duration of the borrow.

The table_id is obtained from table_meta.table_id.

pub fn index_storage<'b>( &'b mut self, index_id: u32, unique: bool, column_indices: Vec<usize>, ) -> IndexStorage<'b, 'a, S::Transaction<'a>>

Get an index storage handle.

Returns an IndexStorage instance that borrows this transaction. The returned storage is valid for the duration of the borrow.

pub fn delete_prefix(&mut self, prefix: &[u8]) -> Result<()>

Delete all keys with the given prefix.

pub fn with_table<R, F>( &mut self, table_meta: &TableMetadata, f: F, ) -> Result<R>

where F: FnOnce(&mut TableStorage<'_, 'a, S::Transaction<'a>>) -> Result<R>,

Execute operations on a table within a closure.

This is a convenience method that creates a TableStorage, executes the closure, and returns the result.

The table_id is obtained from table_meta.table_id.

pub fn with_index<R, F>( &mut self, index_id: u32, unique: bool, column_indices: Vec<usize>, f: F, ) -> Result<R>

where F: FnOnce(&mut IndexStorage<'_, 'a, S::Transaction<'a>>) -> Result<R>,

Execute operations on an index within a closure.

This is a convenience method that creates an IndexStorage, executes the closure, and returns the result.

pub fn commit(self) -> Result<()>

Commit the transaction.

Consumes the transaction. On success, all writes become visible.

pub fn rollback(self) -> Result<()>

Rollback the transaction.

Consumes the transaction. All pending writes are discarded.

Trait Implementations

impl<'a, S: KVStore + 'a> SqlTxn<'a, S> for SqlTransaction<'a, S>

fn mode(&self) -> TxnMode

fn ensure_write_txn(&self) -> CoreResult<()>

fn inner_mut(&mut self) -> &mut S::Transaction<'a>

fn hnsw_entry(&mut self, name: &str) -> CoreResult<&HnswIndex>

fn hnsw_entry_mut(&mut self, name: &str) -> CoreResult<&mut HnswTxnEntry>

fn flush_hnsw(&mut self) -> Result<()>

fn abandon_hnsw(&mut self) -> Result<()>

fn delete_prefix(&mut self, prefix: &[u8]) -> Result<()>

fn table_storage<'a>( &'a mut self, table_meta: &TableMetadata, ) -> TableStorage<'a, 'txn, S::Transaction<'txn>>

fn index_storage<'a>( &'a mut self, index_id: u32, unique: bool, column_indices: Vec<usize>, ) -> IndexStorage<'a, 'txn, S::Transaction<'txn>>

fn with_table<R, F>(&mut self, table_meta: &TableMetadata, f: F) -> Result<R>

where F: FnOnce(&mut TableStorage<'_, 'txn, S::Transaction<'txn>>) -> Result<R>,

fn with_index<R, F>( &mut self, index_id: u32, unique: bool, column_indices: Vec<usize>, f: F, ) -> Result<R>

where F: FnOnce(&mut IndexStorage<'_, 'txn, S::Transaction<'txn>>) -> Result<R>,