Enum Db 

pub enum Db<'a> {
    Pool(&'a PgPool),
    Conn(&'a mut PgConnection),
}

Where a function gets its connection: the pool, or a connection the caller holds, usually an open transaction, so one function serves both.

impl sqlx::Acquire says the same, but its associated types stop the future being Send, which Axum handlers and tokio::spawn need.

use axa_sqlx::{Db, sqlx};

async fn count(db: impl Into<Db<'_>>) -> Result<i64, sqlx::Error> {
    let mut conn = db.into().acquire().await?;
    sqlx::query_scalar("SELECT count(*) FROM items")
        .fetch_one(&mut *conn)
        .await
}

Variants

Pool(&'a PgPool)

Take a connection from the pool for the length of the call.

Conn(&'a mut PgConnection)

Use the caller’s connection.

Implementations

impl<'a> Db<'a>

pub async fn acquire(self) -> Result<Conn<'a>, Error>

The connection to use.

Errors

Fails when the pool has none to give.

Trait Implementations

impl<'a> From<&'a Pool<Postgres>> for Db<'a>

fn from(pool: &'a PgPool) -> Self

Converts to this type from the input type.

impl<'a> From<&'a mut PgConnection> for Db<'a>

fn from(conn: &'a mut PgConnection) -> Self

Converts to this type from the input type.