clientMain.c 45.5 KB
Newer Older
L
Liu Jicong 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#include "catalog.h"
17
#include "clientInt.h"
18
#include "clientLog.h"
L
Liu Jicong 已提交
19
#include "clientStmt.h"
L
Liu Jicong 已提交
20
#include "functionMgt.h"
L
Liu Jicong 已提交
21
#include "os.h"
H
Haojun Liao 已提交
22
#include "query.h"
L
Liu Jicong 已提交
23
#include "scheduler.h"
L
Liu Jicong 已提交
24
#include "tdatablock.h"
25
#include "tglobal.h"
L
Liu Jicong 已提交
26 27 28
#include "tmsg.h"
#include "tref.h"
#include "trpc.h"
S
version  
Shengliang Guan 已提交
29
#include "version.h"
30 31 32 33 34

#define TSC_VAR_NOT_RELEASE 1
#define TSC_VAR_RELEASED    0

static int32_t sentinel = TSC_VAR_NOT_RELEASE;
35
static int32_t createParseContext(const SRequestObj *pRequest, SParseContext **pCxt);
36 37 38 39 40 41 42 43 44 45 46

int taos_options(TSDB_OPTION option, const void *arg, ...) {
  static int32_t lock = 0;

  for (int i = 1; atomic_val_compare_exchange_32(&lock, 0, 1) != 0; ++i) {
    if (i % 1000 == 0) {
      tscInfo("haven't acquire lock after spin %d times.", i);
      sched_yield();
    }
  }

L
Liu Jicong 已提交
47
  int ret = taos_options_imp(option, (const char *)arg);
48 49 50 51 52
  atomic_store_32(&lock, 0);
  return ret;
}
// this function may be called by user or system, or by both simultaneously.
void taos_cleanup(void) {
D
dapan1121 已提交
53
  tscDebug("start to cleanup client environment");
54 55 56 57
  if (atomic_val_compare_exchange_32(&sentinel, TSC_VAR_NOT_RELEASE, TSC_VAR_RELEASED) != TSC_VAR_NOT_RELEASE) {
    return;
  }

D
dapan1121 已提交
58 59
  tscStopCrashReport();

H
Haojun Liao 已提交
60 61
  int32_t id = clientReqRefPool;
  clientReqRefPool = -1;
62 63
  taosCloseRef(id);

D
dapan1121 已提交
64 65 66 67
  hbMgrCleanUp();

  catalogDestroy();
  schedulerDestroy();
68

X
Xiaoyu Wang 已提交
69 70
  fmFuncMgtDestroy();
  qCleanupKeywordsTable();
71
  nodesDestroyAllocatorSet();
X
Xiaoyu Wang 已提交
72

73 74
  id = clientConnRefPool;
  clientConnRefPool = -1;
75 76
  taosCloseRef(id);

D
dapan1121 已提交
77 78
  rpcCleanup();
  tscDebug("rpc cleanup");
79

D
dapan1121 已提交
80
  cleanupTaskQueue();
H
Haojun Liao 已提交
81

D
dapan1121 已提交
82
  taosConvDestroy();
dengyihao's avatar
dengyihao 已提交
83

H
Haojun Liao 已提交
84
  tscInfo("all local resources released");
85
  taosCleanupCfg();
86
  taosCloseLog();
87 88
}

L
Liu Jicong 已提交
89
static setConfRet taos_set_config_imp(const char *config) {
90 91 92 93 94
  setConfRet ret = {SET_CONF_RET_SUCC, {0}};
  // TODO: need re-implementation
  return ret;
}

L
Liu Jicong 已提交
95 96
setConfRet taos_set_config(const char *config) {
  // TODO  pthread_mutex_lock(&setConfMutex);
97
  setConfRet ret = taos_set_config_imp(config);
L
Liu Jicong 已提交
98
  //  pthread_mutex_unlock(&setConfMutex);
99 100 101
  return ret;
}

102
TAOS *taos_connect(const char *ip, const char *user, const char *pass, const char *db, uint16_t port) {
S
Shengliang Guan 已提交
103
  tscDebug("try to connect to %s:%u, user:%s db:%s", ip, port, user, db);
H
Haojun Liao 已提交
104 105 106
  if (user == NULL) {
    user = TSDB_DEFAULT_USER;
  }
107

H
Haojun Liao 已提交
108 109 110
  if (pass == NULL) {
    pass = TSDB_DEFAULT_PASS;
  }
D
dapan1121 已提交
111
  
L
Liu Jicong 已提交
112
  STscObj *pObj = taos_connect_internal(ip, user, pass, NULL, db, port, CONN_TYPE__QUERY);
113
  if (pObj) {
D
dapan1121 已提交
114 115
    int64_t *rid = taosMemoryCalloc(1, sizeof(int64_t));
    *rid = pObj->id;
dengyihao's avatar
dengyihao 已提交
116
    return (TAOS *)rid;
117
  }
L
Liu Jicong 已提交
118

D
dapan1121 已提交
119
  return NULL;
120 121
}

122
void taos_close_internal(void *taos) {
123 124 125 126
  if (taos == NULL) {
    return;
  }

H
Haojun Liao 已提交
127
  STscObj *pTscObj = (STscObj *)taos;
D
dapan1121 已提交
128
  tscDebug("0x%" PRIx64 " try to close connection, numOfReq:%d", pTscObj->id, pTscObj->numOfReqs);
129

D
dapan1121 已提交
130
  taosRemoveRef(clientConnRefPool, pTscObj->id);
131 132
}

133
void taos_close(TAOS *taos) {
D
dapan1121 已提交
134 135 136
  if (taos == NULL) {
    return;
  }
L
Liu Jicong 已提交
137 138

  STscObj *pObj = acquireTscObj(*(int64_t *)taos);
139
  if (NULL == pObj) {
D
dapan1121 已提交
140
    taosMemoryFree(taos);
141 142
    return;
  }
L
Liu Jicong 已提交
143

144
  taos_close_internal(pObj);
L
Liu Jicong 已提交
145
  releaseTscObj(*(int64_t *)taos);
D
dapan1121 已提交
146
  taosMemoryFree(taos);
147 148
}

L
Liu Jicong 已提交
149 150
int taos_errno(TAOS_RES *res) {
  if (res == NULL || TD_RES_TMQ_META(res)) {
151 152 153
    return terrno;
  }

154
  if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
155 156 157
    return 0;
  }

158
  return ((SRequestObj *)res)->code;
159 160
}

161
const char *taos_errstr(TAOS_RES *res) {
L
Liu Jicong 已提交
162
  if (res == NULL || TD_RES_TMQ_META(res)) {
L
Liu Jicong 已提交
163
    return (const char *)tstrerror(terrno);
164 165
  }

166
  if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
167 168 169 170
    return "success";
  }

  SRequestObj *pRequest = (SRequestObj *)res;
171
  if (NULL != pRequest->msgBuf && (strlen(pRequest->msgBuf) > 0 || pRequest->code == TSDB_CODE_RPC_FQDN_ERROR)) {
172 173
    return pRequest->msgBuf;
  } else {
174
    return (const char *)tstrerror(pRequest->code);
175
  }
176 177 178
}

void taos_free_result(TAOS_RES *res) {
D
stmt  
dapan1121 已提交
179 180 181
  if (NULL == res) {
    return;
  }
182

L
Liu Jicong 已提交
183 184
  tscDebug("taos free res %p", res);

L
Liu Jicong 已提交
185 186
  if (TD_RES_QUERY(res)) {
    SRequestObj *pRequest = (SRequestObj *)res;
D
dapan1121 已提交
187
    tscDebug("0x%" PRIx64 " taos_free_result start to free query", pRequest->requestId);
L
Liu Jicong 已提交
188
    destroyRequest(pRequest);
189
  } else if (TD_RES_TMQ_METADATA(res)) {
L
Liu Jicong 已提交
190
    SMqTaosxRspObj *pRsp = (SMqTaosxRspObj *)res;
L
Liu Jicong 已提交
191 192 193 194
    taosArrayDestroyP(pRsp->rsp.blockData, taosMemoryFree);
    taosArrayDestroy(pRsp->rsp.blockDataLen);
    taosArrayDestroyP(pRsp->rsp.blockTbName, taosMemoryFree);
    taosArrayDestroyP(pRsp->rsp.blockSchema, (FDelete)tDeleteSSchemaWrapper);
L
Liu Jicong 已提交
195 196 197 198 199 200 201
    // taosx
    taosArrayDestroy(pRsp->rsp.createTableLen);
    taosArrayDestroyP(pRsp->rsp.createTableReq, taosMemoryFree);

    pRsp->resInfo.pRspMsg = NULL;
    doFreeReqResultInfo(&pRsp->resInfo);
    taosMemoryFree(pRsp);
L
Liu Jicong 已提交
202 203
  } else if (TD_RES_TMQ(res)) {
    SMqRspObj *pRsp = (SMqRspObj *)res;
L
Liu Jicong 已提交
204 205 206 207
    taosArrayDestroyP(pRsp->rsp.blockData, taosMemoryFree);
    taosArrayDestroy(pRsp->rsp.blockDataLen);
    taosArrayDestroyP(pRsp->rsp.blockTbName, taosMemoryFree);
    taosArrayDestroyP(pRsp->rsp.blockSchema, (FDelete)tDeleteSSchemaWrapper);
L
Liu Jicong 已提交
208 209
    pRsp->resInfo.pRspMsg = NULL;
    doFreeReqResultInfo(&pRsp->resInfo);
210
    taosMemoryFree(pRsp);
L
Liu Jicong 已提交
211 212 213 214
  } else if (TD_RES_TMQ_META(res)) {
    SMqMetaRspObj *pRspObj = (SMqMetaRspObj *)res;
    taosMemoryFree(pRspObj->metaRsp.metaRsp);
    taosMemoryFree(pRspObj);
L
Liu Jicong 已提交
215
  }
216 217
}

D
dapan1121 已提交
218 219 220 221
void taos_kill_query(TAOS *taos) {
  if (NULL == taos) {
    return;
  }
dengyihao's avatar
dengyihao 已提交
222

dengyihao's avatar
dengyihao 已提交
223
  int64_t  rid = *(int64_t *)taos;
dengyihao's avatar
dengyihao 已提交
224
  STscObj *pTscObj = acquireTscObj(rid);
D
dapan1121 已提交
225 226 227
  if (pTscObj) {
    stopAllRequests(pTscObj->pRequests);
  }
D
dapan1121 已提交
228 229 230
  releaseTscObj(rid);
}

L
Liu Jicong 已提交
231
int taos_field_count(TAOS_RES *res) {
L
Liu Jicong 已提交
232
  if (res == NULL || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
233 234 235
    return 0;
  }

L
Liu Jicong 已提交
236
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
H
Haojun Liao 已提交
237 238 239
  return pResInfo->numOfCols;
}

L
Liu Jicong 已提交
240
int taos_num_fields(TAOS_RES *res) { return taos_field_count(res); }
H
Haojun Liao 已提交
241 242

TAOS_FIELD *taos_fetch_fields(TAOS_RES *res) {
L
Liu Jicong 已提交
243
  if (taos_num_fields(res) == 0 || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
244 245 246
    return NULL;
  }

L
Liu Jicong 已提交
247
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
248
  return pResInfo->userFields;
H
Haojun Liao 已提交
249 250
}

251
TAOS_RES *taos_query(TAOS *taos, const char *sql) { return taosQueryImpl(taos, sql, false); }
dengyihao's avatar
dengyihao 已提交
252 253 254
TAOS_RES *taos_query_with_reqid(TAOS *taos, const char *sql, int64_t reqid) {
  return taosQueryImplWithReqid(taos, sql, false, reqid);
}
255

256 257
TAOS_ROW taos_fetch_row(TAOS_RES *res) {
  if (res == NULL) {
258 259 260
    return NULL;
  }

L
Liu Jicong 已提交
261 262 263
  if (TD_RES_QUERY(res)) {
    SRequestObj *pRequest = (SRequestObj *)res;
    if (pRequest->type == TSDB_SQL_RETRIEVE_EMPTY_RESULT || pRequest->type == TSDB_SQL_INSERT ||
D
dapan1121 已提交
264
        pRequest->code != TSDB_CODE_SUCCESS || taos_num_fields(res) == 0 || pRequest->killed) {
L
Liu Jicong 已提交
265 266
      return NULL;
    }
D
dapan1121 已提交
267 268

    return doAsyncFetchRows(pRequest, true, true);
269
  } else if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
dengyihao's avatar
dengyihao 已提交
270
    SMqRspObj      *msg = ((SMqRspObj *)res);
L
Liu Jicong 已提交
271 272 273 274 275 276
    SReqResultInfo *pResultInfo;
    if (msg->resIter == -1) {
      pResultInfo = tmqGetNextResInfo(res, true);
    } else {
      pResultInfo = tmqGetCurResInfo(res);
    }
277

L
Liu Jicong 已提交
278
    if (pResultInfo->current < pResultInfo->numOfRows) {
L
Liu Jicong 已提交
279 280
      doSetOneRowPtr(pResultInfo);
      pResultInfo->current += 1;
L
Liu Jicong 已提交
281 282
      return pResultInfo->row;
    } else {
L
Liu Jicong 已提交
283 284 285 286 287
      pResultInfo = tmqGetNextResInfo(res, true);
      if (pResultInfo == NULL) return NULL;
      doSetOneRowPtr(pResultInfo);
      pResultInfo->current += 1;
      return pResultInfo->row;
L
Liu Jicong 已提交
288
    }
L
Liu Jicong 已提交
289 290
  } else if (TD_RES_TMQ_META(res)) {
    return NULL;
L
Liu Jicong 已提交
291
  } else {
292
    // assert to avoid un-initialization error
293 294
    tscError("invalid result passed to taos_fetch_row");
    return NULL;
L
Liu Jicong 已提交
295
  }
296
}
H
Haojun Liao 已提交
297

L
Liu Jicong 已提交
298
int taos_print_row(char *str, TAOS_ROW row, TAOS_FIELD *fields, int num_fields) {
H
Haojun Liao 已提交
299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356
  int32_t len = 0;
  for (int i = 0; i < num_fields; ++i) {
    if (i > 0) {
      str[len++] = ' ';
    }

    if (row[i] == NULL) {
      len += sprintf(str + len, "%s", TSDB_DATA_NULL_STR);
      continue;
    }

    switch (fields[i].type) {
      case TSDB_DATA_TYPE_TINYINT:
        len += sprintf(str + len, "%d", *((int8_t *)row[i]));
        break;

      case TSDB_DATA_TYPE_UTINYINT:
        len += sprintf(str + len, "%u", *((uint8_t *)row[i]));
        break;

      case TSDB_DATA_TYPE_SMALLINT:
        len += sprintf(str + len, "%d", *((int16_t *)row[i]));
        break;

      case TSDB_DATA_TYPE_USMALLINT:
        len += sprintf(str + len, "%u", *((uint16_t *)row[i]));
        break;

      case TSDB_DATA_TYPE_INT:
        len += sprintf(str + len, "%d", *((int32_t *)row[i]));
        break;

      case TSDB_DATA_TYPE_UINT:
        len += sprintf(str + len, "%u", *((uint32_t *)row[i]));
        break;

      case TSDB_DATA_TYPE_BIGINT:
        len += sprintf(str + len, "%" PRId64, *((int64_t *)row[i]));
        break;

      case TSDB_DATA_TYPE_UBIGINT:
        len += sprintf(str + len, "%" PRIu64, *((uint64_t *)row[i]));
        break;

      case TSDB_DATA_TYPE_FLOAT: {
        float fv = 0;
        fv = GET_FLOAT_VAL(row[i]);
        len += sprintf(str + len, "%f", fv);
      } break;

      case TSDB_DATA_TYPE_DOUBLE: {
        double dv = 0;
        dv = GET_DOUBLE_VAL(row[i]);
        len += sprintf(str + len, "%lf", dv);
      } break;

      case TSDB_DATA_TYPE_BINARY:
      case TSDB_DATA_TYPE_NCHAR: {
L
Liu Jicong 已提交
357
        int32_t charLen = varDataLen((char *)row[i] - VARSTR_HEADER_SIZE);
H
Haojun Liao 已提交
358
        if (fields[i].type == TSDB_DATA_TYPE_BINARY) {
359 360 361
          if(ASSERT(charLen <= fields[i].bytes && charLen >= 0)){
            tscError("taos_print_row error binary. charLen:%d, fields[i].bytes:%d", charLen, fields[i].bytes);
          }
H
Haojun Liao 已提交
362
        } else {
363 364 365
          if(ASSERT(charLen <= fields[i].bytes * TSDB_NCHAR_SIZE && charLen >= 0)){
            tscError("taos_print_row error. charLen:%d, fields[i].bytes:%d", charLen, fields[i].bytes);
          }
H
Haojun Liao 已提交
366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381
        }

        memcpy(str + len, row[i], charLen);
        len += charLen;
      } break;

      case TSDB_DATA_TYPE_TIMESTAMP:
        len += sprintf(str + len, "%" PRId64, *((int64_t *)row[i]));
        break;

      case TSDB_DATA_TYPE_BOOL:
        len += sprintf(str + len, "%d", *((int8_t *)row[i]));
      default:
        break;
    }
  }
L
Liu Jicong 已提交
382
  str[len] = 0;
H
Haojun Liao 已提交
383 384 385

  return len;
}
386

L
Liu Jicong 已提交
387
int *taos_fetch_lengths(TAOS_RES *res) {
L
Liu Jicong 已提交
388
  if (res == NULL || TD_RES_TMQ_META(res)) {
389 390 391
    return NULL;
  }

L
Liu Jicong 已提交
392 393
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
  return pResInfo->length;
394 395
}

396
TAOS_ROW *taos_result_block(TAOS_RES *res) {
L
Liu Jicong 已提交
397
  if (res == NULL || TD_RES_TMQ_META(res)) {
398 399 400 401 402 403 404 405
    terrno = TSDB_CODE_INVALID_PARA;
    return NULL;
  }

  if (taos_is_update_query(res)) {
    return NULL;
  }

L
Liu Jicong 已提交
406 407
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
  return &pResInfo->row;
408 409
}

410
// todo intergrate with tDataTypes
411 412
const char *taos_data_type(int type) {
  switch (type) {
L
Liu Jicong 已提交
413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437
    case TSDB_DATA_TYPE_NULL:
      return "TSDB_DATA_TYPE_NULL";
    case TSDB_DATA_TYPE_BOOL:
      return "TSDB_DATA_TYPE_BOOL";
    case TSDB_DATA_TYPE_TINYINT:
      return "TSDB_DATA_TYPE_TINYINT";
    case TSDB_DATA_TYPE_SMALLINT:
      return "TSDB_DATA_TYPE_SMALLINT";
    case TSDB_DATA_TYPE_INT:
      return "TSDB_DATA_TYPE_INT";
    case TSDB_DATA_TYPE_BIGINT:
      return "TSDB_DATA_TYPE_BIGINT";
    case TSDB_DATA_TYPE_FLOAT:
      return "TSDB_DATA_TYPE_FLOAT";
    case TSDB_DATA_TYPE_DOUBLE:
      return "TSDB_DATA_TYPE_DOUBLE";
    case TSDB_DATA_TYPE_VARCHAR:
      return "TSDB_DATA_TYPE_VARCHAR";
      //    case TSDB_DATA_TYPE_BINARY:          return "TSDB_DATA_TYPE_VARCHAR";
    case TSDB_DATA_TYPE_TIMESTAMP:
      return "TSDB_DATA_TYPE_TIMESTAMP";
    case TSDB_DATA_TYPE_NCHAR:
      return "TSDB_DATA_TYPE_NCHAR";
    case TSDB_DATA_TYPE_JSON:
      return "TSDB_DATA_TYPE_JSON";
438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453
    case TSDB_DATA_TYPE_UTINYINT:
      return "TSDB_DATA_TYPE_UTINYINT";
    case TSDB_DATA_TYPE_USMALLINT:
      return "TSDB_DATA_TYPE_USMALLINT";
    case TSDB_DATA_TYPE_UINT:
      return "TSDB_DATA_TYPE_UINT";
    case TSDB_DATA_TYPE_UBIGINT:
      return "TSDB_DATA_TYPE_UBIGINT";
    case TSDB_DATA_TYPE_VARBINARY:
      return "TSDB_DATA_TYPE_VARBINARY";
    case TSDB_DATA_TYPE_DECIMAL:
      return "TSDB_DATA_TYPE_DECIMAL";
    case TSDB_DATA_TYPE_BLOB:
      return "TSDB_DATA_TYPE_BLOB";
    case TSDB_DATA_TYPE_MEDIUMBLOB:
      return "TSDB_DATA_TYPE_MEDIUMBLOB";
L
Liu Jicong 已提交
454 455
    default:
      return "UNKNOWN";
456 457
  }
}
458 459 460

const char *taos_get_client_info() { return version; }

461
// return int32_t
X
Xiaoyu Wang 已提交
462
int taos_affected_rows(TAOS_RES *res) {
463
  if (res == NULL || TD_RES_TMQ(res) || TD_RES_TMQ_META(res) || TD_RES_TMQ_METADATA(res)) {
H
Haojun Liao 已提交
464 465 466
    return 0;
  }

467 468 469 470 471 472
  SRequestObj    *pRequest = (SRequestObj *)res;
  SReqResultInfo *pResInfo = &pRequest->body.resInfo;
  return (int)pResInfo->numOfRows;
}

// return int64_t
A
Alex Duan 已提交
473
int64_t taos_affected_rows64(TAOS_RES *res) {
474 475 476 477
  if (res == NULL || TD_RES_TMQ(res) || TD_RES_TMQ_META(res) || TD_RES_TMQ_METADATA(res)) {
    return 0;
  }

dengyihao's avatar
dengyihao 已提交
478
  SRequestObj    *pRequest = (SRequestObj *)res;
L
Liu Jicong 已提交
479
  SReqResultInfo *pResInfo = &pRequest->body.resInfo;
H
Haojun Liao 已提交
480
  return pResInfo->numOfRows;
X
Xiaoyu Wang 已提交
481
}
482

483
int taos_result_precision(TAOS_RES *res) {
L
Liu Jicong 已提交
484
  if (res == NULL || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
485 486
    return TSDB_TIME_PRECISION_MILLI;
  }
487

L
Liu Jicong 已提交
488 489 490
  if (TD_RES_QUERY(res)) {
    SRequestObj *pRequest = (SRequestObj *)res;
    return pRequest->body.resInfo.precision;
491
  } else if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
L
Liu Jicong 已提交
492 493 494 495
    SReqResultInfo *info = tmqGetCurResInfo(res);
    return info->precision;
  }
  return TSDB_TIME_PRECISION_MILLI;
496
}
497 498

int taos_select_db(TAOS *taos, const char *db) {
L
Liu Jicong 已提交
499
  STscObj *pObj = acquireTscObj(*(int64_t *)taos);
500
  if (pObj == NULL) {
L
Liu Jicong 已提交
501
    releaseTscObj(*(int64_t *)taos);
502 503 504 505 506
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return TSDB_CODE_TSC_DISCONNECTED;
  }

  if (db == NULL || strlen(db) == 0) {
L
Liu Jicong 已提交
507
    releaseTscObj(*(int64_t *)taos);
508 509 510 511 512 513 514
    terrno = TSDB_CODE_TSC_INVALID_INPUT;
    return terrno;
  }

  char sql[256] = {0};
  snprintf(sql, tListLen(sql), "use %s", db);

L
Liu Jicong 已提交
515 516
  TAOS_RES *pRequest = taos_query(taos, sql);
  int32_t   code = taos_errno(pRequest);
517 518

  taos_free_result(pRequest);
L
Liu Jicong 已提交
519
  releaseTscObj(*(int64_t *)taos);
520 521 522 523
  return code;
}

void taos_stop_query(TAOS_RES *res) {
524
  if (res == NULL || TD_RES_TMQ(res) || TD_RES_TMQ_META(res) || TD_RES_TMQ_METADATA(res)) {
525 526 527
    return;
  }

L
Liu Jicong 已提交
528
  SRequestObj *pRequest = (SRequestObj *)res;
D
dapan1121 已提交
529
  pRequest->killed = true;
L
Liu Jicong 已提交
530

531
  // It is not a query, no need to stop.
532
  if (NULL == pRequest->pQuery || QUERY_EXEC_MODE_SCHEDULE != pRequest->pQuery->execMode) {
D
dapan1121 已提交
533
    tscDebug("request 0x%" PRIx64 " no need to be killed since not query", pRequest->requestId);
534 535 536
    return;
  }

D
dapan1121 已提交
537
  schedulerFreeJob(&pRequest->body.queryJob, TSDB_CODE_TSC_QUERY_KILLED);
D
dapan1121 已提交
538
  tscDebug("request %" PRIx64 " killed", pRequest->requestId);
539 540 541
}

bool taos_is_null(TAOS_RES *res, int32_t row, int32_t col) {
L
Liu Jicong 已提交
542 543 544
  if (res == NULL || TD_RES_TMQ_META(res)) {
    return true;
  }
L
Liu Jicong 已提交
545
  SReqResultInfo *pResultInfo = tscGetCurResInfo(res);
546 547 548 549
  if (col >= pResultInfo->numOfCols || col < 0 || row >= pResultInfo->numOfRows || row < 0) {
    return true;
  }

L
Liu Jicong 已提交
550
  SResultColumn *pCol = &pResultInfo->pCol[col];
551 552 553 554 555
  if (IS_VAR_DATA_TYPE(pResultInfo->fields[col].type)) {
    return (pCol->offset[row] == -1);
  } else {
    return colDataIsNull_f(pCol->nullbitmap, row);
  }
556 557
}

L
Liu Jicong 已提交
558
bool taos_is_update_query(TAOS_RES *res) { return taos_num_fields(res) == 0; }
559

L
Liu Jicong 已提交
560
int taos_fetch_block(TAOS_RES *res, TAOS_ROW *rows) {
H
Haojun Liao 已提交
561
  int32_t numOfRows = 0;
L
Liu Jicong 已提交
562
  /*int32_t code = */ taos_fetch_block_s(res, &numOfRows, rows);
H
Haojun Liao 已提交
563 564 565
  return numOfRows;
}

L
Liu Jicong 已提交
566
int taos_fetch_block_s(TAOS_RES *res, int *numOfRows, TAOS_ROW *rows) {
L
Liu Jicong 已提交
567
  if (res == NULL || TD_RES_TMQ_META(res)) {
568 569
    return 0;
  }
570

L
Liu Jicong 已提交
571 572
  if (TD_RES_QUERY(res)) {
    SRequestObj *pRequest = (SRequestObj *)res;
573

L
Liu Jicong 已提交
574 575
    (*rows) = NULL;
    (*numOfRows) = 0;
H
Haojun Liao 已提交
576

L
Liu Jicong 已提交
577 578 579 580
    if (pRequest->type == TSDB_SQL_RETRIEVE_EMPTY_RESULT || pRequest->type == TSDB_SQL_INSERT ||
        pRequest->code != TSDB_CODE_SUCCESS || taos_num_fields(res) == 0) {
      return 0;
    }
581

582
    doAsyncFetchRows(pRequest, false, true);
583

L
Liu Jicong 已提交
584 585 586
    // TODO refactor
    SReqResultInfo *pResultInfo = &pRequest->body.resInfo;
    pResultInfo->current = pResultInfo->numOfRows;
587

L
Liu Jicong 已提交
588 589 590
    (*rows) = pResultInfo->row;
    (*numOfRows) = pResultInfo->numOfRows;
    return pRequest->code;
591
  } else if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
L
Liu Jicong 已提交
592
    SReqResultInfo *pResultInfo = tmqGetNextResInfo(res, true);
L
Liu Jicong 已提交
593
    if (pResultInfo == NULL) return -1;
H
Haojun Liao 已提交
594

L
Liu Jicong 已提交
595 596 597
    pResultInfo->current = pResultInfo->numOfRows;
    (*rows) = pResultInfo->row;
    (*numOfRows) = pResultInfo->numOfRows;
H
Haojun Liao 已提交
598
    return 0;
L
Liu Jicong 已提交
599
  } else {
600
    tscError("taos_fetch_block_s invalid res type");
L
Liu Jicong 已提交
601
    return -1;
H
Haojun Liao 已提交
602
  }
L
Liu Jicong 已提交
603
}
H
Haojun Liao 已提交
604

L
Liu Jicong 已提交
605
int taos_fetch_raw_block(TAOS_RES *res, int *numOfRows, void **pData) {
L
Liu Jicong 已提交
606
  if (res == NULL || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
607 608
    return 0;
  }
609

610
  if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
L
Liu Jicong 已提交
611
    SReqResultInfo *pResultInfo = tmqGetNextResInfo(res, false);
L
Liu Jicong 已提交
612 613 614 615
    if (pResultInfo == NULL) {
      (*numOfRows) = 0;
      return 0;
    }
H
Haojun Liao 已提交
616

L
Liu Jicong 已提交
617 618 619 620
    pResultInfo->current = pResultInfo->numOfRows;
    (*numOfRows) = pResultInfo->numOfRows;
    (*pData) = (void *)pResultInfo->pData;
    return 0;
621
  }
L
Liu Jicong 已提交
622

623 624 625 626 627
  SRequestObj *pRequest = (SRequestObj *)res;

  if (pRequest->type == TSDB_SQL_RETRIEVE_EMPTY_RESULT || pRequest->type == TSDB_SQL_INSERT ||
      pRequest->code != TSDB_CODE_SUCCESS || taos_num_fields(res) == 0) {
    return 0;
L
Liu Jicong 已提交
628
  }
629

630
  doAsyncFetchRows(pRequest, false, false);
631 632 633 634 635 636 637 638

  SReqResultInfo *pResultInfo = &pRequest->body.resInfo;

  pResultInfo->current = pResultInfo->numOfRows;
  (*numOfRows) = pResultInfo->numOfRows;
  (*pData) = (void *)pResultInfo->pData;

  return 0;
639 640
}

H
Haojun Liao 已提交
641
int *taos_get_column_data_offset(TAOS_RES *res, int columnIndex) {
L
Liu Jicong 已提交
642
  if (res == NULL || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
643 644 645
    return 0;
  }

L
Liu Jicong 已提交
646
  int32_t numOfFields = taos_num_fields(res);
H
Haojun Liao 已提交
647 648 649 650
  if (columnIndex < 0 || columnIndex >= numOfFields || numOfFields == 0) {
    return 0;
  }

L
Liu Jicong 已提交
651
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
dengyihao's avatar
dengyihao 已提交
652
  TAOS_FIELD     *pField = &pResInfo->userFields[columnIndex];
H
Haojun Liao 已提交
653 654 655 656
  if (!IS_VAR_DATA_TYPE(pField->type)) {
    return 0;
  }

L
Liu Jicong 已提交
657
  return pResInfo->pCol[columnIndex].offset;
H
Haojun Liao 已提交
658 659
}

660 661
int taos_validate_sql(TAOS *taos, const char *sql) {
  TAOS_RES *pObj = taosQueryImpl(taos, sql, true);
D
dapan1121 已提交
662 663

  int code = taos_errno(pObj);
664

D
dapan1121 已提交
665 666 667
  taos_free_result(pObj);
  return code;
}
668

669
void taos_reset_current_db(TAOS *taos) {
L
Liu Jicong 已提交
670
  STscObj *pTscObj = acquireTscObj(*(int64_t *)taos);
671 672
  if (pTscObj == NULL) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
H
Haojun Liao 已提交
673 674 675
    return;
  }

676 677
  resetConnectDB(pTscObj);

L
Liu Jicong 已提交
678
  releaseTscObj(*(int64_t *)taos);
679 680
}

681
const char *taos_get_server_info(TAOS *taos) {
L
Liu Jicong 已提交
682
  STscObj *pTscObj = acquireTscObj(*(int64_t *)taos);
683 684
  if (pTscObj == NULL) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
685 686 687
    return NULL;
  }

L
Liu Jicong 已提交
688
  releaseTscObj(*(int64_t *)taos);
689

D
dapan1121 已提交
690
  return pTscObj->sDetailVer;
691 692
}

693
int taos_get_current_db(TAOS *taos, char *database, int len, int *required) {
694 695 696
  STscObj *pTscObj = acquireTscObj(*(int64_t *)taos);
  if (pTscObj == NULL) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
697 698 699 700 701 702 703 704
    return -1;
  }

  int code = TSDB_CODE_SUCCESS;
  taosThreadMutexLock(&pTscObj->mutex);
  if(database == NULL || len <= 0){
    if(required != NULL) *required = strlen(pTscObj->db) + 1;
    terrno = TSDB_CODE_INVALID_PARA;
wmmhello's avatar
wmmhello 已提交
705 706
    code = -1;
  }else if(len < strlen(pTscObj->db) + 1){
707 708 709 710 711 712 713 714 715 716
    tstrncpy(database, pTscObj->db, len);
    if(required) *required = strlen(pTscObj->db) + 1;
    terrno = TSDB_CODE_INVALID_PARA;
    code = -1;
  }else{
    strcpy(database, pTscObj->db);
    code = 0;
  }
  taosThreadMutexUnlock(&pTscObj->mutex);
  return code;
717 718
}

719 720 721 722 723
static void destoryTablesReq(void *p) {
  STablesReq *pRes = (STablesReq *)p;
  taosArrayDestroy(pRes->pTables);
}

724 725 726 727 728 729 730 731 732 733 734 735 736
static void destoryCatalogReq(SCatalogReq *pCatalogReq) {
  if (NULL == pCatalogReq) {
    return;
  }
  taosArrayDestroy(pCatalogReq->pDbVgroup);
  taosArrayDestroy(pCatalogReq->pDbCfg);
  taosArrayDestroy(pCatalogReq->pDbInfo);
  taosArrayDestroyEx(pCatalogReq->pTableMeta, destoryTablesReq);
  taosArrayDestroyEx(pCatalogReq->pTableHash, destoryTablesReq);
  taosArrayDestroy(pCatalogReq->pUdf);
  taosArrayDestroy(pCatalogReq->pIndex);
  taosArrayDestroy(pCatalogReq->pUser);
  taosArrayDestroy(pCatalogReq->pTableIndex);
X
Xiaoyu Wang 已提交
737
  taosArrayDestroy(pCatalogReq->pTableCfg);
738 739 740 741 742 743 744 745 746
  taosMemoryFree(pCatalogReq);
}

void destorySqlCallbackWrapper(SSqlCallbackWrapper *pWrapper) {
  if (NULL == pWrapper) {
    return;
  }
  destoryCatalogReq(pWrapper->pCatalogReq);
  qDestroyParseContext(pWrapper->pParseCtx);
747 748 749
  taosMemoryFree(pWrapper);
}

X
Xiaoyu Wang 已提交
750
static void doAsyncQueryFromAnalyse(SMetaData *pResultMeta, void *param, int32_t code) {
751 752 753
  SSqlCallbackWrapper *pWrapper = (SSqlCallbackWrapper *)param;
  SRequestObj         *pRequest = pWrapper->pRequest;
  SQuery              *pQuery = pRequest->pQuery;
754

755 756
  int64_t analyseStart = taosGetTimestampUs();
  pRequest->metric.ctgCostUs = analyseStart - pRequest->metric.ctgStart;
757
  qDebug("0x%" PRIx64 " start to semantic analysis, reqId:0x%" PRIx64, pRequest->self, pRequest->requestId);
D
dapan1121 已提交
758

759
  if (code == TSDB_CODE_SUCCESS) {
760
    code = qAnalyseSqlSemantic(pWrapper->pParseCtx, pWrapper->pCatalogReq, pResultMeta, pQuery);
761
    pRequest->stableQuery = pQuery->stableQuery;
D
dapan1121 已提交
762
    if (pQuery->pRoot) {
dengyihao's avatar
dengyihao 已提交
763
      pRequest->stmtType = pQuery->pRoot->type;
D
dapan1121 已提交
764
    }
765 766
  }

767
  pRequest->metric.analyseCostUs = taosGetTimestampUs() - analyseStart;
D
dapan1121 已提交
768

769 770 771 772 773
  if (code == TSDB_CODE_SUCCESS) {
    if (pQuery->haveResultSet) {
      setResSchemaInfo(&pRequest->body.resInfo, pQuery->pResSchema, pQuery->numOfResCols);
      setResPrecision(&pRequest->body.resInfo, pQuery->precision);
    }
774

775 776
    TSWAP(pRequest->dbList, (pQuery)->pDbList);
    TSWAP(pRequest->tableList, (pQuery)->pTableList);
D
dapan1121 已提交
777
    TSWAP(pRequest->targetTableList, (pQuery)->pTargetTableList);
778

779
    launchAsyncQuery(pRequest, pQuery, pResultMeta, pWrapper);
780
  } else {
781
    destorySqlCallbackWrapper(pWrapper);
X
Xiaoyu Wang 已提交
782 783
    qDestroyQuery(pRequest->pQuery);
    pRequest->pQuery = NULL;
784

785
    if (NEED_CLIENT_HANDLE_ERROR(code)) {
786 787
      tscDebug("0x%" PRIx64 " client retry to handle the error, code:%d - %s, tryCount:%d, reqId:0x%" PRIx64,
               pRequest->self, code, tstrerror(code), pRequest->retry, pRequest->requestId);
788 789 790 791
      pRequest->prevCode = code;
      doAsyncQuery(pRequest, true);
      return;
    }
792

793
    // return to app directly
794 795
    tscError("0x%" PRIx64 " error occurs, code:%s, return to user app, reqId:0x%" PRIx64, pRequest->self,
             tstrerror(code), pRequest->requestId);
796 797 798
    pRequest->code = code;
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
  }
799 800
}

X
Xiaoyu Wang 已提交
801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842
static int32_t getAllMetaAsync(SSqlCallbackWrapper *pWrapper, catalogCallback fp) {
  SRequestConnInfo conn = {.pTrans = pWrapper->pParseCtx->pTransporter,
                           .requestId = pWrapper->pParseCtx->requestId,
                           .requestObjRefId = pWrapper->pParseCtx->requestRid,
                           .mgmtEps = pWrapper->pParseCtx->mgmtEpSet};

  pWrapper->pRequest->metric.ctgStart = taosGetTimestampUs();

  return catalogAsyncGetAllMeta(pWrapper->pParseCtx->pCatalog, &conn, pWrapper->pCatalogReq, fp, pWrapper,
                                &pWrapper->pRequest->body.queryJob);
}

static void doAsyncQueryFromParse(SMetaData *pResultMeta, void *param, int32_t code);

static int32_t phaseAsyncQuery(SSqlCallbackWrapper *pWrapper) {
  int32_t code = TSDB_CODE_SUCCESS;
  switch (pWrapper->pRequest->pQuery->execStage) {
    case QUERY_EXEC_STAGE_PARSE: {
      // continue parse after get metadata
      code = getAllMetaAsync(pWrapper, doAsyncQueryFromParse);
      break;
    }
    case QUERY_EXEC_STAGE_ANALYSE: {
      // analysis after get metadata
      code = getAllMetaAsync(pWrapper, doAsyncQueryFromAnalyse);
      break;
    }
    case QUERY_EXEC_STAGE_SCHEDULE: {
      launchAsyncQuery(pWrapper->pRequest, pWrapper->pRequest->pQuery, NULL, pWrapper);
      break;
    }
    default:
      break;
  }
  return code;
}

static void doAsyncQueryFromParse(SMetaData *pResultMeta, void *param, int32_t code) {
  SSqlCallbackWrapper *pWrapper = (SSqlCallbackWrapper *)param;
  SRequestObj         *pRequest = pWrapper->pRequest;
  SQuery              *pQuery = pRequest->pQuery;

843
  pRequest->metric.ctgCostUs += taosGetTimestampUs() - pRequest->metric.ctgStart;
L
Liu Jicong 已提交
844 845
  qDebug("0x%" PRIx64 " start to continue parse, reqId:0x%" PRIx64 ", code:%s", pRequest->self, pRequest->requestId,
         tstrerror(code));
X
Xiaoyu Wang 已提交
846 847

  if (code == TSDB_CODE_SUCCESS) {
848
    // pWrapper->pCatalogReq->forceUpdate = false;
X
Xiaoyu Wang 已提交
849 850 851 852 853 854 855 856 857 858 859 860
    code = qContinueParseSql(pWrapper->pParseCtx, pWrapper->pCatalogReq, pResultMeta, pQuery);
  }

  if (TSDB_CODE_SUCCESS == code) {
    code = phaseAsyncQuery(pWrapper);
  }

  if (TSDB_CODE_SUCCESS != code) {
    tscError("0x%" PRIx64 " error happens, code:%d - %s, reqId:0x%" PRIx64, pWrapper->pRequest->self, code,
             tstrerror(code), pWrapper->pRequest->requestId);
    destorySqlCallbackWrapper(pWrapper);
    terrno = code;
X
Xiaoyu Wang 已提交
861 862
    pRequest->code = code;
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
X
Xiaoyu Wang 已提交
863 864 865 866 867 868 869 870 871 872 873 874 875 876
  }
}

void continueInsertFromCsv(SSqlCallbackWrapper *pWrapper, SRequestObj *pRequest) {
  int32_t code = qParseSqlSyntax(pWrapper->pParseCtx, &pRequest->pQuery, pWrapper->pCatalogReq);
  if (TSDB_CODE_SUCCESS == code) {
    code = phaseAsyncQuery(pWrapper);
  }

  if (TSDB_CODE_SUCCESS != code) {
    tscError("0x%" PRIx64 " error happens, code:%d - %s, reqId:0x%" PRIx64, pWrapper->pRequest->self, code,
             tstrerror(code), pWrapper->pRequest->requestId);
    destorySqlCallbackWrapper(pWrapper);
    terrno = code;
877 878
    pRequest->code = code;
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
879 880 881
  }
}

882
void taos_query_a(TAOS *taos, const char *sql, __taos_async_fn_t fp, void *param) {
dengyihao's avatar
dengyihao 已提交
883
  int64_t connId = *(int64_t *)taos;
D
dapan1121 已提交
884
  tscDebug("taos_query_a start with sql:%s", sql);
885
  taosAsyncQueryImpl(connId, sql, fp, param, false);
D
dapan1121 已提交
886
  tscDebug("taos_query_a end with sql:%s", sql);
887
}
888

dengyihao's avatar
dengyihao 已提交
889 890 891 892 893
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);
}

894
int32_t createParseContext(const SRequestObj *pRequest, SParseContext **pCxt) {
895 896 897 898 899 900 901
  const STscObj *pTscObj = pRequest->pTscObj;

  *pCxt = taosMemoryCalloc(1, sizeof(SParseContext));
  if (*pCxt == NULL) {
    return TSDB_CODE_OUT_OF_MEMORY;
  }

dengyihao's avatar
dengyihao 已提交
902 903 904 905 906 907 908 909 910 911 912 913 914
  **pCxt = (SParseContext){.requestId = pRequest->requestId,
                           .requestRid = pRequest->self,
                           .acctId = pTscObj->acctId,
                           .db = pRequest->pDb,
                           .topicQuery = false,
                           .pSql = pRequest->sqlstr,
                           .sqlLen = pRequest->sqlLen,
                           .pMsg = pRequest->msgBuf,
                           .msgLen = ERROR_MSG_BUF_DEFAULT_SIZE,
                           .pTransporter = pTscObj->pAppInfo->pTransporter,
                           .pStmtCb = NULL,
                           .pUser = pTscObj->user,
                           .isSuperUser = (0 == strcmp(pTscObj->user, TSDB_DEFAULT_USER)),
915
                           .enableSysInfo = pTscObj->sysInfo,
dengyihao's avatar
dengyihao 已提交
916 917
                           .async = true,
                           .svrVer = pTscObj->sVer,
918 919
                           .nodeOffline = (pTscObj->pAppInfo->onlineDnodes < pTscObj->pAppInfo->totalDnodes),
                           .allocatorId = pRequest->allocatorRefId};
920 921 922
  return TSDB_CODE_SUCCESS;
}

923
void doAsyncQuery(SRequestObj *pRequest, bool updateMetaForce) {
924 925 926
  STscObj             *pTscObj = pRequest->pTscObj;
  SSqlCallbackWrapper *pWrapper = NULL;
  int32_t              code = TSDB_CODE_SUCCESS;
927 928

  if (pRequest->retry++ > REQUEST_TOTAL_EXEC_TIMES) {
929
    code = pRequest->prevCode;
D
dapan1121 已提交
930
    terrno = code;
D
dapan1121 已提交
931 932
    pRequest->code = code;
    tscDebug("call sync query cb with code: %s", tstrerror(code));
D
dapan1121 已提交
933 934
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
    return;
935 936
  }

937 938 939 940 941 942 943
  if (TSDB_CODE_SUCCESS == code) {
    pWrapper = taosMemoryCalloc(1, sizeof(SSqlCallbackWrapper));
    if (pWrapper == NULL) {
      code = TSDB_CODE_OUT_OF_MEMORY;
    } else {
      pWrapper->pRequest = pRequest;
    }
944
  }
945

946 947
  if (TSDB_CODE_SUCCESS == code) {
    code = createParseContext(pRequest, &pWrapper->pParseCtx);
948 949
  }

950 951 952
  if (TSDB_CODE_SUCCESS == code) {
    pWrapper->pParseCtx->mgmtEpSet = getEpSet_s(&pTscObj->pAppInfo->mgmtEp);
    code = catalogGetHandle(pTscObj->pAppInfo->clusterId, &pWrapper->pParseCtx->pCatalog);
953 954
  }

955
  if (TSDB_CODE_SUCCESS == code) {
956
    int64_t syntaxStart = taosGetTimestampUs();
957 958 959 960 961 962 963 964 965 966

    pWrapper->pCatalogReq = taosMemoryCalloc(1, sizeof(SCatalogReq));
    if (pWrapper->pCatalogReq == NULL) {
      code = TSDB_CODE_OUT_OF_MEMORY;
    } else {
      pWrapper->pCatalogReq->forceUpdate = updateMetaForce;
      pWrapper->pCatalogReq->qNodeRequired = qnodeRequired(pRequest);
      code = qParseSqlSyntax(pWrapper->pParseCtx, &pRequest->pQuery, pWrapper->pCatalogReq);
    }

967
    pRequest->metric.parseCostUs += taosGetTimestampUs() - syntaxStart;
D
dapan1121 已提交
968 969
  }

970
  if (TSDB_CODE_SUCCESS == code) {
971
    pRequest->stmtType = pRequest->pQuery->pRoot->type;
X
Xiaoyu Wang 已提交
972 973
    phaseAsyncQuery(pWrapper);
  } else {
974 975 976
    tscError("0x%" PRIx64 " error happens, code:%d - %s, reqId:0x%" PRIx64, pRequest->self, code, tstrerror(code),
             pRequest->requestId);
    destorySqlCallbackWrapper(pWrapper);
D
dapan1121 已提交
977 978
    qDestroyQuery(pRequest->pQuery);
    pRequest->pQuery = NULL;
979 980 981 982 983 984 985 986 987

    if (NEED_CLIENT_HANDLE_ERROR(code)) {
      tscDebug("0x%" PRIx64 " client retry to handle the error, code:%d - %s, tryCount:%d, reqId:0x%" PRIx64,
               pRequest->self, code, tstrerror(code), pRequest->retry, pRequest->requestId);
      pRequest->prevCode = code;
      doAsyncQuery(pRequest, true);
      return;
    }

988 989 990 991
    terrno = code;
    pRequest->code = code;
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
  }
992 993
}

994 995
static void fetchCallback(void *pResult, void *param, int32_t code) {
  SRequestObj *pRequest = (SRequestObj *)param;
996

997
  SReqResultInfo *pResultInfo = &pRequest->body.resInfo;
998

L
Liu Jicong 已提交
999 1000
  tscDebug("0x%" PRIx64 " enter scheduler fetch cb, code:%d - %s, reqId:0x%" PRIx64, pRequest->self, code,
           tstrerror(code), pRequest->requestId);
D
dapan1121 已提交
1001

1002 1003 1004 1005 1006
  pResultInfo->pData = pResult;
  pResultInfo->numOfRows = 0;

  if (code != TSDB_CODE_SUCCESS) {
    pRequest->code = code;
1007
    taosMemoryFreeClear(pResultInfo->pData);
1008 1009 1010 1011 1012
    pRequest->body.fetchFp(pRequest->body.param, pRequest, 0);
    return;
  }

  if (pRequest->code != TSDB_CODE_SUCCESS) {
1013
    taosMemoryFreeClear(pResultInfo->pData);
1014
    pRequest->body.fetchFp(pRequest->body.param, pRequest, 0);
1015
    return;
1016 1017
  }

1018
  pRequest->code =
D
dapan1121 已提交
1019
      setQueryResultFromRsp(pResultInfo, (SRetrieveTableRsp *)pResultInfo->pData, pResultInfo->convertUcs4, true);
1020 1021 1022
  if (pRequest->code != TSDB_CODE_SUCCESS) {
    pResultInfo->numOfRows = 0;
    pRequest->code = code;
1023 1024 1025
    tscError("0x%" PRIx64 " fetch results failed, code:%s, reqId:0x%" PRIx64, pRequest->self, tstrerror(code),
             pRequest->requestId);
  } else {
A
Alex Duan 已提交
1026
    tscDebug("0x%" PRIx64 " fetch results, numOfRows:%" PRId64 " total Rows:%" PRId64 ", complete:%d, reqId:0x%" PRIx64,
1027 1028
             pRequest->self, pResultInfo->numOfRows, pResultInfo->totalRows, pResultInfo->completed,
             pRequest->requestId);
D
dapan1121 已提交
1029 1030 1031

    STscObj            *pTscObj = pRequest->pTscObj;
    SAppClusterSummary *pActivity = &pTscObj->pAppInfo->summary;
dengyihao's avatar
dengyihao 已提交
1032
    atomic_add_fetch_64((int64_t *)&pActivity->fetchBytes, pRequest->body.resInfo.payloadLen);
1033 1034 1035 1036 1037
  }

  pRequest->body.fetchFp(pRequest->body.param, pRequest, pResultInfo->numOfRows);
}

1038
void taos_fetch_rows_a(TAOS_RES *res, __taos_async_fn_t fp, void *param) {
1039 1040 1041 1042 1043 1044 1045 1046
  if(ASSERT(res != NULL && fp != NULL)){
    tscError("taos_fetch_rows_a invalid paras");
    return;
  }
  if(ASSERT(TD_RES_QUERY(res))){
    tscError("taos_fetch_rows_a res is NULL");
    return;
  }
1047 1048 1049

  SRequestObj *pRequest = res;
  pRequest->body.fetchFp = fp;
1050
  pRequest->body.param = param;
1051 1052

  SReqResultInfo *pResultInfo = &pRequest->body.resInfo;
1053 1054 1055

  // this query has no results or error exists, return directly
  if (taos_num_fields(pRequest) == 0 || pRequest->code != TSDB_CODE_SUCCESS) {
1056 1057 1058 1059 1060
    pResultInfo->numOfRows = 0;
    pRequest->body.fetchFp(param, pRequest, pResultInfo->numOfRows);
    return;
  }

1061
  // all data has returned to App already, no need to try again
D
dapan1121 已提交
1062 1063
  if (pResultInfo->completed) {
    // it is a local executed query, no need to do async fetch
X
Xiaoyu Wang 已提交
1064
    if (QUERY_EXEC_MODE_SCHEDULE != pRequest->body.execMode) {
D
dapan1121 已提交
1065 1066 1067 1068 1069 1070
      if (pResultInfo->localResultFetched) {
        pResultInfo->numOfRows = 0;
        pResultInfo->current = 0;
      } else {
        pResultInfo->localResultFetched = true;
      }
1071
    } else {
D
dapan1121 已提交
1072
      pResultInfo->numOfRows = 0;
1073
    }
1074

D
dapan1121 已提交
1075
    pRequest->body.fetchFp(param, pRequest, pResultInfo->numOfRows);
1076
    return;
1077 1078
  }

D
dapan1121 已提交
1079
  SSchedulerReq req = {
dengyihao's avatar
dengyihao 已提交
1080 1081 1082
      .syncReq = false,
      .fetchFp = fetchCallback,
      .cbParam = pRequest,
D
dapan1121 已提交
1083
  };
1084

D
dapan1121 已提交
1085
  schedulerFetchRows(pRequest->body.queryJob, &req);
L
Liu Jicong 已提交
1086
}
1087

1088
void taos_fetch_raw_block_a(TAOS_RES *res, __taos_async_fn_t fp, void *param) {
1089 1090 1091 1092 1093 1094 1095 1096
  if(ASSERT(res != NULL && fp != NULL)){
    tscError("taos_fetch_rows_a invalid paras");
    return;
  }
  if(ASSERT(TD_RES_QUERY(res))){
    tscError("taos_fetch_rows_a res is NULL");
    return;
  }
dengyihao's avatar
dengyihao 已提交
1097
  SRequestObj    *pRequest = res;
1098 1099 1100
  SReqResultInfo *pResultInfo = &pRequest->body.resInfo;

  // set the current block is all consumed
1101 1102
  pResultInfo->convertUcs4 = false;

1103 1104
  // it is a local executed query, no need to do async fetch
  taos_fetch_rows_a(pRequest, fp, param);
1105 1106
}

1107
const void *taos_get_raw_block(TAOS_RES *res) {
1108 1109 1110 1111 1112 1113 1114 1115
  if(ASSERT(res != NULL)){
    tscError("taos_fetch_rows_a invalid paras");
    return NULL;
  }
  if(ASSERT(TD_RES_QUERY(res))){
    tscError("taos_fetch_rows_a res is NULL");
    return NULL;
  }
1116
  SRequestObj *pRequest = res;
H
Haojun Liao 已提交
1117 1118 1119 1120

  return pRequest->body.resInfo.pData;
}

X
Xiaoyu Wang 已提交
1121
int taos_get_db_route_info(TAOS *taos, const char *db, TAOS_DB_ROUTE_INFO *dbInfo) {
1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132
  if (NULL == taos) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return terrno;
  }

  if (NULL == db || NULL == dbInfo) {
    tscError("invalid input param, db:%p, dbInfo:%p", db, dbInfo);
    terrno = TSDB_CODE_TSC_INVALID_INPUT;
    return terrno;
  }

X
Xiaoyu Wang 已提交
1133 1134 1135
  int64_t      connId = *(int64_t *)taos;
  SRequestObj *pRequest = NULL;
  char        *sql = "taos_get_db_route_info";
dengyihao's avatar
dengyihao 已提交
1136
  int32_t      code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest, 0);
1137
  if (code != TSDB_CODE_SUCCESS) {
1138
    terrno = code;
1139 1140 1141
    return terrno;
  }

X
Xiaoyu Wang 已提交
1142
  STscObj  *pTscObj = pRequest->pTscObj;
1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155
  SCatalog *pCtg = NULL;
  code = catalogGetHandle(pTscObj->pAppInfo->clusterId, &pCtg);
  if (code != TSDB_CODE_SUCCESS) {
    goto _return;
  }

  SRequestConnInfo conn = {
      .pTrans = pTscObj->pAppInfo->pTransporter, .requestId = pRequest->requestId, .requestObjRefId = pRequest->self};

  conn.mgmtEps = getEpSet_s(&pTscObj->pAppInfo->mgmtEp);

  char dbFName[TSDB_DB_FNAME_LEN] = {0};
  snprintf(dbFName, sizeof(dbFName), "%d.%s", pTscObj->acctId, db);
X
Xiaoyu Wang 已提交
1156

1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169
  code = catalogGetDBVgInfo(pCtg, &conn, dbFName, dbInfo);
  if (code) {
    goto _return;
  }

_return:

  terrno = code;

  destroyRequest(pRequest);
  return code;
}

X
Xiaoyu Wang 已提交
1170
int taos_get_table_vgId(TAOS *taos, const char *db, const char *table, int *vgId) {
1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181
  if (NULL == taos) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return terrno;
  }

  if (NULL == db || NULL == table || NULL == vgId) {
    tscError("invalid input param, db:%p, table:%p, vgId:%p", db, table, vgId);
    terrno = TSDB_CODE_TSC_INVALID_INPUT;
    return terrno;
  }

X
Xiaoyu Wang 已提交
1182 1183 1184
  int64_t      connId = *(int64_t *)taos;
  SRequestObj *pRequest = NULL;
  char        *sql = "taos_get_table_vgId";
dengyihao's avatar
dengyihao 已提交
1185
  int32_t      code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest, 0);
1186 1187 1188 1189
  if (code != TSDB_CODE_SUCCESS) {
    return terrno;
  }

1190 1191
  pRequest->syncQuery = true;

X
Xiaoyu Wang 已提交
1192
  STscObj  *pTscObj = pRequest->pTscObj;
1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217
  SCatalog *pCtg = NULL;
  code = catalogGetHandle(pTscObj->pAppInfo->clusterId, &pCtg);
  if (code != TSDB_CODE_SUCCESS) {
    goto _return;
  }

  SRequestConnInfo conn = {
      .pTrans = pTscObj->pAppInfo->pTransporter, .requestId = pRequest->requestId, .requestObjRefId = pRequest->self};

  conn.mgmtEps = getEpSet_s(&pTscObj->pAppInfo->mgmtEp);

  SName tableName;
  toName(pTscObj->acctId, db, table, &tableName);

  SVgroupInfo vgInfo;
  code = catalogGetTableHashVgroup(pCtg, &conn, &tableName, &vgInfo);
  if (code) {
    goto _return;
  }

  *vgId = vgInfo.vgId;

_return:

  terrno = code;
1218

1219 1220
  destroyRequest(pRequest);
  return code;
1221 1222
}

D
dapan1121 已提交
1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270
int taos_get_tables_vgId(TAOS *taos, const char *db, const char *table[], int tableNum, int *vgId) {
  if (NULL == taos) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return terrno;
  }

  if (NULL == db || NULL == table || NULL == vgId || tableNum <= 0) {
    tscError("invalid input param, db:%p, table:%p, vgId:%p, tbNum:%d", db, table, vgId, tableNum);
    terrno = TSDB_CODE_TSC_INVALID_INPUT;
    return terrno;
  }

  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, 0);
  if (code != TSDB_CODE_SUCCESS) {
    return terrno;
  }

  pRequest->syncQuery = true;

  STscObj  *pTscObj = pRequest->pTscObj;
  SCatalog *pCtg = NULL;
  code = catalogGetHandle(pTscObj->pAppInfo->clusterId, &pCtg);
  if (code != TSDB_CODE_SUCCESS) {
    goto _return;
  }

  SRequestConnInfo conn = {
      .pTrans = pTscObj->pAppInfo->pTransporter, .requestId = pRequest->requestId, .requestObjRefId = pRequest->self};

  conn.mgmtEps = getEpSet_s(&pTscObj->pAppInfo->mgmtEp);

  code = catalogGetTablesHashVgId(pCtg, &conn, pTscObj->acctId, db, table, tableNum, vgId);
  if (code) {
    goto _return;
  }

_return:

  terrno = code;

  destroyRequest(pRequest);
  return code;
}


1271
int taos_load_table_info(TAOS *taos, const char *tableNameList) {
D
dapan1121 已提交
1272 1273 1274 1275 1276
  if (NULL == taos) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return terrno;
  }

1277
  int64_t       connId = *(int64_t *)taos;
D
dapan1121 已提交
1278
  const int32_t MAX_TABLE_NAME_LENGTH = 12 * 1024 * 1024;  // 12MB list
1279
  int32_t       code = 0;
dengyihao's avatar
dengyihao 已提交
1280
  SRequestObj  *pRequest = NULL;
1281 1282
  SCatalogReq   catalogReq = {0};

D
dapan1121 已提交
1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294
  if (NULL == tableNameList) {
    return TSDB_CODE_SUCCESS;
  }

  int32_t length = (int32_t)strlen(tableNameList);
  if (0 == length) {
    return TSDB_CODE_SUCCESS;
  } else if (length > MAX_TABLE_NAME_LENGTH) {
    tscError("tableNameList too long, length:%d, maximum allowed:%d", length, MAX_TABLE_NAME_LENGTH);
    return TSDB_CODE_TSC_INVALID_OPERATION;
  }

1295
  char *sql = "taos_load_table_info";
dengyihao's avatar
dengyihao 已提交
1296
  code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest, 0);
1297 1298 1299
  if (code != TSDB_CODE_SUCCESS) {
    terrno = code;
    goto _return;
D
dapan1121 已提交
1300 1301
  }

dengyihao's avatar
dengyihao 已提交
1302
  STscObj *pTscObj = pRequest->pTscObj;
D
dapan1121 已提交
1303 1304 1305 1306 1307
  code = transferTableNameList(tableNameList, pTscObj->acctId, pTscObj->db, &catalogReq.pTableMeta);
  if (code) {
    goto _return;
  }

1308
  SCatalog *pCtg = NULL;
D
dapan1121 已提交
1309 1310 1311 1312 1313
  code = catalogGetHandle(pTscObj->pAppInfo->clusterId, &pCtg);
  if (code != TSDB_CODE_SUCCESS) {
    goto _return;
  }

1314 1315
  SRequestConnInfo conn = {
      .pTrans = pTscObj->pAppInfo->pTransporter, .requestId = pRequest->requestId, .requestObjRefId = pRequest->self};
D
dapan1121 已提交
1316 1317 1318

  conn.mgmtEps = getEpSet_s(&pTscObj->pAppInfo->mgmtEp);

D
dapan1121 已提交
1319
  code = catalogAsyncGetAllMeta(pCtg, &conn, &catalogReq, syncCatalogFn, pRequest->body.param, NULL);
D
dapan1121 已提交
1320 1321 1322 1323
  if (code) {
    goto _return;
  }

dengyihao's avatar
dengyihao 已提交
1324
  SSyncQueryParam *pParam = pRequest->body.param;
1325
  tsem_wait(&pParam->sem);
D
dapan1121 已提交
1326 1327 1328 1329 1330

_return:
  taosArrayDestroy(catalogReq.pTableMeta);
  destroyRequest(pRequest);
  return code;
1331 1332
}

L
Liu Jicong 已提交
1333
TAOS_STMT *taos_stmt_init(TAOS *taos) {
L
Liu Jicong 已提交
1334
  STscObj *pObj = acquireTscObj(*(int64_t *)taos);
1335 1336 1337
  if (NULL == pObj) {
    tscError("invalid parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_TSC_DISCONNECTED;
D
stmt  
dapan1121 已提交
1338 1339 1340
    return NULL;
  }

dengyihao's avatar
dengyihao 已提交
1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356
  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);
L
Liu Jicong 已提交
1357 1358

  releaseTscObj(*(int64_t *)taos);
1359 1360

  return pStmt;
1361 1362
}

D
stmt  
dapan1121 已提交
1363 1364
int taos_stmt_prepare(TAOS_STMT *stmt, const char *sql, unsigned long length) {
  if (stmt == NULL || sql == NULL) {
D
stmt  
dapan1121 已提交
1365
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1366 1367 1368 1369
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1370
  return stmtPrepare(stmt, sql, length);
1371 1372
}

D
dapan1121 已提交
1373
int taos_stmt_set_tbname_tags(TAOS_STMT *stmt, const char *name, TAOS_MULTI_BIND *tags) {
D
stmt  
dapan1121 已提交
1374
  if (stmt == NULL || name == NULL) {
D
stmt  
dapan1121 已提交
1375
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1376 1377 1378 1379
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1380 1381 1382 1383 1384 1385 1386 1387 1388 1389
  int32_t code = stmtSetTbName(stmt, name);
  if (code) {
    return code;
  }

  if (tags) {
    return stmtSetTbTags(stmt, tags);
  }

  return TSDB_CODE_SUCCESS;
1390 1391
}

D
stmt  
dapan1121 已提交
1392 1393
int taos_stmt_set_tbname(TAOS_STMT *stmt, const char *name) {
  if (stmt == NULL || name == NULL) {
D
stmt  
dapan1121 已提交
1394
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1395
    terrno = TSDB_CODE_INVALID_PARA;
D
stmt  
dapan1121 已提交
1396
    return terrno;
D
stmt  
dapan1121 已提交
1397 1398
  }

D
stmt  
dapan1121 已提交
1399
  return stmtSetTbName(stmt, name);
1400 1401
}

D
dapan1121 已提交
1402 1403 1404 1405 1406 1407 1408 1409 1410 1411
int taos_stmt_set_tags(TAOS_STMT *stmt, TAOS_MULTI_BIND *tags) {
  if (stmt == NULL || tags == NULL) {
    tscError("NULL parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

  return stmtSetTbTags(stmt, tags);
}

1412
int taos_stmt_set_sub_tbname(TAOS_STMT *stmt, const char *name) { return taos_stmt_set_tbname(stmt, name); }
D
dapan1121 已提交
1413

1414
int taos_stmt_get_tag_fields(TAOS_STMT *stmt, int *fieldNum, TAOS_FIELD_E **fields) {
D
dapan1121 已提交
1415 1416 1417 1418 1419
  if (stmt == NULL || NULL == fieldNum) {
    tscError("NULL parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }
1420

D
dapan1121 已提交
1421 1422 1423
  return stmtGetTagFields(stmt, fieldNum, fields);
}

1424
int taos_stmt_get_col_fields(TAOS_STMT *stmt, int *fieldNum, TAOS_FIELD_E **fields) {
D
dapan1121 已提交
1425 1426 1427 1428 1429
  if (stmt == NULL || NULL == fieldNum) {
    tscError("NULL parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }
1430

D
dapan1121 已提交
1431 1432 1433
  return stmtGetColFields(stmt, fieldNum, fields);
}

1434
// let stmt to reclaim TAOS_FIELD_E that was allocated by `taos_stmt_get_tag_fields`/`taos_stmt_get_col_fields`
1435
void taos_stmt_reclaim_fields(TAOS_STMT *stmt, TAOS_FIELD_E *fields) {
1436 1437 1438 1439 1440
  (void)stmt;
  if (!fields) return;
  taosMemoryFree(fields);
}

D
dapan1121 已提交
1441
int taos_stmt_bind_param(TAOS_STMT *stmt, TAOS_MULTI_BIND *bind) {
D
stmt  
dapan1121 已提交
1442
  if (stmt == NULL || bind == NULL) {
D
stmt  
dapan1121 已提交
1443
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1444
    terrno = TSDB_CODE_INVALID_PARA;
D
stmt  
dapan1121 已提交
1445
    return terrno;
D
stmt  
dapan1121 已提交
1446
  }
1447

D
stmt  
dapan1121 已提交
1448 1449 1450 1451 1452
  if (bind->num > 1) {
    tscError("invalid bind number %d for %s", bind->num, __FUNCTION__);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }
1453

D
stmt  
dapan1121 已提交
1454
  return stmtBindBatch(stmt, bind, -1);
1455 1456
}

D
dapan1121 已提交
1457
int taos_stmt_bind_param_batch(TAOS_STMT *stmt, TAOS_MULTI_BIND *bind) {
D
stmt  
dapan1121 已提交
1458
  if (stmt == NULL || bind == NULL) {
D
stmt  
dapan1121 已提交
1459
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1460 1461 1462 1463
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1464 1465
  if (bind->num <= 0 || bind->num > INT16_MAX) {
    tscError("invalid bind num %d", bind->num);
D
stmt  
dapan1121 已提交
1466 1467 1468 1469
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
dapan1121 已提交
1470 1471 1472 1473 1474 1475 1476 1477
  int32_t insert = 0;
  stmtIsInsert(stmt, &insert);
  if (0 == insert && bind->num > 1) {
    tscError("only one row data allowed for query");
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1478
  return stmtBindBatch(stmt, bind, -1);
1479 1480
}

D
dapan1121 已提交
1481
int taos_stmt_bind_single_param_batch(TAOS_STMT *stmt, TAOS_MULTI_BIND *bind, int colIdx) {
D
stmt  
dapan1121 已提交
1482
  if (stmt == NULL || bind == NULL) {
D
stmt  
dapan1121 已提交
1483
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1484 1485 1486 1487
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1488
  if (colIdx < 0) {
D
stmt  
dapan1121 已提交
1489 1490 1491 1492
    tscError("invalid bind column idx %d", colIdx);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }
D
dapan1121 已提交
1493 1494 1495 1496 1497 1498 1499 1500

  int32_t insert = 0;
  stmtIsInsert(stmt, &insert);
  if (0 == insert && bind->num > 1) {
    tscError("only one row data allowed for query");
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }
1501

D
stmt  
dapan1121 已提交
1502
  return stmtBindBatch(stmt, bind, colIdx);
1503 1504
}

D
stmt  
dapan1121 已提交
1505 1506
int taos_stmt_add_batch(TAOS_STMT *stmt) {
  if (stmt == NULL) {
D
stmt  
dapan1121 已提交
1507
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1508 1509 1510 1511
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1512
  return stmtAddBatch(stmt);
1513 1514
}

D
stmt  
dapan1121 已提交
1515 1516
int taos_stmt_execute(TAOS_STMT *stmt) {
  if (stmt == NULL) {
D
stmt  
dapan1121 已提交
1517
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1518 1519 1520 1521
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1522
  return stmtExec(stmt);
1523 1524
}

1525
int taos_stmt_is_insert(TAOS_STMT *stmt, int *insert) {
D
stmt  
dapan1121 已提交
1526
  if (stmt == NULL || insert == NULL) {
D
stmt  
dapan1121 已提交
1527
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1528 1529 1530 1531 1532
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

  return stmtIsInsert(stmt, insert);
1533 1534
}

1535
int taos_stmt_num_params(TAOS_STMT *stmt, int *nums) {
D
stmt  
dapan1121 已提交
1536
  if (stmt == NULL || nums == NULL) {
D
stmt  
dapan1121 已提交
1537
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1538 1539 1540 1541 1542
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

  return stmtGetParamNum(stmt, nums);
1543 1544
}

D
dapan1121 已提交
1545 1546 1547 1548 1549 1550 1551 1552 1553 1554
int taos_stmt_get_param(TAOS_STMT *stmt, int idx, int *type, int *bytes) {
  if (stmt == NULL || type == NULL || NULL == bytes || idx < 0) {
    tscError("invalid parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

  return stmtGetParam(stmt, idx, type, bytes);
}

D
stmt  
dapan1121 已提交
1555
TAOS_RES *taos_stmt_use_result(TAOS_STMT *stmt) {
D
stmt  
dapan1121 已提交
1556
  if (stmt == NULL) {
D
stmt  
dapan1121 已提交
1557
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1558
    terrno = TSDB_CODE_INVALID_PARA;
D
stmt  
dapan1121 已提交
1559
    return NULL;
D
stmt  
dapan1121 已提交
1560 1561
  }

D
stmt  
dapan1121 已提交
1562
  return stmtUseResult(stmt);
1563 1564
}

1565
char *taos_stmt_errstr(TAOS_STMT *stmt) { return (char *)stmtErrstr(stmt); }
1566

D
stmt  
dapan1121 已提交
1567
int taos_stmt_affected_rows(TAOS_STMT *stmt) {
D
stmt  
dapan1121 已提交
1568
  if (stmt == NULL) {
D
stmt  
dapan1121 已提交
1569
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1570
    terrno = TSDB_CODE_INVALID_PARA;
D
stmt  
dapan1121 已提交
1571
    return 0;
D
stmt  
dapan1121 已提交
1572 1573
  }

D
stmt  
dapan1121 已提交
1574
  return stmtAffectedRows(stmt);
1575 1576
}

D
dapan1121 已提交
1577 1578 1579 1580 1581 1582 1583 1584 1585 1586
int taos_stmt_affected_rows_once(TAOS_STMT *stmt) {
  if (stmt == NULL) {
    tscError("NULL parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_INVALID_PARA;
    return 0;
  }

  return stmtAffectedRowsOnce(stmt);
}

D
stmt  
dapan1121 已提交
1587 1588
int taos_stmt_close(TAOS_STMT *stmt) {
  if (stmt == NULL) {
D
stmt  
dapan1121 已提交
1589
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1590 1591 1592 1593
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1594
  return stmtClose(stmt);
D
stmt  
dapan1121 已提交
1595
}