rbdc-tdengine

TDengine 数据库驱动 for rbatis / rbdc。

基于 taos-connector-rust 实现，通过 WebSocket 协议连接 TDengine。

版本兼容

特性 (Features)

安装

[dependencies]

rbatis = "4.9"

rbdc-tdengine = "4.9"

快速开始

use rbatis::RBatis;
use rbdc_tdengine::driver::TaosDriver;
use rbdc_tdengine::options::TaosConnectOptions;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let mut rb = RBatis::new();
    rb.init_opt(
        TaosDriver {},
        TaosConnectOptions {
            dsn: "taos+ws://localhost:6041/test".to_string(),
        },
    )?;

    // 执行查询
    let rows = rb.exec("CREATE TABLE IF NOT EXISTS meters \
        (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT)",
        vec![],
    ).await?;

    Ok(())
}

使用连接池

[dependencies]

rbdc-pool-deadpool = "4.9"

use rbdc_pool_deadpool::DeadPool;

let pool = DeadPool::new(
    TaosDriver {},
    TaosConnectOptions {
        dsn: "taos+ws://localhost:6041/test".to_string(),
    },
    10, // 最大连接数
);

使用 rbatis CRUD 宏

use rbatis::crud;
use serde::{Serialize, Deserialize};
use rbdc::datetime::DateTime;

#[derive(Clone, Debug, Serialize, Deserialize)]
struct Record {
    ts: DateTime,
    current: Option<f32>,
    voltage: Option<i32>,
    phase: Option<f32>,
}

crud!(Record {}, "meters");

// 插入
let record = Record {
    ts: DateTime::now(),
    current: Some(43.0),
    voltage: Some(44),
    phase: Some(45.0),
};
Record::insert(&mut rb, &record).await?;

DSN 格式

taos+ws://<host>:<port>/<database>

示例：

taos+ws://localhost:6041/test

License

MIT