Struct DieselAsyncMySQLBackend

pub struct DieselAsyncMySQLBackend<P: DieselPoolAssociation<AsyncMysqlConnection>> { /* private fields */ }

Diesel async MySQL backend

Implementations

impl<P: DieselPoolAssociation<AsyncMysqlConnection>> DieselAsyncMySQLBackend<P>

pub async fn new( privileged_config: PrivilegedMySQLConfig, create_privileged_pool: impl Fn(AsyncDieselConnectionManager<AsyncMysqlConnection>) -> P::Builder, create_restricted_pool: impl Fn(AsyncDieselConnectionManager<AsyncMysqlConnection>) -> P::Builder + Send + Sync + 'static, custom_create_connection: Option<Box<dyn Fn() -> SetupCallback<AsyncMysqlConnection> + Send + Sync + 'static>>, create_entities: impl Fn(AsyncMysqlConnection) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>> + Send + Sync + 'static, ) -> Result<Self, P::BuildError>

Creates a new Diesel async MySQL backend

Example

use bb8::Pool;
use db_pool::{
    r#async::{DieselAsyncMySQLBackend, DieselBb8},
    PrivilegedMySQLConfig,
};
use diesel::sql_query;
use diesel_async::RunQueryDsl;
use dotenvy::dotenv;

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

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

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

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<P: DieselPoolAssociation<AsyncMysqlConnection>> Backend for DieselAsyncMySQLBackend<P>

type Pool = <P as DieselPoolAssociation<AsyncMysqlConnection>>::Pool

Connection pool type that implements Send

type BuildError = <P as DieselPoolAssociation<AsyncMysqlConnection>>::BuildError

Connection pool build error type that implements Debug and Send

type PoolError = <P as DieselPoolAssociation<AsyncMysqlConnection>>::PoolError

Connection pool error type that implements Debug and Send

type ConnectionError = ConnectionError

Connection error type that implements Debug

type QueryError = Error

Query error type that implements Debug

fn init<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error<P::BuildError, P::PoolError, ConnectionError, Error>>> + 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<P::Pool, Error<P::BuildError, P::PoolError, ConnectionError, Error>>> + 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<P::BuildError, P::PoolError, ConnectionError, Error>>> + 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<P::BuildError, P::PoolError, ConnectionError, Error>>> + Send + 'async_trait>>

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

Drops a database