mobc-sqlx 2.0.0

SQLx support for the mobc connection pool
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
34
35
36
37
38
39
40

use mobc::{Pool, async_trait};
use sqlx::{
    Database,
    migrate::{Migrate, Migrator},
};

use crate::SqlxConnectionManager;

#[async_trait]
pub trait SqlxMigrationExt<DB>
where
    DB: Database + Sync,
    <DB as Database>::Connection: Migrate,
{
    async fn migrate(
        &self,
        migrator: &Migrator,
    ) -> Result<(), mobc::Error<sqlx::Error>>;
}

#[async_trait]
impl<DB> SqlxMigrationExt<DB> for Pool<SqlxConnectionManager<DB>>
where
    DB: Database + Sync,
    <DB as Database>::Connection: Migrate,
{
    async fn migrate(
        &self,
        migrator: &Migrator,
    ) -> Result<(), mobc::Error<sqlx::Error>> {
        let mut connection = self.get().await?;

        migrator
            .run_direct(&mut *connection)
            .await
            .map_err(sqlx::Error::from)?;

        Ok(())
    }
}