db-pool 0.6.0

A thread-safe database pool for running database-tied integration tests in parallel
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use std::{fmt::Debug, ops::DerefMut};

use async_trait::async_trait;
use diesel::{result::Error, ConnectionError};
use diesel_async::{pooled_connection::AsyncDieselConnectionManager, AsyncConnection};

use crate::r#async::backend::error::Error as BackendError;

#[async_trait]
pub trait DieselPoolAssociation<Connection>: 'static
where
    Connection: AsyncConnection + 'static,
{
    type PooledConnection<'pool>: DerefMut<Target = Connection> + Send;

    type Builder;
    type Pool: Send + Sync + 'static;

    type BuildError: Into<BackendError<Self::BuildError, Self::PoolError, ConnectionError, Error>>
        + Debug
        + Send;
    type PoolError: Into<BackendError<Self::BuildError, Self::PoolError, ConnectionError, Error>>
        + Debug
        + Send;

    async fn build_pool(
        builder: Self::Builder,
        manager: AsyncDieselConnectionManager<Connection>,
    ) -> Result<Self::Pool, Self::BuildError>;
    async fn get_connection<'pool>(
        pool: &'pool Self::Pool,
    ) -> Result<Self::PooledConnection<'pool>, Self::PoolError>;
}