clientMain.c 46.1 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
}

K
kailixu 已提交
122 123 124 125 126 127 128 129 130 131 132 133
int taos_set_notify_cb(TAOS *taos, __taos_notify_fn_t *fp, void *param) {
  if (taos == NULL) {
    return 0;
  }

  STscObj *pObj = acquireTscObj(*(int64_t *)taos);
  if (NULL == pObj) {
    tscError("invalid parameter for %s", __func__);
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return -1;
  }

K
kailixu 已提交
134 135 136 137 138 139 140 141 142
  int32_t type = param ? *(int32_t *)param : 0;
  switch (type) {
    case TAOS_NOTIFY_PASSVER: {
      pObj->passInfo.fp = fp;
      break;
    }
    default:
      break;
  }
K
kailixu 已提交
143

K
kailixu 已提交
144
  releaseTscObj(*(int64_t *)taos);
K
kailixu 已提交
145 146 147
  return 0;
}

148
void taos_close_internal(void *taos) {
149 150 151 152
  if (taos == NULL) {
    return;
  }

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

D
dapan1121 已提交
156
  taosRemoveRef(clientConnRefPool, pTscObj->id);
157 158
}

159
void taos_close(TAOS *taos) {
D
dapan1121 已提交
160 161 162
  if (taos == NULL) {
    return;
  }
L
Liu Jicong 已提交
163 164

  STscObj *pObj = acquireTscObj(*(int64_t *)taos);
165
  if (NULL == pObj) {
D
dapan1121 已提交
166
    taosMemoryFree(taos);
167 168
    return;
  }
L
Liu Jicong 已提交
169

170
  taos_close_internal(pObj);
L
Liu Jicong 已提交
171
  releaseTscObj(*(int64_t *)taos);
D
dapan1121 已提交
172
  taosMemoryFree(taos);
173 174
}

L
Liu Jicong 已提交
175 176
int taos_errno(TAOS_RES *res) {
  if (res == NULL || TD_RES_TMQ_META(res)) {
177 178 179
    return terrno;
  }

180
  if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
181 182 183
    return 0;
  }

184
  return ((SRequestObj *)res)->code;
185 186
}

187
const char *taos_errstr(TAOS_RES *res) {
L
Liu Jicong 已提交
188
  if (res == NULL || TD_RES_TMQ_META(res)) {
L
Liu Jicong 已提交
189
    return (const char *)tstrerror(terrno);
190 191
  }

192
  if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
193 194 195 196
    return "success";
  }

  SRequestObj *pRequest = (SRequestObj *)res;
197
  if (NULL != pRequest->msgBuf && (strlen(pRequest->msgBuf) > 0 || pRequest->code == TSDB_CODE_RPC_FQDN_ERROR)) {
198 199
    return pRequest->msgBuf;
  } else {
200
    return (const char *)tstrerror(pRequest->code);
201
  }
202 203 204
}

void taos_free_result(TAOS_RES *res) {
D
stmt  
dapan1121 已提交
205 206 207
  if (NULL == res) {
    return;
  }
208

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

L
Liu Jicong 已提交
211 212
  if (TD_RES_QUERY(res)) {
    SRequestObj *pRequest = (SRequestObj *)res;
D
dapan1121 已提交
213
    tscDebug("0x%" PRIx64 " taos_free_result start to free query", pRequest->requestId);
L
Liu Jicong 已提交
214
    destroyRequest(pRequest);
215
  } else if (TD_RES_TMQ_METADATA(res)) {
L
Liu Jicong 已提交
216
    SMqTaosxRspObj *pRsp = (SMqTaosxRspObj *)res;
L
Liu Jicong 已提交
217 218 219 220
    taosArrayDestroyP(pRsp->rsp.blockData, taosMemoryFree);
    taosArrayDestroy(pRsp->rsp.blockDataLen);
    taosArrayDestroyP(pRsp->rsp.blockTbName, taosMemoryFree);
    taosArrayDestroyP(pRsp->rsp.blockSchema, (FDelete)tDeleteSSchemaWrapper);
L
Liu Jicong 已提交
221 222 223 224 225 226 227
    // taosx
    taosArrayDestroy(pRsp->rsp.createTableLen);
    taosArrayDestroyP(pRsp->rsp.createTableReq, taosMemoryFree);

    pRsp->resInfo.pRspMsg = NULL;
    doFreeReqResultInfo(&pRsp->resInfo);
    taosMemoryFree(pRsp);
L
Liu Jicong 已提交
228 229
  } else if (TD_RES_TMQ(res)) {
    SMqRspObj *pRsp = (SMqRspObj *)res;
L
Liu Jicong 已提交
230 231 232 233
    taosArrayDestroyP(pRsp->rsp.blockData, taosMemoryFree);
    taosArrayDestroy(pRsp->rsp.blockDataLen);
    taosArrayDestroyP(pRsp->rsp.blockTbName, taosMemoryFree);
    taosArrayDestroyP(pRsp->rsp.blockSchema, (FDelete)tDeleteSSchemaWrapper);
L
Liu Jicong 已提交
234 235
    pRsp->resInfo.pRspMsg = NULL;
    doFreeReqResultInfo(&pRsp->resInfo);
236
    taosMemoryFree(pRsp);
L
Liu Jicong 已提交
237 238 239 240
  } else if (TD_RES_TMQ_META(res)) {
    SMqMetaRspObj *pRspObj = (SMqMetaRspObj *)res;
    taosMemoryFree(pRspObj->metaRsp.metaRsp);
    taosMemoryFree(pRspObj);
L
Liu Jicong 已提交
241
  }
242 243
}

D
dapan1121 已提交
244 245 246 247
void taos_kill_query(TAOS *taos) {
  if (NULL == taos) {
    return;
  }
dengyihao's avatar
dengyihao 已提交
248

dengyihao's avatar
dengyihao 已提交
249
  int64_t  rid = *(int64_t *)taos;
dengyihao's avatar
dengyihao 已提交
250
  STscObj *pTscObj = acquireTscObj(rid);
D
dapan1121 已提交
251 252 253
  if (pTscObj) {
    stopAllRequests(pTscObj->pRequests);
  }
D
dapan1121 已提交
254 255 256
  releaseTscObj(rid);
}

L
Liu Jicong 已提交
257
int taos_field_count(TAOS_RES *res) {
L
Liu Jicong 已提交
258
  if (res == NULL || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
259 260 261
    return 0;
  }

L
Liu Jicong 已提交
262
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
H
Haojun Liao 已提交
263 264 265
  return pResInfo->numOfCols;
}

L
Liu Jicong 已提交
266
int taos_num_fields(TAOS_RES *res) { return taos_field_count(res); }
H
Haojun Liao 已提交
267 268

TAOS_FIELD *taos_fetch_fields(TAOS_RES *res) {
L
Liu Jicong 已提交
269
  if (taos_num_fields(res) == 0 || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
270 271 272
    return NULL;
  }

L
Liu Jicong 已提交
273
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
274
  return pResInfo->userFields;
H
Haojun Liao 已提交
275 276
}

277
TAOS_RES *taos_query(TAOS *taos, const char *sql) { return taosQueryImpl(taos, sql, false); }
dengyihao's avatar
dengyihao 已提交
278 279 280
TAOS_RES *taos_query_with_reqid(TAOS *taos, const char *sql, int64_t reqid) {
  return taosQueryImplWithReqid(taos, sql, false, reqid);
}
281

282 283
TAOS_ROW taos_fetch_row(TAOS_RES *res) {
  if (res == NULL) {
284 285 286
    return NULL;
  }

L
Liu Jicong 已提交
287 288 289
  if (TD_RES_QUERY(res)) {
    SRequestObj *pRequest = (SRequestObj *)res;
    if (pRequest->type == TSDB_SQL_RETRIEVE_EMPTY_RESULT || pRequest->type == TSDB_SQL_INSERT ||
D
dapan1121 已提交
290
        pRequest->code != TSDB_CODE_SUCCESS || taos_num_fields(res) == 0 || pRequest->killed) {
L
Liu Jicong 已提交
291 292
      return NULL;
    }
D
dapan1121 已提交
293 294

    return doAsyncFetchRows(pRequest, true, true);
295
  } else if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
dengyihao's avatar
dengyihao 已提交
296
    SMqRspObj      *msg = ((SMqRspObj *)res);
L
Liu Jicong 已提交
297 298 299 300 301 302
    SReqResultInfo *pResultInfo;
    if (msg->resIter == -1) {
      pResultInfo = tmqGetNextResInfo(res, true);
    } else {
      pResultInfo = tmqGetCurResInfo(res);
    }
303

L
Liu Jicong 已提交
304
    if (pResultInfo->current < pResultInfo->numOfRows) {
L
Liu Jicong 已提交
305 306
      doSetOneRowPtr(pResultInfo);
      pResultInfo->current += 1;
L
Liu Jicong 已提交
307 308
      return pResultInfo->row;
    } else {
L
Liu Jicong 已提交
309
      pResultInfo = tmqGetNextResInfo(res, true);
H
Haojun Liao 已提交
310 311 312 313
      if (pResultInfo == NULL) {
        return NULL;
      }

L
Liu Jicong 已提交
314 315 316
      doSetOneRowPtr(pResultInfo);
      pResultInfo->current += 1;
      return pResultInfo->row;
L
Liu Jicong 已提交
317
    }
L
Liu Jicong 已提交
318 319
  } else if (TD_RES_TMQ_META(res)) {
    return NULL;
L
Liu Jicong 已提交
320
  } else {
321
    // assert to avoid un-initialization error
322 323
    tscError("invalid result passed to taos_fetch_row");
    return NULL;
L
Liu Jicong 已提交
324
  }
325
}
H
Haojun Liao 已提交
326

L
Liu Jicong 已提交
327
int taos_print_row(char *str, TAOS_ROW row, TAOS_FIELD *fields, int num_fields) {
H
Haojun Liao 已提交
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 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385
  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 已提交
386
        int32_t charLen = varDataLen((char *)row[i] - VARSTR_HEADER_SIZE);
H
Haojun Liao 已提交
387
        if (fields[i].type == TSDB_DATA_TYPE_BINARY) {
388 389 390
          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 已提交
391
        } else {
392 393 394
          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 已提交
395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410
        }

        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 已提交
411
  str[len] = 0;
H
Haojun Liao 已提交
412 413 414

  return len;
}
415

L
Liu Jicong 已提交
416
int *taos_fetch_lengths(TAOS_RES *res) {
L
Liu Jicong 已提交
417
  if (res == NULL || TD_RES_TMQ_META(res)) {
418 419 420
    return NULL;
  }

L
Liu Jicong 已提交
421 422
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
  return pResInfo->length;
423 424
}

425
TAOS_ROW *taos_result_block(TAOS_RES *res) {
L
Liu Jicong 已提交
426
  if (res == NULL || TD_RES_TMQ_META(res)) {
427 428 429 430 431 432 433 434
    terrno = TSDB_CODE_INVALID_PARA;
    return NULL;
  }

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

L
Liu Jicong 已提交
435 436
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
  return &pResInfo->row;
437 438
}

439
// todo intergrate with tDataTypes
440 441
const char *taos_data_type(int type) {
  switch (type) {
L
Liu Jicong 已提交
442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466
    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";
467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482
    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 已提交
483 484
    default:
      return "UNKNOWN";
485 486
  }
}
487 488 489

const char *taos_get_client_info() { return version; }

490
// return int32_t
X
Xiaoyu Wang 已提交
491
int taos_affected_rows(TAOS_RES *res) {
492
  if (res == NULL || TD_RES_TMQ(res) || TD_RES_TMQ_META(res) || TD_RES_TMQ_METADATA(res)) {
H
Haojun Liao 已提交
493 494 495
    return 0;
  }

496 497 498 499 500 501
  SRequestObj    *pRequest = (SRequestObj *)res;
  SReqResultInfo *pResInfo = &pRequest->body.resInfo;
  return (int)pResInfo->numOfRows;
}

// return int64_t
A
Alex Duan 已提交
502
int64_t taos_affected_rows64(TAOS_RES *res) {
503 504 505 506
  if (res == NULL || TD_RES_TMQ(res) || TD_RES_TMQ_META(res) || TD_RES_TMQ_METADATA(res)) {
    return 0;
  }

dengyihao's avatar
dengyihao 已提交
507
  SRequestObj    *pRequest = (SRequestObj *)res;
L
Liu Jicong 已提交
508
  SReqResultInfo *pResInfo = &pRequest->body.resInfo;
H
Haojun Liao 已提交
509
  return pResInfo->numOfRows;
X
Xiaoyu Wang 已提交
510
}
511

512
int taos_result_precision(TAOS_RES *res) {
L
Liu Jicong 已提交
513
  if (res == NULL || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
514 515
    return TSDB_TIME_PRECISION_MILLI;
  }
516

L
Liu Jicong 已提交
517 518 519
  if (TD_RES_QUERY(res)) {
    SRequestObj *pRequest = (SRequestObj *)res;
    return pRequest->body.resInfo.precision;
520
  } else if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
L
Liu Jicong 已提交
521 522 523 524
    SReqResultInfo *info = tmqGetCurResInfo(res);
    return info->precision;
  }
  return TSDB_TIME_PRECISION_MILLI;
525
}
526 527

int taos_select_db(TAOS *taos, const char *db) {
L
Liu Jicong 已提交
528
  STscObj *pObj = acquireTscObj(*(int64_t *)taos);
529
  if (pObj == NULL) {
L
Liu Jicong 已提交
530
    releaseTscObj(*(int64_t *)taos);
531 532 533 534 535
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return TSDB_CODE_TSC_DISCONNECTED;
  }

  if (db == NULL || strlen(db) == 0) {
L
Liu Jicong 已提交
536
    releaseTscObj(*(int64_t *)taos);
537 538 539 540 541 542 543
    terrno = TSDB_CODE_TSC_INVALID_INPUT;
    return terrno;
  }

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

L
Liu Jicong 已提交
544 545
  TAOS_RES *pRequest = taos_query(taos, sql);
  int32_t   code = taos_errno(pRequest);
546 547

  taos_free_result(pRequest);
L
Liu Jicong 已提交
548
  releaseTscObj(*(int64_t *)taos);
549 550 551 552
  return code;
}

void taos_stop_query(TAOS_RES *res) {
553
  if (res == NULL || TD_RES_TMQ(res) || TD_RES_TMQ_META(res) || TD_RES_TMQ_METADATA(res)) {
554 555 556
    return;
  }

L
Liu Jicong 已提交
557
  SRequestObj *pRequest = (SRequestObj *)res;
D
dapan1121 已提交
558
  pRequest->killed = true;
L
Liu Jicong 已提交
559

560
  // It is not a query, no need to stop.
561
  if (NULL == pRequest->pQuery || QUERY_EXEC_MODE_SCHEDULE != pRequest->pQuery->execMode) {
D
dapan1121 已提交
562
    tscDebug("request 0x%" PRIx64 " no need to be killed since not query", pRequest->requestId);
563 564 565
    return;
  }

D
dapan1121 已提交
566
  schedulerFreeJob(&pRequest->body.queryJob, TSDB_CODE_TSC_QUERY_KILLED);
D
dapan1121 已提交
567
  tscDebug("request %" PRIx64 " killed", pRequest->requestId);
568 569 570
}

bool taos_is_null(TAOS_RES *res, int32_t row, int32_t col) {
L
Liu Jicong 已提交
571 572 573
  if (res == NULL || TD_RES_TMQ_META(res)) {
    return true;
  }
L
Liu Jicong 已提交
574
  SReqResultInfo *pResultInfo = tscGetCurResInfo(res);
575 576 577 578
  if (col >= pResultInfo->numOfCols || col < 0 || row >= pResultInfo->numOfRows || row < 0) {
    return true;
  }

L
Liu Jicong 已提交
579
  SResultColumn *pCol = &pResultInfo->pCol[col];
580 581 582 583 584
  if (IS_VAR_DATA_TYPE(pResultInfo->fields[col].type)) {
    return (pCol->offset[row] == -1);
  } else {
    return colDataIsNull_f(pCol->nullbitmap, row);
  }
585 586
}

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

L
Liu Jicong 已提交
589
int taos_fetch_block(TAOS_RES *res, TAOS_ROW *rows) {
H
Haojun Liao 已提交
590
  int32_t numOfRows = 0;
L
Liu Jicong 已提交
591
  /*int32_t code = */ taos_fetch_block_s(res, &numOfRows, rows);
H
Haojun Liao 已提交
592 593 594
  return numOfRows;
}

L
Liu Jicong 已提交
595
int taos_fetch_block_s(TAOS_RES *res, int *numOfRows, TAOS_ROW *rows) {
L
Liu Jicong 已提交
596
  if (res == NULL || TD_RES_TMQ_META(res)) {
597 598
    return 0;
  }
599

L
Liu Jicong 已提交
600 601
  if (TD_RES_QUERY(res)) {
    SRequestObj *pRequest = (SRequestObj *)res;
602

L
Liu Jicong 已提交
603 604
    (*rows) = NULL;
    (*numOfRows) = 0;
H
Haojun Liao 已提交
605

L
Liu Jicong 已提交
606 607 608 609
    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;
    }
610

611
    doAsyncFetchRows(pRequest, false, true);
612

L
Liu Jicong 已提交
613 614 615
    // TODO refactor
    SReqResultInfo *pResultInfo = &pRequest->body.resInfo;
    pResultInfo->current = pResultInfo->numOfRows;
616

L
Liu Jicong 已提交
617 618 619
    (*rows) = pResultInfo->row;
    (*numOfRows) = pResultInfo->numOfRows;
    return pRequest->code;
620
  } else if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
L
Liu Jicong 已提交
621
    SReqResultInfo *pResultInfo = tmqGetNextResInfo(res, true);
L
Liu Jicong 已提交
622
    if (pResultInfo == NULL) return -1;
H
Haojun Liao 已提交
623

L
Liu Jicong 已提交
624 625 626
    pResultInfo->current = pResultInfo->numOfRows;
    (*rows) = pResultInfo->row;
    (*numOfRows) = pResultInfo->numOfRows;
H
Haojun Liao 已提交
627
    return 0;
L
Liu Jicong 已提交
628
  } else {
629
    tscError("taos_fetch_block_s invalid res type");
L
Liu Jicong 已提交
630
    return -1;
H
Haojun Liao 已提交
631
  }
L
Liu Jicong 已提交
632
}
H
Haojun Liao 已提交
633

L
Liu Jicong 已提交
634
int taos_fetch_raw_block(TAOS_RES *res, int *numOfRows, void **pData) {
D
dapan1121 已提交
635 636 637
  *numOfRows = 0;
  *pData = NULL;

L
Liu Jicong 已提交
638
  if (res == NULL || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
639 640
    return 0;
  }
641

642
  if (TD_RES_TMQ(res) || TD_RES_TMQ_METADATA(res)) {
L
Liu Jicong 已提交
643
    SReqResultInfo *pResultInfo = tmqGetNextResInfo(res, false);
L
Liu Jicong 已提交
644 645 646 647
    if (pResultInfo == NULL) {
      (*numOfRows) = 0;
      return 0;
    }
H
Haojun Liao 已提交
648

L
Liu Jicong 已提交
649 650 651 652
    pResultInfo->current = pResultInfo->numOfRows;
    (*numOfRows) = pResultInfo->numOfRows;
    (*pData) = (void *)pResultInfo->pData;
    return 0;
653
  }
L
Liu Jicong 已提交
654

655 656 657 658 659
  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 已提交
660
  }
661

662
  doAsyncFetchRows(pRequest, false, false);
663 664 665 666 667 668 669 670

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

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

  return 0;
671 672
}

H
Haojun Liao 已提交
673
int *taos_get_column_data_offset(TAOS_RES *res, int columnIndex) {
L
Liu Jicong 已提交
674
  if (res == NULL || TD_RES_TMQ_META(res)) {
H
Haojun Liao 已提交
675 676 677
    return 0;
  }

L
Liu Jicong 已提交
678
  int32_t numOfFields = taos_num_fields(res);
H
Haojun Liao 已提交
679 680 681 682
  if (columnIndex < 0 || columnIndex >= numOfFields || numOfFields == 0) {
    return 0;
  }

L
Liu Jicong 已提交
683
  SReqResultInfo *pResInfo = tscGetCurResInfo(res);
dengyihao's avatar
dengyihao 已提交
684
  TAOS_FIELD     *pField = &pResInfo->userFields[columnIndex];
H
Haojun Liao 已提交
685 686 687 688
  if (!IS_VAR_DATA_TYPE(pField->type)) {
    return 0;
  }

L
Liu Jicong 已提交
689
  return pResInfo->pCol[columnIndex].offset;
H
Haojun Liao 已提交
690 691
}

692 693
int taos_validate_sql(TAOS *taos, const char *sql) {
  TAOS_RES *pObj = taosQueryImpl(taos, sql, true);
D
dapan1121 已提交
694 695

  int code = taos_errno(pObj);
696

D
dapan1121 已提交
697 698 699
  taos_free_result(pObj);
  return code;
}
700

701
void taos_reset_current_db(TAOS *taos) {
L
Liu Jicong 已提交
702
  STscObj *pTscObj = acquireTscObj(*(int64_t *)taos);
703 704
  if (pTscObj == NULL) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
H
Haojun Liao 已提交
705 706 707
    return;
  }

708 709
  resetConnectDB(pTscObj);

L
Liu Jicong 已提交
710
  releaseTscObj(*(int64_t *)taos);
711 712
}

713
const char *taos_get_server_info(TAOS *taos) {
L
Liu Jicong 已提交
714
  STscObj *pTscObj = acquireTscObj(*(int64_t *)taos);
715 716
  if (pTscObj == NULL) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
717 718 719
    return NULL;
  }

L
Liu Jicong 已提交
720
  releaseTscObj(*(int64_t *)taos);
721

D
dapan1121 已提交
722
  return pTscObj->sDetailVer;
723 724
}

725
int taos_get_current_db(TAOS *taos, char *database, int len, int *required) {
726 727 728
  STscObj *pTscObj = acquireTscObj(*(int64_t *)taos);
  if (pTscObj == NULL) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
729 730 731 732 733 734 735 736
    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 已提交
737 738
    code = -1;
  }else if(len < strlen(pTscObj->db) + 1){
739 740 741 742 743 744 745 746 747 748
    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;
749 750
}

751 752 753 754 755
static void destoryTablesReq(void *p) {
  STablesReq *pRes = (STablesReq *)p;
  taosArrayDestroy(pRes->pTables);
}

756 757 758 759 760 761 762 763 764 765 766 767 768
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 已提交
769
  taosArrayDestroy(pCatalogReq->pTableCfg);
770 771 772 773 774 775 776 777 778
  taosMemoryFree(pCatalogReq);
}

void destorySqlCallbackWrapper(SSqlCallbackWrapper *pWrapper) {
  if (NULL == pWrapper) {
    return;
  }
  destoryCatalogReq(pWrapper->pCatalogReq);
  qDestroyParseContext(pWrapper->pParseCtx);
779 780 781
  taosMemoryFree(pWrapper);
}

X
Xiaoyu Wang 已提交
782
static void doAsyncQueryFromAnalyse(SMetaData *pResultMeta, void *param, int32_t code) {
783 784 785
  SSqlCallbackWrapper *pWrapper = (SSqlCallbackWrapper *)param;
  SRequestObj         *pRequest = pWrapper->pRequest;
  SQuery              *pQuery = pRequest->pQuery;
786

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

791
  if (code == TSDB_CODE_SUCCESS) {
792
    code = qAnalyseSqlSemantic(pWrapper->pParseCtx, pWrapper->pCatalogReq, pResultMeta, pQuery);
793
    pRequest->stableQuery = pQuery->stableQuery;
D
dapan1121 已提交
794
    if (pQuery->pRoot) {
dengyihao's avatar
dengyihao 已提交
795
      pRequest->stmtType = pQuery->pRoot->type;
D
dapan1121 已提交
796
    }
797 798
  }

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

801 802 803 804 805
  if (code == TSDB_CODE_SUCCESS) {
    if (pQuery->haveResultSet) {
      setResSchemaInfo(&pRequest->body.resInfo, pQuery->pResSchema, pQuery->numOfResCols);
      setResPrecision(&pRequest->body.resInfo, pQuery->precision);
    }
806

807 808
    TSWAP(pRequest->dbList, (pQuery)->pDbList);
    TSWAP(pRequest->tableList, (pQuery)->pTableList);
D
dapan1121 已提交
809
    TSWAP(pRequest->targetTableList, (pQuery)->pTargetTableList);
810

811
    launchAsyncQuery(pRequest, pQuery, pResultMeta, pWrapper);
812
  } else {
813
    destorySqlCallbackWrapper(pWrapper);
X
Xiaoyu Wang 已提交
814 815
    qDestroyQuery(pRequest->pQuery);
    pRequest->pQuery = NULL;
816

817
    if (NEED_CLIENT_HANDLE_ERROR(code)) {
818 819
      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);
820 821 822 823
      pRequest->prevCode = code;
      doAsyncQuery(pRequest, true);
      return;
    }
824

825
    // return to app directly
826 827
    tscError("0x%" PRIx64 " error occurs, code:%s, return to user app, reqId:0x%" PRIx64, pRequest->self,
             tstrerror(code), pRequest->requestId);
828 829 830
    pRequest->code = code;
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
  }
831 832
}

X
Xiaoyu Wang 已提交
833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874
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;

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

  if (code == TSDB_CODE_SUCCESS) {
880
    // pWrapper->pCatalogReq->forceUpdate = false;
X
Xiaoyu Wang 已提交
881 882 883 884 885 886 887 888 889 890 891 892
    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 已提交
893 894
    pRequest->code = code;
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
X
Xiaoyu Wang 已提交
895 896 897 898 899 900 901 902 903 904 905 906 907 908
  }
}

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;
909 910
    pRequest->code = code;
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
911 912 913
  }
}

914
void taos_query_a(TAOS *taos, const char *sql, __taos_async_fn_t fp, void *param) {
dengyihao's avatar
dengyihao 已提交
915
  int64_t connId = *(int64_t *)taos;
D
dapan1121 已提交
916
  tscDebug("taos_query_a start with sql:%s", sql);
917
  taosAsyncQueryImpl(connId, sql, fp, param, false);
D
dapan1121 已提交
918
  tscDebug("taos_query_a end with sql:%s", sql);
919
}
920

dengyihao's avatar
dengyihao 已提交
921 922 923 924 925
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);
}

926
int32_t createParseContext(const SRequestObj *pRequest, SParseContext **pCxt) {
927 928 929 930 931 932 933
  const STscObj *pTscObj = pRequest->pTscObj;

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

dengyihao's avatar
dengyihao 已提交
934 935 936 937 938 939 940 941 942 943 944 945 946
  **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)),
947
                           .enableSysInfo = pTscObj->sysInfo,
dengyihao's avatar
dengyihao 已提交
948 949
                           .async = true,
                           .svrVer = pTscObj->sVer,
950 951
                           .nodeOffline = (pTscObj->pAppInfo->onlineDnodes < pTscObj->pAppInfo->totalDnodes),
                           .allocatorId = pRequest->allocatorRefId};
952 953 954
  return TSDB_CODE_SUCCESS;
}

955
void doAsyncQuery(SRequestObj *pRequest, bool updateMetaForce) {
956 957 958
  STscObj             *pTscObj = pRequest->pTscObj;
  SSqlCallbackWrapper *pWrapper = NULL;
  int32_t              code = TSDB_CODE_SUCCESS;
959 960

  if (pRequest->retry++ > REQUEST_TOTAL_EXEC_TIMES) {
961
    code = pRequest->prevCode;
D
dapan1121 已提交
962
    terrno = code;
D
dapan1121 已提交
963 964
    pRequest->code = code;
    tscDebug("call sync query cb with code: %s", tstrerror(code));
D
dapan1121 已提交
965 966
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
    return;
967 968
  }

969 970 971 972 973 974 975
  if (TSDB_CODE_SUCCESS == code) {
    pWrapper = taosMemoryCalloc(1, sizeof(SSqlCallbackWrapper));
    if (pWrapper == NULL) {
      code = TSDB_CODE_OUT_OF_MEMORY;
    } else {
      pWrapper->pRequest = pRequest;
    }
976
  }
977

978 979
  if (TSDB_CODE_SUCCESS == code) {
    code = createParseContext(pRequest, &pWrapper->pParseCtx);
980 981
  }

982 983 984
  if (TSDB_CODE_SUCCESS == code) {
    pWrapper->pParseCtx->mgmtEpSet = getEpSet_s(&pTscObj->pAppInfo->mgmtEp);
    code = catalogGetHandle(pTscObj->pAppInfo->clusterId, &pWrapper->pParseCtx->pCatalog);
985 986
  }

987
  if (TSDB_CODE_SUCCESS == code) {
988
    int64_t syntaxStart = taosGetTimestampUs();
989 990 991 992 993 994 995 996 997 998

    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);
    }

999
    pRequest->metric.parseCostUs += taosGetTimestampUs() - syntaxStart;
D
dapan1121 已提交
1000 1001
  }

1002
  if (TSDB_CODE_SUCCESS == code) {
1003
    pRequest->stmtType = pRequest->pQuery->pRoot->type;
X
Xiaoyu Wang 已提交
1004 1005
    phaseAsyncQuery(pWrapper);
  } else {
1006 1007 1008
    tscError("0x%" PRIx64 " error happens, code:%d - %s, reqId:0x%" PRIx64, pRequest->self, code, tstrerror(code),
             pRequest->requestId);
    destorySqlCallbackWrapper(pWrapper);
D
dapan1121 已提交
1009 1010
    qDestroyQuery(pRequest->pQuery);
    pRequest->pQuery = NULL;
1011 1012 1013 1014 1015 1016 1017 1018 1019

    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;
    }

1020 1021 1022 1023
    terrno = code;
    pRequest->code = code;
    pRequest->body.queryFp(pRequest->body.param, pRequest, code);
  }
1024 1025
}

1026 1027
static void fetchCallback(void *pResult, void *param, int32_t code) {
  SRequestObj *pRequest = (SRequestObj *)param;
1028

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

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

1034 1035 1036 1037 1038
  pResultInfo->pData = pResult;
  pResultInfo->numOfRows = 0;

  if (code != TSDB_CODE_SUCCESS) {
    pRequest->code = code;
1039
    taosMemoryFreeClear(pResultInfo->pData);
1040 1041 1042 1043 1044
    pRequest->body.fetchFp(pRequest->body.param, pRequest, 0);
    return;
  }

  if (pRequest->code != TSDB_CODE_SUCCESS) {
1045
    taosMemoryFreeClear(pResultInfo->pData);
1046
    pRequest->body.fetchFp(pRequest->body.param, pRequest, 0);
1047
    return;
1048 1049
  }

1050
  pRequest->code =
wmmhello's avatar
wmmhello 已提交
1051
      setQueryResultFromRsp(pResultInfo, (const SRetrieveTableRsp *)pResultInfo->pData, pResultInfo->convertUcs4, true);
1052 1053 1054
  if (pRequest->code != TSDB_CODE_SUCCESS) {
    pResultInfo->numOfRows = 0;
    pRequest->code = code;
1055 1056 1057
    tscError("0x%" PRIx64 " fetch results failed, code:%s, reqId:0x%" PRIx64, pRequest->self, tstrerror(code),
             pRequest->requestId);
  } else {
A
Alex Duan 已提交
1058
    tscDebug("0x%" PRIx64 " fetch results, numOfRows:%" PRId64 " total Rows:%" PRId64 ", complete:%d, reqId:0x%" PRIx64,
1059 1060
             pRequest->self, pResultInfo->numOfRows, pResultInfo->totalRows, pResultInfo->completed,
             pRequest->requestId);
D
dapan1121 已提交
1061 1062 1063

    STscObj            *pTscObj = pRequest->pTscObj;
    SAppClusterSummary *pActivity = &pTscObj->pAppInfo->summary;
dengyihao's avatar
dengyihao 已提交
1064
    atomic_add_fetch_64((int64_t *)&pActivity->fetchBytes, pRequest->body.resInfo.payloadLen);
1065 1066 1067 1068 1069
  }

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

1070
void taos_fetch_rows_a(TAOS_RES *res, __taos_async_fn_t fp, void *param) {
1071 1072 1073 1074 1075 1076 1077 1078
  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;
  }
1079 1080 1081

  SRequestObj *pRequest = res;
  pRequest->body.fetchFp = fp;
1082
  pRequest->body.param = param;
1083 1084

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

  // this query has no results or error exists, return directly
  if (taos_num_fields(pRequest) == 0 || pRequest->code != TSDB_CODE_SUCCESS) {
1088 1089 1090 1091 1092
    pResultInfo->numOfRows = 0;
    pRequest->body.fetchFp(param, pRequest, pResultInfo->numOfRows);
    return;
  }

1093
  // all data has returned to App already, no need to try again
D
dapan1121 已提交
1094 1095
  if (pResultInfo->completed) {
    // it is a local executed query, no need to do async fetch
X
Xiaoyu Wang 已提交
1096
    if (QUERY_EXEC_MODE_SCHEDULE != pRequest->body.execMode) {
D
dapan1121 已提交
1097 1098 1099 1100 1101 1102
      if (pResultInfo->localResultFetched) {
        pResultInfo->numOfRows = 0;
        pResultInfo->current = 0;
      } else {
        pResultInfo->localResultFetched = true;
      }
1103
    } else {
D
dapan1121 已提交
1104
      pResultInfo->numOfRows = 0;
1105
    }
1106

D
dapan1121 已提交
1107
    pRequest->body.fetchFp(param, pRequest, pResultInfo->numOfRows);
1108
    return;
1109 1110
  }

D
dapan1121 已提交
1111
  SSchedulerReq req = {
dengyihao's avatar
dengyihao 已提交
1112 1113 1114
      .syncReq = false,
      .fetchFp = fetchCallback,
      .cbParam = pRequest,
D
dapan1121 已提交
1115
  };
1116

D
dapan1121 已提交
1117
  schedulerFetchRows(pRequest->body.queryJob, &req);
L
Liu Jicong 已提交
1118
}
1119

1120
void taos_fetch_raw_block_a(TAOS_RES *res, __taos_async_fn_t fp, void *param) {
1121 1122 1123 1124 1125 1126 1127 1128
  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 已提交
1129
  SRequestObj    *pRequest = res;
1130 1131 1132
  SReqResultInfo *pResultInfo = &pRequest->body.resInfo;

  // set the current block is all consumed
1133 1134
  pResultInfo->convertUcs4 = false;

1135 1136
  // it is a local executed query, no need to do async fetch
  taos_fetch_rows_a(pRequest, fp, param);
1137 1138
}

1139
const void *taos_get_raw_block(TAOS_RES *res) {
1140 1141 1142 1143 1144 1145 1146 1147
  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;
  }
1148
  SRequestObj *pRequest = res;
H
Haojun Liao 已提交
1149 1150 1151 1152

  return pRequest->body.resInfo.pData;
}

X
Xiaoyu Wang 已提交
1153
int taos_get_db_route_info(TAOS *taos, const char *db, TAOS_DB_ROUTE_INFO *dbInfo) {
1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164
  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 已提交
1165 1166 1167
  int64_t      connId = *(int64_t *)taos;
  SRequestObj *pRequest = NULL;
  char        *sql = "taos_get_db_route_info";
dengyihao's avatar
dengyihao 已提交
1168
  int32_t      code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest, 0);
1169
  if (code != TSDB_CODE_SUCCESS) {
1170
    terrno = code;
1171 1172 1173
    return terrno;
  }

X
Xiaoyu Wang 已提交
1174
  STscObj  *pTscObj = pRequest->pTscObj;
1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187
  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 已提交
1188

1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201
  code = catalogGetDBVgInfo(pCtg, &conn, dbFName, dbInfo);
  if (code) {
    goto _return;
  }

_return:

  terrno = code;

  destroyRequest(pRequest);
  return code;
}

X
Xiaoyu Wang 已提交
1202
int taos_get_table_vgId(TAOS *taos, const char *db, const char *table, int *vgId) {
1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213
  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 已提交
1214 1215 1216
  int64_t      connId = *(int64_t *)taos;
  SRequestObj *pRequest = NULL;
  char        *sql = "taos_get_table_vgId";
dengyihao's avatar
dengyihao 已提交
1217
  int32_t      code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest, 0);
1218 1219 1220 1221
  if (code != TSDB_CODE_SUCCESS) {
    return terrno;
  }

1222 1223
  pRequest->syncQuery = true;

X
Xiaoyu Wang 已提交
1224
  STscObj  *pTscObj = pRequest->pTscObj;
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
  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;
1250

1251 1252
  destroyRequest(pRequest);
  return code;
1253 1254
}

D
dapan1121 已提交
1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302
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;
}


1303
int taos_load_table_info(TAOS *taos, const char *tableNameList) {
D
dapan1121 已提交
1304 1305 1306 1307 1308
  if (NULL == taos) {
    terrno = TSDB_CODE_TSC_DISCONNECTED;
    return terrno;
  }

1309
  int64_t       connId = *(int64_t *)taos;
D
dapan1121 已提交
1310
  const int32_t MAX_TABLE_NAME_LENGTH = 12 * 1024 * 1024;  // 12MB list
1311
  int32_t       code = 0;
dengyihao's avatar
dengyihao 已提交
1312
  SRequestObj  *pRequest = NULL;
1313 1314
  SCatalogReq   catalogReq = {0};

D
dapan1121 已提交
1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326
  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;
  }

1327
  char *sql = "taos_load_table_info";
dengyihao's avatar
dengyihao 已提交
1328
  code = buildRequest(connId, sql, strlen(sql), NULL, false, &pRequest, 0);
1329 1330 1331
  if (code != TSDB_CODE_SUCCESS) {
    terrno = code;
    goto _return;
D
dapan1121 已提交
1332 1333
  }

dengyihao's avatar
dengyihao 已提交
1334
  STscObj *pTscObj = pRequest->pTscObj;
D
dapan1121 已提交
1335 1336 1337 1338 1339
  code = transferTableNameList(tableNameList, pTscObj->acctId, pTscObj->db, &catalogReq.pTableMeta);
  if (code) {
    goto _return;
  }

1340
  SCatalog *pCtg = NULL;
D
dapan1121 已提交
1341 1342 1343 1344 1345
  code = catalogGetHandle(pTscObj->pAppInfo->clusterId, &pCtg);
  if (code != TSDB_CODE_SUCCESS) {
    goto _return;
  }

1346 1347
  SRequestConnInfo conn = {
      .pTrans = pTscObj->pAppInfo->pTransporter, .requestId = pRequest->requestId, .requestObjRefId = pRequest->self};
D
dapan1121 已提交
1348 1349 1350

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

D
dapan1121 已提交
1351
  code = catalogAsyncGetAllMeta(pCtg, &conn, &catalogReq, syncCatalogFn, pRequest->body.param, NULL);
D
dapan1121 已提交
1352 1353 1354 1355
  if (code) {
    goto _return;
  }

dengyihao's avatar
dengyihao 已提交
1356
  SSyncQueryParam *pParam = pRequest->body.param;
1357
  tsem_wait(&pParam->sem);
D
dapan1121 已提交
1358 1359 1360 1361 1362

_return:
  taosArrayDestroy(catalogReq.pTableMeta);
  destroyRequest(pRequest);
  return code;
1363 1364
}

L
Liu Jicong 已提交
1365
TAOS_STMT *taos_stmt_init(TAOS *taos) {
L
Liu Jicong 已提交
1366
  STscObj *pObj = acquireTscObj(*(int64_t *)taos);
1367 1368 1369
  if (NULL == pObj) {
    tscError("invalid parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_TSC_DISCONNECTED;
D
stmt  
dapan1121 已提交
1370 1371 1372
    return NULL;
  }

dengyihao's avatar
dengyihao 已提交
1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388
  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 已提交
1389 1390

  releaseTscObj(*(int64_t *)taos);
1391 1392

  return pStmt;
1393 1394
}

D
stmt  
dapan1121 已提交
1395 1396
int taos_stmt_prepare(TAOS_STMT *stmt, const char *sql, unsigned long length) {
  if (stmt == NULL || sql == NULL) {
D
stmt  
dapan1121 已提交
1397
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1398 1399 1400 1401
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1402
  return stmtPrepare(stmt, sql, length);
1403 1404
}

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

D
stmt  
dapan1121 已提交
1412 1413 1414 1415 1416 1417 1418 1419 1420 1421
  int32_t code = stmtSetTbName(stmt, name);
  if (code) {
    return code;
  }

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

  return TSDB_CODE_SUCCESS;
1422 1423
}

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

D
stmt  
dapan1121 已提交
1431
  return stmtSetTbName(stmt, name);
1432 1433
}

D
dapan1121 已提交
1434 1435 1436 1437 1438 1439 1440 1441 1442 1443
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);
}

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

1446
int taos_stmt_get_tag_fields(TAOS_STMT *stmt, int *fieldNum, TAOS_FIELD_E **fields) {
D
dapan1121 已提交
1447 1448 1449 1450 1451
  if (stmt == NULL || NULL == fieldNum) {
    tscError("NULL parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }
1452

D
dapan1121 已提交
1453 1454 1455
  return stmtGetTagFields(stmt, fieldNum, fields);
}

1456
int taos_stmt_get_col_fields(TAOS_STMT *stmt, int *fieldNum, TAOS_FIELD_E **fields) {
D
dapan1121 已提交
1457 1458 1459 1460 1461
  if (stmt == NULL || NULL == fieldNum) {
    tscError("NULL parameter for %s", __FUNCTION__);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }
1462

D
dapan1121 已提交
1463 1464 1465
  return stmtGetColFields(stmt, fieldNum, fields);
}

1466
// let stmt to reclaim TAOS_FIELD_E that was allocated by `taos_stmt_get_tag_fields`/`taos_stmt_get_col_fields`
1467
void taos_stmt_reclaim_fields(TAOS_STMT *stmt, TAOS_FIELD_E *fields) {
1468 1469 1470 1471 1472
  (void)stmt;
  if (!fields) return;
  taosMemoryFree(fields);
}

D
dapan1121 已提交
1473
int taos_stmt_bind_param(TAOS_STMT *stmt, TAOS_MULTI_BIND *bind) {
D
stmt  
dapan1121 已提交
1474
  if (stmt == NULL || bind == NULL) {
D
stmt  
dapan1121 已提交
1475
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1476
    terrno = TSDB_CODE_INVALID_PARA;
D
stmt  
dapan1121 已提交
1477
    return terrno;
D
stmt  
dapan1121 已提交
1478
  }
1479

D
stmt  
dapan1121 已提交
1480 1481 1482 1483 1484
  if (bind->num > 1) {
    tscError("invalid bind number %d for %s", bind->num, __FUNCTION__);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }
1485

D
stmt  
dapan1121 已提交
1486
  return stmtBindBatch(stmt, bind, -1);
1487 1488
}

D
dapan1121 已提交
1489
int taos_stmt_bind_param_batch(TAOS_STMT *stmt, TAOS_MULTI_BIND *bind) {
D
stmt  
dapan1121 已提交
1490
  if (stmt == NULL || bind == NULL) {
D
stmt  
dapan1121 已提交
1491
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1492 1493 1494 1495
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1496 1497
  if (bind->num <= 0 || bind->num > INT16_MAX) {
    tscError("invalid bind num %d", bind->num);
D
stmt  
dapan1121 已提交
1498 1499 1500 1501
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
dapan1121 已提交
1502 1503 1504 1505 1506 1507 1508 1509
  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 已提交
1510
  return stmtBindBatch(stmt, bind, -1);
1511 1512
}

D
dapan1121 已提交
1513
int taos_stmt_bind_single_param_batch(TAOS_STMT *stmt, TAOS_MULTI_BIND *bind, int colIdx) {
D
stmt  
dapan1121 已提交
1514
  if (stmt == NULL || bind == NULL) {
D
stmt  
dapan1121 已提交
1515
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1516 1517 1518 1519
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1520
  if (colIdx < 0) {
D
stmt  
dapan1121 已提交
1521 1522 1523 1524
    tscError("invalid bind column idx %d", colIdx);
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }
D
dapan1121 已提交
1525 1526 1527 1528 1529 1530 1531 1532

  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;
  }
1533

D
stmt  
dapan1121 已提交
1534
  return stmtBindBatch(stmt, bind, colIdx);
1535 1536
}

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

D
stmt  
dapan1121 已提交
1544
  return stmtAddBatch(stmt);
1545 1546
}

D
stmt  
dapan1121 已提交
1547 1548
int taos_stmt_execute(TAOS_STMT *stmt) {
  if (stmt == NULL) {
D
stmt  
dapan1121 已提交
1549
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1550 1551 1552 1553
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1554
  return stmtExec(stmt);
1555 1556
}

1557
int taos_stmt_is_insert(TAOS_STMT *stmt, int *insert) {
D
stmt  
dapan1121 已提交
1558
  if (stmt == NULL || insert == NULL) {
D
stmt  
dapan1121 已提交
1559
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1560 1561 1562 1563 1564
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

  return stmtIsInsert(stmt, insert);
1565 1566
}

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

  return stmtGetParamNum(stmt, nums);
1575 1576
}

D
dapan1121 已提交
1577 1578 1579 1580 1581 1582 1583 1584 1585 1586
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 已提交
1587
TAOS_RES *taos_stmt_use_result(TAOS_STMT *stmt) {
D
stmt  
dapan1121 已提交
1588
  if (stmt == NULL) {
D
stmt  
dapan1121 已提交
1589
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1590
    terrno = TSDB_CODE_INVALID_PARA;
D
stmt  
dapan1121 已提交
1591
    return NULL;
D
stmt  
dapan1121 已提交
1592 1593
  }

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

1597
char *taos_stmt_errstr(TAOS_STMT *stmt) { return (char *)stmtErrstr(stmt); }
1598

D
stmt  
dapan1121 已提交
1599
int taos_stmt_affected_rows(TAOS_STMT *stmt) {
D
stmt  
dapan1121 已提交
1600
  if (stmt == NULL) {
D
stmt  
dapan1121 已提交
1601
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1602
    terrno = TSDB_CODE_INVALID_PARA;
D
stmt  
dapan1121 已提交
1603
    return 0;
D
stmt  
dapan1121 已提交
1604 1605
  }

D
stmt  
dapan1121 已提交
1606
  return stmtAffectedRows(stmt);
1607 1608
}

D
dapan1121 已提交
1609 1610 1611 1612 1613 1614 1615 1616 1617 1618
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 已提交
1619 1620
int taos_stmt_close(TAOS_STMT *stmt) {
  if (stmt == NULL) {
D
stmt  
dapan1121 已提交
1621
    tscError("NULL parameter for %s", __FUNCTION__);
D
stmt  
dapan1121 已提交
1622 1623 1624 1625
    terrno = TSDB_CODE_INVALID_PARA;
    return terrno;
  }

D
stmt  
dapan1121 已提交
1626
  return stmtClose(stmt);
D
stmt  
dapan1121 已提交
1627
}