Struct Transaction 

pub struct Transaction<'c, DB>
where
    DB: Database,
{ /* private fields */ }

An in-progress database transaction or savepoint.

A transaction starts with a call to Pool::begin or Connection::begin.

A transaction should end with a call to commit or rollback. If neither are called before the transaction goes out-of-scope, rollback is called. In other words, rollback is called on drop if the transaction is still in-progress.

A savepoint is a special mark inside a transaction that allows all commands that are executed after it was established to be rolled back, restoring the transaction state to what it was at the time of the savepoint.

Implementations

impl<'c, DB> Transaction<'c, DB>

where DB: Database,

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

Commits this transaction or savepoint.

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

Aborts this transaction or savepoint.

Trait Implementations

impl<'c, 't> Acquire<'t> for &'t mut Transaction<'c, Any>

Available on (crate features postgres or mysql or mssql or sqlite or odbc) and crate feature any only.

type Database = Any

type Connection = &'t mut <Any as Database>::Connection

fn acquire(self) -> BoxFuture<'t, Result<Self::Connection, Error>>

fn begin(self) -> BoxFuture<'t, Result<Transaction<'t, Any>, Error>>

impl<'c, 't> Acquire<'t> for &'t mut Transaction<'c, Mssql>

Available on crate feature mssql only.

type Database = Mssql

type Connection = &'t mut <Mssql as Database>::Connection

fn acquire(self) -> BoxFuture<'t, Result<Self::Connection, Error>>

fn begin(self) -> BoxFuture<'t, Result<Transaction<'t, Mssql>, Error>>

impl<'c, 't> Acquire<'t> for &'t mut Transaction<'c, MySql>

Available on crate feature mysql only.

type Database = MySql

type Connection = &'t mut <MySql as Database>::Connection

fn acquire(self) -> BoxFuture<'t, Result<Self::Connection, Error>>

fn begin(self) -> BoxFuture<'t, Result<Transaction<'t, MySql>, Error>>

impl<'c, 't> Acquire<'t> for &'t mut Transaction<'c, Odbc>

Available on crate feature odbc only.

type Database = Odbc

type Connection = &'t mut <Odbc as Database>::Connection

fn acquire(self) -> BoxFuture<'t, Result<Self::Connection, Error>>

fn begin(self) -> BoxFuture<'t, Result<Transaction<'t, Odbc>, Error>>

impl<'c, 't> Acquire<'t> for &'t mut Transaction<'c, Postgres>

Available on crate feature postgres only.

type Database = Postgres

type Connection = &'t mut <Postgres as Database>::Connection

fn acquire(self) -> BoxFuture<'t, Result<Self::Connection, Error>>

fn begin(self) -> BoxFuture<'t, Result<Transaction<'t, Postgres>, Error>>

impl<'c, 't> Acquire<'t> for &'t mut Transaction<'c, Sqlite>

Available on crate feature sqlite only.

type Database = Sqlite

type Connection = &'t mut <Sqlite as Database>::Connection

fn acquire(self) -> BoxFuture<'t, Result<Self::Connection, Error>>

fn begin(self) -> BoxFuture<'t, Result<Transaction<'t, Sqlite>, Error>>

impl<'c, DB> Debug for Transaction<'c, DB>

where DB: Database,

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

Formats the value using the given formatter.

impl<'c, DB> Deref for Transaction<'c, DB>

where DB: Database,

type Target = <DB as Database>::Connection

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<'c, DB> DerefMut for Transaction<'c, DB>

where DB: Database,

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<'c, DB> Drop for Transaction<'c, DB>

where DB: Database,

fn drop(&mut self)

Executes the destructor for this type.

impl<'c, 't> Executor<'t> for &'t mut Transaction<'c, Any>

Available on (crate features postgres or mysql or mssql or sqlite or odbc) and crate feature any only.

type Database = Any

fn fetch_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<Either<<Any as Database>::QueryResult, AnyRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute multiple queries and return the generated results as a stream from each query, in a stream.

fn fetch_optional<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Option<AnyRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute the query and returns at most one row.

fn prepare_with<'e, 'q: 'e>( self, sql: &'q str, parameters: &'e [<Self::Database as Database>::TypeInfo], ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 't: 'e,

Prepare the SQL query, with parameter type information, to inspect the type information about its parameters and results.

fn execute<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the total number of rows affected.

fn execute_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute multiple queries and return the rows affected from each query, in a stream.

fn fetch<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the generated results as a stream.

fn fetch_all<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Vec<<Self::Database as Database>::Row>, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return all the generated results, collected into a Vec.

fn fetch_one<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and returns exactly one row.

fn prepare<'e, 'q: 'e>( self, query: &'q str, ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 'c: 'e,

Prepare the SQL query to inspect the type information of its parameters and results.

impl<'c, 't> Executor<'t> for &'t mut Transaction<'c, Mssql>

Available on crate feature mssql only.

type Database = Mssql

fn fetch_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<Either<<Mssql as Database>::QueryResult, MssqlRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute multiple queries and return the generated results as a stream from each query, in a stream.

fn fetch_optional<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Option<MssqlRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute the query and returns at most one row.

fn prepare_with<'e, 'q: 'e>( self, sql: &'q str, parameters: &'e [<Self::Database as Database>::TypeInfo], ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 't: 'e,

Prepare the SQL query, with parameter type information, to inspect the type information about its parameters and results.

fn execute<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the total number of rows affected.

fn execute_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute multiple queries and return the rows affected from each query, in a stream.

fn fetch<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the generated results as a stream.

fn fetch_all<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Vec<<Self::Database as Database>::Row>, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return all the generated results, collected into a Vec.

fn fetch_one<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and returns exactly one row.

fn prepare<'e, 'q: 'e>( self, query: &'q str, ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 'c: 'e,

Prepare the SQL query to inspect the type information of its parameters and results.

impl<'c, 't> Executor<'t> for &'t mut Transaction<'c, MySql>

Available on crate feature mysql only.

type Database = MySql

fn fetch_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<Either<<MySql as Database>::QueryResult, MySqlRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute multiple queries and return the generated results as a stream from each query, in a stream.

fn fetch_optional<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Option<MySqlRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute the query and returns at most one row.

fn prepare_with<'e, 'q: 'e>( self, sql: &'q str, parameters: &'e [<Self::Database as Database>::TypeInfo], ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 't: 'e,

Prepare the SQL query, with parameter type information, to inspect the type information about its parameters and results.

fn execute<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the total number of rows affected.

fn execute_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute multiple queries and return the rows affected from each query, in a stream.

fn fetch<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the generated results as a stream.

fn fetch_all<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Vec<<Self::Database as Database>::Row>, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return all the generated results, collected into a Vec.

fn fetch_one<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and returns exactly one row.

fn prepare<'e, 'q: 'e>( self, query: &'q str, ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 'c: 'e,

Prepare the SQL query to inspect the type information of its parameters and results.

impl<'c, 't> Executor<'t> for &'t mut Transaction<'c, Odbc>

Available on crate feature odbc only.

type Database = Odbc

fn fetch_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<Either<<Odbc as Database>::QueryResult, OdbcRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute multiple queries and return the generated results as a stream from each query, in a stream.

fn fetch_optional<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Option<OdbcRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute the query and returns at most one row.

fn prepare_with<'e, 'q: 'e>( self, sql: &'q str, parameters: &'e [<Self::Database as Database>::TypeInfo], ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 't: 'e,

Prepare the SQL query, with parameter type information, to inspect the type information about its parameters and results.

fn execute<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the total number of rows affected.

fn execute_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute multiple queries and return the rows affected from each query, in a stream.

fn fetch<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the generated results as a stream.

fn fetch_all<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Vec<<Self::Database as Database>::Row>, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return all the generated results, collected into a Vec.

fn fetch_one<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and returns exactly one row.

fn prepare<'e, 'q: 'e>( self, query: &'q str, ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 'c: 'e,

Prepare the SQL query to inspect the type information of its parameters and results.

impl<'c, 't> Executor<'t> for &'t mut Transaction<'c, Postgres>

Available on crate feature postgres only.

type Database = Postgres

fn fetch_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<Either<<Postgres as Database>::QueryResult, PgRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute multiple queries and return the generated results as a stream from each query, in a stream.

fn fetch_optional<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Option<PgRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute the query and returns at most one row.

fn prepare_with<'e, 'q: 'e>( self, sql: &'q str, parameters: &'e [<Self::Database as Database>::TypeInfo], ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 't: 'e,

Prepare the SQL query, with parameter type information, to inspect the type information about its parameters and results.

fn execute<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the total number of rows affected.

fn execute_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute multiple queries and return the rows affected from each query, in a stream.

fn fetch<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the generated results as a stream.

fn fetch_all<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Vec<<Self::Database as Database>::Row>, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return all the generated results, collected into a Vec.

fn fetch_one<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and returns exactly one row.

fn prepare<'e, 'q: 'e>( self, query: &'q str, ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 'c: 'e,

Prepare the SQL query to inspect the type information of its parameters and results.

impl<'c, 't> Executor<'t> for &'t mut Transaction<'c, Sqlite>

Available on crate feature sqlite only.

type Database = Sqlite

fn fetch_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<Either<<Sqlite as Database>::QueryResult, SqliteRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute multiple queries and return the generated results as a stream from each query, in a stream.

fn fetch_optional<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Option<SqliteRow>, Error>>

where E: Execute<'q, Self::Database> + 'q, 't: 'e,

Execute the query and returns at most one row.

fn prepare_with<'e, 'q: 'e>( self, sql: &'q str, parameters: &'e [<Self::Database as Database>::TypeInfo], ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 't: 'e,

Prepare the SQL query, with parameter type information, to inspect the type information about its parameters and results.

fn execute<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the total number of rows affected.

fn execute_many<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute multiple queries and return the rows affected from each query, in a stream.

fn fetch<'e, 'q: 'e, E>( self, query: E, ) -> BoxStream<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return the generated results as a stream.

fn fetch_all<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<Vec<<Self::Database as Database>::Row>, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and return all the generated results, collected into a Vec.

fn fetch_one<'e, 'q: 'e, E>( self, query: E, ) -> BoxFuture<'e, Result<<Self::Database as Database>::Row, Error>>

where E: Execute<'q, Self::Database> + 'q, 'c: 'e,

Execute the query and returns exactly one row.

fn prepare<'e, 'q: 'e>( self, query: &'q str, ) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>

where 'c: 'e,

Prepare the SQL query to inspect the type information of its parameters and results.