docs: rust and go

docs/en/05-develop/01-connect/04-rust.md

@@ -6,13 +6,18 @@ pagination_next: develop/insert-data
 import Tabs from '@theme/Tabs';
 import TabItem from '@theme/TabItem';
 
+## Create Project
+
+```
+cargo new cloud_example
+```
 ## Add Dependency
 
 Add dependency to `Cargo.toml`. 
 
 ```toml title="Cargo.toml"
 [dependencies]
-libtaos = { version = "0.4.2"}
+libtaos = { version="*", feature=["rest"]}
 ```
 
 ## Config
@@ -59,15 +64,7 @@ To obtain the value of cloud token and URL, please log in [TDengine Cloud](https
 Copy following code to `main.rs`.
 
 ```rust title="main.rs"
-use libtaos::*;
-
-fn main() {
-    let token =  std::env::var("TDENGINE_CLOUD_TOKEN").unwrap();
-    let url = std::env::var("TDENGINE_CLOUD_URL").unwrap();
-    let dsn = url + "?token=" + &token;
-    let taos = Taos::from_dsn(dsn)?;
-    println!("connected");
-}
+{{#include docs/examples/rust/cloud_example/src/main.rs}}
 ```
 
 Then you can execute `cargo run` to test the connection.
\ No newline at end of file

docs/examples/go/connectexample/main.go

@@ -15,11 +15,12 @@ func main() {
 		fmt.Println(err)
 		return
 	}
-	_, err = taos.Query("select server_version()")
+	defer taos.Close()
+	rows, err := taos.Query("select server_version()")
 	if err != nil {
 		fmt.Println(err)
 		return
 	}
+	rows.Close()
 	fmt.Println("connect success")
-	defer taos.Close()
 }

docs/examples/rust/Cargo.toml

-[workspace]
-members = ["restexample", "nativeexample", "schemalessexample"]

docs/examples/rust/nativeexample/Cargo.toml → docs/examples/rust/cloud_example/Cargo.toml

 [package]
-name = "nativeexample"
+name = "cloud_example"
 version = "0.1.0"
 edition = "2021"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+
 [dependencies]
-libtaos = { version = "0.4.3" }
-tokio = { version = "*", features = ["rt", "macros", "rt-multi-thread"] }
-bstr = { version = "*" }
+libtaos = { version="0.4.5-alpha.0", feature=["rest"]}
+tokio = { version = "1", features = ["full"]}

docs/examples/rust/cloud_example/src/main.rs

+use libtaos::*;
+
+fn main() {
+    let token =  std::env::var("TDENGINE_CLOUD_TOKEN").unwrap();
+    let url = std::env::var("TDENGINE_CLOUD_URL").unwrap();
+    let dsn = url + "?token=" + &token;
+    let taos = TaosCfg::from_dsn(dsn)?;
+    println!("connected");
+}
\ No newline at end of file

docs/examples/rust/nativeexample/examples/connect.rs

-use libtaos::*;
-
-fn taos_connect() -> Result<Taos, Error> {
-    TaosCfgBuilder::default()
-        .ip("localhost")
-        .user("root")
-        .pass("taosdata")
-        // .db("log") // remove comment if you want to connect to database log by default.
-        .port(6030u16)
-        .build()
-        .expect("TaosCfg builder error")
-        .connect()
-}
-
-fn main() {
-    #[allow(unused_variables)]
-    let taos = taos_connect().unwrap();
-    println!("Connected")
-}

docs/examples/rust/nativeexample/examples/stmt_example.rs

-use bstr::BString;
-use libtaos::*;
-
-#[tokio::main]
-async fn main() -> Result<(), Error> {
-    let taos = TaosCfg::default().connect().expect("fail to connect");
-    taos.create_database("power").await?;
-    taos.use_database("power").await?;
-    taos.exec("CREATE STABLE meters (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT) TAGS (location BINARY(64), groupId INT)").await?;
-    let mut stmt = taos.stmt("INSERT INTO ? USING meters TAGS(?, ?) VALUES(?, ?, ?, ?)")?;
-    // bind table name and tags
-    stmt.set_tbname_tags(
-        "d1001",
-        [
-            Field::Binary(BString::from("California.SanFrancisco")),
-            Field::Int(2),
-        ],
-    )?;
-    // bind values.
-    let values = vec![
-        Field::Timestamp(Timestamp::new(1648432611249, TimestampPrecision::Milli)),
-        Field::Float(10.3),
-        Field::Int(219),
-        Field::Float(0.31),
-    ];
-    stmt.bind(&values)?;
-    // bind one more row
-    let values2 = vec![
-        Field::Timestamp(Timestamp::new(1648432611749, TimestampPrecision::Milli)),
-        Field::Float(12.6),
-        Field::Int(218),
-        Field::Float(0.33),
-    ];
-    stmt.bind(&values2)?;
-    // execute
-    stmt.execute()?;
-    Ok(())
-}

docs/examples/rust/nativeexample/examples/subscribe_demo.rs

-fn main() {
-  
-}
\ No newline at end of file

docs/examples/rust/nativeexample/src/main.rs

-fn main() {
-    println!("Hello, world!");
-}

docs/examples/rust/restexample/Cargo.toml

-[package]
-name = "restexample"
-version = "0.1.0"
-edition = "2021"
-
-[dependencies]
-libtaos = { version = "0.4.3", features = ["rest"] }
-tokio = { version = "*", features = ["rt", "macros", "rt-multi-thread"] }

docs/examples/rust/restexample/examples/connect.rs

-use libtaos::*;
-
-fn taos_connect() -> Result<Taos, Error> {
-    TaosCfgBuilder::default()
-        .ip("localhost")
-        .user("root")
-        .pass("taosdata")
-        // .db("log") // remove comment if you want to connect to database log by default.
-        .port(6030u16)
-        .build()
-        .expect("TaosCfg builder error")
-        .connect()
-}
-
-#[tokio::main]
-async fn main() {
-    #[allow(unused_variables)]
-    let taos = taos_connect().expect("connect error");
-    println!("Connected")
-}

docs/examples/rust/restexample/examples/insert_example.rs

-use libtaos::*;
-
-#[tokio::main]
-async fn main() -> Result<(), Error> {
-    let taos = TaosCfg::default().connect().expect("fail to connect");
-    taos.create_database("power").await?;
-    taos.exec("CREATE STABLE power.meters (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT) TAGS (location BINARY(64), groupId INT)").await?;
-    let sql = "INSERT INTO power.d1001 USING power.meters TAGS(California.SanFrancisco, 2) VALUES ('2018-10-03 14:38:05.000', 10.30000, 219, 0.31000) ('2018-10-03 14:38:15.000', 12.60000, 218, 0.33000) ('2018-10-03 14:38:16.800', 12.30000, 221, 0.31000)
-    power.d1002 USING power.meters TAGS(California.SanFrancisco, 3) VALUES ('2018-10-03 14:38:16.650', 10.30000, 218, 0.25000)
-    power.d1003 USING power.meters TAGS(California.LosAngeles, 2) VALUES ('2018-10-03 14:38:05.500', 11.80000, 221, 0.28000) ('2018-10-03 14:38:16.600', 13.40000, 223, 0.29000)
-    power.d1004 USING power.meters TAGS(California.LosAngeles, 3) VALUES ('2018-10-03 14:38:05.000', 10.80000, 223, 0.29000) ('2018-10-03 14:38:06.500', 11.50000, 221, 0.35000)";
-    let result = taos.query(sql).await?;
-    println!("{:?}", result);
-    Ok(())
-}
-
-// output:
-// TaosQueryData { column_meta: [ColumnMeta { name: "affected_rows", type_: Int, bytes: 4 }], rows: [[Int(8)]] }

docs/examples/rust/restexample/examples/query_example.rs

-use libtaos::*;
-
-fn taos_connect() -> Result<Taos, Error> {
-    TaosCfgBuilder::default()
-        .ip("localhost")
-        .user("root")
-        .pass("taosdata")
-        .db("power")
-        .port(6030u16)
-        .build()
-        .expect("TaosCfg builder error")
-        .connect()
-}
-
-#[tokio::main]
-async fn main() -> Result<(), Error> {
-    let taos = taos_connect().expect("connect error");
-    let result = taos.query("SELECT ts, current FROM meters LIMIT 2").await?;
-    // print column names
-    let meta: Vec<ColumnMeta> = result.column_meta;
-    for column in meta {
-        print!("{}\t", column.name)
-    }
-    println!();
-    // print rows
-    let rows: Vec<Vec<Field>> = result.rows;
-    for row in rows {
-        for field in row {
-            print!("{}\t", field);
-        }
-        println!();
-    }
-    Ok(())
-}
-
-// output:
-// ts      current
-// 2022-03-28 09:56:51.249 10.3
-// 2022-03-28 09:56:51.749 12.6

docs/examples/rust/restexample/src/main.rs

-fn main() {
-    println!("Hello, world!");
-}

docs/examples/rust/schemalessexample/Cargo.toml

-[package]
-name = "schemalessexample"
-version = "0.1.0"
-edition = "2021"
-
-[dependencies]
-libtaos = { version = "0.4.3" }

docs/examples/rust/schemalessexample/examples/influxdb_line_example.rs

-use libtaos::schemaless::*;
-use libtaos::*;
-
-fn main() {
-    let taos = TaosCfg::default().connect().expect("fail to connect");
-    taos.raw_query("CREATE DATABASE test").unwrap();
-    taos.raw_query("USE test").unwrap();
-    let lines = ["meters,location=California.LosAngeles,groupid=2 current=11.8,voltage=221,phase=0.28 1648432611249",
-    "meters,location=California.LosAngeles,groupid=2 current=13.4,voltage=223,phase=0.29 1648432611250",
-    "meters,location=California.LosAngeles,groupid=3 current=10.8,voltage=223,phase=0.29 1648432611249",
-    "meters,location=California.LosAngeles,groupid=3 current=11.3,voltage=221,phase=0.35 1648432611250"];
-    let affected_rows = taos
-        .schemaless_insert(
-            &lines,
-            TSDB_SML_LINE_PROTOCOL,
-            TSDB_SML_TIMESTAMP_MILLISECONDS,
-        )
-        .unwrap();
-    println!("affected_rows={}", affected_rows);
-}
-
-// run with:  cargo run --example influxdb_line_example

docs/examples/rust/schemalessexample/examples/opentsdb_json_example.rs

-use libtaos::schemaless::*;
-use libtaos::*;
-
-fn main() {
-    let taos = TaosCfg::default().connect().expect("fail to connect");
-    taos.raw_query("CREATE DATABASE test").unwrap();
-    taos.raw_query("USE test").unwrap();
-    let lines = [
-        r#"[{"metric": "meters.current", "timestamp": 1648432611249, "value": 10.3, "tags": {"location": "California.SanFrancisco", "groupid": 2}},
-        {"metric": "meters.voltage", "timestamp": 1648432611249, "value": 219, "tags": {"location": "California.LosAngeles", "groupid": 1}},
-        {"metric": "meters.current", "timestamp": 1648432611250, "value": 12.6, "tags": {"location": "California.SanFrancisco", "groupid": 2}},
-        {"metric": "meters.voltage", "timestamp": 1648432611250, "value": 221, "tags": {"location": "California.LosAngeles", "groupid": 1}}]"#,
-    ];
-
-    let affected_rows = taos
-        .schemaless_insert(
-            &lines,
-            TSDB_SML_JSON_PROTOCOL,
-            TSDB_SML_TIMESTAMP_NOT_CONFIGURED,
-        )
-        .unwrap();
-    println!("affected_rows={}", affected_rows); // affected_rows=4
-}
-
-// run with:  cargo run --example opentsdb_json_example

docs/examples/rust/schemalessexample/examples/opentsdb_telnet_example.rs

-use libtaos::schemaless::*;
-use libtaos::*;
-
-fn main() {
-    let taos = TaosCfg::default().connect().expect("fail to connect");
-    taos.raw_query("CREATE DATABASE test").unwrap();
-    taos.raw_query("USE test").unwrap();
-    let lines = [
-        "meters.current 1648432611249 10.3 location=California.SanFrancisco groupid=2",
-        "meters.current 1648432611250 12.6 location=California.SanFrancisco groupid=2",
-        "meters.current 1648432611249 10.8 location=California.LosAngeles groupid=3",
-        "meters.current 1648432611250 11.3 location=California.LosAngeles groupid=3",
-        "meters.voltage 1648432611249 219 location=California.SanFrancisco groupid=2",
-        "meters.voltage 1648432611250 218 location=California.SanFrancisco groupid=2",
-        "meters.voltage 1648432611249 221 location=California.LosAngeles groupid=3",
-        "meters.voltage 1648432611250 217 location=California.LosAngeles groupid=3",
-    ];
-    let affected_rows = taos
-        .schemaless_insert(
-            &lines,
-            TSDB_SML_TELNET_PROTOCOL,
-            TSDB_SML_TIMESTAMP_NOT_CONFIGURED,
-        )
-        .unwrap();
-    println!("affected_rows={}", affected_rows); // affected_rows=8
-}
-
-// run with:  cargo run --example opentsdb_telnet_example

docs/examples/rust/schemalessexample/src/main.rs

-fn main() {
-    println!("Hello, world!");
-}