文盘Rust -- rust 连接云上数仓 starwift

  curl -O 'https://builds.clickhouse.com/master/macos/clickhouse' && chmod a  +x ./clickhouse

clickhouse client --host service-terrabase-9s29mdlsb7.terrabase-9s29mdlsb7-hb-public.jvessel2.jdcloud.com \--port 9000 \--user sample \--password xxxxxx

clickhouse:) show databases

# clickhouse tcptokio = { version = "1.21.2", features = ["full"] }clickhouse-rs = { git = "https://github.com/suharev7/clickhouse-rs", features = ["default"]}

use clickhouse_rs::Pool;
#[tokio::main]async fn main() {    let database_url="tcp://username:password@service-terrabase-9s29mdlsb7.terrabase-9s2mdsb-hb-public.jvessel2.jdcloud.com:9000?compression=lz4".to_string();    let pool = Pool::new(database_url);        let mut client = pool.get_handle().await.unwrap();    let sql = "show databases;";    let r = client.query(sql).fetch_all().await;    println!("result is: {:?}", r);}

# clickhouse httpclickhouse = {git = "https://github.com/loyd/clickhouse.rs", features = ["test-util"]}

use clickhouse::Client;use clickhouse::Row;use serde::{Deserialize, Serialize};    #[derive(Debug, Row, Serialize, Deserialize)]struct Database {    name: String,}    #[tokio::main]async fn main() {    let client = Client::default()    .with_url("https://service-terrabase-9s29mdlsb7.terrabase-9sdlb7-hb-public.jvessel2.jdcloud.com:8123")    .with_user("username")    .with_password("password");        let sql = "SHOW databases";    let r = client.query(sql).fetch_all::<Database>().await;    println!("result is: {:?}", r);}