Struct SqlxPostgresBackend

pub struct SqlxPostgresBackend { /* private fields */ }

sqlx Postgres backend

Implementations

impl SqlxPostgresBackend

pub fn new( privileged_options: PgConnectOptions, create_privileged_pool: impl Fn() -> PgPoolOptions, create_restricted_pool: impl Fn() -> PgPoolOptions + Send + Sync + 'static, create_entities: impl Fn(PgConnection) -> Pin<Box<dyn Future<Output = PgConnection> + Send + 'static>> + Send + Sync + 'static, ) -> Self

Creates a new sqlx Postgres backend

Example

use db_pool::{r#async::SqlxPostgresBackend, PrivilegedPostgresConfig};
use dotenvy::dotenv;
use sqlx::{postgres::PgPoolOptions, Executor};

async fn f() {
    dotenv().ok();

    let config = PrivilegedPostgresConfig::from_env().unwrap();

    let backend = SqlxPostgresBackend::new(
        config.into(),
        || PgPoolOptions::new().max_connections(10),
        || PgPoolOptions::new().max_connections(2),
        move |mut conn| {
            Box::pin(async move {
                conn.execute("CREATE TABLE book(id SERIAL PRIMARY KEY, title TEXT NOT NULL)")
                    .await
                    .unwrap();
                conn
            })
        },
    );
}

tokio_test::block_on(f());

pub fn drop_previous_databases(self, value: bool) -> Self

Drop databases created in previous runs upon initialization

Trait Implementations

impl Backend for SqlxPostgresBackend

type Pool = Pool<Postgres>

Connection pool type that implements Send

type BuildError = BuildError

Connection pool build error type that implements Debug and Send

type PoolError = PoolError

Connection pool error type that implements Debug and Send

type ConnectionError = ConnectionError

Connection error type that implements Debug

type QueryError = QueryError

Query error type that implements Debug

fn init<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error<BuildError, PoolError, ConnectionError, QueryError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initializes the backend

fn create<'life0, 'async_trait>( &'life0 self, db_id: Uuid, restrict_privileges: bool, ) -> Pin<Box<dyn Future<Output = Result<PgPool, Error<BuildError, PoolError, ConnectionError, QueryError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Creates a database

fn clean<'life0, 'async_trait>( &'life0 self, db_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), Error<BuildError, PoolError, ConnectionError, QueryError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Cleans a database

fn drop<'life0, 'async_trait>( &'life0 self, db_id: Uuid, is_restricted: bool, ) -> Pin<Box<dyn Future<Output = Result<(), Error<BuildError, PoolError, ConnectionError, QueryError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Drops a database