clickhouse 0.15.2

Official Rust client for ClickHouse DB
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

//! Tests for the `database` URL query parameter.
//!
//! See: <https://github.com/ClickHouse/clickhouse-rs/issues/448>

use clickhouse::Client;

/// Build a client for the current test environment with the given URL query string.
fn client_with_url_query(query: &str) -> Client {
    match crate::test_env() {
        crate::TestEnv::Local => {
            Client::default().with_url(format!("http://localhost:8123?{query}"))
        }
        crate::TestEnv::Cloud => Client::default()
            .with_url(format!("{}?{query}", crate::get_cloud_url()))
            .with_user("default")
            .with_password(crate::require_env_var("CLICKHOUSE_CLOUD_PASSWORD")),
    }
}

async fn current_database(client: &Client) -> String {
    client
        .query("SELECT currentDatabase()")
        .fetch_one::<String>()
        .await
        .unwrap()
}

#[tokio::test]
async fn query_uses_url_database_param() {
    let client = client_with_url_query("database=system");
    assert_eq!(current_database(&client).await, "system");
}

#[tokio::test]
async fn last_configured_database_wins() {
    let client = client_with_url_query("database=system").with_database("default");
    assert_eq!(current_database(&client).await, "default");
}