Struct Transaction 

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

A transaction wrapper. This is mainly to enforce the transaction management by the caller. There is a bit of cabling in the query method to pass the parameters and instantiate the stream.

Implementations

impl<'a> Transaction<'a>

pub async fn start(transaction: TokioTransaction<'a>) -> Self

create an open transaction.

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

Commit the transaction.

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

Rollback the transaction.

pub async fn query<E: SqlEntity>( &self, query: SqlQuery<'a, E>, ) -> Result<EntityStream<E>>

Query the database with a query and return a stream of entities.