Struct PostgresTransaction 

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

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

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

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

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

General method to send any query and return any result type (either row or count)

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

Execute the query and returns the rows.

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

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

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,

Append entities to a table. Defaults to insert query for drivers that do not support this feature.

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

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

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