datasources 0.1.5

Async datasource interfaces, middleware, registry, and test doubles
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

use std::sync::Arc;

use crate::{Connection, IUnitOfWork, MockConnection, MockTransaction, UnitOfWorkTransaction};

#[tokio::test]
async fn nested_begin_starts_once() {
    let txn = Arc::new(MockTransaction::new_unbound());
    let connection = MockConnection::with_transaction(txn.clone());
    let shared: Arc<dyn Connection> = connection.clone();
    let mut outer = UnitOfWorkTransaction::new(shared.clone());
    outer.begin().await.expect("begin");
    let mut inner = UnitOfWorkTransaction::new(shared);
    inner.begin().await.expect("join");
    inner.commit().await.expect("join commit");
    outer.commit().await.expect("commit");
    assert_eq!(connection.start_calls(), 1);
    assert_eq!(txn.commit_calls(), 1);
    assert_eq!(txn.abort_calls(), 0);
}

#[tokio::test]
async fn nested_abort_rolls_back_once() {
    let txn = Arc::new(MockTransaction::new_unbound());
    let connection = MockConnection::with_transaction(txn.clone());
    let shared: Arc<dyn Connection> = connection.clone();
    let mut outer = UnitOfWorkTransaction::new(shared.clone());
    outer.begin().await.expect("begin");
    let mut inner = UnitOfWorkTransaction::new(shared);
    inner.begin().await.expect("join");
    inner.abort().await.expect("join abort");
    outer.abort().await.expect("abort");
    assert_eq!(connection.start_calls(), 1);
    assert_eq!(txn.commit_calls(), 0);
    assert_eq!(txn.abort_calls(), 1);
}