Struct Transaction 

pub struct Transaction<'p, DB, Repos = ()> { /* private fields */ }

Transaction builder for composing repositories.

Use Transaction::new to create a builder, then chain .with_*() methods to add repositories, and finally call .run() to execute.

Type Parameters

• DB — Database type (e.g., Postgres)
• Repos — Tuple of repository adapters accumulated via builder

Implementations

impl<'p, DB> Transaction<'p, DB>

pub const fn new(pool: &'p DB) -> Transaction<'p, DB>

Create a new transaction builder.

Arguments

• pool — Database connection pool

Example

let tx = Transaction::new(&pool);

impl<'p, DB, Repos> Transaction<'p, DB, Repos>

pub const fn pool(&self) -> &'p DB

Get reference to the underlying pool.

impl<'p, Repos> Transaction<'p, Pool<Postgres>, Repos>

where Repos: Send,

pub async fn run<F, Fut, T, E>(self, f: F) -> Result<T, E>

where F: for<'t> FnOnce(TransactionContext<'t, Transaction<'t, Postgres>, Repos>) -> Fut + Send, Fut: Future<Output = Result<T, E>> + Send, E: From<TransactionError<Error>>, Repos: Default,

Execute a closure within a PostgreSQL transaction.

Automatically commits on Ok, rolls back on Err or drop.

Example

Transaction::new(&pool)
    .with_users()
    .run(|mut ctx| async move {
        ctx.users().create(dto).await
    })
    .await?;