update rust example code

This commit is contained in:
sheyanjie-qq 2024-08-04 09:44:50 +08:00 committed by gccgdb1234
parent cacfef82d7
commit c18a47f9ab
2 changed files with 34 additions and 0 deletions

View File

@ -1,4 +1,6 @@
use taos::*;
use chrono::Local;
use chrono::DateTime;
#[tokio::main]
async fn main() -> anyhow::Result<()> {
@ -61,6 +63,33 @@ async fn main() -> anyhow::Result<()> {
}
// ANCHOR_END: query_data
// ANCHOR: query_data_2
// query data, make sure the database and table are created before
#[derive(Debug, serde::Deserialize)]
#[allow(dead_code)]
struct Record {
// deserialize timestamp to chrono::DateTime<Local>
ts: DateTime<Local>,
// float to f32
current: Option<f32>,
// int to i32
voltage: Option<i32>,
phase: Option<f32>,
groupid: i32,
// binary/varchar to String
location: String,
}
let records: Vec<Record> = taos
.query("select ts, current, voltage, phase, groupid, location from power.meters limit 100")
.await?
.deserialize()
.try_collect()
.await?;
dbg!(records);
// ANCHOR_END: query_data_2
// ANCHOR: query_with_req_id
let result = taos.query_with_req_id("SELECT ts, current, location FROM power.meters limit 1", 1).await?;
for field in result.fields() {

View File

@ -202,6 +202,11 @@ curl --location -uroot:taosdata 'http://127.0.0.1:6041/rest/sql' \
{{#include docs/examples/rust/nativeexample/examples/query.rs:query_data}}
```
rust 连接器还支持使用 **serde** 进行反序列化行为结构体的结果获取方式:
```rust
{{#include docs/examples/rust/nativeexample/examples/query.rs:query_data_2}}
```
</TabItem>
<TabItem label="Node.js" value="node.js">
```js