tablet.into performance optimization

Author: manlge

Cargo.toml

@@ -14,26 +14,26 @@
 # under the License.
 
 [package]
-name = "iotdb-client-rs"
-version = "0.3.7"
 authors = ["Mark Liu <[email protected]>"]
+categories = ["database"]
+description = "Rust client library for Apache IoTDB"
+documentation = "https://docs.rs/iotdb-client-rs"
 edition = "2021"
+keywords = ["iotdb", "iotdb-client-rust", "apache-iotdb"]
 license = "Apache-2.0"
+name = "iotdb-client-rs"
 readme = "README.md"
-description = "Rust client library for Apache IoTDB"
-keywords = ["iotdb", "iotdb-client-rust", "apache-iotdb"]
 repository = "https://github.com/manlge/iotdb-client-rs.git"
-categories = ["database"]
-documentation = "https://docs.rs/iotdb-client-rs"
+version = "0.3.8"
 
 [lib]
 name = "iotdb"
 
 [dev-dependencies]
-chrono="0.4.19"
+chrono = "0.4.19"
 prettytable-rs = "0.8.0"
 structopt = "0.3.25"
 
 [dependencies]
-thrift="0.15.0"
-permutation = "0.2.5"
+permutation = "0.2.5"
+thrift = "0.15.0"

README.md

@@ -61,7 +61,7 @@ Put this in your `Cargo.toml`:
 
 ```toml
 [dependencies]
-iotdb-client-rs="^0.3.7"
+iotdb-client-rs="^0.3.8"
 ```
 
 ## Example
@@ -70,7 +70,7 @@ Put this in your example's `Cargo.toml`:
 
 ```toml
 [dependencies]
-iotdb-client-rs="^0.3.7"
+iotdb-client-rs="^0.3.8"
 chrono="0.4.19"
 prettytable-rs="0.8.0"
 structopt = "0.3.25"

src/client/mod.rs

@@ -67,10 +67,23 @@ impl Into<Vec<u8>> for &Tablet {
     fn into(self) -> Vec<u8> {
         let mut buffer: Vec<u8> = Vec::with_capacity(self.get_row_count()*self.get_column_count()*8);
         self.columns.iter().for_each(|column| {
-            column.iter().for_each(|v| {
-                let mut value_data: Vec<u8> = v.into();
-                value_data.remove(0); //first item is datatype, remove it.
-                buffer.append(&mut value_data);
+            column.iter().for_each(|value| {
+                match value{
+                    Value::Bool(v) =>  match v {
+                        true => buffer.push(1),
+                        false => buffer.push(0),
+                    },
+                    Value::Int32(v) => buffer.append(&mut v.to_be_bytes().to_vec()),
+                    Value::Int64(v) => buffer.append(&mut v.to_be_bytes().to_vec()),
+                    Value::Float(v) =>  buffer.append(&mut v.to_be_bytes().to_vec()),
+                    Value::Double(v) =>  buffer.append(&mut v.to_be_bytes().to_vec()),
+                    Value::Text(t) => {
+                        let len = t.len() as i32;
+                        buffer.append(&mut len.to_be_bytes().to_vec());
+                        buffer.append(&mut t.as_bytes().to_vec());
+                    },
+                    Value::Null => unimplemented!("null value doesn't implemented for tablet"),
+                }
             });
         });
         buffer