Struct Transaction 

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

A transaction guard. Ensures the transaction is committed or rolled back.

Created via PgConnection::transaction(). Provides the same query methods as PgConnection. On drop, if neither commit nor rollback was called, automatically rolls back.

Implementations

impl<'a> Transaction<'a>

pub fn commit(&mut self) -> PgResult<()>

Commit this transaction (or release savepoint if nested).

pub fn rollback(&mut self) -> PgResult<()>

Rollback this transaction (or rollback to savepoint if nested).

pub fn transaction<F, T>(&mut self, f: F) -> PgResult<T>

where F: FnOnce(&mut Transaction<'_>) -> PgResult<T>,

Execute a nested transaction using a SAVEPOINT.

Creates a savepoint, calls the closure, and either releases (on success) or rolls back to the savepoint (on error/drop).

Nesting is unlimited — each level creates a new savepoint.

Example

conn.transaction(|tx| {
    tx.execute("INSERT INTO users (name) VALUES ($1)", &[&"Alice"])?;
    tx.transaction(|nested| {
        nested.execute("INSERT INTO logs (msg) VALUES ($1)", &[&"nested"])?;
        Ok(())
    })?;
    Ok(())
})?;

pub fn query_simple(&mut self, sql: &str) -> PgResult<Vec<Row>>

Execute a simple query (no parameters).

pub fn query(&mut self, sql: &str, params: &[&dyn ToSql]) -> PgResult<Vec<Row>>

Execute a parameterized query.

pub fn query_one(&mut self, sql: &str, params: &[&dyn ToSql]) -> PgResult<Row>

Execute a query expecting exactly one row.

pub fn query_opt( &mut self, sql: &str, params: &[&dyn ToSql], ) -> PgResult<Option<Row>>

Execute a query expecting zero or one row.

pub fn execute(&mut self, sql: &str, params: &[&dyn ToSql]) -> PgResult<u64>

Execute a statement that returns no rows.

pub fn savepoint(&mut self, name: &str) -> PgResult<()>

Create a savepoint within this transaction.

pub fn rollback_to(&mut self, name: &str) -> PgResult<()>

Rollback to a savepoint.

pub fn release_savepoint(&mut self, name: &str) -> PgResult<()>

Release a savepoint.

pub fn status(&self) -> TransactionStatus

Get the transaction status.

Trait Implementations

impl<'a> Drop for Transaction<'a>

fn drop(&mut self)

Executes the destructor for this type.