Enum DbConn 

pub enum DbConn<'a> {
    Pool(PgPool),
    Transaction(Arc<Mutex<Transaction<'static, Postgres>>>, &'a PgPool),
}

Abstraction over pool and transaction connections.

Allows shared helper functions to work with any context type. Obtain via ctx.db_conn() on pool-based contexts (queries, jobs, crons, daemons, webhooks, MCP tools) or via ctx.db() on MutationContext.

Example

pub async fn list_items(db: DbConn<'_>) -> Result<Vec<Item>> {
    db.fetch_all(sqlx::query_as!(Item, "SELECT * FROM items ORDER BY created_at DESC"))
        .await
        .map_err(Into::into)
}

Variants

Pool(PgPool)

Direct pool connection (queries, jobs, crons, daemons, webhooks, MCP).

Transaction(Arc<Mutex<Transaction<'static, Postgres>>>, &'a PgPool)

Transaction handle (transactional mutations).

Implementations

impl DbConn<'_>

pub async fn fetch_one<'q, O>( &self, query: QueryAs<'q, Postgres, O, PgArguments>, ) -> Result<O>

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

Fetch exactly one row.

pub async fn fetch_optional<'q, O>( &self, query: QueryAs<'q, Postgres, O, PgArguments>, ) -> Result<Option<O>>

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

Fetch zero or one row.

pub async fn fetch_all<'q, O>( &self, query: QueryAs<'q, Postgres, O, PgArguments>, ) -> Result<Vec<O>>

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

Fetch all matching rows.

pub async fn execute<'q>( &self, query: Query<'q, Postgres, PgArguments>, ) -> Result<PgQueryResult>

Execute a statement (INSERT, UPDATE, DELETE).

Trait Implementations

impl Debug for DbConn<'_>

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

Formats the value using the given formatter.