Struct Transaction 

pub struct Transaction { /* private fields */ }

A transaction on one Turso connection.

Created with Database::begin or Database::begin_with_mode. Nested transactions (txn.begin()) are SAVEPOINTs on the same connection. Dropping an unfinished transaction rolls it back: a top-level transaction discards its connection, a nested one is rolled back to its savepoint before the parent runs its next statement.

Implementations

impl Transaction

pub fn depth(&self) -> u32

The savepoint depth: 0 for a top-level transaction.

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

Commits the transaction — COMMIT, or RELEASE SAVEPOINT when nested.

Errors

Returns Error::Turso when the commit fails; an MVCC write conflict surfaces here with ErrorKind::Busy.

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

Rolls the transaction back — ROLLBACK, or ROLLBACK TO SAVEPOINT when nested.

Errors

Returns Error::Turso when the rollback fails.

Trait Implementations

impl ConnectionTrait for &Transaction

fn execute<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<ExecResult>> + Send + 'async_trait>>

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

Runs a statement that returns no rows.

fn execute_unprepared<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ExecResult>> + Send + 'async_trait>>

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

Runs one or more ;-separated statements without parameters.

fn query_one<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<Option<Row>>> + Send + 'async_trait>>

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

Fetches at most one row.

fn query_all<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>>> + Send + 'async_trait>>

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

Fetches all rows.

impl ConnectionTrait for Transaction

fn execute<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<ExecResult>> + Send + 'async_trait>>

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

Runs a statement that returns no rows.

fn execute_unprepared<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ExecResult>> + Send + 'async_trait>>

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

Runs one or more ;-separated statements without parameters.

fn query_one<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<Option<Row>>> + Send + 'async_trait>>

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

Fetches at most one row.

fn query_all<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>>> + Send + 'async_trait>>

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

Fetches all rows.

impl Debug for Transaction

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for Transaction

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 StreamTrait for Transaction

fn stream<'a>( &'a self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<RowStream<'a>>> + Send + 'a>>

Runs a query and streams its rows.

impl TransactionTrait for Transaction

fn begin<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Transaction>> + Send + 'async_trait>>

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

Begins with BEGIN DEFERRED, or a savepoint when called on a transaction.

fn begin_with_mode<'life0, 'async_trait>( &'life0 self, _mode: TransactionMode, ) -> Pin<Box<dyn Future<Output = Result<Transaction>> + Send + 'async_trait>>

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

Begins with an explicit mode; the mode is ignored for nested transactions, which are always savepoints.

fn transaction<'life0, 'async_trait, F, T, E>( &'life0 self, callback: F, ) -> Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'async_trait>>

where F: for<'c> FnOnce(&'c Transaction) -> Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'c>> + Send + 'async_trait, T: Send + 'async_trait, E: From<Error> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Runs callback inside a transaction, committing on Ok and rolling back on Err.