Struct MySQLBackend

pub struct MySQLBackend { /* private fields */ }

MySQL backend

Implementations

impl MySQLBackend

pub fn new( opts: Opts, create_privileged_pool: impl Fn() -> Builder<MySqlConnectionManager>, create_restricted_pool: impl Fn() -> Builder<MySqlConnectionManager> + Send + Sync + 'static, create_entities: impl Fn(&mut Conn) + Send + Sync + 'static, ) -> Result<Self, Error>

Creates a new MySQL backend

Example

use db_pool::{sync::MySQLBackend, PrivilegedMySQLConfig};
use dotenvy::dotenv;
use r2d2::Pool;
use r2d2_mysql::mysql::{prelude::Queryable, OptsBuilder};

dotenv().ok();

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

let backend = MySQLBackend::new(
    config.into(),
    || Pool::builder().max_size(10),
    || Pool::builder().max_size(2),
    move |conn| {
        conn.query_drop(
            "CREATE TABLE book(id INTEGER PRIMARY KEY AUTO_INCREMENT, title TEXT NOT NULL)",
        )
        .unwrap();
    },
)
.unwrap();

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

Drop databases created in previous runs upon initialization

Trait Implementations

impl Backend for MySQLBackend

type ConnectionManager = MySqlConnectionManager

Type that implements the r2d2::ManageConnection trait

type ConnectionError = Error

Connection error type that implements Debug

type QueryError = Error

Query error type that implements Debug

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

Initializes the backend

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

Creates a database

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

Cleans a database

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

Drops a database