Struct Transaction 

pub struct Transaction { /* private fields */ }

A database transaction.

Created by Pool::begin(). Must be explicitly committed via commit(). If dropped without commit(), the connection is discarded from the pool (unless no queries were executed, in which case BEGIN was never sent and the connection is clean).

Implementations

impl Transaction

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

Commit the transaction and return the connection to the pool.

Consumes self — the transaction cannot be used after commit.

If no queries were executed (BEGIN was never sent), this is a no-op: no COMMIT is sent and the connection returns cleanly.

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

Explicitly roll back the transaction and return the connection to the pool.

Consumes self — the transaction cannot be used after rollback.

If no queries were executed (BEGIN was never sent), this is a no-op: no ROLLBACK is sent and the connection returns cleanly.

Trait Implementations

impl Debug for Transaction

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

Formats the value using the given formatter.

impl Drop for Transaction

fn drop(&mut self)

Executes the destructor for this type.

impl Executor for Transaction

type Rows = Vec<Row>

Row container returned by query_raw / query_raw_readonly.

async fn query_raw( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> BsqlResult<Vec<Row>>

Execute a query and return all rows.

async fn query_raw_readonly( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> BsqlResult<Vec<Row>>

Execute a read-only query. Routes to replicas when available.

async fn execute_raw( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> BsqlResult<u64>

Execute a query and return the number of affected rows.