cartel-pg 0.5.0

Async PostgreSQL driver for the dope runtime
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

use dope_fiber::Fiber;

use crate::{Dispatched, Error, ExtractUnit, PgOps, QuerySet};

pub trait PgRawExt<'d, I>: PgOps<'d, I>
where
    I: QuerySet + 'd,
{
    fn execute_raw(&self, sql: &str) -> Dispatched<'d, I, ExtractUnit> {
        self.dispatch_sql(sql)
    }

    fn migrate(
        &self,
        stmts: &'static [&'static str],
    ) -> impl Fiber<'d, Output = Result<(), Error>> + use<'d, Self, I> {
        let client = self.client();
        dope_fiber::fiber!('d => async move {
            for statement in stmts {
                client.dispatch_sql(statement).await?;
            }
            Ok(())
        })
    }
}

impl<'d, I, T> PgRawExt<'d, I> for T
where
    T: PgOps<'d, I>,
    I: QuerySet + 'd,
{
}