butane 0.8.1

An ORM with a focus on simplicity and on writing Rust, not SQL.
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

#[cfg(any(feature = "pg", feature = "sqlite"))]
use butane::db::ConnectionManager;
use butane_test_helper::*;
#[cfg(any(feature = "pg", feature = "sqlite"))]
#[cfg(any(feature = "pg", feature = "sqlite"))]
use r2d2;
use std::ops::DerefMut;

#[cfg(feature = "sqlite")]
#[test]
fn r2d2_sqlite() {
    let manager = ConnectionManager::new(sqlite_connspec());
    let pool = r2d2::Pool::builder().max_size(3).build(manager).unwrap();

    {
        let mut conn1 = pool.get().unwrap();
        assert_eq!(pool.state().connections, 3);
        assert_eq!(pool.state().idle_connections, 2);
        setup_db(&mut conn1);

        let _conn2 = pool.get().unwrap();
        assert_eq!(pool.state().idle_connections, 1);
    }
    assert_eq!(pool.state().idle_connections, 3);
}

#[cfg(feature = "pg")]
#[test]
fn r2d2_pq() {
    let rt = tokio::runtime::Builder::new_current_thread()
        .enable_all()
        .build()
        .unwrap();
    let (connspec, _data) = rt.block_on(pg_connspec());
    let manager = ConnectionManager::new(connspec);
    let pool = r2d2::Pool::builder().max_size(3).build(manager).unwrap();

    {
        let mut conn1 = pool.get().unwrap();
        assert_eq!(pool.state().connections, 3);
        assert_eq!(pool.state().idle_connections, 2);
        setup_db(&mut conn1);

        let _conn2 = pool.get().unwrap();
        assert_eq!(pool.state().idle_connections, 1);
    }
    assert_eq!(pool.state().idle_connections, 3);
}

#[tokio::test]
async fn deadpool_test_pg_async() {
    let (connspec, _data) = pg_connspec().await;
    let manager = ConnectionManager::new(connspec);
    let pool = deadpool::managed::Pool::builder(manager).build().unwrap();
    assert_eq!(pool.status().size, 0);
    assert_eq!(pool.status().available, 0);
    {
        let mut conn: deadpool::managed::Object<ConnectionManager> = pool.get().await.unwrap();
        assert_eq!(pool.status().size, 1);
        assert_eq!(pool.status().available, 0);

        setup_db_async(conn.deref_mut()).await;
    }
    assert_eq!(pool.status().size, 1);
    assert_eq!(pool.status().available, 1);
}