diff --git a/Cargo.toml b/Cargo.toml index 1cadb15..1c5333c 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -2,7 +2,7 @@ name = "questdb" description = "Connector for questdb" repository = "https://github.com/solanav/questdb-rs" -version = "0.1.2" +version = "0.2.0" authors = ["solanav "] edition = "2018" license = "MIT" @@ -12,7 +12,7 @@ categories = ["database"] documentation = "https://docs.rs/questdb" [dependencies] -serde = { version = "1.0", features = ["derive"] } -serde_json = "1.0" -reqwest = { version = "0.10", features = ["json", "blocking"] } -tokio = { version = "0.2", features = ["macros"] } \ No newline at end of file +serde = { version = "1", features = ["derive"] } +serde_json = "1" +reqwest = { version = "0.11", features = ["json", "blocking", "multipart"] } +tokio = { version = "1", features = ["macros", "rt"] } \ No newline at end of file diff --git a/src/lib.rs b/src/lib.rs index 5a7f9fd..b215511 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -12,27 +12,29 @@ pub use api::QuestDB; /// Custom error pub use error::Error; -use serde::Deserialize; - -#[derive(Deserialize, Debug)] -struct TestData { - id: i32, - ts: String, - temp: f64, - sensor_id: i32, -} - #[cfg(test)] mod tests { use crate::api::QuestDB; - use crate::TestData; use crate::types::Atomicity; + use serde::Deserialize; use std::fs::File; + #[allow(dead_code)] + #[derive(Deserialize, Debug)] + struct TestData { + id: i32, + ts: String, + temp: f64, + sensor_id: i32, + } + #[tokio::test] async fn test_exec() { let connection = QuestDB::new("http://192.168.1.37:9000"); - let _res = match connection.exec::("select * from readings", Some(5), None, None).await { + let _res = match connection + .exec::("select * from readings", Some(5), None, None) + .await + { Ok(res) => res, Err(e) => { println!("{}", e); @@ -44,13 +46,16 @@ mod tests { #[tokio::test] async fn test_imp() { let connection = QuestDB::new("http://192.168.1.37:9000"); - let _res = match connection.imp( - "./links.csv", - "nu_table", - Some(false), - Some(true), - Some(Atomicity::Strict), - ).await { + let _res = match connection + .imp( + "./links.csv", + "nu_table", + Some(false), + Some(true), + Some(Atomicity::Strict), + ) + .await + { Ok(res) => res, Err(e) => { println!("{}", e); @@ -64,7 +69,10 @@ mod tests { let connection = QuestDB::new("http://192.168.1.37:9000"); let mut output_file = File::create("output.csv").unwrap(); - let _res = match connection.exp("select * from nu_table", Some(5), &mut output_file).await { + let _res = match connection + .exp("select * from nu_table", Some(5), &mut output_file) + .await + { Ok(res) => res, Err(e) => { println!("{}", e);