add integration tests (#784)

Author: jiacai2050

integration_tests/cases/env/local/influxql/basic.result

@@ -29,6 +29,11 @@ SELECT * FROM "h2o_feet";
 
 {"results":[{"statement_id":0,"series":[{"name":"h2o_feet","columns":["time","level_description","location","water_level"],"values":[[1439827200000,"below 3 feet","santa_monica",2.064],[1439827200000,"between 6 and 9 feet","coyote_creek",8.12],[1439827560000,"below 3 feet","santa_monica",2.116],[1439827560000,"between 6 and 9 feet","coyote_creek",8.005],[1439827620000,"below 3 feet","santa_monica",2.028],[1439827620000,"between 6 and 9 feet","coyote_creek",7.887]]}]}]}
 
+-- SQLNESS ARG protocol=influxql method=get
+SELECT * FROM "h2o_feet";
+
+{"results":[{"statement_id":0,"series":[{"name":"h2o_feet","columns":["time","level_description","location","water_level"],"values":[[1439827200000,"below 3 feet","santa_monica",2.064],[1439827200000,"between 6 and 9 feet","coyote_creek",8.12],[1439827560000,"below 3 feet","santa_monica",2.116],[1439827560000,"between 6 and 9 feet","coyote_creek",8.005],[1439827620000,"below 3 feet","santa_monica",2.028],[1439827620000,"between 6 and 9 feet","coyote_creek",7.887]]}]}]}
+
 -- SQLNESS ARG protocol=influxql
 SELECT "level_description", location, water_level FROM "h2o_feet" where location = 'santa_monica';
 

integration_tests/cases/env/local/influxql/basic.sql

@@ -29,6 +29,9 @@ INSERT INTO h2o_feet(time, level_description, location, water_level)
 -- SQLNESS ARG protocol=influxql
 SELECT * FROM "h2o_feet";
 
+-- SQLNESS ARG protocol=influxql method=get
+SELECT * FROM "h2o_feet";
+
 -- SQLNESS ARG protocol=influxql
 SELECT "level_description", location, water_level FROM "h2o_feet" where location = 'santa_monica';
 

integration_tests/src/database.rs

@@ -16,7 +16,7 @@ use ceresdb_client::{
     model::sql_query::{display::CsvFormatter, Request},
     RpcContext,
 };
-use reqwest::ClientBuilder;
+use reqwest::{ClientBuilder, Url};
 use sql::{
     ast::{Statement, TableName},
     parser::Parser,
@@ -212,7 +212,7 @@ impl<T: Send + Sync> Database for CeresDB<T> {
             Protocol::Sql => Self::execute_sql(query, self.db_client.clone()).await,
             Protocol::InfluxQL => {
                 let http_client = self.http_client.clone();
-                Self::execute_influxql(query, http_client).await
+                Self::execute_influxql(query, http_client, context.context).await
             }
         }
     }
@@ -244,16 +244,25 @@ impl<T: Backend> CeresDB<T> {
 }
 
 impl<T> CeresDB<T> {
-    async fn execute_influxql(query: String, http_client: HttpClient) -> Box<dyn Display> {
-        let query = format!("q={query}");
+    async fn execute_influxql(
+        query: String,
+        http_client: HttpClient,
+        params: HashMap<String, String>,
+    ) -> Box<dyn Display> {
         let url = format!("http://{}/influxdb/v1/query", http_client.endpoint);
-        let resp = http_client
-            .client
-            .post(url)
-            .body(query)
-            .send()
-            .await
-            .unwrap();
+        let resp = match params.get("method") {
+            Some(v) if v == "get" => {
+                let url = Url::parse_with_params(&url, &[("q", query)]).unwrap();
+                http_client.client.get(url).send().await.unwrap()
+            }
+            _ => http_client
+                .client
+                .post(url)
+                .form(&[("q", query)])
+                .send()
+                .await
+                .unwrap(),
+        };
         let query_res = match resp.text().await {
             Ok(text) => text,
             Err(e) => format!("Failed to do influxql query, err:{e:?}"),