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

pub mod test;
pub mod test_bytes;
pub mod test_decimal;
pub mod test_enum;
pub mod test_flatten;
#[cfg(feature = "geo-types")]
pub mod test_geo;
pub mod test_into;
pub mod test_lock;
pub mod test_nested;
pub mod test_options;
pub mod test_ordering;
pub mod test_raw_string;
pub mod test_robustness;
pub mod test_serialize;
pub mod test_types;

use nativeclick::{Client, ClientOptions};

pub async fn get_client() -> Client {
    let mut options = ClientOptions::default();

    if let Ok(user) = std::env::var("NATIVECLICK_TEST_USER") {
        options.username = user;
    }

    if let Ok(password) = std::env::var("NATIVECLICK_TEST_PASSWORD") {
        options.password = password;
    }

    if let Ok(database) = std::env::var("NATIVECLICK_TEST_DATABASE") {
        options.default_database = database;
    }

    let address =
        std::env::var("NATIVECLICK_TEST_ADDR").unwrap_or_else(|_| "127.0.0.1:9000".into());

    Client::connect(address, options).await.unwrap()
}
/// Drop the table if it exists, and create it with the given structure.
/// Make sure to use distinct table names across tests to avoid conflicts between tests executing
/// simultaneously.
pub async fn prepare_table(table_name: &str, table_struct: &str, client: &Client) {
    client
        .execute(format!("DROP TABLE IF EXISTS {table_name}"))
        .await
        .unwrap();
    client
        .execute(format!(
            "CREATE TABLE {table_name} ({table_struct}) ENGINE = Memory;"
        ))
        .await
        .unwrap();
}