Struct PostgresTransaction 

pub struct PostgresTransaction<'c>(/* private fields */);

Postgres transaction.

Implementations

impl<'c> PostgresTransaction<'c>

pub async fn new(client: &'c mut PostgresConnection) -> Result<Self>

Trait Implementations

impl<'c> Executor for PostgresTransaction<'c>

type Driver = PostgresDriver

Associated driver.

async fn do_prepare(&mut self, sql: String) -> Result<Query<Self::Driver>>

Actual implementation for prepare.

fn run<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Stream<Item = Result<QueryResult>> + Send

Execute a query, streaming QueryResult (rows or affected counts).

fn accepts_multiple_statements(&self) -> bool

Supports multiple statements per request.

fn driver(&self) -> Self::Driver

where Self: Sized,

Get the driver instance.

fn prepare<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Future<Output = Result<Query<Self::Driver>, Error>> + Send

Prepare query.

fn fetch<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Stream<Item = Result<RowLabeled, Error>> + Send

Execute a query yielding RowLabeled from the resulting stream (filtering out RowsAffected).

fn execute<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Future<Output = Result<RowsAffected, Error>> + Send

Execute and aggregate affected rows counter.

fn append<'a, E, It>( &mut self, entities: It, ) -> impl Future<Output = Result<RowsAffected, Error>> + Send

where E: Entity + 'a, It: IntoIterator<Item = &'a E> + Send, <It as IntoIterator>::IntoIter: Send,

Insert many entities efficiently.

impl<'c> Transaction<'c> for PostgresTransaction<'c>

fn commit(self) -> impl Future<Output = Result<()>>

Commit the outstanding changes.

fn rollback(self) -> impl Future<Output = Result<()>>

Rollback any uncommitted changes.