版本：2.4.x

连接 CnosDB

CnosDB 支持多种编程语言，以下提供一些示例。

HTTP API 查询命令如下所示，用代码实现 HTTP API 请求时，可以参考此段命令。

语法

curl -X POST "http://<cnosdb_url>:<cnosdb_port>/api/v1/sql?db=<database_name>&pretty=true" \
  -u "<username>:<password>" \
  -H "Content-Type: application/x-www-form-urlencoded" \
  -d "<your SQL statement>"

示例

curl -X POST "http://127.0.0.1:8902/api/v1/sql?db=public&pretty=true" \
  -u "root:" \
  -H "Content-Type: application/x-www-form-urlencoded" \
  -d "CREATE TABLE air (
    visibility DOUBLE,
    temperature DOUBLE,
    pressure DOUBLE,
    TAGS(station)
  );"

使用编程语言

Rust
Golang
Java

示例代码使用reqwest构建Http请求。

http请求需要指定操作的数据库，写在url query里 db=database_name。

let url = Url::parse("http://127.0.0.1:8902/api/v1/sql?db=public&pretty=true").unwrap();
let sql = r#"
CREATE TABLE air (
 visibility DOUBLE,
 temperature DOUBLE,
 pressure DOUBLE,
 TAGS(station)
);"#.to_string();

请求执行的SQL放在http的body中。

用户名和密码需要basic编码添加到Authorization头中。

let user_name = "cnosdb";
let password = "";
let http_client = reqwest::Client::new();
let request = http_client
    .request(Method::POST, url)
    //用户名和密码
    .basic_auth::<&str, &str>(user_name, Some(password))
    .body(sql)
    .build()
    .unwrap();

response的status code 会指示SQL是否执行成功，200为成功。

失败信息或正确执行的结果会在response的text()中。

let response = http_client.execute(request).await.unwrap();
let success = response.status().is_success();
let result = response.text().await.unwrap();

示例代码使用fasthttp作为依赖。

以下为构造http request所需的参数。

user := "cnosdb"
pwd := ""
// db means database, we use default db 'public'
url := "http://127.0.0.1:8902/" + "api/v1/sql?db=public&pretty=true"
query1 := `
CREATE TABLE air (
  visibility DOUBLE,****
  temperature DOUBLE,
  pressure DOUBLE,
  TAGS(station)
);`

构造http request：

func basicAuth(username, password string) string {
    auth := username + ":" + password
    return "Basic " + base64.StdEncoding.EncodeToString([]byte(auth))
}

req := fasthttp.AcquireRequest()
req.Header.SetMethod("POST")
req.Header.Set("Authorization", basicAuth(user, pwd))
req.SetBody([]byte(query1))
req.SetRequestURI(url)

发送http请求：

cli := fasthttp.Client{}
resp := fasthttp.Response{}
err := cli.Do(req, &resp)
if err != nil {
    return
}
fmt.Println(resp.StatusCode())

response的status code 会指示SQL是否执行成功，200为成功。示例代码使用fasthttp作为依赖。