qldb 3.2.9

Driver for Amazon's QLDB Database implemented in pure rust.
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

mod utils;
use eyre::Result;
use ion_binary_rs::IonValue;
use qldb::QldbClient;
use std::collections::HashMap;
use utils::ensure_test_table;

#[async_std::test]
async fn closing_session_pool() -> Result<()> {
    let mut client = QldbClient::default("rust-crate-test", 200).await?;

    let test_table = ensure_test_table(&client).await;

    client
        .transaction_within(|client| {
            let test_table = test_table.clone();
            async move {
                client
                    .query(&format!(r#"SELECT COUNT(*) FROM {};"#, test_table))
                    .execute()
                    .await?;

                Ok(())
            }
        })
        .await?;

    client.close().await;

    async_std::task::sleep(std::time::Duration::from_millis(100)).await;

    let result_b = client
        .transaction_within(|client| {
            let test_table = test_table.clone();
            async move {
                client
                    .query(&format!("INSERT INTO {} VALUE ?", test_table))
                    .param(get_value_to_insert())
                    .execute()
                    .await?;

                Ok(())
            }
        })
        .await;

    println!("{:?}", result_b);

    if !result_b.is_err() {
        panic!("Close should make the transaction to fail")
    }

    Ok(())
}

fn get_value_to_insert() -> IonValue {
    let mut map = HashMap::new();
    map.insert("test_column".to_string(), IonValue::String("test_value".to_string()));
    IonValue::Struct(map)
}