Struct Transaction 

pub struct Transaction { /* private fields */ }

Transaction guard for automatic commit/rollback

This wrapper around SQLx transactions provides:

• Automatic commit on drop (if not already committed/rolled back)
• Explicit commit and rollback methods
• Prevents accidental use after commit/rollback

Example

use ormkit::transaction::Transaction;

let mut tx = Transaction::begin(pool).await?;

// Perform operations
sqlx::query("INSERT INTO users (name) VALUES ($1)")
    .bind("John")
    .execute(&mut *tx)
    .await?;

// Explicitly commit
tx.commit().await?;

Implementations

impl Transaction

pub async fn begin(pool: &PgPool) -> TransactionResult<Self>

Begin a new transaction

Arguments

• pool - The database connection pool

Returns

A new transaction guard

pub async fn begin_with_isolation( pool: &PgPool, isolation_level: IsolationLevel, ) -> TransactionResult<Self>

Begin a transaction with a specific isolation level

Arguments

• pool - The database connection pool
• isolation_level - The isolation level to use

Returns

A new transaction guard

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

Commit the transaction

Returns

Ok on success, Err if already committed or rolled back

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

Rollback the transaction

Returns

Ok on success, Err if already committed or rolled back

pub async fn savepoint(&mut self, _name: &str) -> TransactionResult<()>

Create a savepoint within this transaction

Arguments

• name - The name for the savepoint

Returns

A savepoint guard

Note

Savepoints are not currently supported by SQLx’s public API. This method is a placeholder for future implementation.

pub fn is_active(&self) -> bool

Check if the transaction is still active

pub fn is_committed(&self) -> bool

Check if the transaction has been committed

pub fn is_rolled_back(&self) -> bool

Check if the transaction has been rolled back

Trait Implementations

impl Deref for Transaction

type Target = Transaction<'static, Postgres>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for Transaction

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl Drop for Transaction

Auto-commit on drop if not already committed/rolled back

fn drop(&mut self)

Executes the destructor for this type.