1 unstable release
0.1.2 | Apr 2, 2023 |
---|---|
0.1.1 |
|
0.1.0 |
|
#36 in #clickhouse
200KB
6K
SLoC
CLICKHOUSE-READONLY
Asynchronious TCP Connector to Clickhouse Database with readonly
permissions (E.g. you can only execute queries but not made Cmd::DATA
calls for PacketStream
).
Date
or another Date Types are not supported.Int256
provided byethnum::I256
and can be resolved only toethereum_types::U256
.FixedString(42)
can be resolved toethereum_types::Address
Supported types:
pub enum SqlType {
UInt8,
UInt16,
UInt32,
UInt64,
Int8,
Int16,
Int32,
Int64,
Int256,
String,
FixedString,
Float32,
Float64,
Nullable,
Array,
}
<!> Crate is not planned to be update and can be used as it exists.
Example
cargo run --package clickhouse-readonly --example query_stream
use clickhouse_readonly::{ClickhouseResult, Pool, PoolConfig};
use futures_util::StreamExt;
#[tokio::main]
async fn main() -> ClickhouseResult<()> {
std::env::set_var("RUST_LOG", "clickhouse_readonly=trace");
env_logger::init();
let config = PoolConfig::new(
"127.0.0.1".parse().unwrap(),
"default".to_string(),
"username".to_string(),
"password".to_string(),
true,
).build();
let pool = Pool::new(config);
let mut handle = pool.get_handle().await?;
let mut stream = handle.query("SELECT * FROM default.some_table").stream();
while let Some(row) = stream.next().await {
let row = row?;
let asset: ethereum_types::Address = row.get("asset")?;
let ticker: String = row.get("asset_symbol")?;
let rate: ethereum_types::U256 = row.get("deposit")?;
eprintln!("Found {ticker}: {asset:?} / rate: {rate:?}");
}
Ok(())
}
Dependencies
~9–22MB
~317K SLoC