nativeclick 0.26.9

Nativeclick is a pure Rust SDK for working with Clickhouse with the native protocol in async environments with minimal boilerplate and maximal performance.
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

use nativeclick::Row;

#[derive(nativeclick::Row, Debug, Default, PartialEq, Clone)]
pub struct TestRow {
    field: u32,
    #[nativeclick(flatten)]
    subrow: SubRow,
    field2: u32,
}

#[derive(nativeclick::Row, Debug, Default, PartialEq, Clone)]
pub struct SubRow {
    a: u32,
    b: f32,
}

#[tokio::test]
async fn test_client() {
    let _ = env_logger::builder()
        .filter_level(log::LevelFilter::Info)
        .try_init();

    assert!(
        TestRow::column_names()
            .unwrap()
            .into_iter()
            .zip(["field", "a", "b"])
            .all(|(x, y)| x == y)
    );

    let client = super::get_client().await;

    super::prepare_table(
        "test_flatten",
        "field UInt32,
         field2 UInt32,
         a UInt32,
         b Float32",
        &client,
    )
    .await;

    let row = TestRow {
        field: 1,
        field2: 4,
        subrow: SubRow { a: 2, b: 3.0 },
    };

    client
        .insert_native_block("INSERT INTO test_flatten FORMAT Native", vec![row.clone()])
        .await
        .unwrap();

    tokio::time::sleep(std::time::Duration::from_secs(1)).await;

    let row2 = client
        .query_one::<TestRow>("SELECT * FROM test_flatten")
        .await
        .unwrap();
    assert_eq!(row, row2);
}