taos 0.12.3

Driver for TDengine - a timeseries database and analysis platform
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

use taos::*;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    pretty_env_logger::formatted_timed_builder().init();
    let dsn = "taos+ws://root:taosdata@";

    let pool = TaosBuilder::from_dsn(dsn)?.pool()?;
    log::trace!("start");

    let taos = pool.get().await?;
    log::trace!("got connection");

    let mut result = taos
        .query("select * from information_schema.ins_databases")
        .await?;

    for field in result.fields() {
        println!("got field: {}", field.name());
    }

    // Query option 1, use rows stream.
    let mut rows = result.rows();
    let mut nrows = 0;
    while let Some(row) = rows.try_next().await? {
        for (col, (name, value)) in row.enumerate() {
            println!(
                "[{}] got value in col {} (named `{:>8}`): {}",
                nrows, col, name, value
            );
        }
        nrows += 1;
    }
    Ok(())
}