Struct SqliteTransaction 

pub struct SqliteTransaction<'a> { /* private fields */ }

A SQLite transaction backed by raw BEGIN/COMMIT/ROLLBACK statements.

Holds a guard on the connection-level transaction mutex so that no other async task can start a concurrent BEGIN on the same SqliteConnection. When dropped without an explicit commit or rollback, the transaction attempts a best-effort ROLLBACK via a background task.

ROLLBACK limitation

Limbo 0.0.22 does not support ROLLBACK (bail_parse_error!("ROLLBACK not supported yet")). Calling rollback() returns Err(OxiSqlError::Other("ROLLBACK is not supported by the limbo 0.0.22 engine …")) rather than propagating a raw parse error.

The Drop impl still fires a fire-and-forget background task so that any future limbo release that adds ROLLBACK support will clean up implicitly.

Trait Implementations

impl<'a> Drop for SqliteTransaction<'a>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl<'a> Transaction for SqliteTransaction<'a>

fn execute<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, sql: &'life1 str, params: &'life2 [&'life3 dyn ToSqlValue], ) -> Pin<Box<dyn Future<Output = Result<u64, OxiSqlError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Execute a DML/DDL statement within the transaction.

fn query<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, sql: &'life1 str, params: &'life2 [&'life3 dyn ToSqlValue], ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>, OxiSqlError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Execute a SELECT statement within the transaction.

fn commit<'async_trait>( self: Box<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), OxiSqlError>> + Send + 'async_trait>>

where Self: 'async_trait,

Commit all changes made within this transaction.

fn rollback<'async_trait>( self: Box<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), OxiSqlError>> + Send + 'async_trait>>

where Self: 'async_trait,

Roll back all changes made within this transaction.

fn savepoint<'life0, 'life1, 'async_trait>( &'life0 mut self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), OxiSqlError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Create a named savepoint within the transaction.

fn release_savepoint<'life0, 'life1, 'async_trait>( &'life0 mut self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), OxiSqlError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Release (discard) a named savepoint.

fn rollback_to_savepoint<'life0, 'life1, 'async_trait>( &'life0 mut self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), OxiSqlError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Roll back the transaction to the named savepoint, undoing all changes made after the savepoint was created without ending the transaction.