Struct TransactionManager 

pub struct TransactionManager { /* private fields */ }

Transaction manager with ACID guarantees

Implementations

impl TransactionManager

pub fn new(wal_dir: impl AsRef<Path>) -> Result<Self, OxirsError>

Create a new transaction manager

pub fn begin( &mut self, isolation: IsolationLevel, ) -> Result<AcidTransaction, OxirsError>

Begin a new transaction with specified isolation level

pub fn begin_named_graph_transaction( &mut self, isolation: IsolationLevel, ) -> Result<NamedGraphTransaction, OxirsError>

Begin a new named graph transaction with specified isolation level

This provides graph-specific operations with ACID guarantees:

• Atomic multi-graph operations
• Graph-level isolation
• MVCC snapshot isolation per graph

pub fn recover<F, G>( &mut self, insert_fn: F, delete_fn: G, ) -> Result<usize, OxirsError>

where F: FnMut(Quad) -> Result<bool, OxirsError>, G: FnMut(&Quad) -> Result<bool, OxirsError>,

Recover from WAL after crash

This method replays committed transactions from the Write-Ahead Log using callback functions to apply operations to the store.

Arguments

• insert_fn - Callback to insert a quad into the store
• delete_fn - Callback to delete a quad from the store

Example

let mut tx_mgr = TransactionManager::new("./wal")?;
let mut store = RdfStore::new()?;

tx_mgr.recover(
    |quad| store.insert_quad(quad),
    |quad| store.remove_quad(quad)
)?;

pub fn checkpoint(&mut self) -> Result<(), OxirsError>

Checkpoint WAL (write buffered entries to disk)

pub fn stats(&self) -> TransactionStats

Get transaction statistics