Struct Tx 

pub struct Tx { /* private fields */ }

A database transaction.

Wraps a pooled connection with an active transaction. If commit() is not called before the Tx is dropped, the transaction is automatically rolled back when the connection returns to the pool.

Implementations

impl Tx

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

Commit the transaction.

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

Explicitly rollback the transaction.

Trait Implementations

impl Debug for Tx

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

Formats the value using the given formatter.

impl Executor for Tx

async fn execute_raw( &self, sql: &str, params: Vec<Value>, ) -> Result<u64, FlozError>

Execute a raw SQL statement, returning the number of affected rows.

async fn fetch_all<T>( &self, sql: &str, params: Vec<Value>, ) -> Result<Vec<T>, FlozError>

where T: Send + Unpin + for<'r> FromRow<'r, PgRow>,

Fetch all matching rows.

async fn fetch_one<T>( &self, sql: &str, params: Vec<Value>, ) -> Result<T, FlozError>

where T: Send + Unpin + for<'r> FromRow<'r, PgRow>,

Fetch exactly one row. Returns FlozError::NotFound if no rows match.

async fn fetch_optional<T>( &self, sql: &str, params: Vec<Value>, ) -> Result<Option<T>, FlozError>

where T: Send + Unpin + for<'r> FromRow<'r, PgRow>,

Fetch zero or one row.