Struct DatabasePool

pub struct DatabasePool<B: Backend> { /* private fields */ }

Database pool

Implementations

impl<B: Backend> DatabasePool<B>

pub async fn pull_immutable(&self) -> ReusableConnectionPool<'_, B>

Pulls a reusable connection pool

Privileges are granted only for SELECT, INSERT, UPDATE, and DELETE operations.

Example

use bb8::Pool;
use db_pool::{
    r#async::{DatabasePoolBuilderTrait, DieselAsyncPostgresBackend, DieselBb8},
    PrivilegedPostgresConfig,
};
use diesel::sql_query;
use diesel_async::RunQueryDsl;
use dotenvy::dotenv;

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

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

    let backend = DieselAsyncPostgresBackend::<DieselBb8>::new(
        config,
        |_| Pool::builder().max_size(10),
        |_| Pool::builder().max_size(2),
        None,
        move |mut conn| {
            Box::pin(async {
                sql_query("CREATE TABLE book(id SERIAL PRIMARY KEY, title TEXT NOT NULL)")
                    .execute(&mut conn)
                    .await
                    .unwrap();
                Some(conn)
            })
        },
    )
    .await
    .unwrap();

    let db_pool = backend.create_database_pool().await.unwrap();
    let conn_pool = db_pool.pull_immutable();
}

tokio_test::block_on(f());

pub async fn create_mutable( &self, ) -> Result<SingleUseConnectionPool<B>, Error<B::BuildError, B::PoolError, B::ConnectionError, B::QueryError>>

Creates a single-use connection pool

All privileges are granted.

Example

use bb8::Pool;
use db_pool::{
    r#async::{DatabasePoolBuilderTrait, DieselAsyncPostgresBackend, DieselBb8},
    PrivilegedPostgresConfig,
};
use diesel::sql_query;
use diesel_async::RunQueryDsl;
use dotenvy::dotenv;

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

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

    let backend = DieselAsyncPostgresBackend::<DieselBb8>::new(
        config,
        |_| Pool::builder().max_size(10),
        |_| Pool::builder().max_size(2),
        None,
        move |mut conn| {
            Box::pin(async {
                sql_query("CREATE TABLE book(id SERIAL PRIMARY KEY, title TEXT NOT NULL)")
                    .execute(&mut conn)
                    .await
                    .unwrap();
                Some(conn)
            })
        },
    )
    .await
    .unwrap();

    let db_pool = backend.create_database_pool().await.unwrap();
    let conn_pool = db_pool.create_mutable();
}

tokio_test::block_on(f());