Struct PgTransaction 

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

A wrapper around tokio_postgres::Transaction implementing the NextSQL Transaction trait. Supports nested transactions (savepoints) and commit/rollback. Drop without calling commit() will rollback the transaction.

Implementations

impl<'a> PgTransaction<'a>

pub fn new(tx: Transaction<'a>) -> PgTransaction<'a>

Trait Implementations

impl QueryExecutor for PgTransaction<'_>

type Error = Error

type Row = PgRow

fn query( &self, sql: &str, params: &[&dyn ToSqlParam], ) -> impl Future<Output = Result<Vec<<PgTransaction<'_> as QueryExecutor>::Row>, <PgTransaction<'_> as QueryExecutor>::Error>> + Send

Execute a query that returns rows.

fn execute( &self, sql: &str, params: &[&dyn ToSqlParam], ) -> impl Future<Output = Result<u64, <PgTransaction<'_> as QueryExecutor>::Error>> + Send

Execute a statement that returns the number of affected rows.

impl Transaction for PgTransaction<'_>

type Nested<'a> = PgTransaction<'a> where PgTransaction<'_>: 'a

fn transaction( &mut self, ) -> impl Future<Output = Result<<PgTransaction<'_> as Transaction>::Nested<'_>, <PgTransaction<'_> as QueryExecutor>::Error>> + Send

Begin a nested transaction (savepoint).

fn commit( self, ) -> impl Future<Output = Result<(), <PgTransaction<'_> as QueryExecutor>::Error>> + Send

Commit this transaction.

fn rollback( self, ) -> impl Future<Output = Result<(), <PgTransaction<'_> as QueryExecutor>::Error>> + Send

Rollback this transaction.