conn.rs

/*
cargo run -p clickhouse-demo-postgres-client --bin clickhouse-demo-postgres-client-conn postgres://default:xxx@127.0.0.1:9005
*/

use std::env;

use clickhouse_postgres_client::{connect, execute, fetch_all};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    run().await
}

async fn run() -> Result<(), Box<dyn std::error::Error>> {
    let database_url = env::args().nth(1).unwrap_or_else(|| {
        env::var("DATABASE_URL")
            .unwrap_or_else(|_| "postgres://default:xxx@127.0.0.1:9005".to_owned())
    });

    let mut conn = connect(&database_url).await?;

    execute("use default", &mut conn).await?;

    let rows = fetch_all("show databases", &mut conn).await?;
    for row in rows.iter() {
        println!("data: {:?}", row.try_get_data());
    }

    Ok(())
}