Rust 連接器

Crates.io

Rust 連接器仍然在快速開發中，版本API變動在所難免，在1.0 之前無法保證其向后兼容，請使用時注意版本及對應的文檔。

感謝對的貢獻，使Rust社區能夠使用Rust 連接. 項目旨在為Rust開發者提供官方支持，使用taosc接口及HTTP接口構建兼容API以便于用戶切換接口方式。

依賴

默認情況下，使用 C 接口連接數據庫，所以您需要：

TDengine客戶端
clang: bindgen 使用 libclangAST 來生成對應的Rust綁定。

特性列表

[x] C 接口的Rust綁定
[x] 使用 rest feature 來啟用 RESTful API.
連接池支持（feature r2d2）
[ ] 迭代器接口
[ ] 流式計算接口
[ ] 訂閱支持

構建和測試

cargo build
cargo test

測試使用默認用戶名密碼和本地連接。您可以根據具體情況設置環境變量：

TEST_TAOS_IP
TEST_TAOS_PORT
TEST_TAOS_USER
TEST_TAOS_PASS
TEST_TAOS_DB

使用

使用默認的taosc 連接方式，可以在 Cargo.toml 中直接添加 libtaos 依賴：

[dependencies]
libtaos = "v0.3.8"

添加 feature r2d2 來啟動連接池：

[dependencies]
libtaos = { version = "*", features = ["r2d2"] }

對于RESTful接口，可使用 rest 特性來替代taosc，免去安裝TDengine客戶端。

[dependencies]
libtaos = { version = "*", features = ["rest"] }

本項目中提供一個如下：

// ...
#[tokio::main]
async fn main() -> Result<(), Error> {
    init();
    let taos = taos_connect()?;

    assert_eq!(
        taos.query("drop database if exists demo").await.is_ok(),
        true
    );
    assert_eq!(taos.query("create database demo").await.is_ok(), true);
    assert_eq!(taos.query("use demo").await.is_ok(), true);
    assert_eq!(
        taos.query("create table m1 (ts timestamp, speed int)")
            .await
            .is_ok(),
        true
    );

    for i in 0..10i32 {
        assert_eq!(
            taos.query(format!("insert into m1 values (now+{}s, {})", i, i).as_str())
                .await
                .is_ok(),
            true
        );
    }
    let rows = taos.query("select * from m1").await?;

    println!("{}", rows.column_meta.into_iter().map(|col| col.name).join(","));
    for row in rows.rows {
        println!("{}", row.into_iter().join(","));
    }
    Ok(())
}

您可以在 - 一個 Rust 編寫的 Prometheus 遠程存儲 API 適配器 - 看到如何在具體應用中使用 Rust 連接器。