Merge pull request #17887 from taosdata/enh/add_reqId_interface

enh: add req_id interface
2022-11-07 14:17:33 +08:00 · 2022-11-07 14:17:33 +08:00 · b8dd38430f
parent 32b90b09f2 335867cd92
commit b8dd38430f
12 changed files with 988 additions and 401 deletions
--- a/examples/c/CMakeLists.txt
+++ b/examples/c/CMakeLists.txt
@ -15,6 +15,7 @@ IF (TD_LINUX)
  add_executable(tmq "")
  add_executable(stream_demo "")
  add_executable(demoapi "")
  add_executable(api_reqid "")
  target_sources(tmq
      PRIVATE
@ -31,6 +32,12 @@ IF (TD_LINUX)
      "demoapi.c"
      )
  target_sources(api_reqid
    PRIVATE 
    "api_with_reqid_test.c"
    )
  target_link_libraries(tmq
      taos_static
      )
@ -43,6 +50,11 @@ IF (TD_LINUX)
      taos_static
      )
  target_link_libraries(api_reqid
      taos_static
      )
  target_include_directories(tmq
      PUBLIC "${TD_SOURCE_DIR}/include/os"
      PRIVATE "${CMAKE_CURRENT_SOURCE_DIR}/inc"
@ -58,9 +70,16 @@ IF (TD_LINUX)
      PRIVATE "${CMAKE_CURRENT_SOURCE_DIR}/inc"
      )
  target_include_directories(api_reqid
      PUBLIC "${TD_SOURCE_DIR}/include/client"
      PUBLIC "${TD_SOURCE_DIR}/include/os"
      PRIVATE "${CMAKE_CURRENT_SOURCE_DIR}/inc"
      )
  SET_TARGET_PROPERTIES(tmq PROPERTIES OUTPUT_NAME tmq)
  SET_TARGET_PROPERTIES(stream_demo PROPERTIES OUTPUT_NAME stream_demo)
  SET_TARGET_PROPERTIES(demoapi PROPERTIES OUTPUT_NAME demoapi)
  SET_TARGET_PROPERTIES(api_reqid PROPERTIES OUTPUT_NAME api_reqid)
 ENDIF ()
 IF (TD_DARWIN)
  INCLUDE_DIRECTORIES(. ${TD_SOURCE_DIR}/src/inc ${TD_SOURCE_DIR}/src/client/inc  ${TD_SOURCE_DIR}/inc)
--- a/examples/c/api_with_reqid_test.c
+++ b/examples/c/api_with_reqid_test.c
@ -0,0 +1,449 @@
 // sample code to verify all TDengine API
 // to compile: gcc -o apitest apitest.c -ltaos
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
 #include <unistd.h>
 #include "taos.h"
 static int64_t count = 10000;
 int64_t genReqid() {
  count += 100;
  return count;
 }
 static void prepare_data(TAOS* taos) {
  TAOS_RES* result;
  result = taos_query_with_reqid(taos, "drop database if exists test;", genReqid());
  taos_free_result(result);
  usleep(100000);
  result = taos_query_with_reqid(taos, "create database test precision 'us';", genReqid());
  taos_free_result(result);
  usleep(100000);
  taos_select_db(taos, "test");
  result = taos_query_with_reqid(taos, "create table meters(ts timestamp, a int) tags(area int);", genReqid());
  taos_free_result(result);
  result = taos_query_with_reqid(taos, "create table t0 using meters tags(0);", genReqid());
  taos_free_result(result);
  result = taos_query_with_reqid(taos, "create table t1 using meters tags(1);", genReqid());
  taos_free_result(result);
  result = taos_query_with_reqid(taos, "create table t2 using meters tags(2);", genReqid());
  taos_free_result(result);
  result = taos_query_with_reqid(taos, "create table t3 using meters tags(3);", genReqid());
  taos_free_result(result);
  result = taos_query_with_reqid(taos, "create table t4 using meters tags(4);", genReqid());
  taos_free_result(result);
  result = taos_query_with_reqid(taos, "create table t5 using meters tags(5);", genReqid());
  taos_free_result(result);
  result = taos_query_with_reqid(taos, "create table t6 using meters tags(6);", genReqid());
  taos_free_result(result);
  result = taos_query_with_reqid(taos, "create table t7 using meters tags(7);", genReqid());
  taos_free_result(result);
  result = taos_query_with_reqid(taos, "create table t8 using meters tags(8);", genReqid());
  taos_free_result(result);
  result = taos_query(taos, "create table t9 using meters tags(9);");
  taos_free_result(result);
  result = taos_query_with_reqid(taos,
                                 "insert into t0 values('2020-01-01 00:00:00.000', 0)"
                                 " ('2020-01-01 00:01:00.000', 0)"
                                 " ('2020-01-01 00:02:00.000', 0)"
                                 " t1 values('2020-01-01 00:00:00.000', 0)"
                                 " ('2020-01-01 00:01:00.000', 0)"
                                 " ('2020-01-01 00:02:00.000', 0)"
                                 " ('2020-01-01 00:03:00.000', 0)"
                                 " t2 values('2020-01-01 00:00:00.000', 0)"
                                 " ('2020-01-01 00:01:00.000', 0)"
                                 " ('2020-01-01 00:01:01.000', 0)"
                                 " ('2020-01-01 00:01:02.000', 0)"
                                 " t3 values('2020-01-01 00:01:02.000', 0)"
                                 " t4 values('2020-01-01 00:01:02.000', 0)"
                                 " t5 values('2020-01-01 00:01:02.000', 0)"
                                 " t6 values('2020-01-01 00:01:02.000', 0)"
                                 " t7 values('2020-01-01 00:01:02.000', 0)"
                                 " t8 values('2020-01-01 00:01:02.000', 0)"
                                 " t9 values('2020-01-01 00:01:02.000', 0)",
                                 genReqid());
  int affected = taos_affected_rows(result);
  if (affected != 18) {
    printf("\033[31m%d rows affected by last insert statement, but it should be 18\033[0m\n", affected);
  }
  taos_free_result(result);
  // super tables subscription
  usleep(1000000);
 }
 static int print_result(TAOS_RES* res, int blockFetch) {
  TAOS_ROW    row = NULL;
  int         num_fields = taos_num_fields(res);
  TAOS_FIELD* fields = taos_fetch_fields(res);
  int         nRows = 0;
  if (blockFetch) {
    int rows = 0;
    while ((rows = taos_fetch_block(res, &row))) {
      // for (int i = 0; i < rows; i++) {
      //   char temp[256];
      //   taos_print_row(temp, row + i, fields, num_fields);
      //   puts(temp);
      // }
      nRows += rows;
    }
  } else {
    while ((row = taos_fetch_row(res))) {
      char temp[256] = {0};
      taos_print_row(temp, row, fields, num_fields);
      puts(temp);
      nRows++;
    }
  }
  printf("%d rows consumed.\n", nRows);
  return nRows;
 }
 static void check_row_count(int line, TAOS_RES* res, int expected) {
  int actual = print_result(res, expected % 2);
  if (actual != expected) {
    printf("\033[31mline %d: row count mismatch, expected: %d, actual: %d\033[0m\n", line, expected, actual);
  } else {
    printf("line %d: %d rows consumed as expected\n", line, actual);
  }
 }
 static void verify_query(TAOS* taos) {
  prepare_data(taos);
  int code = taos_load_table_info(taos, "t0,t1,t2,t3,t4,t5,t6,t7,t8,t9");
  if (code != 0) {
    printf("\033[31mfailed to load table info: 0x%08x\033[0m\n", code);
  }
  code = taos_validate_sql(taos, "select * from nonexisttable");
  if (code == 0) {
    printf("\033[31mimpossible, the table does not exists\033[0m\n");
  }
  code = taos_validate_sql(taos, "select * from meters");
  if (code != 0) {
    printf("\033[31mimpossible, the table does exists: 0x%08x\033[0m\n", code);
  }
  TAOS_RES* res = taos_query_with_reqid(taos, "select * from meters", genReqid());
  check_row_count(__LINE__, res, 18);
  printf("result precision is: %d\n", taos_result_precision(res));
  int c = taos_field_count(res);
  printf("field count is: %d\n", c);
  int* lengths = taos_fetch_lengths(res);
  for (int i = 0; i < c; i++) {
    printf("length of column %d is %d\n", i, lengths[i]);
  }
  taos_free_result(res);
  res = taos_query_with_reqid(taos, "select * from t0", genReqid());
  check_row_count(__LINE__, res, 3);
  taos_free_result(res);
  res = taos_query_with_reqid(taos, "select * from nonexisttable", genReqid());
  code = taos_errno(res);
  printf("code=%d, error msg=%s\n", code, taos_errstr(res));
  taos_free_result(res);
  res = taos_query_with_reqid(taos, "select * from meters", genReqid());
  taos_stop_query(res);
  taos_free_result(res);
 }
 void retrieve_callback(void* param, TAOS_RES* tres, int numOfRows) {
  if (numOfRows > 0) {
    printf("%d rows async retrieved\n", numOfRows);
    taos_fetch_rows_a(tres, retrieve_callback, param);
  } else {
    if (numOfRows < 0) {
      printf("\033[31masync retrieve failed, code: %d\033[0m\n", numOfRows);
    } else {
      printf("async retrieve completed\n");
    }
    taos_free_result(tres);
  }
 }
 void select_callback(void* param, TAOS_RES* tres, int code) {
  if (code == 0 && tres) {
    taos_fetch_rows_a(tres, retrieve_callback, param);
  } else {
    printf("\033[31masync select failed, code: %d\033[0m\n", code);
  }
 }
 void verify_async(TAOS* taos) {
  prepare_data(taos);
  taos_query_a_with_reqid(taos, "select * from meters", select_callback, NULL, genReqid());
  usleep(1000000);
 }
 int32_t verify_schema_less(TAOS* taos) {
  TAOS_RES* result;
  result = taos_query_with_reqid(taos, "drop database if exists test;", genReqid());
  taos_free_result(result);
  usleep(100000);
  result = taos_query_with_reqid(taos, "create database test precision 'us' update 1;", genReqid());
  taos_free_result(result);
  usleep(100000);
  taos_select_db(taos, "test");
  result = taos_query_with_reqid(taos, "create stable ste(ts timestamp, f int) tags(t1 bigint)", genReqid());
  taos_free_result(result);
  usleep(100000);
  int code = 0;
  char* lines[] = {
      "st,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000ns",
      "st,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64 1626006833640000000ns",
      "ste,t2=5f64,t3=L\"ste\" c1=true,c2=4i64,c3=\"iam\" 1626056811823316532ns",
      "st,t1=4i64,t2=5f64,t3=\"t4\" c1=3i64,c3=L\"passitagain\",c2=true,c4=5f64 1626006833642000000ns",
      "ste,t2=5f64,t3=L\"ste2\" c3=\"iamszhou\",c4=false 1626056811843316532ns",
      "ste,t2=5f64,t3=L\"ste2\" c3=\"iamszhou\",c4=false,c5=32i8,c6=64i16,c7=32i32,c8=88.88f32 1626056812843316532ns",
      "st,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 "
      "1626006933640000000ns",
      "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 "
      "1626006933640000000ns",
      "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 "
      "1626006933641000000ns"};
  taos_select_db(taos, "test");
  TAOS_RES* res = taos_schemaless_insert_with_reqid(taos, lines, sizeof(lines) / sizeof(char*), TSDB_SML_LINE_PROTOCOL,
                                                    TSDB_SML_TIMESTAMP_NOT_CONFIGURED, genReqid());
  if (taos_errno(res) != 0) {
    printf("failed to insert schema-less data, reason: %s\n", taos_errstr(res));
  } else {
    int affectedRow = taos_affected_rows(res);
    printf("successfully inserted %d rows\n", affectedRow);
  }
  taos_free_result(res);
  return (code);
 }
 void veriry_stmt(TAOS* taos) {
  TAOS_RES* result = taos_query(taos, "drop database if exists test;");
  taos_free_result(result);
  usleep(100000);
  result = taos_query(taos, "create database test;");
  int code = taos_errno(result);
  if (code != 0) {
    printf("\033[31mfailed to create database, reason:%s\033[0m\n", taos_errstr(result));
    taos_free_result(result);
    return;
  }
  taos_free_result(result);
  usleep(100000);
  taos_select_db(taos, "test");
  // create table
  const char* sql =
      "create table m1 (ts timestamp, b bool, v1 tinyint, v2 smallint, v4 int, v8 bigint, f4 float, f8 double, bin "
      "binary(40), blob nchar(10))";
  result = taos_query(taos, sql);
  code = taos_errno(result);
  if (code != 0) {
    printf("\033[31mfailed to create table, reason:%s\033[0m\n", taos_errstr(result));
    taos_free_result(result);
    return;
  }
  taos_free_result(result);
  // insert 10 records
  struct {
    int64_t ts[10];
    int8_t  b[10];
    int8_t  v1[10];
    int16_t v2[10];
    int32_t v4[10];
    int64_t v8[10];
    float   f4[10];
    double  f8[10];
    char    bin[10][40];
    char    blob[10][80];
  } v;
  int32_t* t8_len = malloc(sizeof(int32_t) * 10);
  int32_t* t16_len = malloc(sizeof(int32_t) * 10);
  int32_t* t32_len = malloc(sizeof(int32_t) * 10);
  int32_t* t64_len = malloc(sizeof(int32_t) * 10);
  int32_t* float_len = malloc(sizeof(int32_t) * 10);
  int32_t* double_len = malloc(sizeof(int32_t) * 10);
  int32_t* bin_len = malloc(sizeof(int32_t) * 10);
  int32_t* blob_len = malloc(sizeof(int32_t) * 10);
  TAOS_STMT*      stmt = taos_stmt_init_with_reqid(taos, genReqid());
  TAOS_MULTI_BIND params[10];
  char            is_null[10] = {0};
  params[0].buffer_type = TSDB_DATA_TYPE_TIMESTAMP;
  params[0].buffer_length = sizeof(v.ts[0]);
  params[0].buffer = v.ts;
  params[0].length = t64_len;
  params[0].is_null = is_null;
  params[0].num = 10;
  params[1].buffer_type = TSDB_DATA_TYPE_BOOL;
  params[1].buffer_length = sizeof(v.b[0]);
  params[1].buffer = v.b;
  params[1].length = t8_len;
  params[1].is_null = is_null;
  params[1].num = 10;
  params[2].buffer_type = TSDB_DATA_TYPE_TINYINT;
  params[2].buffer_length = sizeof(v.v1[0]);
  params[2].buffer = v.v1;
  params[2].length = t8_len;
  params[2].is_null = is_null;
  params[2].num = 10;
  params[3].buffer_type = TSDB_DATA_TYPE_SMALLINT;
  params[3].buffer_length = sizeof(v.v2[0]);
  params[3].buffer = v.v2;
  params[3].length = t16_len;
  params[3].is_null = is_null;
  params[3].num = 10;
  params[4].buffer_type = TSDB_DATA_TYPE_INT;
  params[4].buffer_length = sizeof(v.v4[0]);
  params[4].buffer = v.v4;
  params[4].length = t32_len;
  params[4].is_null = is_null;
  params[4].num = 10;
  params[5].buffer_type = TSDB_DATA_TYPE_BIGINT;
  params[5].buffer_length = sizeof(v.v8[0]);
  params[5].buffer = v.v8;
  params[5].length = t64_len;
  params[5].is_null = is_null;
  params[5].num = 10;
  params[6].buffer_type = TSDB_DATA_TYPE_FLOAT;
  params[6].buffer_length = sizeof(v.f4[0]);
  params[6].buffer = v.f4;
  params[6].length = float_len;
  params[6].is_null = is_null;
  params[6].num = 10;
  params[7].buffer_type = TSDB_DATA_TYPE_DOUBLE;
  params[7].buffer_length = sizeof(v.f8[0]);
  params[7].buffer = v.f8;
  params[7].length = double_len;
  params[7].is_null = is_null;
  params[7].num = 10;
  params[8].buffer_type = TSDB_DATA_TYPE_BINARY;
  params[8].buffer_length = sizeof(v.bin[0]);
  params[8].buffer = v.bin;
  params[8].length = bin_len;
  params[8].is_null = is_null;
  params[8].num = 10;
  params[9].buffer_type = TSDB_DATA_TYPE_NCHAR;
  params[9].buffer_length = sizeof(v.blob[0]);
  params[9].buffer = v.blob;
  params[9].length = blob_len;
  params[9].is_null = is_null;
  params[9].num = 10;
  sql = "insert into ? (ts, b, v1, v2, v4, v8, f4, f8, bin, blob) values(?,?,?,?,?,?,?,?,?,?)";
  code = taos_stmt_prepare(stmt, sql, 0);
  if (code != 0) {
    printf("\033[31mfailed to execute taos_stmt_prepare. error:%s\033[0m\n", taos_stmt_errstr(stmt));
    taos_stmt_close(stmt);
    return;
  }
  code = taos_stmt_set_tbname(stmt, "m1");
  if (code != 0) {
    printf("\033[31mfailed to execute taos_stmt_prepare. error:%s\033[0m\n", taos_stmt_errstr(stmt));
    taos_stmt_close(stmt);
    return;
  }
  int64_t ts = 1591060628000;
  for (int i = 0; i < 10; ++i) {
    v.ts[i] = ts++;
    is_null[i] = 0;
    v.b[i] = (int8_t)i % 2;
    v.v1[i] = (int8_t)i;
    v.v2[i] = (int16_t)(i * 2);
    v.v4[i] = (int32_t)(i * 4);
    v.v8[i] = (int64_t)(i * 8);
    v.f4[i] = (float)(i * 40);
    v.f8[i] = (double)(i * 80);
    for (int j = 0; j < sizeof(v.bin[0]); ++j) {
      v.bin[i][j] = (char)(i + '0');
    }
    strcpy(v.blob[i], "一二三四五六七八九十");
    t8_len[i] = sizeof(int8_t);
    t16_len[i] = sizeof(int16_t);
    t32_len[i] = sizeof(int32_t);
    t64_len[i] = sizeof(int64_t);
    float_len[i] = sizeof(float);
    double_len[i] = sizeof(double);
    bin_len[i] = sizeof(v.bin[0]);
    blob_len[i] = (int32_t)strlen(v.blob[i]);
  }
  taos_stmt_bind_param_batch(stmt, params);
  taos_stmt_add_batch(stmt);
  if (taos_stmt_execute(stmt) != 0) {
    printf("\033[31mfailed to execute insert statement.error:%s\033[0m\n", taos_stmt_errstr(stmt));
    taos_stmt_close(stmt);
    return;
  }
  taos_stmt_close(stmt);
  free(t8_len);
  free(t16_len);
  free(t32_len);
  free(t64_len);
  free(float_len);
  free(double_len);
  free(bin_len);
  free(blob_len);
 }
 int main(int argc, char* argv[]) {
  const char* host = "127.0.0.1";
  const char* user = "root";
  const char* passwd = "taosdata";
  taos_options(TSDB_OPTION_TIMEZONE, "GMT-8");
  TAOS* taos = taos_connect(host, user, passwd, "", 0);
  if (taos == NULL) {
    printf("\033[31mfailed to connect to db, reason:%s\033[0m\n", taos_errstr(taos));
    exit(1);
  }
  printf("************  verify schema-less  *************\n");
  verify_schema_less(taos);
  printf("************  verify query  *************\n");
  verify_query(taos);
  printf("*********  verify async query  **********\n");
  verify_async(taos);
  printf("*********  verify stmt query  **********\n");
  veriry_stmt(taos);
  printf("done\n");
  taos_close(taos);
  taos_cleanup();
 }
--- a/examples/c/apitest.c
+++ b/examples/c/apitest.c
@ -1,8 +1,8 @@
 // sample code to verify all TDengine API
 // to compile: gcc -o apitest apitest.c -ltaos
 #include "taoserror.h"
 #include "cJSON.h"
 #include "taoserror.h"
 #include <stdio.h>
 #include <stdlib.h>
@ -11,7 +11,7 @@
 #include "../../../include/client/taos.h"
 static void prepare_data(TAOS* taos) {
-  TAOS_RES *result;
+  TAOS_RES* result;
  result = taos_query(taos, "drop database if exists test;");
  taos_free_result(result);
  usleep(100000);
@ -44,7 +44,8 @@ static void prepare_data(TAOS* taos) {
  result = taos_query(taos, "create table t9 using meters tags(9);");
  taos_free_result(result);
-  result = taos_query(taos, "insert into t0 values('2020-01-01 00:00:00.000', 0)"
+  result = taos_query(taos,
                      "insert into t0 values('2020-01-01 00:00:00.000', 0)"
                      " ('2020-01-01 00:01:00.000', 0)"
                      " ('2020-01-01 00:02:00.000', 0)"
                      " t1 values('2020-01-01 00:00:00.000', 0)"
@ -80,11 +81,11 @@ static int print_result(TAOS_RES* res, int blockFetch) {
  if (blockFetch) {
    int rows = 0;
    while ((rows = taos_fetch_block(res, &row))) {
-      //for (int i = 0; i < rows; i++) {
+      // for (int i = 0; i < rows; i++) {
      //   char temp[256];
      //   taos_print_row(temp, row + i, fields, num_fields);
      //   puts(temp);
-      //}
+      // }
      nRows += rows;
    }
  } else {
@ -127,7 +128,7 @@ static void verify_query(TAOS* taos) {
    printf("\033[31mimpossible, the table does exists: 0x%08x\033[0m\n", code);
  }
-  TAOS_RES* res = taos_query(taos, "select * from meters");
+  TAOS_RES* res = taos_query_with_reqid(taos, "select * from meters", genReqid());
  check_row_count(__LINE__, res, 18);
  printf("result precision is: %d\n", taos_result_precision(res));
  int c = taos_field_count(res);
@ -138,21 +139,21 @@ static void verify_query(TAOS* taos) {
  }
  taos_free_result(res);
-  res = taos_query(taos, "select * from t0");
+  res = taos_query_with_reqid(taos, "select * from t0", genReqid());
  check_row_count(__LINE__, res, 3);
  taos_free_result(res);
-  res = taos_query(taos, "select * from nonexisttable");
+  res = taos_query_with_reqid(taos, "select * from nonexisttable", genReqid());
  code = taos_errno(res);
  printf("code=%d, error msg=%s\n", code, taos_errstr(res));
  taos_free_result(res);
-  res = taos_query(taos, "select * from meters");
+  res = taos_query_with_reqid(taos, "select * from meters", genReqid());
  taos_stop_query(res);
  taos_free_result(res);
 }
-void subscribe_callback(TAOS_SUB* tsub, TAOS_RES *res, void* param, int code) {
+void subscribe_callback(TAOS_SUB* tsub, TAOS_RES* res, void* param, int code) {
  int rows = print_result(res, *(int*)param);
  printf("%d rows consumed in subscribe_callback\n", rows);
 }
@ -167,7 +168,7 @@ static void verify_subscribe(TAOS* taos) {
  res = taos_consume(tsub);
  check_row_count(__LINE__, res, 0);
-  TAOS_RES *result;
+  TAOS_RES* result;
  result = taos_query(taos, "insert into t0 values('2020-01-01 00:02:00.001', 0);");
  taos_free_result(result);
  result = taos_query(taos, "insert into t8 values('2020-01-01 00:01:03.000', 0);");
@ -253,8 +254,10 @@ void verify_prepare(TAOS* taos) {
  taos_select_db(taos, "test");
  // create table
-  const char* sql = "create table m1 (ts timestamp, b bool, v1 tinyint, v2 smallint, v4 int, v8 bigint, f4 float, f8 double, bin binary(40), blob nchar(10))";
+  const char* sql =
-  result = taos_query(taos, sql);
+      "create table m1 (ts timestamp, b bool, v1 tinyint, v2 smallint, v4 int, v8 bigint, f4 float, f8 double, bin "
      "binary(40), blob nchar(10))";
  result = taos_query_with_reqid(taos, sql, genReqid());
  code = taos_errno(result);
  if (code != 0) {
    printf("\033[31mfailed to create table, reason:%s\033[0m\n", taos_errstr(result));
@ -344,7 +347,7 @@ void verify_prepare(TAOS* taos) {
  sql = "insert into m1 values(?,?,?,?,?,?,?,?,?,?)";
  code = taos_stmt_prepare(stmt, sql, 0);
-  if (code != 0){
+  if (code != 0) {
    printf("\033[31mfailed to execute taos_stmt_prepare. error:%s\033[0m\n", taos_stmt_errstr(stmt));
    taos_stmt_close(stmt);
    return;
@ -393,7 +396,7 @@ void verify_prepare(TAOS* taos) {
  TAOS_ROW    row;
  int         rows = 0;
  int         num_fields = taos_num_fields(result);
-  TAOS_FIELD *fields = taos_fetch_fields(result);
+  TAOS_FIELD* fields = taos_fetch_fields(result);
  // fetch the records row by row
  while ((row = taos_fetch_row(result))) {
@ -425,7 +428,9 @@ void verify_prepare2(TAOS* taos) {
  taos_select_db(taos, "test");
  // create table
-  const char* sql = "create table m1 (ts timestamp, b bool, v1 tinyint, v2 smallint, v4 int, v8 bigint, f4 float, f8 double, bin binary(40), blob nchar(10))";
+  const char* sql =
      "create table m1 (ts timestamp, b bool, v1 tinyint, v2 smallint, v4 int, v8 bigint, f4 float, f8 double, bin "
      "binary(40), blob nchar(10))";
  result = taos_query(taos, sql);
  code = taos_errno(result);
  if (code != 0) {
@ -449,14 +454,14 @@ void verify_prepare2(TAOS* taos) {
    char    blob[10][80];
  } v;
-  int32_t *t8_len = malloc(sizeof(int32_t) * 10);
+  int32_t* t8_len = malloc(sizeof(int32_t) * 10);
-  int32_t *t16_len = malloc(sizeof(int32_t) * 10);
+  int32_t* t16_len = malloc(sizeof(int32_t) * 10);
-  int32_t *t32_len = malloc(sizeof(int32_t) * 10);
+  int32_t* t32_len = malloc(sizeof(int32_t) * 10);
-  int32_t *t64_len = malloc(sizeof(int32_t) * 10);
+  int32_t* t64_len = malloc(sizeof(int32_t) * 10);
-  int32_t *float_len = malloc(sizeof(int32_t) * 10);
+  int32_t* float_len = malloc(sizeof(int32_t) * 10);
-  int32_t *double_len = malloc(sizeof(int32_t) * 10);
+  int32_t* double_len = malloc(sizeof(int32_t) * 10);
-  int32_t *bin_len = malloc(sizeof(int32_t) * 10);
+  int32_t* bin_len = malloc(sizeof(int32_t) * 10);
-  int32_t *blob_len = malloc(sizeof(int32_t) * 10);
+  int32_t* blob_len = malloc(sizeof(int32_t) * 10);
  TAOS_STMT*      stmt = taos_stmt_init(taos);
  TAOS_MULTI_BIND params[10];
@ -541,7 +546,7 @@ void verify_prepare2(TAOS* taos) {
  }
  code = taos_stmt_set_tbname(stmt, "m1");
-  if (code != 0){
+  if (code != 0) {
    printf("\033[31mfailed to execute taos_stmt_prepare. error:%s\033[0m\n", taos_stmt_errstr(stmt));
    taos_stmt_close(stmt);
    return;
@ -616,7 +621,7 @@ void verify_prepare2(TAOS* taos) {
  TAOS_ROW    row;
  int         rows = 0;
  int         num_fields = taos_num_fields(result);
-  TAOS_FIELD *fields = taos_fetch_fields(result);
+  TAOS_FIELD* fields = taos_fetch_fields(result);
  // fetch the records row by row
  while ((row = taos_fetch_row(result))) {
@ -657,7 +662,9 @@ void verify_prepare3(TAOS* taos) {
  taos_select_db(taos, "test");
  // create table
-  const char* sql = "create stable st1 (ts timestamp, b bool, v1 tinyint, v2 smallint, v4 int, v8 bigint, f4 float, f8 double, bin binary(40), blob nchar(10)) tags (id1 int, id2 binary(40))";
+  const char* sql =
      "create stable st1 (ts timestamp, b bool, v1 tinyint, v2 smallint, v4 int, v8 bigint, f4 float, f8 double, bin "
      "binary(40), blob nchar(10)) tags (id1 int, id2 binary(40))";
  result = taos_query(taos, sql);
  code = taos_errno(result);
  if (code != 0) {
@ -685,7 +692,6 @@ void verify_prepare3(TAOS* taos) {
  tags[1].length = &id2_len;
  tags[1].is_null = NULL;
  // insert 10 records
  struct {
    int64_t ts[10];
@ -700,14 +706,14 @@ void verify_prepare3(TAOS* taos) {
    char    blob[10][80];
  } v;
-  int32_t *t8_len = malloc(sizeof(int32_t) * 10);
+  int32_t* t8_len = malloc(sizeof(int32_t) * 10);
-  int32_t *t16_len = malloc(sizeof(int32_t) * 10);
+  int32_t* t16_len = malloc(sizeof(int32_t) * 10);
-  int32_t *t32_len = malloc(sizeof(int32_t) * 10);
+  int32_t* t32_len = malloc(sizeof(int32_t) * 10);
-  int32_t *t64_len = malloc(sizeof(int32_t) * 10);
+  int32_t* t64_len = malloc(sizeof(int32_t) * 10);
-  int32_t *float_len = malloc(sizeof(int32_t) * 10);
+  int32_t* float_len = malloc(sizeof(int32_t) * 10);
-  int32_t *double_len = malloc(sizeof(int32_t) * 10);
+  int32_t* double_len = malloc(sizeof(int32_t) * 10);
-  int32_t *bin_len = malloc(sizeof(int32_t) * 10);
+  int32_t* bin_len = malloc(sizeof(int32_t) * 10);
-  int32_t *blob_len = malloc(sizeof(int32_t) * 10);
+  int32_t* blob_len = malloc(sizeof(int32_t) * 10);
  TAOS_STMT*      stmt = taos_stmt_init(taos);
  TAOS_MULTI_BIND params[10];
@ -783,17 +789,16 @@ void verify_prepare3(TAOS* taos) {
  params[9].is_null = is_null;
  params[9].num = 10;
  sql = "insert into ? using st1 tags(?,?) values(?,?,?,?,?,?,?,?,?,?)";
  code = taos_stmt_prepare(stmt, sql, 0);
-  if (code != 0){
+  if (code != 0) {
    printf("\033[31mfailed to execute taos_stmt_prepare. error:%s\033[0m\n", taos_stmt_errstr(stmt));
    taos_stmt_close(stmt);
    return;
  }
  code = taos_stmt_set_tbname_tags(stmt, "m1", tags);
-  if (code != 0){
+  if (code != 0) {
    printf("\033[31mfailed to execute taos_stmt_prepare. error:%s\033[0m\n", taos_stmt_errstr(stmt));
    taos_stmt_close(stmt);
    return;
@ -868,7 +873,7 @@ void verify_prepare3(TAOS* taos) {
  TAOS_ROW    row;
  int         rows = 0;
  int         num_fields = taos_num_fields(result);
-  TAOS_FIELD *fields = taos_fetch_fields(result);
+  TAOS_FIELD* fields = taos_fetch_fields(result);
  // fetch the records row by row
  while ((row = taos_fetch_row(result))) {
@ -891,8 +896,7 @@ void verify_prepare3(TAOS* taos) {
  free(blob_len);
 }
-void retrieve_callback(void *param, TAOS_RES *tres, int numOfRows)
+void retrieve_callback(void* param, TAOS_RES* tres, int numOfRows) {
 {
  if (numOfRows > 0) {
    printf("%d rows async retrieved\n", numOfRows);
    taos_fetch_rows_a(tres, retrieve_callback, param);
@ -906,8 +910,7 @@ void retrieve_callback(void *param, TAOS_RES *tres, int numOfRows)
  }
 }
-void select_callback(void *param, TAOS_RES *tres, int code)
+void select_callback(void* param, TAOS_RES* tres, int code) {
 {
  if (code == 0 && tres) {
    taos_fetch_rows_a(tres, retrieve_callback, param);
  } else {
@ -921,7 +924,7 @@ void verify_async(TAOS* taos) {
  usleep(1000000);
 }
-void stream_callback(void *param, TAOS_RES *res, TAOS_ROW row) {
+void stream_callback(void* param, TAOS_RES* res, TAOS_ROW row) {
  if (res == NULL || row == NULL) {
    return;
  }
@ -937,13 +940,8 @@ void stream_callback(void *param, TAOS_RES *res, TAOS_ROW row) {
 void verify_stream(TAOS* taos) {
  prepare_data(taos);
-  TAOS_STREAM* strm = taos_open_stream(
+  TAOS_STREAM* strm =
-    taos,
+      taos_open_stream(taos, "select count(*) from meters interval(1m)", stream_callback, 0, NULL, NULL);
    "select count(*) from meters interval(1m)",
    stream_callback,
    0,
    NULL,
    NULL);
  printf("waiting for stream data\n");
  usleep(100000);
  TAOS_RES* result = taos_query(taos, "insert into t0 values(now, 0)(now+5s,1)(now+10s, 2);");
@ -953,7 +951,7 @@ void verify_stream(TAOS* taos) {
 }
 int32_t verify_schema_less(TAOS* taos) {
-  TAOS_RES *result;
+  TAOS_RES* result;
  result = taos_query(taos, "drop database if exists test;");
  taos_free_result(result);
  usleep(100000);
@ -975,50 +973,52 @@ int32_t verify_schema_less(TAOS* taos) {
      "st,t1=4i64,t2=5f64,t3=\"t4\" c1=3i64,c3=L\"passitagain\",c2=true,c4=5f64 1626006833642000000ns",
      "ste,t2=5f64,t3=L\"ste2\" c3=\"iamszhou\",c4=false 1626056811843316532ns",
      "ste,t2=5f64,t3=L\"ste2\" c3=\"iamszhou\",c4=false,c5=32i8,c6=64i16,c7=32i32,c8=88.88f32 1626056812843316532ns",
-      "st,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000ns",
+      "st,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 "
-      "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000ns",
+      "1626006933640000000ns",
-      "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933641000000ns"
+      "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 "
-  };
+      "1626006933640000000ns",
      "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 "
      "1626006933641000000ns"};
-  code = taos_insert_lines(taos, lines , sizeof(lines)/sizeof(char*));
+  code = taos_insert_lines(taos, lines, sizeof(lines) / sizeof(char*));
  char* lines2[] = {
      "stg,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000ns",
-      "stg,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64 1626006833640000000ns"
+      "stg,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64 1626006833640000000ns"};
  };
  code = taos_insert_lines(taos, &lines2[0], 1);
  code = taos_insert_lines(taos, &lines2[1], 1);
  char* lines3[] = {
-      "sth,t1=4i64,t2=5f64,t4=5f64,ID=\"childtable\" c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933641ms",
+      "sth,t1=4i64,t2=5f64,t4=5f64,ID=\"childtable\" c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 "
-      "sth,t1=4i64,t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933654ms"
+      "1626006933641ms",
-  };
+      "sth,t1=4i64,t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933654ms"};
  code = taos_insert_lines(taos, lines3, 2);
-  char* lines4[] = {
+  char* lines4[] = {"st123456,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000ns",
-      "st123456,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000ns",
+                    "dgtyqodr,t2=5f64,t3=L\"ste\" c1=tRue,c2=4i64,c3=\"iam\" 1626056811823316532ns"};
      "dgtyqodr,t2=5f64,t3=L\"ste\" c1=tRue,c2=4i64,c3=\"iam\" 1626056811823316532ns"
  };
  code = taos_insert_lines(taos, lines4, 2);
  char* lines5[] = {
-      "zqlbgs,id=\"zqlbgs_39302_21680\",t0=f,t1=127i8,t2=32767i16,t3=2147483647i32,t4=9223372036854775807i64,t5=11.12345f32,t6=22.123456789f64,t7=\"binaryTagValue\",t8=L\"ncharTagValue\" c0=f,c1=127i8,c2=32767i16,c3=2147483647i32,c4=9223372036854775807i64,c5=11.12345f32,c6=22.123456789f64,c7=\"binaryColValue\",c8=L\"ncharColValue\",c9=7u64 1626006833639000000ns",
+      "zqlbgs,id=\"zqlbgs_39302_21680\",t0=f,t1=127i8,t2=32767i16,t3=2147483647i32,t4=9223372036854775807i64,t5=11."
-      "zqlbgs,t9=f,id=\"zqlbgs_39302_21680\",t0=f,t1=127i8,t11=127i8,t2=32767i16,t3=2147483647i32,t4=9223372036854775807i64,t5=11.12345f32,t6=22.123456789f64,t7=\"binaryTagValue\",t8=L\"ncharTagValue\",t10=L\"ncharTagValue\" c10=f,c0=f,c1=127i8,c12=127i8,c2=32767i16,c3=2147483647i32,c4=9223372036854775807i64,c5=11.12345f32,c6=22.123456789f64,c7=\"binaryColValue\",c8=L\"ncharColValue\",c9=7u64,c11=L\"ncharColValue\" 1626006833639000000ns"
+      "12345f32,t6=22.123456789f64,t7=\"binaryTagValue\",t8=L\"ncharTagValue\" "
-  };
+      "c0=f,c1=127i8,c2=32767i16,c3=2147483647i32,c4=9223372036854775807i64,c5=11.12345f32,c6=22.123456789f64,c7="
      "\"binaryColValue\",c8=L\"ncharColValue\",c9=7u64 1626006833639000000ns",
      "zqlbgs,t9=f,id=\"zqlbgs_39302_21680\",t0=f,t1=127i8,t11=127i8,t2=32767i16,t3=2147483647i32,t4="
      "9223372036854775807i64,t5=11.12345f32,t6=22.123456789f64,t7=\"binaryTagValue\",t8=L\"ncharTagValue\",t10="
      "L\"ncharTagValue\" "
      "c10=f,c0=f,c1=127i8,c12=127i8,c2=32767i16,c3=2147483647i32,c4=9223372036854775807i64,c5=11.12345f32,c6=22."
      "123456789f64,c7=\"binaryColValue\",c8=L\"ncharColValue\",c9=7u64,c11=L\"ncharColValue\" 1626006833639000000ns"};
  code = taos_insert_lines(taos, &lines5[0], 1);
  code = taos_insert_lines(taos, &lines5[1], 1);
-
+  char* lines6[] = {"st123456,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000ns",
-  char* lines6[] = {
+                    "dgtyqodr,t2=5f64,t3=L\"ste\" c1=tRue,c2=4i64,c3=\"iam\" 1626056811823316532ns"};
      "st123456,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000ns",
      "dgtyqodr,t2=5f64,t3=L\"ste\" c1=tRue,c2=4i64,c3=\"iam\" 1626056811823316532ns"
  };
  code = taos_insert_lines(taos, lines6, 2);
  return (code);
 }
 void verify_telnet_insert(TAOS* taos) {
-  TAOS_RES *result;
+  TAOS_RES* result;
  result = taos_query(taos, "drop database if exists db;");
  taos_free_result(result);
@ -1043,12 +1043,9 @@ void verify_telnet_insert(TAOS* taos) {
  /* timestamp */
  char* lines1[] = {
-      "stb1 1626006833s 1i8 host=\"host0\"",
+      "stb1 1626006833s 1i8 host=\"host0\"",        "stb1 1626006833639000000ns 2i8 host=\"host0\"",
-      "stb1 1626006833639000000ns 2i8 host=\"host0\"",
+      "stb1 1626006833640000us 3i8 host=\"host0\"", "stb1 1626006833641123 4i8 host=\"host0\"",
-      "stb1 1626006833640000us 3i8 host=\"host0\"",
+      "stb1 1626006833651ms 5i8 host=\"host0\"",    "stb1 0 6i8 host=\"host0\"",
      "stb1 1626006833641123 4i8 host=\"host0\"",
      "stb1 1626006833651ms 5i8 host=\"host0\"",
      "stb1 0 6i8 host=\"host0\"",
  };
  code = taos_insert_telnet_lines(taos, lines1, 6);
  if (code) {
@ -1056,113 +1053,83 @@ void verify_telnet_insert(TAOS* taos) {
  }
  /* metric value */
-  //tinyin
+  // tinyin
-  char* lines2_0[] = {
+  char* lines2_0[] = {"stb2_0 1626006833651ms -127i8 host=\"host0\"", "stb2_0 1626006833652ms 127i8 host=\"host0\""};
      "stb2_0 1626006833651ms -127i8 host=\"host0\"",
      "stb2_0 1626006833652ms 127i8 host=\"host0\""
  };
  code = taos_insert_telnet_lines(taos, lines2_0, 2);
  if (code) {
    printf("lines2_0 code: %d, %s.\n", code, tstrerror(code));
  }
-  //smallint
+  // smallint
-  char* lines2_1[] = {
+  char* lines2_1[] = {"stb2_1 1626006833651ms -32767i16 host=\"host0\"",
-      "stb2_1 1626006833651ms -32767i16 host=\"host0\"",
+                      "stb2_1 1626006833652ms 32767i16 host=\"host0\""};
      "stb2_1 1626006833652ms 32767i16 host=\"host0\""
  };
  code = taos_insert_telnet_lines(taos, lines2_1, 2);
  if (code) {
    printf("lines2_1 code: %d, %s.\n", code, tstrerror(code));
  }
-  //int
+  // int
-  char* lines2_2[] = {
+  char* lines2_2[] = {"stb2_2 1626006833651ms -2147483647i32 host=\"host0\"",
-      "stb2_2 1626006833651ms -2147483647i32 host=\"host0\"",
+                      "stb2_2 1626006833652ms 2147483647i32 host=\"host0\""};
      "stb2_2 1626006833652ms 2147483647i32 host=\"host0\""
  };
  code = taos_insert_telnet_lines(taos, lines2_2, 2);
  if (code) {
    printf("lines2_2 code: %d, %s.\n", code, tstrerror(code));
  }
-  //bigint
+  // bigint
-  char* lines2_3[] = {
+  char* lines2_3[] = {"stb2_3 1626006833651ms -9223372036854775807i64 host=\"host0\"",
-      "stb2_3 1626006833651ms -9223372036854775807i64 host=\"host0\"",
+                      "stb2_3 1626006833652ms 9223372036854775807i64 host=\"host0\""};
      "stb2_3 1626006833652ms 9223372036854775807i64 host=\"host0\""
  };
  code = taos_insert_telnet_lines(taos, lines2_3, 2);
  if (code) {
    printf("lines2_3 code: %d, %s.\n", code, tstrerror(code));
  }
-  //float
+  // float
  char* lines2_4[] = {
-      "stb2_4 1626006833610ms 3f32 host=\"host0\"",
+      "stb2_4 1626006833610ms 3f32 host=\"host0\"",      "stb2_4 1626006833620ms -3f32 host=\"host0\"",
-      "stb2_4 1626006833620ms -3f32 host=\"host0\"",
+      "stb2_4 1626006833630ms 3.4f32 host=\"host0\"",    "stb2_4 1626006833640ms -3.4f32 host=\"host0\"",
-      "stb2_4 1626006833630ms 3.4f32 host=\"host0\"",
+      "stb2_4 1626006833650ms 3.4E10f32 host=\"host0\"", "stb2_4 1626006833660ms -3.4e10f32 host=\"host0\"",
-      "stb2_4 1626006833640ms -3.4f32 host=\"host0\"",
+      "stb2_4 1626006833670ms 3.4E+2f32 host=\"host0\"", "stb2_4 1626006833680ms -3.4e-2f32 host=\"host0\"",
-      "stb2_4 1626006833650ms 3.4E10f32 host=\"host0\"",
+      "stb2_4 1626006833690ms 3.15 host=\"host0\"",      "stb2_4 1626006833700ms 3.4E38f32 host=\"host0\"",
-      "stb2_4 1626006833660ms -3.4e10f32 host=\"host0\"",
+      "stb2_4 1626006833710ms -3.4E38f32 host=\"host0\""};
      "stb2_4 1626006833670ms 3.4E+2f32 host=\"host0\"",
      "stb2_4 1626006833680ms -3.4e-2f32 host=\"host0\"",
      "stb2_4 1626006833690ms 3.15 host=\"host0\"",
      "stb2_4 1626006833700ms 3.4E38f32 host=\"host0\"",
      "stb2_4 1626006833710ms -3.4E38f32 host=\"host0\""
  };
  code = taos_insert_telnet_lines(taos, lines2_4, 11);
  if (code) {
    printf("lines2_4 code: %d, %s.\n", code, tstrerror(code));
  }
-  //double
+  // double
  char* lines2_5[] = {
-      "stb2_5 1626006833610ms 3f64 host=\"host0\"",
+      "stb2_5 1626006833610ms 3f64 host=\"host0\"",       "stb2_5 1626006833620ms -3f64 host=\"host0\"",
-      "stb2_5 1626006833620ms -3f64 host=\"host0\"",
+      "stb2_5 1626006833630ms 3.4f64 host=\"host0\"",     "stb2_5 1626006833640ms -3.4f64 host=\"host0\"",
-      "stb2_5 1626006833630ms 3.4f64 host=\"host0\"",
+      "stb2_5 1626006833650ms 3.4E10f64 host=\"host0\"",  "stb2_5 1626006833660ms -3.4e10f64 host=\"host0\"",
-      "stb2_5 1626006833640ms -3.4f64 host=\"host0\"",
+      "stb2_5 1626006833670ms 3.4E+2f64 host=\"host0\"",  "stb2_5 1626006833680ms -3.4e-2f64 host=\"host0\"",
-      "stb2_5 1626006833650ms 3.4E10f64 host=\"host0\"",
+      "stb2_5 1626006833690ms 1.7E308f64 host=\"host0\"", "stb2_5 1626006833700ms -1.7E308f64 host=\"host0\""};
      "stb2_5 1626006833660ms -3.4e10f64 host=\"host0\"",
      "stb2_5 1626006833670ms 3.4E+2f64 host=\"host0\"",
      "stb2_5 1626006833680ms -3.4e-2f64 host=\"host0\"",
      "stb2_5 1626006833690ms 1.7E308f64 host=\"host0\"",
      "stb2_5 1626006833700ms -1.7E308f64 host=\"host0\""
  };
  code = taos_insert_telnet_lines(taos, lines2_5, 10);
  if (code) {
    printf("lines2_5 code: %d, %s.\n", code, tstrerror(code));
  }
-  //bool
+  // bool
-  char* lines2_6[] = {
+  char* lines2_6[] = {"stb2_6 1626006833610ms t host=\"host0\"",     "stb2_6 1626006833620ms T host=\"host0\"",
-      "stb2_6 1626006833610ms t host=\"host0\"",
+                      "stb2_6 1626006833630ms true host=\"host0\"",  "stb2_6 1626006833640ms True host=\"host0\"",
-      "stb2_6 1626006833620ms T host=\"host0\"",
+                      "stb2_6 1626006833650ms TRUE host=\"host0\"",  "stb2_6 1626006833660ms f host=\"host0\"",
-      "stb2_6 1626006833630ms true host=\"host0\"",
+                      "stb2_6 1626006833670ms F host=\"host0\"",     "stb2_6 1626006833680ms false host=\"host0\"",
-      "stb2_6 1626006833640ms True host=\"host0\"",
+                      "stb2_6 1626006833690ms False host=\"host0\"", "stb2_6 1626006833700ms FALSE host=\"host0\""};
      "stb2_6 1626006833650ms TRUE host=\"host0\"",
      "stb2_6 1626006833660ms f host=\"host0\"",
      "stb2_6 1626006833670ms F host=\"host0\"",
      "stb2_6 1626006833680ms false host=\"host0\"",
      "stb2_6 1626006833690ms False host=\"host0\"",
      "stb2_6 1626006833700ms FALSE host=\"host0\""
  };
  code = taos_insert_telnet_lines(taos, lines2_6, 10);
  if (code) {
    printf("lines2_6 code: %d, %s.\n", code, tstrerror(code));
  }
-  //binary
+  // binary
-  char* lines2_7[] = {
+  char* lines2_7[] = {"stb2_7 1626006833610ms \"binary_val.!@#$%^&*\" host=\"host0\"",
      "stb2_7 1626006833610ms \"binary_val.!@#$%^&*\" host=\"host0\"",
                      "stb2_7 1626006833620ms \"binary_val.:;,./?|+-=\" host=\"host0\"",
-      "stb2_7 1626006833630ms \"binary_val.()[]{}<>\" host=\"host0\""
+                      "stb2_7 1626006833630ms \"binary_val.()[]{}<>\" host=\"host0\""};
  };
  code = taos_insert_telnet_lines(taos, lines2_7, 3);
  if (code) {
    printf("lines2_7 code: %d, %s.\n", code, tstrerror(code));
  }
-  //nchar
+  // nchar
  char* lines2_8[] = {
      "stb2_8 1626006833610ms L\"nchar_val数值一\" host=\"host0\"",
      "stb2_8 1626006833620ms L\"nchar_val数值二\" host=\"host0\"",
@ -1173,22 +1140,23 @@ void verify_telnet_insert(TAOS* taos) {
  }
  /* tags */
-  //tag value types
+  // tag value types
  char* lines3_0[] = {
-      "stb3_0 1626006833610ms 1 t1=127i8,t2=32767i16,t3=2147483647i32,t4=9223372036854775807i64,t5=3.4E38f32,t6=1.7E308f64,t7=true,t8=\"binary_val_1\",t9=L\"标签值1\"",
+      "stb3_0 1626006833610ms 1 "
-      "stb3_0 1626006833610ms 2 t1=-127i8,t2=-32767i16,t3=-2147483647i32,t4=-9223372036854775807i64,t5=-3.4E38f32,t6=-1.7E308f64,t7=false,t8=\"binary_val_2\",t9=L\"标签值2\""
+      "t1=127i8,t2=32767i16,t3=2147483647i32,t4=9223372036854775807i64,t5=3.4E38f32,t6=1.7E308f64,t7=true,t8=\"binary_"
-  };
+      "val_1\",t9=L\"标签值1\"",
      "stb3_0 1626006833610ms 2 "
      "t1=-127i8,t2=-32767i16,t3=-2147483647i32,t4=-9223372036854775807i64,t5=-3.4E38f32,t6=-1.7E308f64,t7=false,t8="
      "\"binary_val_2\",t9=L\"标签值2\""};
  code = taos_insert_telnet_lines(taos, lines3_0, 2);
  if (code) {
    printf("lines3_0 code: %d, %s.\n", code, tstrerror(code));
  }
-  //tag ID as child table name
+  // tag ID as child table name
-  char* lines3_1[] = {
+  char* lines3_1[] = {"stb3_1 1626006833610ms 1 id=\"child_table1\",host=\"host1\"",
      "stb3_1 1626006833610ms 1 id=\"child_table1\",host=\"host1\"",
                      "stb3_1 1626006833610ms 2 host=\"host2\",iD=\"child_table2\"",
-      "stb3_1 1626006833610ms 3 ID=\"child_table3\",host=\"host3\""
+                      "stb3_1 1626006833610ms 3 ID=\"child_table3\",host=\"host3\""};
  };
  code = taos_insert_telnet_lines(taos, lines3_1, 3);
  if (code) {
    printf("lines3_1 code: %d, %s.\n", code, tstrerror(code));
@ -1198,7 +1166,7 @@ void verify_telnet_insert(TAOS* taos) {
 }
 void verify_json_insert(TAOS* taos) {
-  TAOS_RES *result;
+  TAOS_RES* result;
  result = taos_query(taos, "drop database if exists db;");
  taos_free_result(result);
@ -1210,7 +1178,7 @@ void verify_json_insert(TAOS* taos) {
  (void)taos_select_db(taos, "db");
  int32_t code = 0;
-  char *message =
+  char* message =
      "{                                      \
      \"metric\":\"cpu_load_0\",          \
      \"timestamp\": 1626006833610123,    \
@ -1228,7 +1196,7 @@ void verify_json_insert(TAOS* taos) {
    printf("payload_0 code: %d, %s.\n", code, tstrerror(code));
  }
-  char *message1 =
+  char* message1 =
      "[                                       \
    {                                      \
       \"metric\":\"cpu_load_1\",          \
@ -1259,7 +1227,7 @@ void verify_json_insert(TAOS* taos) {
    printf("payload_1 code: %d, %s.\n", code, tstrerror(code));
  }
-  char *message2 =
+  char* message2 =
      "[                                       \
    {                                      \
       \"metric\":\"cpu_load_3\",          \
@ -1310,12 +1278,11 @@ void verify_json_insert(TAOS* taos) {
    printf("payload_2 code: %d, %s.\n", code, tstrerror(code));
  }
  cJSON *payload, *tags;
-  char *payload_str;
+  char*  payload_str;
  /* Default format */
-  //number
+  // number
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb0_0");
  cJSON_AddNumberToObject(payload, "timestamp", 1626006833610123);
@ -1327,7 +1294,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1336,7 +1303,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //true
+  // true
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb0_1");
  cJSON_AddNumberToObject(payload, "timestamp", 1626006833610123);
@ -1348,7 +1315,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1357,7 +1324,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //false
+  // false
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb0_2");
  cJSON_AddNumberToObject(payload, "timestamp", 1626006833610123);
@ -1369,7 +1336,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1378,7 +1345,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //string
+  // string
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb0_3");
  cJSON_AddNumberToObject(payload, "timestamp", 1626006833610123);
@ -1390,7 +1357,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1399,7 +1366,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //timestamp 0 -> current time
+  // timestamp 0 -> current time
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb0_4");
  cJSON_AddNumberToObject(payload, "timestamp", 0);
@ -1411,7 +1378,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1420,7 +1387,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //ID
+  // ID
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb0_5");
  cJSON_AddNumberToObject(payload, "timestamp", 0);
@ -1435,7 +1402,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "id", "tb555");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1445,9 +1412,9 @@ void verify_json_insert(TAOS* taos) {
  cJSON_Delete(payload);
  /* Nested format */
-  //timestamp
+  // timestamp
-  cJSON *timestamp;
+  cJSON* timestamp;
-  //seconds
+  // seconds
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb1_0");
@ -1464,7 +1431,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1473,7 +1440,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //milleseconds
+  // milleseconds
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb1_1");
@ -1490,7 +1457,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1499,7 +1466,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //microseconds
+  // microseconds
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb1_2");
@ -1516,7 +1483,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1525,7 +1492,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //nanoseconds
+  // nanoseconds
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb1_3");
@ -1542,7 +1509,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1551,7 +1518,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //now
+  // now
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb1_4");
@ -1568,7 +1535,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1577,9 +1544,9 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //metric value
+  // metric value
-  cJSON *metric_val;
+  cJSON* metric_val;
-  //bool
+  // bool
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb2_0");
@ -1600,7 +1567,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1609,7 +1576,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //tinyint
+  // tinyint
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb2_1");
@ -1630,7 +1597,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1639,7 +1606,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //smallint
+  // smallint
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb2_2");
@ -1660,7 +1627,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1669,7 +1636,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //int
+  // int
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb2_3");
@ -1690,7 +1657,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1699,7 +1666,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //bigint
+  // bigint
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb2_4");
@ -1720,7 +1687,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1729,7 +1696,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //float
+  // float
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb2_5");
@ -1750,7 +1717,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1759,7 +1726,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //double
+  // double
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb2_6");
@ -1780,7 +1747,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1789,7 +1756,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //binary
+  // binary
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb2_7");
@ -1810,7 +1777,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1819,7 +1786,7 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //nchar
+  // nchar
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb2_8");
@ -1840,7 +1807,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddStringToObject(tags, "t4", "123_abc_.!@#$%^&*:;,./?|+-=()[]{}<>");
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1849,8 +1816,8 @@ void verify_json_insert(TAOS* taos) {
  free(payload_str);
  cJSON_Delete(payload);
-  //tag value
+  // tag value
-  cJSON *tag;
+  cJSON* tag;
  payload = cJSON_CreateObject();
  cJSON_AddStringToObject(payload, "metric", "stb3_0");
@ -1920,7 +1887,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_AddItemToObject(payload, "tags", tags);
  payload_str = cJSON_Print(payload);
-  //printf("%s\n", payload_str);
+  // printf("%s\n", payload_str);
  code = taos_insert_json_payload(taos, payload_str);
  if (code) {
@ -1930,7 +1897,7 @@ void verify_json_insert(TAOS* taos) {
  cJSON_Delete(payload);
 }
-int main(int argc, char *argv[]) {
+int main(int argc, char* argv[]) {
  const char* host = "127.0.0.1";
  const char* user = "root";
  const char* passwd = "taosdata";
--- a/include/client/taos.h
+++ b/include/client/taos.h
@ -130,7 +130,7 @@ typedef struct TAOS_VGROUP_HASH_INFO {
  int32_t  vgId;
  uint32_t hashBegin;
  uint32_t hashEnd;
-} TAOS_VGROUP_HASH_INFO ;
+} TAOS_VGROUP_HASH_INFO;
 typedef struct TAOS_DB_ROUTE_INFO {
  int32_t                routeVersion;
@ -139,8 +139,7 @@ typedef struct TAOS_DB_ROUTE_INFO {
  int8_t                 hashMethod;
  int32_t                vgNum;
  TAOS_VGROUP_HASH_INFO *vgHash;
-} TAOS_DB_ROUTE_INFO ;
+} TAOS_DB_ROUTE_INFO;
 DLL_EXPORT void       taos_cleanup(void);
 DLL_EXPORT int        taos_options(TSDB_OPTION option, const void *arg, ...);
@ -153,6 +152,7 @@ DLL_EXPORT void  taos_close(TAOS *taos);
 const char *taos_data_type(int type);
 DLL_EXPORT TAOS_STMT *taos_stmt_init(TAOS *taos);
 DLL_EXPORT TAOS_STMT *taos_stmt_init_with_reqid(TAOS *taos, int64_t reqid);
 DLL_EXPORT int        taos_stmt_prepare(TAOS_STMT *stmt, const char *sql, unsigned long length);
 DLL_EXPORT int        taos_stmt_set_tbname_tags(TAOS_STMT *stmt, const char *name, TAOS_MULTI_BIND *tags);
 DLL_EXPORT int        taos_stmt_set_tbname(TAOS_STMT *stmt, const char *name);
@ -176,6 +176,7 @@ DLL_EXPORT int       taos_stmt_affected_rows(TAOS_STMT *stmt);
 DLL_EXPORT int       taos_stmt_affected_rows_once(TAOS_STMT *stmt);
 DLL_EXPORT TAOS_RES *taos_query(TAOS *taos, const char *sql);
 DLL_EXPORT TAOS_RES *taos_query_with_reqid(TAOS *taos, const char *sql, int64_t reqId);
 DLL_EXPORT TAOS_ROW taos_fetch_row(TAOS_RES *res);
 DLL_EXPORT int      taos_result_precision(TAOS_RES *res);  // get the time precision of result
@ -208,16 +209,22 @@ DLL_EXPORT const char *taos_errstr(TAOS_RES *res);
 DLL_EXPORT int         taos_errno(TAOS_RES *res);
 DLL_EXPORT void taos_query_a(TAOS *taos, const char *sql, __taos_async_fn_t fp, void *param);
 DLL_EXPORT void taos_query_a_with_reqid(TAOS *taos, const char *sql, __taos_async_fn_t fp, void *param, int64_t reqid);
 DLL_EXPORT void taos_fetch_rows_a(TAOS_RES *res, __taos_async_fn_t fp, void *param);
 DLL_EXPORT void taos_fetch_raw_block_a(TAOS_RES *res, __taos_async_fn_t fp, void *param);
 DLL_EXPORT const void *taos_get_raw_block(TAOS_RES *res);
-DLL_EXPORT int       taos_get_db_route_info(TAOS* taos, const char* db, TAOS_DB_ROUTE_INFO* dbInfo);
+DLL_EXPORT int taos_get_db_route_info(TAOS *taos, const char *db, TAOS_DB_ROUTE_INFO *dbInfo);
-DLL_EXPORT int       taos_get_table_vgId(TAOS* taos, const char* db, const char* table, int* vgId);
+DLL_EXPORT int taos_get_table_vgId(TAOS *taos, const char *db, const char *table, int *vgId);
 DLL_EXPORT int       taos_load_table_info(TAOS *taos, const char *tableNameList);
 DLL_EXPORT TAOS_RES *taos_schemaless_insert(TAOS *taos, char *lines[], int numLines, int protocol, int precision);
-DLL_EXPORT TAOS_RES *taos_schemaless_insert_raw(TAOS* taos, char* lines, int len, int32_t *totalRows, int protocol, int precision);
+DLL_EXPORT TAOS_RES *taos_schemaless_insert_with_reqid(TAOS *taos, char *lines[], int numLines, int protocol,
                                                       int precision, int64_t reqid);
 DLL_EXPORT TAOS_RES *taos_schemaless_insert_raw(TAOS *taos, char *lines, int len, int32_t *totalRows, int protocol,
                                                int precision);
 DLL_EXPORT TAOS_RES *taos_schemaless_insert_raw_with_reqid(TAOS *taos, char *lines, int len, int32_t *totalRows,
                                                           int protocol, int precision, int64_t reqid);
 /* --------------------------TMQ INTERFACE------------------------------- */
--- a/source/client/inc/clientInt.h
+++ b/source/client/inc/clientInt.h
@ -271,7 +271,11 @@ int32_t transferTableNameList(const char* tbList, int32_t acctId, char* dbName,
 void    syncCatalogFn(SMetaData* pResult, void* param, int32_t code);
 TAOS_RES* taosQueryImpl(TAOS* taos, const char* sql, bool validateOnly);
 TAOS_RES* taosQueryImplWithReqid(TAOS* taos, const char* sql, bool validateOnly, int64_t reqid);
 void taosAsyncQueryImpl(uint64_t connId, const char* sql, __taos_async_fn_t fp, void* param, bool validateOnly);
 void taosAsyncQueryImplWithReqid(uint64_t connId, const char* sql, __taos_async_fn_t fp, void* param, bool validateOnly,
                                 int64_t reqid);
 int32_t getVersion1BlockMetaSize(const char* p, int32_t numOfCols);
@ -318,11 +322,11 @@ void*    createTscObj(const char* user, const char* auth, const char* db, int32_
 void     destroyTscObj(void* pObj);
 STscObj* acquireTscObj(int64_t rid);
 int32_t  releaseTscObj(int64_t rid);
-void destroyAppInst(SAppInstInfo *pAppInfo);
+void     destroyAppInst(SAppInstInfo* pAppInfo);
 uint64_t generateRequestId();
-void*        createRequest(uint64_t connId, int32_t type);
+void*        createRequest(uint64_t connId, int32_t type, int64_t reqid);
 void         destroyRequest(SRequestObj* pRequest);
 SRequestObj* acquireRequest(int64_t rid);
 int32_t      releaseRequest(int64_t rid);
@ -353,7 +357,7 @@ int32_t parseSql(SRequestObj* pRequest, bool topicQuery, SQuery** pQuery, SStmtC
 int32_t getPlan(SRequestObj* pRequest, SQuery* pQuery, SQueryPlan** pPlan, SArray* pNodeList);
 int32_t buildRequest(uint64_t connId, const char* sql, int sqlLen, void* param, bool validateSql,
-                     SRequestObj** pRequest);
+                     SRequestObj** pRequest, int64_t reqid);
 void taos_close_internal(void* taos);
--- a/source/client/inc/clientStmt.h
+++ b/source/client/inc/clientStmt.h
@ -101,11 +101,18 @@ typedef struct STscStmt {
  SStmtSQLInfo  sql;
  SStmtExecInfo exec;
  SStmtBindInfo bInfo;
  int64_t reqid;
 } STscStmt;
 extern char *gStmtStatusStr[];
-#define STMT_LOG_SEQ(n) do { (pStmt)->seqId++; (pStmt)->seqIds[n]++; STMT_DLOG("the %dth:%d %s", (pStmt)->seqIds[n], (pStmt)->seqId, gStmtStatusStr[n]); } while (0)
+#define STMT_LOG_SEQ(n)                                                                 \
  do {                                                                                  \
    (pStmt)->seqId++;                                                                   \
    (pStmt)->seqIds[n]++;                                                               \
    STMT_DLOG("the %dth:%d %s", (pStmt)->seqIds[n], (pStmt)->seqId, gStmtStatusStr[n]); \
  } while (0)
 #define STMT_STATUS_NE(S) (pStmt->sql.status != STMT_##S)
 #define STMT_STATUS_EQ(S) (pStmt->sql.status == STMT_##S)
@ -141,7 +148,7 @@ extern char *gStmtStatusStr[];
 #define STMT_ELOG_E(param) qError("stmt:%p " param, pStmt)
 #define STMT_DLOG_E(param) qDebug("stmt:%p " param, pStmt)
-TAOS_STMT  *stmtInit(STscObj *taos);
+TAOS_STMT  *stmtInit(STscObj *taos, int64_t reqid);
 int         stmtClose(TAOS_STMT *stmt);
 int         stmtExec(TAOS_STMT *stmt);
 const char *stmtErrstr(TAOS_STMT *stmt);
--- a/source/client/src/clientEnv.c
+++ b/source/client/src/clientEnv.c
@ -77,19 +77,19 @@ static void deregisterRequest(SRequestObj *pRequest) {
           pRequest->self, pTscObj->id, pRequest->requestId, duration / 1000.0, num, currentInst);
  if (QUERY_NODE_VNODE_MODIF_STMT == pRequest->stmtType) {
-//    tscPerf("insert duration %" PRId64 "us: syntax:%" PRId64 "us, ctg:%" PRId64 "us, semantic:%" PRId64
+    //    tscPerf("insert duration %" PRId64 "us: syntax:%" PRId64 "us, ctg:%" PRId64 "us, semantic:%" PRId64
-//            "us, exec:%" PRId64 "us",
+    //            "us, exec:%" PRId64 "us",
-//            duration, pRequest->metric.syntaxEnd - pRequest->metric.syntaxStart,
+    //            duration, pRequest->metric.syntaxEnd - pRequest->metric.syntaxStart,
-//            pRequest->metric.ctgEnd - pRequest->metric.ctgStart, pRequest->metric.semanticEnd - pRequest->metric.ctgEnd,
+    //            pRequest->metric.ctgEnd - pRequest->metric.ctgStart, pRequest->metric.semanticEnd -
-//            pRequest->metric.execEnd - pRequest->metric.semanticEnd);
+    //            pRequest->metric.ctgEnd, pRequest->metric.execEnd - pRequest->metric.semanticEnd);
    atomic_add_fetch_64((int64_t *)&pActivity->insertElapsedTime, duration);
  } else if (QUERY_NODE_SELECT_STMT == pRequest->stmtType) {
-//    tscPerf("select duration %" PRId64 "us: syntax:%" PRId64 "us, ctg:%" PRId64 "us, semantic:%" PRId64
+    //    tscPerf("select duration %" PRId64 "us: syntax:%" PRId64 "us, ctg:%" PRId64 "us, semantic:%" PRId64
-//            "us, planner:%" PRId64 "us, exec:%" PRId64 "us, reqId:0x%" PRIx64,
+    //            "us, planner:%" PRId64 "us, exec:%" PRId64 "us, reqId:0x%" PRIx64,
-//            duration, pRequest->metric.syntaxEnd - pRequest->metric.syntaxStart,
+    //            duration, pRequest->metric.syntaxEnd - pRequest->metric.syntaxStart,
-//            pRequest->metric.ctgEnd - pRequest->metric.ctgStart, pRequest->metric.semanticEnd - pRequest->metric.ctgEnd,
+    //            pRequest->metric.ctgEnd - pRequest->metric.ctgStart, pRequest->metric.semanticEnd -
-//            pRequest->metric.planEnd - pRequest->metric.semanticEnd,
+    //            pRequest->metric.ctgEnd, pRequest->metric.planEnd - pRequest->metric.semanticEnd,
-//            pRequest->metric.resultReady - pRequest->metric.planEnd, pRequest->requestId);
+    //            pRequest->metric.resultReady - pRequest->metric.planEnd, pRequest->requestId);
    atomic_add_fetch_64((int64_t *)&pActivity->queryElapsedTime, duration);
  }
@ -271,7 +271,7 @@ STscObj *acquireTscObj(int64_t rid) { return (STscObj *)taosAcquireRef(clientCon
 int32_t releaseTscObj(int64_t rid) { return taosReleaseRef(clientConnRefPool, rid); }
-void *createRequest(uint64_t connId, int32_t type) {
+void *createRequest(uint64_t connId, int32_t type, int64_t reqid) {
  SRequestObj *pRequest = (SRequestObj *)taosMemoryCalloc(1, sizeof(SRequestObj));
  if (NULL == pRequest) {
    terrno = TSDB_CODE_TSC_OUT_OF_MEMORY;
@ -286,7 +286,7 @@ void *createRequest(uint64_t connId, int32_t type) {
  }
  pRequest->resType = RES_TYPE__QUERY;
-  pRequest->requestId = generateRequestId();
+  pRequest->requestId = reqid == 0 ? generateRequestId() : reqid;
  pRequest->metric.start = taosGetTimestampUs();
  pRequest->body.resInfo.convertUcs4 = true;  // convert ucs4 by default
--- a/source/client/src/clientImpl.c
+++ b/source/client/src/clientImpl.c
@ -154,8 +154,8 @@ STscObj* taos_connect_internal(const char* ip, const char* user, const char* pas
 }
 int32_t buildRequest(uint64_t connId, const char* sql, int sqlLen, void* param, bool validateSql,
-                     SRequestObj** pRequest) {
+                     SRequestObj** pRequest, int64_t reqid) {
-  *pRequest = createRequest(connId, TSDB_SQL_SELECT);
+  *pRequest = createRequest(connId, TSDB_SQL_SELECT, reqid);
  if (*pRequest == NULL) {
    tscError("failed to malloc sqlObj, %s", sql);
    return terrno;
@ -1230,7 +1230,7 @@ STscObj* taosConnectImpl(const char* user, const char* auth, const char* db, __t
    return pTscObj;
  }
-  SRequestObj* pRequest = createRequest(pTscObj->id, TDMT_MND_CONNECT);
+  SRequestObj* pRequest = createRequest(pTscObj->id, TDMT_MND_CONNECT, 0);
  if (pRequest == NULL) {
    destroyTscObj(pTscObj);
    return NULL;
@ -2234,7 +2234,37 @@ void taosAsyncQueryImpl(uint64_t connId, const char* sql, __taos_async_fn_t fp,
  }
  SRequestObj* pRequest = NULL;
-  int32_t      code = buildRequest(connId, sql, sqlLen, param, validateOnly, &pRequest);
+  int32_t      code = buildRequest(connId, sql, sqlLen, param, validateOnly, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    terrno = code;
    fp(param, NULL, terrno);
    return;
  }
  pRequest->body.queryFp = fp;
  doAsyncQuery(pRequest, false);
 }
 void taosAsyncQueryImplWithReqid(uint64_t connId, const char* sql, __taos_async_fn_t fp, void* param, bool validateOnly,
                                 int64_t reqid) {
  if (sql == NULL || NULL == fp) {
    terrno = TSDB_CODE_INVALID_PARA;
    if (fp) {
      fp(param, NULL, terrno);
    }
    return;
  }
  size_t sqlLen = strlen(sql);
  if (sqlLen > (size_t)TSDB_MAX_ALLOWED_SQL_LEN) {
    tscError("sql string exceeds max length:%d", TSDB_MAX_ALLOWED_SQL_LEN);
    terrno = TSDB_CODE_TSC_EXCEED_SQL_LIMIT;
    fp(param, NULL, terrno);
    return;
  }
  SRequestObj* pRequest = NULL;
  int32_t      code = buildRequest(connId, sql, sqlLen, param, validateOnly, &pRequest, reqid);
  if (code != TSDB_CODE_SUCCESS) {
    terrno = code;
    fp(param, NULL, terrno);
@ -2261,3 +2291,20 @@ TAOS_RES* taosQueryImpl(TAOS* taos, const char* sql, bool validateOnly) {
  }
  return param->pRequest;
 }
 TAOS_RES* taosQueryImplWithReqid(TAOS* taos, const char* sql, bool validateOnly, int64_t reqid) {
  if (NULL == taos) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return NULL;
  }
  SSyncQueryParam* param = taosMemoryCalloc(1, sizeof(SSyncQueryParam));
  tsem_init(&param->sem, 0, 0);
  taosAsyncQueryImplWithReqid(*(int64_t*)taos, sql, syncQueryFn, param, validateOnly, reqid);
  tsem_wait(&param->sem);
  if (param->pRequest != NULL) {
    param->pRequest->syncQuery = true;
  }
  return param->pRequest;
 }
--- a/source/client/src/clientMain.c
+++ b/source/client/src/clientMain.c
@ -248,6 +248,9 @@ TAOS_FIELD *taos_fetch_fields(TAOS_RES *res) {
 }
 TAOS_RES *taos_query(TAOS *taos, const char *sql) { return taosQueryImpl(taos, sql, false); }
 TAOS_RES *taos_query_with_reqid(TAOS *taos, const char *sql, int64_t reqid) {
  return taosQueryImplWithReqid(taos, sql, false, reqid);
 }
 TAOS_ROW taos_fetch_row(TAOS_RES *res) {
  if (res == NULL) {
@ -763,6 +766,11 @@ void taos_query_a(TAOS *taos, const char *sql, __taos_async_fn_t fp, void *param
  taosAsyncQueryImpl(connId, sql, fp, param, false);
 }
 void taos_query_a_with_reqid(TAOS *taos, const char *sql, __taos_async_fn_t fp, void *param, int64_t reqid) {
  int64_t connId = *(int64_t *)taos;
  taosAsyncQueryImplWithReqid(connId, sql, fp, param, false, reqid);
 }
 int32_t createParseContext(const SRequestObj *pRequest, SParseContext **pCxt) {
  const STscObj *pTscObj = pRequest->pTscObj;
@ -992,7 +1000,7 @@ int taos_get_db_route_info(TAOS *taos, const char *db, TAOS_DB_ROUTE_INFO *dbInf
  int64_t      connId = *(int64_t *)taos;
  SRequestObj *pRequest = NULL;
  char        *sql = "taos_get_db_route_info";
-  int32_t      code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest);
+  int32_t      code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    terrno = code;
    return terrno;
@ -1041,7 +1049,7 @@ int taos_get_table_vgId(TAOS *taos, const char *db, const char *table, int *vgId
  int64_t      connId = *(int64_t *)taos;
  SRequestObj *pRequest = NULL;
  char        *sql = "taos_get_table_vgId";
-  int32_t      code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest);
+  int32_t      code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    return terrno;
  }
@ -1102,7 +1110,7 @@ int taos_load_table_info(TAOS *taos, const char *tableNameList) {
  }
  char *sql = "taos_load_table_info";
-  code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest);
+  code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    terrno = code;
    goto _return;
@ -1147,7 +1155,22 @@ TAOS_STMT *taos_stmt_init(TAOS *taos) {
    return NULL;
  }
-  TAOS_STMT *pStmt = stmtInit(pObj);
+  TAOS_STMT *pStmt = stmtInit(pObj, 0);
  releaseTscObj(*(int64_t *)taos);
  return pStmt;
 }
 TAOS_STMT *taos_stmt_init_with_reqid(TAOS *taos, int64_t reqid) {
  STscObj *pObj = acquireTscObj(*(int64_t *)taos);
  if (NULL == pObj) {
    tscError("invalid parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return NULL;
  }
  TAOS_STMT *pStmt = stmtInit(pObj, reqid);
  releaseTscObj(*(int64_t *)taos);
--- a/source/client/src/clientRawBlockWrite.c
+++ b/source/client/src/clientRawBlockWrite.c
@ -603,7 +603,7 @@ static int32_t taosCreateStb(TAOS* taos, void* meta, int32_t metaLen) {
  int32_t        code = TSDB_CODE_SUCCESS;
  SRequestObj*   pRequest = NULL;
-  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest);
+  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    goto end;
  }
@ -692,7 +692,7 @@ static int32_t taosDropStb(TAOS* taos, void* meta, int32_t metaLen) {
  int32_t      code = TSDB_CODE_SUCCESS;
  SRequestObj* pRequest = NULL;
-  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest);
+  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    goto end;
  }
@ -773,7 +773,7 @@ static int32_t taosCreateTable(TAOS* taos, void* meta, int32_t metaLen) {
  SQuery*            pQuery = NULL;
  SHashObj*          pVgroupHashmap = NULL;
-  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest);
+  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    goto end;
  }
@ -926,7 +926,7 @@ static int32_t taosDropTable(TAOS* taos, void* meta, int32_t metaLen) {
  SQuery*          pQuery = NULL;
  SHashObj*        pVgroupHashmap = NULL;
-  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest);
+  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    goto end;
  }
@ -1097,7 +1097,7 @@ static int32_t taosAlterTable(TAOS* taos, void* meta, int32_t metaLen) {
  SArray*        pArray = NULL;
  SVgDataBlocks* pVgData = NULL;
-  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest);
+  code = buildRequest(*(int64_t*)taos, "", 0, NULL, false, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    goto end;
@ -1217,7 +1217,7 @@ int taos_write_raw_block(TAOS* taos, int rows, char* pData, const char* tbname)
  SQuery*     pQuery = NULL;
  SSubmitReq* subReq = NULL;
-  SRequestObj* pRequest = (SRequestObj*)createRequest(*(int64_t*)taos, TSDB_SQL_INSERT);
+  SRequestObj* pRequest = (SRequestObj*)createRequest(*(int64_t*)taos, TSDB_SQL_INSERT, 0);
  if (!pRequest) {
    uError("WriteRaw:createRequest error request is null");
    code = terrno;
@ -1407,7 +1407,7 @@ static int32_t tmqWriteRawDataImpl(TAOS* taos, void* data, int32_t dataLen) {
  STableMeta* pTableMeta = NULL;
  terrno = TSDB_CODE_SUCCESS;
-  SRequestObj* pRequest = (SRequestObj*)createRequest(*(int64_t*)taos, TSDB_SQL_INSERT);
+  SRequestObj* pRequest = (SRequestObj*)createRequest(*(int64_t*)taos, TSDB_SQL_INSERT, 0);
  if (!pRequest) {
    uError("WriteRaw:createRequest error request is null");
    return terrno;
@ -1674,7 +1674,7 @@ static int32_t tmqWriteRawMetaDataImpl(TAOS* taos, void* data, int32_t dataLen)
  STableMeta*    pTableMeta = NULL;
  terrno = TSDB_CODE_SUCCESS;
-  SRequestObj* pRequest = (SRequestObj*)createRequest(*(int64_t*)taos, TSDB_SQL_INSERT);
+  SRequestObj* pRequest = (SRequestObj*)createRequest(*(int64_t*)taos, TSDB_SQL_INSERT, 0);
  if (!pRequest) {
    uError("WriteRaw:createRequest error request is null");
    return terrno;
--- a/source/client/src/clientSml.c
+++ b/source/client/src/clientSml.c
@ -353,7 +353,7 @@ static int32_t smlSendMetaMsg(SSmlHandle *info, SName *pName, SArray *pColumns,
  pReq.numOfTags = taosArrayGetSize(pTags);
  pReq.pTags = pTags;
-  code = buildRequest(info->taos->id, "", 0, NULL, false, &pRequest);
+  code = buildRequest(info->taos->id, "", 0, NULL, false, &pRequest, 0);
  if (code != TSDB_CODE_SUCCESS) {
    goto end;
  }
@ -1010,9 +1010,9 @@ static void smlParseTelnetElement(const char **sql, const char *sqlEnd, const ch
  }
 }
-static int32_t smlParseTelnetTags(const char *data, const char *sqlEnd, SArray *cols, char *childTableName, SHashObj *dumplicateKey,
+static int32_t smlParseTelnetTags(const char *data, const char *sqlEnd, SArray *cols, char *childTableName,
-                                  SSmlMsgBuf *msg) {
+                                  SHashObj *dumplicateKey, SSmlMsgBuf *msg) {
-  if(!cols) return TSDB_CODE_OUT_OF_MEMORY;
+  if (!cols) return TSDB_CODE_OUT_OF_MEMORY;
  const char *sql = data;
  size_t      childTableNameLen = strlen(tsSmlChildTableName);
  while (sql < sqlEnd) {
@ -1093,7 +1093,8 @@ static int32_t smlParseTelnetTags(const char *data, const char *sqlEnd, SArray *
 }
 // format: <metric> <timestamp> <value> <tagk_1>=<tagv_1>[ <tagk_n>=<tagv_n>]
-static int32_t smlParseTelnetString(SSmlHandle *info, const char *sql, const char *sqlEnd, SSmlTableInfo *tinfo, SArray *cols) {
+static int32_t smlParseTelnetString(SSmlHandle *info, const char *sql, const char *sqlEnd, SSmlTableInfo *tinfo,
                                    SArray *cols) {
  if (!sql) return TSDB_CODE_SML_INVALID_DATA;
  // parse metric
@ -1374,17 +1375,17 @@ static int32_t smlKvTimeHashCompare(const void *key1, const void *key2) {
  SHashObj *s2 = *(SHashObj **)key2;
  SSmlKv  **kv1pp = (SSmlKv **)taosHashGet(s1, TS, TS_LEN);
  SSmlKv  **kv2pp = (SSmlKv **)taosHashGet(s2, TS, TS_LEN);
-  if(!kv1pp || !kv2pp){
+  if (!kv1pp || !kv2pp) {
    uError("smlKvTimeHashCompare kv is null");
    return -1;
  }
  SSmlKv *kv1 = *kv1pp;
  SSmlKv *kv2 = *kv2pp;
-  if(!kv1 || kv1->type != TSDB_DATA_TYPE_TIMESTAMP){
+  if (!kv1 || kv1->type != TSDB_DATA_TYPE_TIMESTAMP) {
    uError("smlKvTimeHashCompare kv1");
    return -1;
  }
-  if(!kv2 || kv2->type != TSDB_DATA_TYPE_TIMESTAMP){
+  if (!kv2 || kv2->type != TSDB_DATA_TYPE_TIMESTAMP) {
    uError("smlKvTimeHashCompare kv2");
    return -1;
  }
@ -1947,7 +1948,7 @@ static int32_t smlParseValueFromJSON(cJSON *root, SSmlKv *kv) {
 }
 static int32_t smlParseColsFromJSON(cJSON *root, SArray *cols) {
-  if(!cols) return TSDB_CODE_OUT_OF_MEMORY;
+  if (!cols) return TSDB_CODE_OUT_OF_MEMORY;
  cJSON *metricVal = cJSON_GetObjectItem(root, "value");
  if (metricVal == NULL) {
    return TSDB_CODE_TSC_INVALID_JSON;
@ -1971,7 +1972,7 @@ static int32_t smlParseColsFromJSON(cJSON *root, SArray *cols) {
 static int32_t smlParseTagsFromJSON(cJSON *root, SArray *pKVs, char *childTableName, SHashObj *dumplicateKey,
                                    SSmlMsgBuf *msg) {
  int32_t ret = TSDB_CODE_SUCCESS;
-  if (!pKVs){
+  if (!pKVs) {
    return TSDB_CODE_OUT_OF_MEMORY;
  }
  cJSON *tags = cJSON_GetObjectItem(root, "tags");
@ -2204,7 +2205,7 @@ static int32_t smlParseTelnetLine(SSmlHandle *info, void *data, const int len) {
  }
  if (info->protocol == TSDB_SML_TELNET_PROTOCOL) {
-    ret = smlParseTelnetString(info, (const char *)data, (char*)data + len, tinfo, cols);
+    ret = smlParseTelnetString(info, (const char *)data, (char *)data + len, tinfo, cols);
  } else if (info->protocol == TSDB_SML_JSON_PROTOCOL) {
    ret = smlParseJSONString(info, (cJSON *)data, tinfo, cols);
  } else {
@ -2384,16 +2385,16 @@ static void smlPrintStatisticInfo(SSmlHandle *info) {
         info->cost.endTime - info->cost.insertRpcTime, info->cost.endTime - info->cost.parseTime);
 }
-static int32_t smlParseLine(SSmlHandle *info, char *lines[], char* rawLine, char* rawLineEnd, int numLines) {
+static int32_t smlParseLine(SSmlHandle *info, char *lines[], char *rawLine, char *rawLineEnd, int numLines) {
  int32_t code = TSDB_CODE_SUCCESS;
  if (info->protocol == TSDB_SML_JSON_PROTOCOL) {
-    if(lines){
+    if (lines) {
      code = smlParseJSON(info, *lines);
-    }else if(rawLine){
+    } else if (rawLine) {
      code = smlParseJSON(info, rawLine);
    }
    if (code != TSDB_CODE_SUCCESS) {
-      uError("SML:0x%" PRIx64 " smlParseJSON failed:%s", info->id, lines?*lines:rawLine);
+      uError("SML:0x%" PRIx64 " smlParseJSON failed:%s", info->id, lines ? *lines : rawLine);
      return code;
    }
    return code;
@ -2402,18 +2403,18 @@ static int32_t smlParseLine(SSmlHandle *info, char *lines[], char* rawLine, char
  for (int32_t i = 0; i < numLines; ++i) {
    char *tmp = NULL;
    int   len = 0;
-    if(lines){
+    if (lines) {
      tmp = lines[i];
      len = strlen(tmp);
-    }else if(rawLine){
+    } else if (rawLine) {
      tmp = rawLine;
-      while(rawLine < rawLineEnd){
+      while (rawLine < rawLineEnd) {
-        if(*(rawLine++) == '\n'){
+        if (*(rawLine++) == '\n') {
          break;
        }
        len++;
      }
-      if(info->protocol == TSDB_SML_LINE_PROTOCOL && tmp[0] == '#'){ // this line is comment
+      if (info->protocol == TSDB_SML_LINE_PROTOCOL && tmp[0] == '#') {  // this line is comment
        continue;
      }
    }
@ -2433,7 +2434,7 @@ static int32_t smlParseLine(SSmlHandle *info, char *lines[], char* rawLine, char
  return code;
 }
-static int smlProcess(SSmlHandle *info, char *lines[], char* rawLine, char* rawLineEnd, int numLines) {
+static int smlProcess(SSmlHandle *info, char *lines[], char *rawLine, char *rawLineEnd, int numLines) {
  int32_t code = TSDB_CODE_SUCCESS;
  int32_t retryNum = 0;
@ -2532,8 +2533,8 @@ static void smlInsertCallback(void *param, void *res, int32_t code) {
  smlDestroyInfo(info);
 }
-
+TAOS_RES *taos_schemaless_insert_inner(SRequestObj *request, char *lines[], char *rawLine, char *rawLineEnd,
-TAOS_RES *taos_schemaless_insert_inner(SRequestObj *request, char *lines[], char *rawLine, char *rawLineEnd, int numLines, int protocol, int precision) {
+                                       int numLines, int protocol, int precision) {
  int      batchs = 0;
  STscObj *pTscObj = request->pTscObj;
@ -2581,7 +2582,7 @@ TAOS_RES *taos_schemaless_insert_inner(SRequestObj *request, char *lines[], char
  batchs = ceil(((double)numLines) / LINE_BATCH);
  params.total = batchs;
  for (int i = 0; i < batchs; ++i) {
-    SRequestObj *req = (SRequestObj *)createRequest(pTscObj->id, TSDB_SQL_INSERT);
+    SRequestObj *req = (SRequestObj *)createRequest(pTscObj->id, TSDB_SQL_INSERT, 0);
    if (!req) {
      request->code = TSDB_CODE_OUT_OF_MEMORY;
      uError("SML:taos_schemaless_insert error request is null");
@ -2608,16 +2609,16 @@ TAOS_RES *taos_schemaless_insert_inner(SRequestObj *request, char *lines[], char
    info->pRequest->body.queryFp = smlInsertCallback;
    info->pRequest->body.param = info;
    int32_t code = smlProcess(info, lines, rawLine, rawLineEnd, perBatch);
-    if(lines){
+    if (lines) {
      lines += perBatch;
    }
-    if(rawLine){
+    if (rawLine) {
      int num = 0;
-      while(rawLine < rawLineEnd){
+      while (rawLine < rawLineEnd) {
-        if(*(rawLine++) == '\n'){
+        if (*(rawLine++) == '\n') {
          num++;
        }
-        if(num == perBatch){
+        if (num == perBatch) {
          break;
        }
      }
@ -2628,7 +2629,7 @@ TAOS_RES *taos_schemaless_insert_inner(SRequestObj *request, char *lines[], char
  }
  tsem_wait(&params.sem);
-  end:
+end:
  taosThreadSpinDestroy(&params.lock);
  tsem_destroy(&params.sem);
  //  ((STscObj *)taos)->schemalessType = 0;
@ -2653,9 +2654,7 @@ TAOS_RES *taos_schemaless_insert_inner(SRequestObj *request, char *lines[], char
 *                  0 - influxDB line protocol
 *                  1 - OpenTSDB telnet line protocol
 *                  2 - OpenTSDB JSON format protocol
- * @return return zero for successful insertion. Otherwise return none-zero error code of
+ * @return TAOS_RES
 *         failure reason.
 *
 */
 TAOS_RES *taos_schemaless_insert(TAOS *taos, char *lines[], int numLines, int protocol, int precision) {
@ -2664,7 +2663,7 @@ TAOS_RES *taos_schemaless_insert(TAOS *taos, char *lines[], int numLines, int pr
    return NULL;
  }
-  SRequestObj *request = (SRequestObj *)createRequest(*(int64_t *)taos, TSDB_SQL_INSERT);
+  SRequestObj *request = (SRequestObj *)createRequest(*(int64_t *)taos, TSDB_SQL_INSERT, 0);
  if (!request) {
    uError("SML:taos_schemaless_insert error request is null");
    return NULL;
@ -2680,13 +2679,37 @@ TAOS_RES *taos_schemaless_insert(TAOS *taos, char *lines[], int numLines, int pr
  return taos_schemaless_insert_inner(request, lines, NULL, NULL, numLines, protocol, precision);
 }
-TAOS_RES *taos_schemaless_insert_raw(TAOS* taos, char* lines, int len, int32_t *totalRows, int protocol, int precision){
+TAOS_RES *taos_schemaless_insert_with_reqid(TAOS *taos, char *lines[], int numLines, int protocol, int precision,
                                            int64_t reqid) {
  if (NULL == taos) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return NULL;
  }
-  SRequestObj *request = (SRequestObj *)createRequest(*(int64_t *)taos, TSDB_SQL_INSERT);
+  SRequestObj *request = (SRequestObj *)createRequest(*(int64_t *)taos, TSDB_SQL_INSERT, reqid);
  if (!request) {
    uError("SML:taos_schemaless_insert error request is null");
    return NULL;
  }
  if (!lines) {
    SSmlMsgBuf msg = {ERROR_MSG_BUF_DEFAULT_SIZE, request->msgBuf};
    request->code = TSDB_CODE_SML_INVALID_DATA;
    smlBuildInvalidDataMsg(&msg, "lines is null", NULL);
    return (TAOS_RES *)request;
  }
  return taos_schemaless_insert_inner(request, lines, NULL, NULL, numLines, protocol, precision);
 }
 TAOS_RES *taos_schemaless_insert_raw(TAOS *taos, char *lines, int len, int32_t *totalRows, int protocol,
                                     int precision) {
  if (NULL == taos) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return NULL;
  }
  SRequestObj *request = (SRequestObj *)createRequest(*(int64_t *)taos, TSDB_SQL_INSERT, 0);
  if (!request) {
    uError("SML:taos_schemaless_insert error request is null");
    return NULL;
@ -2702,10 +2725,45 @@ TAOS_RES *taos_schemaless_insert_raw(TAOS* taos, char* lines, int len, int32_t *
  int numLines = 0;
  *totalRows = 0;
  char *tmp = lines;
-  for(int i = 0; i < len; i++){
+  for (int i = 0; i < len; i++) {
-    if(lines[i] == '\n' || i == len - 1){
+    if (lines[i] == '\n' || i == len - 1) {
      numLines++;
-      if(tmp[0] != '#' || protocol != TSDB_SML_LINE_PROTOCOL){    //ignore comment
+      if (tmp[0] != '#' || protocol != TSDB_SML_LINE_PROTOCOL) {  // ignore comment
        (*totalRows)++;
      }
      tmp = lines + i + 1;
    }
  }
  return taos_schemaless_insert_inner(request, NULL, lines, lines + len, numLines, protocol, precision);
 }
 TAOS_RES *taos_schemaless_insert_raw_with_reqid(TAOS *taos, char *lines, int len, int32_t *totalRows, int protocol,
                                                int precision, int64_t reqid) {
  if (NULL == taos) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return NULL;
  }
  SRequestObj *request = (SRequestObj *)createRequest(*(int64_t *)taos, TSDB_SQL_INSERT, reqid);
  if (!request) {
    uError("SML:taos_schemaless_insert error request is null");
    return NULL;
  }
  if (!lines || len <= 0) {
    SSmlMsgBuf msg = {ERROR_MSG_BUF_DEFAULT_SIZE, request->msgBuf};
    request->code = TSDB_CODE_SML_INVALID_DATA;
    smlBuildInvalidDataMsg(&msg, "lines is null", NULL);
    return (TAOS_RES *)request;
  }
  int numLines = 0;
  *totalRows = 0;
  char *tmp = lines;
  for (int i = 0; i < len; i++) {
    if (lines[i] == '\n' || i == len - 1) {
      numLines++;
      if (tmp[0] != '#' || protocol != TSDB_SML_LINE_PROTOCOL) {  // ignore comment
        (*totalRows)++;
      }
      tmp = lines + i + 1;
--- a/source/client/src/clientStmt.c
+++ b/source/client/src/clientStmt.c
@ -5,13 +5,18 @@
 #include "clientStmt.h"
-char *gStmtStatusStr[] = {"unknown", "init", "prepare", "settbname", "settags", "fetchFields", "bind", "bindCol", "addBatch", "exec"};
+char* gStmtStatusStr[] = {"unknown",     "init", "prepare", "settbname", "settags",
                          "fetchFields", "bind", "bindCol", "addBatch",  "exec"};
 static int32_t stmtCreateRequest(STscStmt* pStmt) {
  int32_t code = 0;
  if (pStmt->exec.pRequest == NULL) {
-    code = buildRequest(pStmt->taos->id, pStmt->sql.sqlStr, pStmt->sql.sqlLen, NULL, false, &pStmt->exec.pRequest);
+    code = buildRequest(pStmt->taos->id, pStmt->sql.sqlStr, pStmt->sql.sqlLen, NULL, false, &pStmt->exec.pRequest,
                        pStmt->reqid);
    if (pStmt->reqid != 0) {
      pStmt->reqid++;
    }
    if (TSDB_CODE_SUCCESS == code) {
      pStmt->exec.pRequest->syncQuery = true;
    }
@ -207,7 +212,7 @@ int32_t stmtCacheBlock(STscStmt* pStmt) {
  }
  STableDataBlocks** pSrc = taosHashGet(pStmt->exec.pBlockHash, pStmt->bInfo.tbFName, strlen(pStmt->bInfo.tbFName));
-  if(!pSrc){
+  if (!pSrc) {
    return TSDB_CODE_OUT_OF_MEMORY;
  }
  STableDataBlocks* pDst = NULL;
@ -513,7 +518,7 @@ int32_t stmtResetStmt(STscStmt* pStmt) {
  return TSDB_CODE_SUCCESS;
 }
-TAOS_STMT* stmtInit(STscObj* taos) {
+TAOS_STMT* stmtInit(STscObj* taos, int64_t reqid) {
  STscObj*  pObj = (STscObj*)taos;
  STscStmt* pStmt = NULL;
@ -533,6 +538,7 @@ TAOS_STMT* stmtInit(STscObj* taos) {
  pStmt->taos = pObj;
  pStmt->bInfo.needParse = true;
  pStmt->sql.status = STMT_INIT;
  pStmt->reqid = reqid;
  STMT_LOG_SEQ(STMT_INIT);