[TD-6217]<feauture> merge develop

tests/examples/c/connect_two_cluster.c

+#include <stdio.h>
+#include <pthread.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include "taos.h"
+int numOfThreads = 1;
+
+void* connectClusterAndDeal(void *arg) {
+  int port = *(int *)arg;
+  const char *host = "127.0.0.1";  
+  const char *user = "root";  
+  const char *passwd = "taosdata"; 
+  TAOS* taos1 = taos_connect(host, user, passwd, "", port); 
+  TAOS* taos2 = taos_connect(host, user, passwd, "", port + 1000); 
+  if (NULL == taos1 || NULL == taos2) {
+    printf("connect to (%d/%d) failed \n", port, port + 1000); 
+    return NULL;
+  } 
+  TAOS_RES *result = NULL;
+  result = taos_query(taos1, "drop database if exists db"); 
+  if (0 != taos_errno(result)) {
+    printf("failed %s\n", taos_errstr(result));
+  }
+  taos_free_result(result);
+
+  taos_query(taos2, "drop database if exists db"); 
+  if (0 != taos_errno(result)) {
+    printf("failed %s\n", taos_errstr(result));
+  }
+  
+  taos_free_result(result);
+  // ========= build database
+  {
+    result = taos_query(taos1, "create database db");
+    if (0 != taos_errno(result)) {
+      printf("failed %s\n", taos_errstr(result));
+    }
+    
+    taos_free_result(result);
+  }
+  {
+    result = taos_query(taos2, "create database db");
+    if (0 != taos_errno(result)) {
+      printf("failed %s\n", taos_errstr(result));
+    }
+    taos_free_result(result);
+  }
+  
+  //======== create table 
+  {
+    result = taos_query(taos1, "create stable db.stest (ts timestamp, port int) tags(tport int)");
+    if (0 != taos_errno(result)) {
+      printf("failed %s\n", taos_errstr(result));
+    }
+    taos_free_result(result);
+  }
+  {
+    result = taos_query(taos2, "create stable db.stest (ts timestamp, port int) tags(tport int)");
+    if (0 != taos_errno(result)) {
+      printf("failed %s\n", taos_errstr(result));
+    }
+    taos_free_result(result);
+
+  }
+  //======== create table 
+  {
+    result = taos_query(taos1, "use db");
+    if (0 != taos_errno(result)) {
+      printf("failed %s\n", taos_errstr(result));
+    }
+    taos_free_result(result);
+  }
+  {
+    result = taos_query(taos2, "use db");
+    if (0 != taos_errno(result)) {
+      printf("failed %s\n", taos_errstr(result));
+    }
+    taos_free_result(result);
+
+  }
+  {
+    char buf[1024] = {0};
+    sprintf(buf, "insert into db.t1 using stest tags(%d) values(now, %d)", port, port);
+    for (int i = 0; i < 100000; i++) {
+      //printf("error here\t");
+      result = taos_query(taos1, buf);
+    if (0 != taos_errno(result)) {
+      printf("failed %s\n", taos_errstr(result));
+    }
+      taos_free_result(result);
+      //sleep(1); 
+    }
+  }
+
+  {
+    char buf[1024] = {0};
+    sprintf(buf, "insert into db.t1 using stest tags(%d) values(now, %d)", port + 1000, port + 1000);
+    for (int i = 0; i < 100000; i++) {
+      result = taos_query(taos2, buf);
+      if (0 != taos_errno(result)) {
+        printf("failed %s\n", taos_errstr(result));
+      }
+      taos_free_result(result);
+      //sleep(1); 
+    }
+  }
+  // query result
+  {
+    result = taos_query(taos1, "select * from stest");
+    if (result == NULL || taos_errno(result) != 0) {
+      printf("query failed %s\n", taos_errstr(result));
+      taos_free_result(result);
+    }
+    TAOS_ROW row;
+    int rows = 0;
+    int num_fields = taos_field_count(result);
+    TAOS_FIELD *fields = taos_fetch_fields(result);
+    while ((row = taos_fetch_row(result))) {
+      char temp[1024] = {0};
+      rows++;
+      taos_print_row(temp, row, fields , num_fields);
+      printf("%s\n", temp);
+    }
+    taos_free_result(result);
+  } 
+
+  // query result
+  {
+    result = taos_query(taos2, "select * from stest");
+    if (result == NULL || taos_errno(result) != 0) {
+      printf("query failed %s\n", taos_errstr(result));
+      taos_free_result(result);
+    }
+    TAOS_ROW row;
+    int rows = 0;
+    int num_fields = taos_field_count(result);
+    TAOS_FIELD *fields = taos_fetch_fields(result);
+    while ((row = taos_fetch_row(result))) {
+      char temp[1024] = {0};
+      rows++;
+      taos_print_row(temp, row, fields , num_fields);
+      printf("%s\n", temp);
+    }
+    taos_free_result(result);
+  } 
+  taos_close(taos1); 
+  taos_close(taos2); 
+  return NULL;
+}
+int main(int argc, char* argv[]) {
+  pthread_t *pthreads = malloc(sizeof(pthread_t) * numOfThreads);   
+  
+  int *port = malloc(sizeof(int) * numOfThreads);
+  port[0] = 6030;
+  for (int i = 0; i < numOfThreads; i++) {
+    pthread_create(&pthreads[i], NULL, connectClusterAndDeal, (void *)&port[i]);
+  }
+  for (int i = 0; i < numOfThreads; i++) {
+    pthread_join(pthreads[i], NULL);
+  }
+  free(port);
+}