clickhouse-rs
clickhouse-rs copied to clipboard
Asynchronous ClickHouse client library for Rust programming language.
In case of a TCP disconnect (i.e., server-side graceful TCP shutdown), query result stream should return error instead of just hanging indefinitely. Before this change, it would hang due to...
I got below error, any idea ? let mut client = pool.get_handle().await?; | ^^^^^^^^^^^^^^^^^^^^^^^ `GetHandle` is not a future My Cargo.toml is below clickhouse-rs = "*"
Hi! It looks like clickhouse-rs does not percent-decode username and password strings extracted from DSNs. https://github.com/suharev7/clickhouse-rs/blob/1be33ab41dba1c99204c848c0a60bbd587a1eb02/src/types/options.rs#L527-L529 Because of that, it's not possible to pass a password containing `/` or other...
This line doesn't seem correct to me: https://github.com/suharev7/clickhouse-rs/blob/b7f0df499ee1e1390e84c38cf2ccffef3ce7c612/src/types/column/fixed_string.rs#L70 Let's take a closer look at the implementation: ``` fn push(&mut self, value: Value) { let bs: String = String::from(value); let l...
I read the code of clickhouse-rs and found that after setting the capacity in Block::with_capacity, the later code does not use it. Shouldn't this be changed here? ``` cpp ///...
"1.0.0-alpha.1" ``` type ServerDate = chrono::Date; type ServerDateTime = chrono::DateTime; let date: ServerDateTime = row.get("datetime")?; | ^^^ the trait `clickhouse_rs::types::FromSql
It seems like some references to `tokio_tls` were overlooked when updating the `tokio-tls` dependency to `tokio-native-tls`. The yandex ClickHouse image used for Travis CI doesn't expose TLS ports by default,...
Hi! The code below ``` let block = client .query("SELECT * FROM demo LIMIT 1") .fetch_all() .await?; ``` causes error if table contains column with type `Nullable(DateTime('Europe/Moscow'))`: ``` Error: Io(Custom...
Is there any plan to support SELECT FORMAT ?
I'm getting such error: ``` error[E0277]: `GetHandle` is not a future --> src/main.rs:72:22 | 72 | let mut client = pool.get_handle().await?; | ^^^^^^^^^^^^^^^^^^^^^^^ `GetHandle` is not a future | =...