taosdata / taos-connector-rust Goto Github PK

thread 'core::training::tests::test_register_in_parallel' panicked at 'not yet implemented'

the trait bound `taos::taos_query::Manager<taos::TaosBuilder>: r2d2::ManageConnection` is not satisfied
the trait `r2d2::ManageConnection` is not implemented for `taos::taos_query::Manager<taos::TaosBuilder>`

        let conn = self.td_conns.get(machine_index as usize).unwrap();
        let query_clone = query.clone();
        let result = conn.query(query_clone).await;
        let mut result = match result {
            Ok(result) => result,
            Err(err) => {
                return Err(format!("查询taos 错误 ,sql语句 is {}, err is {}", query, err));
            }
        };

 Jan 29 01:41:07.621  INFO axum_study::controller::jian_pan_controller: 查询失败 "查询taos 错误 ,sql语句 is select 1 as sort_order ,'dcs_rhte' as tablename,'undefined' as description ,'' as label ,'1' as borderType ,'undefined' as unit, l
ast(ts) as ts ,last(pvalue) as pvalue from dcs_rhte  order by sort_order ;, err is [0x2662] Internal error: `����������������������������������������������������������������������������������������������������������������������������������
��������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������systS�x�`"

        let start = Instant::now();
        // 建立 taos 连接
        let taos_futures: Vec<_> = config.cfg.iter().enumerate().map(|(index, cfg)| {
            let dsn = format!("taos://{}:{}@{}:{}/{}", cfg.user, cfg.password, cfg.host, cfg.port, cfg.database);
            info!("{}号机 taos 连接字符串为: {}", index + 1, dsn);
            async move {
                let builder = TaosBuilder::from_dsn(&dsn).map_err(|e| format!("创建 TaosBuilder 失败：{}", e))?;
                builder.build().await.map_err(|e| format!("{}号机 taos 数据库连接失败：{}", index + 1, e))
            }
        }).collect();

        // let taos = Vec::new();
        let taos: Vec<_> = join_all(taos_futures)
            .await
            .into_iter()
            .map(|db| db.unwrap_or_else(|e| panic!("taos 数据库连接失败：{}", e)))
            .collect();

        let duration = start.elapsed();
        info!("建立taos 连接耗时为 :{:?}", duration);

~/taos-connector-rust-test$ cargo test test_ok
    Finished test [unoptimized + debuginfo] target(s) in 0.11s
     Running unittests src/main.rs (target/debug/deps/taos_connector_rust_test-e94ad84d9c31444b)

running 1 test
test tests::test_ok ... ok

test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 2 filtered out; finished in 1.46s

~/taos-connector-rust-test$ cargo test test_ws_null
    Finished test [unoptimized + debuginfo] target(s) in 0.11s
     Running unittests src/main.rs (target/debug/deps/taos_connector_rust_test-e94ad84d9c31444b)

running 1 test
test tests::test_ws_null ... ok

test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 2 filtered out; finished in 0.60s

~/taos-connector-rust-test$ cargo test test_taos_null --bin taos-connector-rust-test
    Finished test [unoptimized + debuginfo] target(s) in 0.11s
     Running unittests src/main.rs (target/debug/deps/taos_connector_rust_test-e94ad84d9c31444b)

running 1 test
error: test failed, to rerun pass `--bin taos-connector-rust-test`

Caused by:
  process didn't exit successfully: `/home/zky/taos-connector-rust-test/target/debug/deps/taos_connector_rust_test-e94ad84d9c31444b test_taos_null` (signal: 11, SIGSEGV: invalid memory reference)

use taos::*;

async fn test_null_tag(dsn: &str, tag_value: Value) -> anyhow::Result<()> {
    let taos = TaosBuilder::from_dsn(dsn)?.build().await?;
    taos.exec("DROP DATABASE IF EXISTS power").await?;
    taos.create_database("power").await?;
    taos.use_database("power").await?;
    taos.exec("CREATE STABLE IF NOT EXISTS meters (ts TIMESTAMP, current FLOAT) TAGS (location BINARY(64), groupId INT)").await?;

    let mut stmt = Stmt::init(&taos).await?;
    stmt.prepare("INSERT INTO ? USING meters TAGS(?, ?) VALUES(?, ?)")
        .await?;
    // bind table name and tags
    stmt.set_tbname_tags(
        "d1001",
        &[Value::VarChar("California.SanFransico".into()), tag_value],
    )
    .await?;
    // bind values.
    let values = vec![
        ColumnView::from_millis_timestamp(vec![1648432611249]),
        ColumnView::from_floats(vec![10.3]),
    ];
    stmt.bind(&values).await?;

    stmt.add_batch().await?;

    // execute.
    let rows = stmt.execute().await?;
    assert_eq!(rows, 1);
    Ok(())
}

#[cfg(test)]
mod tests {
    use super::*;
    use anyhow::Result;

    #[tokio::test]
    async fn test_taos_null() -> Result<()> {
        test_null_tag("taos://", Value::Null(Ty::Int)).await?;
        Ok(())
    }
    #[tokio::test]
    async fn test_ws_null() -> Result<()> {
        test_null_tag("ws://", Value::Null(Ty::Int)).await?;
        Ok(())
    }
    #[tokio::test]
    async fn test_ok() -> Result<()> {
        test_null_tag("ws://", Value::Int(8)).await?;
        test_null_tag("taos://", Value::Int(8)).await?;
        Ok(())
    }
}

[package]
name = "taos-connector-rust-test"
version = "0.1.0"
edition = "2021"

[dependencies]
taos = "*"
anyhow = "1"

error: failed to run custom build command for `taos-sys v0.3.12 (/Users/zmlgirl/Documents/codes/github/taosdata/taos-connector-rust/taos-sys)`

Caused by:
  process didn't exit successfully: `/Users/zmlgirl/Documents/codes/github/taosdata/taos-connector-rust/target/release/build/taos-sys-a09b52143fd67bfc/build-script-build` (exit status: 101)
  --- stdout
  cargo:rerun-if-env-changed=TAOS_LIBRARY_PATH
  TAOS_LIBRARY_PATH unset

  --- stderr
  thread 'main' panicked at 'internal error: entered unreachable code: the current os is not supported', taos-sys/build.rs:60:9
  note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace
warning: build failed, waiting for other jobs to finish...