Struct AnsiTransactionManager

pub struct AnsiTransactionManager { /* private fields */ }

An implementation of TransactionManager which can be used for backends which use ANSI standard syntax for savepoints such as SQLite and PostgreSQL.

Implementations

impl AnsiTransactionManager

pub async fn begin_transaction_sql<Conn>( conn: &mut Conn, sql: &str, ) -> QueryResult<()>

where Conn: AsyncConnection<TransactionManager = Self>,

Begin a transaction with custom SQL

This is used by connections to implement more complex transaction APIs to set things such as isolation levels. Returns an error if already inside of a transaction.

Trait Implementations

impl Debug for AnsiTransactionManager

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

Formats the value using the given formatter.

impl Default for AnsiTransactionManager

fn default() -> AnsiTransactionManager

Returns the “default value” for a type.

impl<Conn> TransactionManager<Conn> for AnsiTransactionManager

where Conn: AsyncConnection<TransactionManager = Self>,

fn commit_transaction<'life0, 'async_trait>( conn: &'life0 mut Conn, ) -> Pin<Box<dyn Future<Output = QueryResult<()>> + Send + 'async_trait>>

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

If the transaction fails to commit due to a SerializationFailure or a ReadOnlyTransaction a rollback will be attempted. If the rollback succeeds, the original error will be returned, otherwise the error generated by the rollback will be returned. In the second case the connection will be considered broken as it contains a uncommitted unabortable open transaction.

type TransactionStateData = AnsiTransactionManager

Data stored as part of the connection implementation to track the current transaction state of a connection

fn begin_transaction<'life0, 'async_trait>( conn: &'life0 mut Conn, ) -> Pin<Box<dyn Future<Output = QueryResult<()>> + Send + 'async_trait>>

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

Begin a new transaction or savepoint

fn rollback_transaction<'life0, 'async_trait>( conn: &'life0 mut Conn, ) -> Pin<Box<dyn Future<Output = QueryResult<()>> + Send + 'async_trait>>

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

Rollback the inner-most transaction or savepoint

fn transaction<'a, 'life0, 'async_trait, F, R, E>( conn: &'life0 mut Conn, callback: F, ) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'async_trait>>

where F: for<'r> FnOnce(&'r mut Conn) -> ScopedBoxFuture<'a, 'r, Result<R, E>> + Send + 'a + 'async_trait, E: From<Error> + Send + 'async_trait, R: Send + 'async_trait, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

Executes the given function inside of a database transaction