Struct DieselPostgresBackend

pub struct DieselPostgresBackend { /* private fields */ }

Diesel Postgres backend

Implementations

impl DieselPostgresBackend

pub fn new( privileged_config: PrivilegedPostgresConfig, create_privileged_pool: impl Fn() -> Builder<ConnectionManager<PgConnection>>, create_restricted_pool: impl Fn() -> Builder<ConnectionManager<PgConnection>> + Send + Sync + 'static, create_entities: impl Fn(&mut PgConnection) + Send + Sync + 'static, ) -> Result<Self, Error>

Creates a new Diesel Postgres backend

Example

use db_pool::{sync::DieselPostgresBackend, PrivilegedPostgresConfig};
use diesel::{sql_query, RunQueryDsl};
use dotenvy::dotenv;
use r2d2::Pool;

dotenv().ok();

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

let backend = DieselPostgresBackend::new(
    config,
    || Pool::builder().max_size(10),
    || Pool::builder().max_size(2),
    move |conn| {
        sql_query("CREATE TABLE book(id SERIAL PRIMARY KEY, title TEXT NOT NULL)")
            .execute(conn)
            .unwrap();
    },
)
.unwrap();

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

Drop databases created in previous runs upon initialization

Trait Implementations

impl Backend for DieselPostgresBackend

type ConnectionManager = ConnectionManager<PgConnection>

Type that implements the r2d2::ManageConnection trait

type ConnectionError = ConnectionError

Connection error type that implements Debug

type QueryError = Error

Query error type that implements Debug

fn init(&self) -> Result<(), BackendError<ConnectionError, Error>>

Initializes the backend

fn create( &self, db_id: Uuid, restrict_privileges: bool, ) -> Result<Pool<ConnectionManager<PgConnection>>, BackendError<ConnectionError, Error>>

Creates a database

fn clean(&self, db_id: Uuid) -> Result<(), BackendError<ConnectionError, Error>>

Cleans a database

fn drop( &self, db_id: Uuid, is_restricted: bool, ) -> Result<(), BackendError<ConnectionError, Error>>

Drops a database