cdbc 0.1.23

Rust Coroutine Database Driver Connectivity
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

use crate::database::Database;
use crate::error::Error;
use crate::pool::{MaybePoolConnection, Pool, PoolConnection};
use crate::transaction::Transaction;
use std::ops::{Deref, DerefMut};

pub trait Acquire<'c> {
    type Database: Database;

    type Connection: Deref<Target = <Self::Database as Database>::Connection> + DerefMut + Send;

    fn acquire(self) ->  Result<Self::Connection, Error>;

    fn begin(self) ->  Result<Transaction<'c, Self::Database>, Error>;
}

impl<'a, DB: Database> Acquire<'a> for &'_ Pool<DB> {
    type Database = DB;

    type Connection = PoolConnection<DB>;

    fn acquire(self) ->  Result<Self::Connection, Error> {
        self.acquire()
    }

    fn begin(self) ->  Result<Transaction<'a, DB>, Error> {
        let conn = self.acquire();
        Transaction::begin(MaybePoolConnection::PoolConnection(conn?))
    }
}