• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

taosdata / TDengine / #3581

15 Jan 2025 01:12AM UTC coverage: 63.809% (+0.3%) from 63.556%
#3581

push

travis-ci

web-flow
Merge pull request #29561 from taosdata/fix/TD-33504

fix:[TD-33504]add test case

141492 of 284535 branches covered (49.73%)

Branch coverage included in aggregate %.

219814 of 281694 relevant lines covered (78.03%)

19173854.68 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

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

16
#include "function.h"
17
#include "functionMgt.h"
18
#include "index.h"
19
#include "os.h"
20
#include "query.h"
21
#include "tdatablock.h"
22
#include "thash.h"
23
#include "tmsg.h"
24
#include "ttime.h"
25

26
#include "executil.h"
27
#include "executorInt.h"
28
#include "querytask.h"
29
#include "storageapi.h"
30
#include "tcompression.h"
31

32
typedef struct tagFilterAssist {
33
  SHashObj* colHash;
34
  int32_t   index;
35
  SArray*   cInfoList;
36
  int32_t   code;
37
} tagFilterAssist;
38

39
typedef struct STransTagExprCtx {
40
  int32_t      code;
41
  SMetaReader* pReader;
42
} STransTagExprCtx;
43

44
typedef enum {
45
  FILTER_NO_LOGIC = 1,
46
  FILTER_AND,
47
  FILTER_OTHER,
48
} FilterCondType;
49

50
static FilterCondType checkTagCond(SNode* cond);
51
static int32_t optimizeTbnameInCond(void* metaHandle, int64_t suid, SArray* list, SNode* pTagCond, SStorageAPI* pAPI);
52
static int32_t optimizeTbnameInCondImpl(void* metaHandle, SArray* list, SNode* pTagCond, SStorageAPI* pStoreAPI);
53

54
static int32_t getTableList(void* pVnode, SScanPhysiNode* pScanNode, SNode* pTagCond, SNode* pTagIndexCond,
55
                            STableListInfo* pListInfo, uint8_t* digest, const char* idstr, SStorageAPI* pStorageAPI);
56

57
static int64_t getLimit(const SNode* pLimit) { return NULL == pLimit ? -1 : ((SLimitNode*)pLimit)->limit; }
27,999,614✔
58
static int64_t getOffset(const SNode* pLimit) { return NULL == pLimit ? -1 : ((SLimitNode*)pLimit)->offset; }
28,010,068✔
59
static void    releaseColInfoData(void* pCol);
60

61
void initResultRowInfo(SResultRowInfo* pResultRowInfo) {
11,628,462✔
62
  pResultRowInfo->size = 0;
11,628,462✔
63
  pResultRowInfo->cur.pageId = -1;
11,628,462✔
64
}
11,628,462✔
65

66
void closeResultRow(SResultRow* pResultRow) { pResultRow->closed = true; }
8,845,968✔
67

68
void resetResultRow(SResultRow* pResultRow, size_t entrySize) {
71,249,503✔
69
  pResultRow->numOfRows = 0;
71,249,503✔
70
  pResultRow->closed = false;
71,249,503✔
71
  pResultRow->endInterp = false;
71,249,503✔
72
  pResultRow->startInterp = false;
71,249,503✔
73

74
  if (entrySize > 0) {
71,249,503!
75
    memset(pResultRow->pEntryInfo, 0, entrySize);
71,255,679✔
76
  }
77
}
71,249,503✔
78

79
// TODO refactor: use macro
80
SResultRowEntryInfo* getResultEntryInfo(const SResultRow* pRow, int32_t index, const int32_t* offset) {
2,147,483,647✔
81
  return (SResultRowEntryInfo*)((char*)pRow->pEntryInfo + offset[index]);
2,147,483,647✔
82
}
83

84
size_t getResultRowSize(SqlFunctionCtx* pCtx, int32_t numOfOutput) {
8,619,841✔
85
  int32_t rowSize = (numOfOutput * sizeof(SResultRowEntryInfo)) + sizeof(SResultRow);
8,619,841✔
86

87
  for (int32_t i = 0; i < numOfOutput; ++i) {
38,187,006✔
88
    rowSize += pCtx[i].resDataInfo.interBufSize;
29,567,165✔
89
  }
90

91
  return rowSize;
8,619,841✔
92
}
93

94
// Convert buf read from rocksdb to result row
95
int32_t getResultRowFromBuf(SExprSupp *pSup, const char* inBuf, size_t inBufSize, char **outBuf, size_t *outBufSize) {
2,721✔
96
  if (inBuf == NULL || pSup == NULL) {
2,721!
97
    qError("invalid input parameters, inBuf:%p, pSup:%p", inBuf, pSup);
18!
98
    return TSDB_CODE_INVALID_PARA;
18✔
99
  }
100
  SqlFunctionCtx *pCtx = pSup->pCtx;
2,703✔
101
  int32_t        *offset = pSup->rowEntryInfoOffset;
2,703✔
102
  SResultRow     *pResultRow  = NULL;
2,703✔
103
  size_t          processedSize = 0;
2,703✔
104
  int32_t         code = TSDB_CODE_SUCCESS;
2,703✔
105

106
  // calculate the size of output buffer
107
  *outBufSize = getResultRowSize(pCtx, pSup->numOfExprs);
2,703✔
108
  *outBuf = taosMemoryMalloc(*outBufSize);
2,703!
109
  if (*outBuf == NULL) {
2,703!
110
    qError("failed to allocate memory for output buffer, size:%zu", *outBufSize);
×
111
    return terrno;
×
112
  }
113
  pResultRow = (SResultRow*)*outBuf;
2,703✔
114
  (void)memcpy(pResultRow, inBuf, sizeof(SResultRow));
2,703✔
115
  inBuf += sizeof(SResultRow);
2,703✔
116
  processedSize += sizeof(SResultRow);
2,703✔
117

118
  for (int32_t i = 0; i < pSup->numOfExprs; ++i) {
41,273✔
119
    int32_t len = *(int32_t*)inBuf;
38,570✔
120
    inBuf += sizeof(int32_t);
38,570✔
121
    processedSize += sizeof(int32_t);
38,570✔
122
    if (pResultRow->version != FUNCTION_RESULT_INFO_VERSION && pCtx->fpSet.decode) {
38,570!
123
      code = pCtx->fpSet.decode(&pCtx[i], inBuf, getResultEntryInfo(pResultRow, i, offset), pResultRow->version);
×
124
      if (code != TSDB_CODE_SUCCESS) {
×
125
        qError("failed to decode result row, code:%d", code);
×
126
        return code;
×
127
      }
128
    } else {
129
      (void)memcpy(getResultEntryInfo(pResultRow, i, offset), inBuf, len);
38,570✔
130
    }
131
    inBuf += len;
38,570✔
132
    processedSize += len;
38,570✔
133
  }
134

135
  if (processedSize < inBufSize) {
2,703✔
136
    // stream stores extra data after result row
137
    size_t leftLen = inBufSize - processedSize;
1,049✔
138
    TAOS_MEMORY_REALLOC(*outBuf, *outBufSize + leftLen);
1,049!
139
    if (*outBuf == NULL) {
1,049!
140
      qError("failed to reallocate memory for output buffer, size:%zu", *outBufSize + leftLen);
×
141
      return terrno;
×
142
    }
143
    (void)memcpy(*outBuf + *outBufSize, inBuf, leftLen);
1,049✔
144
    inBuf += leftLen;
1,049✔
145
    processedSize += leftLen;
1,049✔
146
    *outBufSize += leftLen;
1,049✔
147
  }
148
  return TSDB_CODE_SUCCESS;
2,703✔
149
}
150

151
// Convert result row to buf for rocksdb
152
int32_t putResultRowToBuf(SExprSupp *pSup, const char* inBuf, size_t inBufSize, char **outBuf, size_t *outBufSize) {
1,791,284✔
153
  if (pSup == NULL || inBuf == NULL || outBuf == NULL || outBufSize == NULL) {
1,791,284!
154
    qError("invalid input parameters, inBuf:%p, pSup:%p, outBufSize:%p, outBuf:%p", inBuf, pSup, outBufSize, outBuf);
64!
155
    return TSDB_CODE_INVALID_PARA;
×
156
  }
157

158
  SqlFunctionCtx *pCtx = pSup->pCtx;
1,791,220✔
159
  int32_t        *offset = pSup->rowEntryInfoOffset;
1,791,220✔
160
  SResultRow     *pResultRow = (SResultRow*)inBuf;
1,791,220✔
161
  size_t          rowSize = getResultRowSize(pCtx, pSup->numOfExprs);
1,791,220✔
162

163
  if (rowSize > inBufSize) {
1,790,726!
164
    qError("invalid input buffer size, rowSize:%zu, inBufSize:%zu", rowSize, inBufSize);
×
165
    return TSDB_CODE_INVALID_PARA;
×
166
  }
167

168
  // calculate the size of output buffer
169
  *outBufSize = rowSize + sizeof(int32_t) * pSup->numOfExprs;
1,790,726✔
170
  if (rowSize < inBufSize) {
1,790,726✔
171
    *outBufSize += inBufSize - rowSize;
1,445✔
172
  }
173

174
  *outBuf = taosMemoryMalloc(*outBufSize);
1,790,726!
175
  if (*outBuf == NULL) {
1,790,435!
176
    qError("failed to allocate memory for output buffer, size:%zu", *outBufSize);
×
177
    return terrno;
×
178
  }
179

180
  char *pBuf = *outBuf;
1,790,435✔
181
  pResultRow->version = FUNCTION_RESULT_INFO_VERSION;
1,790,435✔
182
  (void)memcpy(pBuf, pResultRow, sizeof(SResultRow));
1,790,435✔
183
  pBuf += sizeof(SResultRow);
1,790,435✔
184
  for (int32_t i = 0; i < pSup->numOfExprs; ++i) {
11,017,819✔
185
    size_t len = sizeof(SResultRowEntryInfo) + pCtx[i].resDataInfo.interBufSize;
9,233,965✔
186
    *(int32_t *) pBuf = (int32_t)len;
9,233,965✔
187
    pBuf += sizeof(int32_t);
9,233,965✔
188
    (void)memcpy(pBuf, getResultEntryInfo(pResultRow, i, offset), len);
9,233,965✔
189
    pBuf += len;
9,227,384✔
190
  }
191

192
  if (rowSize < inBufSize) {
1,783,854✔
193
    // stream stores extra data after result row
194
    size_t leftLen = inBufSize - rowSize;
1,445✔
195
    (void)memcpy(pBuf, inBuf + rowSize, leftLen);
1,445✔
196
    pBuf += leftLen;
1,445✔
197
  }
198
  return TSDB_CODE_SUCCESS;
1,783,854✔
199
}
200

201
static void freeEx(void* p) { taosMemoryFree(*(void**)p); }
×
202

203
void cleanupGroupResInfo(SGroupResInfo* pGroupResInfo) {
4,635,980✔
204
  taosMemoryFreeClear(pGroupResInfo->pBuf);
4,635,980!
205
  if (pGroupResInfo->freeItem) {
4,636,831!
206
    //    taosArrayDestroy(pGroupResInfo->pRows);
207
    taosArrayDestroyEx(pGroupResInfo->pRows, freeEx);
×
208
    pGroupResInfo->freeItem = false;
×
209
    pGroupResInfo->pRows = NULL;
×
210
  } else {
211
    taosArrayDestroy(pGroupResInfo->pRows);
4,636,831✔
212
    pGroupResInfo->pRows = NULL;
4,637,616✔
213
  }
214
  pGroupResInfo->index = 0;
4,637,616✔
215
}
4,637,616✔
216

217
int32_t resultrowComparAsc(const void* p1, const void* p2) {
1,934,502,004✔
218
  SResKeyPos* pp1 = *(SResKeyPos**)p1;
1,934,502,004✔
219
  SResKeyPos* pp2 = *(SResKeyPos**)p2;
1,934,502,004✔
220

221
  if (pp1->groupId == pp2->groupId) {
1,934,502,004✔
222
    int64_t pts1 = *(int64_t*)pp1->key;
1,746,360,489✔
223
    int64_t pts2 = *(int64_t*)pp2->key;
1,746,360,489✔
224

225
    if (pts1 == pts2) {
1,746,360,489!
226
      return 0;
×
227
    } else {
228
      return pts1 < pts2 ? -1 : 1;
1,746,360,489✔
229
    }
230
  } else {
231
    return pp1->groupId < pp2->groupId ? -1 : 1;
188,141,515✔
232
  }
233
}
234

235
static int32_t resultrowComparDesc(const void* p1, const void* p2) { return resultrowComparAsc(p2, p1); }
78,965,326✔
236

237
int32_t initGroupedResultInfo(SGroupResInfo* pGroupResInfo, SSHashObj* pHashmap, int32_t order) {
3,737,227✔
238
  int32_t code = TSDB_CODE_SUCCESS;
3,737,227✔
239
  int32_t lino = 0;
3,737,227✔
240
  if (pGroupResInfo->pRows != NULL) {
3,737,227✔
241
    taosArrayDestroy(pGroupResInfo->pRows);
49,902✔
242
  }
243
  if (pGroupResInfo->pBuf) {
3,737,227✔
244
    taosMemoryFree(pGroupResInfo->pBuf);
49,902!
245
    pGroupResInfo->pBuf = NULL;
49,902✔
246
  }
247

248
  // extract the result rows information from the hash map
249
  int32_t size = tSimpleHashGetSize(pHashmap);
3,737,227✔
250

251
  void* pData = NULL;
3,737,430✔
252
  pGroupResInfo->pRows = taosArrayInit(size, POINTER_BYTES);
3,737,430✔
253
  QUERY_CHECK_NULL(pGroupResInfo->pRows, code, lino, _end, terrno);
3,738,372!
254

255
  size_t  keyLen = 0;
3,738,372✔
256
  int32_t iter = 0;
3,738,372✔
257
  int64_t bufLen = 0, offset = 0;
3,738,372✔
258

259
  // todo move away and record this during create window
260
  while ((pData = tSimpleHashIterate(pHashmap, pData, &iter)) != NULL) {
213,639,532✔
261
    /*void* key = */ (void)tSimpleHashGetKey(pData, &keyLen);
262
    bufLen += keyLen + sizeof(SResultRowPosition);
209,901,160✔
263
  }
264

265
  pGroupResInfo->pBuf = taosMemoryMalloc(bufLen);
3,727,184!
266
  QUERY_CHECK_NULL(pGroupResInfo->pBuf, code, lino, _end, terrno);
3,738,433!
267

268
  iter = 0;
3,738,433✔
269
  while ((pData = tSimpleHashIterate(pHashmap, pData, &iter)) != NULL) {
213,342,731✔
270
    void* key = tSimpleHashGetKey(pData, &keyLen);
209,629,556✔
271

272
    SResKeyPos* p = (SResKeyPos*)(pGroupResInfo->pBuf + offset);
209,629,556✔
273

274
    p->groupId = *(uint64_t*)key;
209,629,556✔
275
    p->pos = *(SResultRowPosition*)pData;
209,629,556✔
276
    memcpy(p->key, (char*)key + sizeof(uint64_t), keyLen - sizeof(uint64_t));
209,629,556✔
277
    void* tmp = taosArrayPush(pGroupResInfo->pRows, &p);
209,629,556✔
278
    QUERY_CHECK_NULL(pGroupResInfo->pBuf, code, lino, _end, terrno);
209,604,298!
279

280
    offset += keyLen + sizeof(struct SResultRowPosition);
209,604,298✔
281
  }
282

283
  if (order == TSDB_ORDER_ASC || order == TSDB_ORDER_DESC) {
3,738,567✔
284
    __compar_fn_t fn = (order == TSDB_ORDER_ASC) ? resultrowComparAsc : resultrowComparDesc;
1,653,364✔
285
    size = POINTER_BYTES;
1,653,364✔
286
    taosSort(pGroupResInfo->pRows->pData, taosArrayGetSize(pGroupResInfo->pRows), size, fn);
1,653,364✔
287
  }
288

289
  pGroupResInfo->index = 0;
3,739,005✔
290

291
_end:
3,739,005✔
292
  if (code != TSDB_CODE_SUCCESS) {
3,739,005!
293
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
294
  }
295
  return code;
3,738,411✔
296
}
297

298
void initMultiResInfoFromArrayList(SGroupResInfo* pGroupResInfo, SArray* pArrayList) {
36,901✔
299
  if (pGroupResInfo->pRows != NULL) {
36,901✔
300
    taosArrayDestroy(pGroupResInfo->pRows);
32,912✔
301
  }
302

303
  pGroupResInfo->freeItem = true;
36,904✔
304
  pGroupResInfo->pRows = pArrayList;
36,904✔
305
  pGroupResInfo->index = 0;
36,904✔
306
}
36,904✔
307

308
bool hasRemainResults(SGroupResInfo* pGroupResInfo) {
10,811,403✔
309
  if (pGroupResInfo->pRows == NULL) {
10,811,403✔
310
    return false;
1,486✔
311
  }
312

313
  return pGroupResInfo->index < taosArrayGetSize(pGroupResInfo->pRows);
10,809,917✔
314
}
315

316
int32_t getNumOfTotalRes(SGroupResInfo* pGroupResInfo) {
7,112,150✔
317
  if (pGroupResInfo->pRows == 0) {
7,112,150✔
318
    return 0;
1,769✔
319
  }
320

321
  return (int32_t)taosArrayGetSize(pGroupResInfo->pRows);
7,110,381✔
322
}
323

324
SArray* createSortInfo(SNodeList* pNodeList) {
2,277,319✔
325
  size_t numOfCols = 0;
2,277,319✔
326

327
  if (pNodeList != NULL) {
2,277,319✔
328
    numOfCols = LIST_LENGTH(pNodeList);
2,276,284!
329
  } else {
330
    numOfCols = 0;
1,035✔
331
  }
332

333
  SArray* pList = taosArrayInit(numOfCols, sizeof(SBlockOrderInfo));
2,277,319✔
334
  if (pList == NULL) {
2,277,411!
335
    return pList;
×
336
  }
337

338
  for (int32_t i = 0; i < numOfCols; ++i) {
4,703,208✔
339
    SOrderByExprNode* pSortKey = (SOrderByExprNode*)nodesListGetNode(pNodeList, i);
2,425,720✔
340
    if (!pSortKey) {
2,425,787✔
341
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
13!
342
      taosArrayDestroy(pList);
13✔
343
      pList = NULL;
×
344
      terrno = TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR;
×
345
      break;
×
346
    }
347
    SBlockOrderInfo   bi = {0};
2,425,774✔
348
    bi.order = (pSortKey->order == ORDER_ASC) ? TSDB_ORDER_ASC : TSDB_ORDER_DESC;
2,425,774✔
349
    bi.nullFirst = (pSortKey->nullOrder == NULL_ORDER_FIRST);
2,425,774✔
350

351
    SColumnNode* pColNode = (SColumnNode*)pSortKey->pExpr;
2,425,774✔
352
    bi.slotId = pColNode->slotId;
2,425,774✔
353
    void* tmp = taosArrayPush(pList, &bi);
2,425,797✔
354
    if (!tmp) {
2,425,797!
355
      taosArrayDestroy(pList);
×
356
      pList = NULL;
×
357
      break;
×
358
    }
359
  }
360

361
  return pList;
2,277,488✔
362
}
363

364
SSDataBlock* createDataBlockFromDescNode(SDataBlockDescNode* pNode) {
21,115,304✔
365
  int32_t      numOfCols = LIST_LENGTH(pNode->pSlots);
21,115,304!
366
  SSDataBlock* pBlock = NULL;
21,115,304✔
367
  int32_t      code = createDataBlock(&pBlock);
21,115,304✔
368
  if (code) {
21,127,273!
369
    terrno = code;
×
370
    return NULL;
×
371
  }
372

373
  pBlock->info.id.blockId = pNode->dataBlockId;
21,133,369✔
374
  pBlock->info.type = STREAM_INVALID;
21,133,369✔
375
  pBlock->info.calWin = (STimeWindow){.skey = INT64_MIN, .ekey = INT64_MAX};
21,133,369✔
376
  pBlock->info.watermark = INT64_MIN;
21,133,369✔
377

378
  for (int32_t i = 0; i < numOfCols; ++i) {
113,172,399✔
379
    SSlotDescNode*  pDescNode = (SSlotDescNode*)nodesListGetNode(pNode->pSlots, i);
92,026,545✔
380
    if (!pDescNode) {
92,102,155!
381
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
×
382
      blockDataDestroy(pBlock);
×
383
      pBlock = NULL;
×
384
      terrno = TSDB_CODE_INVALID_PARA;
×
385
      break;
×
386
    }
387
    SColumnInfoData idata =
388
        createColumnInfoData(pDescNode->dataType.type, pDescNode->dataType.bytes, pDescNode->slotId);
92,102,155✔
389
    idata.info.scale = pDescNode->dataType.scale;
92,190,769✔
390
    idata.info.precision = pDescNode->dataType.precision;
92,190,769✔
391
    idata.info.noData = pDescNode->reserve;
92,190,769✔
392

393
    code = blockDataAppendColInfo(pBlock, &idata);
92,190,769✔
394
    if (code != TSDB_CODE_SUCCESS) {
92,039,030!
395
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
×
396
      blockDataDestroy(pBlock);
×
397
      pBlock = NULL;
×
398
      terrno = code;
×
399
      break;
×
400
    }
401
  }
402

403
  return pBlock;
21,145,854✔
404
}
405

406
int32_t prepareDataBlockBuf(SSDataBlock* pDataBlock, SColMatchInfo* pMatchInfo) {
4,919,053✔
407
  SDataBlockInfo* pBlockInfo = &pDataBlock->info;
4,919,053✔
408

409
  for (int32_t i = 0; i < taosArrayGetSize(pMatchInfo->pList); ++i) {
27,972,131✔
410
    SColMatchItem* pItem = taosArrayGet(pMatchInfo->pList, i);
23,272,005✔
411
    if (!pItem) {
23,283,499✔
412
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
1,222!
413
      return terrno;
1,222✔
414
    }
415

416
    if (pItem->isPk) {
23,282,277✔
417
      SColumnInfoData* pInfoData = taosArrayGet(pDataBlock->pDataBlock, pItem->dstSlotId);
229,199✔
418
      if (!pInfoData) {
229,207!
419
        qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
420
        return terrno;
×
421
      }
422
      pBlockInfo->pks[0].type = pInfoData->info.type;
229,207✔
423
      pBlockInfo->pks[1].type = pInfoData->info.type;
229,207✔
424

425
      // allocate enough buffer size, which is pInfoData->info.bytes
426
      if (IS_VAR_DATA_TYPE(pItem->dataType.type)) {
229,207!
427
        pBlockInfo->pks[0].pData = taosMemoryCalloc(1, pInfoData->info.bytes);
26,872!
428
        if (pBlockInfo->pks[0].pData == NULL) {
26,840!
429
          return terrno;
×
430
        }
431

432
        pBlockInfo->pks[1].pData = taosMemoryCalloc(1, pInfoData->info.bytes);
26,840!
433
        if (pBlockInfo->pks[1].pData == NULL) {
26,836!
434
          taosMemoryFreeClear(pBlockInfo->pks[0].pData);
×
435
          return terrno;
×
436
        }
437

438
        pBlockInfo->pks[0].nData = pInfoData->info.bytes;
26,836✔
439
        pBlockInfo->pks[1].nData = pInfoData->info.bytes;
26,836✔
440
      }
441

442
      break;
229,171✔
443
    }
444
  }
445

446
  return TSDB_CODE_SUCCESS;
4,915,837✔
447
}
448

449
EDealRes doTranslateTagExpr(SNode** pNode, void* pContext) {
6,137✔
450
  STransTagExprCtx* pCtx = pContext;
6,137✔
451
  SMetaReader*      mr = pCtx->pReader;
6,137✔
452
  bool              isTagCol = false, isTbname = false;
6,137✔
453
  if (nodeType(*pNode) == QUERY_NODE_COLUMN) {
6,137✔
454
    SColumnNode* pCol = (SColumnNode*)*pNode;
1,765✔
455
    if (pCol->colType == COLUMN_TYPE_TBNAME)
1,765!
456
      isTbname = true;
×
457
    else
458
      isTagCol = true;
1,765✔
459
  } else if (nodeType(*pNode) == QUERY_NODE_FUNCTION) {
4,372!
460
    SFunctionNode* pFunc = (SFunctionNode*)*pNode;
×
461
    if (pFunc->funcType == FUNCTION_TYPE_TBNAME) isTbname = true;
×
462
  }
463
  if (isTagCol) {
6,137✔
464
    SColumnNode* pSColumnNode = *(SColumnNode**)pNode;
1,765✔
465

466
    SValueNode* res = NULL;
1,765✔
467
    pCtx->code = nodesMakeNode(QUERY_NODE_VALUE, (SNode**)&res);
1,765✔
468
    if (NULL == res) {
1,765!
469
      return DEAL_RES_ERROR;
×
470
    }
471

472
    res->translate = true;
1,765✔
473
    res->node.resType = pSColumnNode->node.resType;
1,765✔
474

475
    STagVal tagVal = {0};
1,765✔
476
    tagVal.cid = pSColumnNode->colId;
1,765✔
477
    const char* p = mr->pAPI->extractTagVal(mr->me.ctbEntry.pTags, pSColumnNode->node.resType.type, &tagVal);
1,765✔
478
    if (p == NULL) {
1,765!
479
      res->node.resType.type = TSDB_DATA_TYPE_NULL;
×
480
    } else if (pSColumnNode->node.resType.type == TSDB_DATA_TYPE_JSON) {
1,765!
481
      int32_t len = ((const STag*)p)->len;
×
482
      res->datum.p = taosMemoryCalloc(len + 1, 1);
×
483
      if (NULL == res->datum.p) {
×
484
        return DEAL_RES_ERROR;
×
485
      }
486
      memcpy(res->datum.p, p, len);
×
487
    } else if (IS_VAR_DATA_TYPE(pSColumnNode->node.resType.type)) {
1,765!
488
      res->datum.p = taosMemoryCalloc(tagVal.nData + VARSTR_HEADER_SIZE + 1, 1);
1,742!
489
      if (NULL == res->datum.p) {
1,742!
490
        return DEAL_RES_ERROR;
×
491
      }
492
      memcpy(varDataVal(res->datum.p), tagVal.pData, tagVal.nData);
1,742✔
493
      varDataSetLen(res->datum.p, tagVal.nData);
1,742✔
494
    } else {
495
      int32_t code = nodesSetValueNodeValue(res, &(tagVal.i64));
23✔
496
      if (code != TSDB_CODE_SUCCESS) {
23!
497
        return DEAL_RES_ERROR;
×
498
      }
499
    }
500
    nodesDestroyNode(*pNode);
1,765✔
501
    *pNode = (SNode*)res;
1,765✔
502
  } else if (isTbname) {
4,372!
503
    SValueNode* res = NULL;
×
504
    pCtx->code = nodesMakeNode(QUERY_NODE_VALUE, (SNode**)&res);
×
505
    if (NULL == res) {
×
506
      return DEAL_RES_ERROR;
×
507
    }
508

509
    res->translate = true;
×
510
    res->node.resType = ((SExprNode*)(*pNode))->resType;
×
511

512
    int32_t len = strlen(mr->me.name);
×
513
    res->datum.p = taosMemoryCalloc(len + VARSTR_HEADER_SIZE + 1, 1);
×
514
    if (NULL == res->datum.p) {
×
515
      return DEAL_RES_ERROR;
×
516
    }
517
    memcpy(varDataVal(res->datum.p), mr->me.name, len);
×
518
    varDataSetLen(res->datum.p, len);
×
519
    nodesDestroyNode(*pNode);
×
520
    *pNode = (SNode*)res;
×
521
  }
522

523
  return DEAL_RES_CONTINUE;
6,137✔
524
}
525

526
int32_t isQualifiedTable(STableKeyInfo* info, SNode* pTagCond, void* metaHandle, bool* pQualified, SStorageAPI* pAPI) {
881✔
527
  int32_t     code = TSDB_CODE_SUCCESS;
881✔
528
  SMetaReader mr = {0};
881✔
529

530
  pAPI->metaReaderFn.initReader(&mr, metaHandle, META_READER_LOCK, &pAPI->metaFn);
881✔
531
  code = pAPI->metaReaderFn.getEntryGetUidCache(&mr, info->uid);
881✔
532
  if (TSDB_CODE_SUCCESS != code) {
881!
533
    pAPI->metaReaderFn.clearReader(&mr);
×
534
    *pQualified = false;
×
535

536
    return TSDB_CODE_SUCCESS;
×
537
  }
538

539
  SNode* pTagCondTmp = NULL;
881✔
540
  code = nodesCloneNode(pTagCond, &pTagCondTmp);
881✔
541
  if (TSDB_CODE_SUCCESS != code) {
881!
542
    *pQualified = false;
×
543
    pAPI->metaReaderFn.clearReader(&mr);
×
544
    return code;
×
545
  }
546
  STransTagExprCtx ctx = {.code = 0, .pReader = &mr};
881✔
547
  nodesRewriteExprPostOrder(&pTagCondTmp, doTranslateTagExpr, &ctx);
881✔
548
  pAPI->metaReaderFn.clearReader(&mr);
881✔
549
  if (TSDB_CODE_SUCCESS != ctx.code) {
881!
550
    *pQualified = false;
×
551
    terrno = code;
×
552
    return code;
×
553
  }
554

555
  SNode* pNew = NULL;
881✔
556
  code = scalarCalculateConstants(pTagCondTmp, &pNew);
881✔
557
  if (TSDB_CODE_SUCCESS != code) {
881!
558
    terrno = code;
×
559
    nodesDestroyNode(pTagCondTmp);
×
560
    *pQualified = false;
×
561

562
    return code;
×
563
  }
564

565
  SValueNode* pValue = (SValueNode*)pNew;
881✔
566
  *pQualified = pValue->datum.b;
881✔
567

568
  nodesDestroyNode(pNew);
881✔
569
  return TSDB_CODE_SUCCESS;
881✔
570
}
571

572
static EDealRes getColumn(SNode** pNode, void* pContext) {
99,361,870✔
573
  tagFilterAssist* pData = (tagFilterAssist*)pContext;
99,361,870✔
574
  SColumnNode*     pSColumnNode = NULL;
99,361,870✔
575
  if (QUERY_NODE_COLUMN == nodeType((*pNode))) {
99,361,870✔
576
    pSColumnNode = *(SColumnNode**)pNode;
3,465,705✔
577
  } else if (QUERY_NODE_FUNCTION == nodeType((*pNode))) {
95,896,165✔
578
    SFunctionNode* pFuncNode = *(SFunctionNode**)(pNode);
431,021✔
579
    if (pFuncNode->funcType == FUNCTION_TYPE_TBNAME) {
431,021✔
580
      pData->code = nodesMakeNode(QUERY_NODE_COLUMN, (SNode**)&pSColumnNode);
418,985✔
581
      if (NULL == pSColumnNode) {
418,985!
582
        return DEAL_RES_ERROR;
×
583
      }
584
      pSColumnNode->colId = -1;
418,985✔
585
      pSColumnNode->colType = COLUMN_TYPE_TBNAME;
418,985✔
586
      pSColumnNode->node.resType.type = TSDB_DATA_TYPE_VARCHAR;
418,985✔
587
      pSColumnNode->node.resType.bytes = TSDB_TABLE_FNAME_LEN - 1 + VARSTR_HEADER_SIZE;
418,985✔
588
      nodesDestroyNode(*pNode);
418,985✔
589
      *pNode = (SNode*)pSColumnNode;
418,980✔
590
    } else {
591
      return DEAL_RES_CONTINUE;
12,036✔
592
    }
593
  } else {
594
    return DEAL_RES_CONTINUE;
95,465,144✔
595
  }
596

597
  void* data = taosHashGet(pData->colHash, &pSColumnNode->colId, sizeof(pSColumnNode->colId));
3,884,685✔
598
  if (!data) {
3,883,425✔
599
    int32_t tempRes =
600
        taosHashPut(pData->colHash, &pSColumnNode->colId, sizeof(pSColumnNode->colId), pNode, sizeof((*pNode)));
3,172,372✔
601
    if (tempRes != TSDB_CODE_SUCCESS && tempRes != TSDB_CODE_DUP_KEY) {
3,175,421!
602
      return DEAL_RES_ERROR;
×
603
    }
604
    pSColumnNode->slotId = pData->index++;
3,175,421✔
605
    SColumnInfo cInfo = {.colId = pSColumnNode->colId,
3,175,421✔
606
                         .type = pSColumnNode->node.resType.type,
3,175,421✔
607
                         .bytes = pSColumnNode->node.resType.bytes,
3,175,421✔
608
                         .pk = pSColumnNode->isPk};
3,175,421✔
609
#if TAG_FILTER_DEBUG
610
    qDebug("tagfilter build column info, slotId:%d, colId:%d, type:%d", pSColumnNode->slotId, cInfo.colId, cInfo.type);
611
#endif
612
    void* tmp = taosArrayPush(pData->cInfoList, &cInfo);
3,175,421✔
613
    if (!tmp) {
3,174,228!
614
      return DEAL_RES_ERROR;
×
615
    }
616
  } else {
617
    SColumnNode* col = *(SColumnNode**)data;
711,053✔
618
    pSColumnNode->slotId = col->slotId;
711,053✔
619
  }
620

621
  return DEAL_RES_CONTINUE;
3,885,281✔
622
}
623

624
static int32_t createResultData(SDataType* pType, int32_t numOfRows, SScalarParam* pParam) {
1,355,140✔
625
  SColumnInfoData* pColumnData = taosMemoryCalloc(1, sizeof(SColumnInfoData));
1,355,140!
626
  if (pColumnData == NULL) {
1,355,588!
627
    return terrno;
×
628
  }
629

630
  pColumnData->info.type = pType->type;
1,355,588✔
631
  pColumnData->info.bytes = pType->bytes;
1,355,588✔
632
  pColumnData->info.scale = pType->scale;
1,355,588✔
633
  pColumnData->info.precision = pType->precision;
1,355,588✔
634

635
  int32_t code = colInfoDataEnsureCapacity(pColumnData, numOfRows, true);
1,355,588✔
636
  if (code != TSDB_CODE_SUCCESS) {
1,355,624!
637
    terrno = code;
×
638
    releaseColInfoData(pColumnData);
×
639
    return terrno;
×
640
  }
641

642
  pParam->columnData = pColumnData;
1,355,647✔
643
  pParam->colAlloced = true;
1,355,647✔
644
  return TSDB_CODE_SUCCESS;
1,355,647✔
645
}
646

647
static void releaseColInfoData(void* pCol) {
76,299✔
648
  if (pCol) {
76,299!
649
    SColumnInfoData* col = (SColumnInfoData*)pCol;
76,300✔
650
    colDataDestroy(col);
76,300✔
651
    taosMemoryFree(col);
76,308✔
652
  }
653
}
76,310✔
654

655
void freeItem(void* p) {
3,316,380✔
656
  STUidTagInfo* pInfo = p;
3,316,380✔
657
  if (pInfo->pTagVal != NULL) {
3,316,380✔
658
    taosMemoryFree(pInfo->pTagVal);
3,146,179!
659
  }
660
}
3,317,520✔
661

662
static int32_t genTagFilterDigest(const SNode* pTagCond, T_MD5_CTX* pContext) {
×
663
  if (pTagCond == NULL) {
×
664
    return TSDB_CODE_SUCCESS;
×
665
  }
666

667
  char*   payload = NULL;
×
668
  int32_t len = 0;
×
669
  int32_t code = nodesNodeToMsg(pTagCond, &payload, &len);
×
670
  if (code != TSDB_CODE_SUCCESS) {
×
671
    qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
×
672
    return code;
×
673
  }
674

675
  tMD5Init(pContext);
×
676
  tMD5Update(pContext, (uint8_t*)payload, (uint32_t)len);
×
677
  tMD5Final(pContext);
×
678

679
  taosMemoryFree(payload);
×
680
  return TSDB_CODE_SUCCESS;
×
681
}
682

683
static int32_t genTbGroupDigest(const SNode* pGroup, uint8_t* filterDigest, T_MD5_CTX* pContext) {
×
684
  int32_t code = TSDB_CODE_SUCCESS;
×
685
  int32_t lino = 0;
×
686
  char*   payload = NULL;
×
687
  int32_t len = 0;
×
688
  code = nodesNodeToMsg(pGroup, &payload, &len);
×
689
  QUERY_CHECK_CODE(code, lino, _end);
×
690

691
  if (filterDigest[0]) {
×
692
    payload = taosMemoryRealloc(payload, len + tListLen(pContext->digest));
×
693
    QUERY_CHECK_NULL(payload, code, lino, _end, terrno);
×
694
    memcpy(payload + len, filterDigest + 1, tListLen(pContext->digest));
×
695
    len += tListLen(pContext->digest);
×
696
  }
697

698
  tMD5Init(pContext);
×
699
  tMD5Update(pContext, (uint8_t*)payload, (uint32_t)len);
×
700
  tMD5Final(pContext);
×
701

702
_end:
×
703
  taosMemoryFree(payload);
×
704
  if (code != TSDB_CODE_SUCCESS) {
×
705
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
706
  }
707
  return code;
×
708
}
709

710
int32_t getColInfoResultForGroupby(void* pVnode, SNodeList* group, STableListInfo* pTableListInfo, uint8_t* digest,
64,141✔
711
                                   SStorageAPI* pAPI, bool initRemainGroups) {
712
  int32_t      code = TSDB_CODE_SUCCESS;
64,141✔
713
  int32_t      lino = 0;
64,141✔
714
  SArray*      pBlockList = NULL;
64,141✔
715
  SSDataBlock* pResBlock = NULL;
64,141✔
716
  void*        keyBuf = NULL;
64,141✔
717
  SArray*      groupData = NULL;
64,141✔
718
  SArray*      pUidTagList = NULL;
64,141✔
719
  SArray*      tableList = NULL;
64,141✔
720

721
  int32_t rows = taosArrayGetSize(pTableListInfo->pTableList);
64,141✔
722
  if (rows == 0) {
64,177!
723
    return TSDB_CODE_SUCCESS;
×
724
  }
725

726
  tagFilterAssist ctx = {0};
64,177✔
727
  ctx.colHash = taosHashInit(4, taosGetDefaultHashFunction(TSDB_DATA_TYPE_SMALLINT), false, HASH_NO_LOCK);
64,177✔
728
  if (ctx.colHash == NULL) {
64,199!
729
    code = terrno;
×
730
    goto end;
×
731
  }
732

733
  ctx.index = 0;
64,199✔
734
  ctx.cInfoList = taosArrayInit(4, sizeof(SColumnInfo));
64,199✔
735
  if (ctx.cInfoList == NULL) {
64,218✔
736
    code = terrno;
23✔
737
    goto end;
×
738
  }
739

740
  SNode* pNode = NULL;
64,195✔
741
  FOREACH(pNode, group) {
140,471!
742
    nodesRewriteExprPostOrder(&pNode, getColumn, (void*)&ctx);
76,248✔
743
    if (TSDB_CODE_SUCCESS != ctx.code) {
76,276!
744
      code = ctx.code;
×
745
      goto end;
×
746
    }
747
    REPLACE_NODE(pNode);
76,276✔
748
  }
749

750
  T_MD5_CTX context = {0};
64,223✔
751
  if (tsTagFilterCache) {
64,223!
752
    SNodeListNode* listNode = NULL;
×
753
    code = nodesMakeNode(QUERY_NODE_NODE_LIST, (SNode**)&listNode);
×
754
    if (TSDB_CODE_SUCCESS != code) {
×
755
      goto end;
×
756
    }
757
    listNode->pNodeList = group;
×
758
    code = genTbGroupDigest((SNode*)listNode, digest, &context);
×
759
    QUERY_CHECK_CODE(code, lino, end);
×
760

761
    nodesFree(listNode);
×
762

763
    code = pAPI->metaFn.metaGetCachedTbGroup(pVnode, pTableListInfo->idInfo.suid, context.digest,
×
764
                                             tListLen(context.digest), &tableList);
765
    QUERY_CHECK_CODE(code, lino, end);
×
766

767
    if (tableList) {
×
768
      taosArrayDestroy(pTableListInfo->pTableList);
×
769
      pTableListInfo->pTableList = tableList;
×
770
      qDebug("retrieve tb group list from cache, numOfTables:%d",
×
771
             (int32_t)taosArrayGetSize(pTableListInfo->pTableList));
772
      goto end;
×
773
    }
774
  }
775

776
  pUidTagList = taosArrayInit(8, sizeof(STUidTagInfo));
64,223✔
777
  QUERY_CHECK_NULL(pUidTagList, code, lino, end, terrno);
64,134!
778

779
  for (int32_t i = 0; i < rows; ++i) {
312,065✔
780
    STableKeyInfo* pkeyInfo = taosArrayGet(pTableListInfo->pTableList, i);
247,832✔
781
    QUERY_CHECK_NULL(pkeyInfo, code, lino, end, terrno);
247,766!
782
    STUidTagInfo   info = {.uid = pkeyInfo->uid};
247,766✔
783
    void*          tmp = taosArrayPush(pUidTagList, &info);
247,924✔
784
    QUERY_CHECK_NULL(tmp, code, lino, end, terrno);
247,924!
785
  }
786

787
  code = pAPI->metaFn.getTableTags(pVnode, pTableListInfo->idInfo.suid, pUidTagList);
64,233✔
788
  if (code != TSDB_CODE_SUCCESS) {
64,241!
789
    goto end;
×
790
  }
791

792
  int32_t numOfTables = taosArrayGetSize(pUidTagList);
64,241✔
793
  pResBlock = createTagValBlockForFilter(ctx.cInfoList, numOfTables, pUidTagList, pVnode, pAPI);
64,230✔
794
  if (pResBlock == NULL) {
64,228!
795
    code = terrno;
×
796
    goto end;
×
797
  }
798

799
  //  int64_t st1 = taosGetTimestampUs();
800
  //  qDebug("generate tag block rows:%d, cost:%ld us", rows, st1-st);
801

802
  pBlockList = taosArrayInit(2, POINTER_BYTES);
64,228✔
803
  QUERY_CHECK_NULL(pBlockList, code, lino, end, terrno);
64,234!
804

805
  void* tmp = taosArrayPush(pBlockList, &pResBlock);
64,226✔
806
  QUERY_CHECK_NULL(tmp, code, lino, end, terrno);
64,226!
807

808
  groupData = taosArrayInit(2, POINTER_BYTES);
64,226✔
809
  QUERY_CHECK_NULL(groupData, code, lino, end, terrno);
64,230!
810

811
  FOREACH(pNode, group) {
140,519!
812
    SScalarParam output = {0};
76,294✔
813

814
    switch (nodeType(pNode)) {
76,294!
815
      case QUERY_NODE_VALUE:
×
816
        break;
×
817
      case QUERY_NODE_COLUMN:
76,294✔
818
      case QUERY_NODE_OPERATOR:
819
      case QUERY_NODE_FUNCTION: {
820
        SExprNode* expNode = (SExprNode*)pNode;
76,294✔
821
        code = createResultData(&expNode->resType, rows, &output);
76,294✔
822
        if (code != TSDB_CODE_SUCCESS) {
76,303!
823
          goto end;
×
824
        }
825
        break;
76,303✔
826
      }
827

828
      default:
×
829
        code = TSDB_CODE_OPS_NOT_SUPPORT;
×
830
        goto end;
×
831
    }
832

833
    if (nodeType(pNode) == QUERY_NODE_COLUMN) {
76,303✔
834
      SColumnNode*     pSColumnNode = (SColumnNode*)pNode;
71,837✔
835
      SColumnInfoData* pColInfo = (SColumnInfoData*)taosArrayGet(pResBlock->pDataBlock, pSColumnNode->slotId);
71,837✔
836
      QUERY_CHECK_NULL(pColInfo, code, lino, end, terrno);
71,816!
837
      code = colDataAssign(output.columnData, pColInfo, rows, NULL);
71,816✔
838
    } else if (nodeType(pNode) == QUERY_NODE_VALUE) {
4,466!
839
      continue;
×
840
    } else {
841
      code = scalarCalculate(pNode, pBlockList, &output);
4,466✔
842
    }
843

844
    if (code != TSDB_CODE_SUCCESS) {
76,284!
845
      releaseColInfoData(output.columnData);
×
846
      goto end;
×
847
    }
848

849
    void* tmp = taosArrayPush(groupData, &output.columnData);
76,289✔
850
    QUERY_CHECK_NULL(tmp, code, lino, end, terrno);
76,289!
851
  }
852

853
  int32_t keyLen = 0;
64,225✔
854
  SNode*  node;
855
  FOREACH(node, group) {
140,507✔
856
    SExprNode* pExpr = (SExprNode*)node;
76,282✔
857
    keyLen += pExpr->resType.bytes;
76,282✔
858
  }
859

860
  int32_t nullFlagSize = sizeof(int8_t) * LIST_LENGTH(group);
64,225✔
861
  keyLen += nullFlagSize;
64,225✔
862

863
  keyBuf = taosMemoryCalloc(1, keyLen);
64,225✔
864
  if (keyBuf == NULL) {
64,214!
865
    code = terrno;
×
866
    goto end;
×
867
  }
868

869
  if (initRemainGroups) {
64,214✔
870
    pTableListInfo->remainGroups =
13,012✔
871
        taosHashInit(rows, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BIGINT), false, HASH_NO_LOCK);
13,022✔
872
    if (pTableListInfo->remainGroups == NULL) {
13,012!
873
      code = terrno;
×
874
      goto end;
×
875
    }
876
  }
877

878
  for (int i = 0; i < rows; i++) {
312,120✔
879
    STableKeyInfo* info = taosArrayGet(pTableListInfo->pTableList, i);
247,868✔
880
    QUERY_CHECK_NULL(info, code, lino, end, terrno);
247,784✔
881

882
    char* isNull = (char*)keyBuf;
247,778✔
883
    char* pStart = (char*)keyBuf + sizeof(int8_t) * LIST_LENGTH(group);
247,778!
884
    for (int j = 0; j < taosArrayGetSize(groupData); j++) {
524,849✔
885
      SColumnInfoData* pValue = (SColumnInfoData*)taosArrayGetP(groupData, j);
277,191✔
886

887
      if (colDataIsNull_s(pValue, i)) {
554,170✔
888
        isNull[j] = 1;
486✔
889
      } else {
890
        isNull[j] = 0;
276,599✔
891
        char* data = colDataGetData(pValue, i);
276,599!
892
        if (pValue->info.type == TSDB_DATA_TYPE_JSON) {
276,599✔
893
          if (tTagIsJson(data)) {
264✔
894
            code = TSDB_CODE_QRY_JSON_IN_GROUP_ERROR;
12✔
895
            goto end;
12✔
896
          }
897
          if (tTagIsJsonNull(data)) {
252!
898
            isNull[j] = 1;
×
899
            continue;
×
900
          }
901
          int32_t len = getJsonValueLen(data);
252✔
902
          memcpy(pStart, data, len);
252✔
903
          pStart += len;
252✔
904
        } else if (IS_VAR_DATA_TYPE(pValue->info.type)) {
276,335!
905
          if (varDataTLen(data) > pValue->info.bytes) {
246,444✔
906
            code = TSDB_CODE_TDB_INVALID_TABLE_SCHEMA_VER;
2✔
907
            goto end;
2✔
908
          }
909
          memcpy(pStart, data, varDataTLen(data));
246,442✔
910
          pStart += varDataTLen(data);
246,442✔
911
        } else {
912
          memcpy(pStart, data, pValue->info.bytes);
29,891✔
913
          pStart += pValue->info.bytes;
29,891✔
914
        }
915
      }
916
    }
917

918
    int32_t len = (int32_t)(pStart - (char*)keyBuf);
246,778✔
919
    info->groupId = calcGroupId(keyBuf, len);
246,778✔
920
    if (initRemainGroups) {
247,921✔
921
      // groupId ~ table uid
922
      code = taosHashPut(pTableListInfo->remainGroups, &(info->groupId), sizeof(info->groupId), &(info->uid),
76,381✔
923
                         sizeof(info->uid));
924
      if (code == TSDB_CODE_DUP_KEY) {
76,376✔
925
        code = TSDB_CODE_SUCCESS;
1,261✔
926
      }
927
      QUERY_CHECK_CODE(code, lino, end);
76,376!
928
    }
929
  }
930

931
  if (tsTagFilterCache) {
64,252!
932
    tableList = taosArrayDup(pTableListInfo->pTableList, NULL);
×
933
    QUERY_CHECK_NULL(tableList, code, lino, end, terrno);
×
934

935
    code = pAPI->metaFn.metaPutTbGroupToCache(pVnode, pTableListInfo->idInfo.suid, context.digest,
×
936
                                              tListLen(context.digest), tableList,
937
                                              taosArrayGetSize(tableList) * sizeof(STableKeyInfo));
×
938
    QUERY_CHECK_CODE(code, lino, end);
×
939
  }
940

941
  //  int64_t st2 = taosGetTimestampUs();
942
  //  qDebug("calculate tag block rows:%d, cost:%ld us", rows, st2-st1);
943

944
end:
64,252✔
945
  taosMemoryFreeClear(keyBuf);
64,266!
946
  taosHashCleanup(ctx.colHash);
64,260✔
947
  taosArrayDestroy(ctx.cInfoList);
64,231✔
948
  blockDataDestroy(pResBlock);
64,241✔
949
  taosArrayDestroy(pBlockList);
64,242✔
950
  taosArrayDestroyEx(pUidTagList, freeItem);
64,235✔
951
  taosArrayDestroyP(groupData, releaseColInfoData);
64,238✔
952
  if (code != TSDB_CODE_SUCCESS) {
64,241✔
953
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
14!
954
  }
955
  return code;
64,235✔
956
}
957

958
static int32_t nameComparFn(const void* p1, const void* p2) {
2,419✔
959
  const char* pName1 = *(const char**)p1;
2,419✔
960
  const char* pName2 = *(const char**)p2;
2,419✔
961

962
  int32_t ret = strcmp(pName1, pName2);
2,419✔
963
  if (ret == 0) {
2,419✔
964
    return 0;
16✔
965
  } else {
966
    return (ret > 0) ? 1 : -1;
2,403✔
967
  }
968
}
969

970
static SArray* getTableNameList(const SNodeListNode* pList) {
413,261✔
971
  int32_t    code = TSDB_CODE_SUCCESS;
413,261✔
972
  int32_t    lino = 0;
413,261✔
973
  int32_t    len = LIST_LENGTH(pList->pNodeList);
413,261!
974
  SListCell* cell = pList->pNodeList->pHead;
413,261✔
975

976
  SArray* pTbList = taosArrayInit(len, POINTER_BYTES);
413,261✔
977
  QUERY_CHECK_NULL(pTbList, code, lino, _end, terrno);
413,269!
978

979
  for (int i = 0; i < pList->pNodeList->length; i++) {
828,240✔
980
    SValueNode* valueNode = (SValueNode*)cell->pNode;
414,972✔
981
    if (!IS_VAR_DATA_TYPE(valueNode->node.resType.type)) {
414,972!
982
      terrno = TSDB_CODE_INVALID_PARA;
×
983
      taosArrayDestroy(pTbList);
×
984
      return NULL;
×
985
    }
986

987
    char* name = varDataVal(valueNode->datum.p);
414,972✔
988
    void* tmp = taosArrayPush(pTbList, &name);
414,971✔
989
    QUERY_CHECK_NULL(tmp, code, lino, _end, terrno);
414,971!
990
    cell = cell->pNext;
414,971✔
991
  }
992

993
  size_t numOfTables = taosArrayGetSize(pTbList);
413,268✔
994

995
  // order the name
996
  taosArraySort(pTbList, nameComparFn);
413,261✔
997

998
  // remove the duplicates
999
  SArray* pNewList = taosArrayInit(taosArrayGetSize(pTbList), sizeof(void*));
413,258✔
1000
  QUERY_CHECK_NULL(pNewList, code, lino, _end, terrno);
413,267!
1001
  void*   tmpTbl = taosArrayGet(pTbList, 0);
413,267✔
1002
  QUERY_CHECK_NULL(tmpTbl, code, lino, _end, terrno);
413,261!
1003
  void*   tmp = taosArrayPush(pNewList, tmpTbl);
413,261✔
1004
  QUERY_CHECK_NULL(tmp, code, lino, _end, terrno);
413,261!
1005

1006
  for (int32_t i = 1; i < numOfTables; ++i) {
414,968✔
1007
    char** name = taosArrayGetLast(pNewList);
1,705✔
1008
    char** nameInOldList = taosArrayGet(pTbList, i);
1,704✔
1009
    QUERY_CHECK_NULL(nameInOldList, code, lino, _end, terrno);
1,707!
1010
    if (strcmp(*name, *nameInOldList) == 0) {
1,707✔
1011
      continue;
16✔
1012
    }
1013

1014
    tmp = taosArrayPush(pNewList, nameInOldList);
1,691✔
1015
    QUERY_CHECK_NULL(tmp, code, lino, _end, terrno);
1,691!
1016
  }
1017

1018
_end:
413,263✔
1019
  taosArrayDestroy(pTbList);
413,263✔
1020
  if (code != TSDB_CODE_SUCCESS) {
413,263✔
1021
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
3!
1022
    return NULL;
×
1023
  }
1024
  return pNewList;
413,260✔
1025
}
1026

1027
static int tableUidCompare(const void* a, const void* b) {
×
1028
  uint64_t u1 = *(uint64_t*)a;
×
1029
  uint64_t u2 = *(uint64_t*)b;
×
1030

1031
  if (u1 == u2) {
×
1032
    return 0;
×
1033
  }
1034

1035
  return u1 < u2 ? -1 : 1;
×
1036
}
1037

1038
static int32_t filterTableInfoCompare(const void* a, const void* b) {
32✔
1039
  STUidTagInfo* p1 = (STUidTagInfo*)a;
32✔
1040
  STUidTagInfo* p2 = (STUidTagInfo*)b;
32✔
1041

1042
  if (p1->uid == p2->uid) {
32!
1043
    return 0;
×
1044
  }
1045

1046
  return p1->uid < p2->uid ? -1 : 1;
32!
1047
}
1048

1049
static FilterCondType checkTagCond(SNode* cond) {
1,312,967✔
1050
  if (nodeType(cond) == QUERY_NODE_OPERATOR) {
1,312,967✔
1051
    return FILTER_NO_LOGIC;
355,229✔
1052
  }
1053
  if (nodeType(cond) != QUERY_NODE_LOGIC_CONDITION || ((SLogicConditionNode*)cond)->condType != LOGIC_COND_TYPE_AND) {
957,738!
1054
    return FILTER_AND;
7,484✔
1055
  }
1056
  return FILTER_OTHER;
950,254✔
1057
}
1058

1059
static int32_t optimizeTbnameInCond(void* pVnode, int64_t suid, SArray* list, SNode* cond, SStorageAPI* pAPI) {
1,313,116✔
1060
  int32_t ret = -1;
1,313,116✔
1061
  int32_t ntype = nodeType(cond);
1,313,116✔
1062

1063
  if (ntype == QUERY_NODE_OPERATOR) {
1,313,116✔
1064
    ret = optimizeTbnameInCondImpl(pVnode, list, cond, pAPI);
355,233✔
1065
  }
1066

1067
  if (ntype != QUERY_NODE_LOGIC_CONDITION || ((SLogicConditionNode*)cond)->condType != LOGIC_COND_TYPE_AND) {
1,313,964✔
1068
    return ret;
363,968✔
1069
  }
1070

1071
  bool                 hasTbnameCond = false;
949,996✔
1072
  SLogicConditionNode* pNode = (SLogicConditionNode*)cond;
949,996✔
1073
  SNodeList*           pList = (SNodeList*)pNode->pParameterList;
949,996✔
1074

1075
  int32_t len = LIST_LENGTH(pList);
949,996✔
1076
  if (len <= 0) {
949,996!
1077
    return ret;
×
1078
  }
1079

1080
  SListCell* cell = pList->pHead;
949,996✔
1081
  for (int i = 0; i < len; i++) {
3,233,877✔
1082
    if (cell == NULL) break;
2,526,418!
1083
    if (optimizeTbnameInCondImpl(pVnode, list, cell->pNode, pAPI) == 0) {
2,526,418✔
1084
      hasTbnameCond = true;
242,352✔
1085
      break;
242,352✔
1086
    }
1087
    cell = cell->pNext;
2,283,881✔
1088
  }
1089

1090
  taosArraySort(list, filterTableInfoCompare);
949,811✔
1091
  taosArrayRemoveDuplicate(list, filterTableInfoCompare, NULL);
948,353✔
1092

1093
  if (hasTbnameCond) {
948,699✔
1094
    ret = pAPI->metaFn.getTableTagsByUid(pVnode, suid, list);
242,346✔
1095
  }
1096

1097
  return ret;
948,799✔
1098
}
1099

1100
// only return uid that does not contained in pExistedUidList
1101
static int32_t optimizeTbnameInCondImpl(void* pVnode, SArray* pExistedUidList, SNode* pTagCond,
2,880,704✔
1102
                                        SStorageAPI* pStoreAPI) {
1103
  if (nodeType(pTagCond) != QUERY_NODE_OPERATOR) {
2,880,704✔
1104
    return -1;
134,986✔
1105
  }
1106

1107
  SOperatorNode* pNode = (SOperatorNode*)pTagCond;
2,745,718✔
1108
  if (pNode->opType != OP_TYPE_IN) {
2,745,718✔
1109
    return -1;
1,875,151✔
1110
  }
1111

1112
  if ((pNode->pLeft != NULL && nodeType(pNode->pLeft) == QUERY_NODE_COLUMN &&
870,567!
1113
       ((SColumnNode*)pNode->pLeft)->colType == COLUMN_TYPE_TBNAME) &&
872,852✔
1114
      (pNode->pRight != NULL && nodeType(pNode->pRight) == QUERY_NODE_NODE_LIST)) {
413,265!
1115
    SNodeListNode* pList = (SNodeListNode*)pNode->pRight;
413,264✔
1116

1117
    int32_t len = LIST_LENGTH(pList->pNodeList);
413,264!
1118
    if (len <= 0) {
413,264!
1119
      return -1;
×
1120
    }
1121

1122
    SArray*   pTbList = getTableNameList(pList);
413,264✔
1123
    int32_t   numOfTables = taosArrayGetSize(pTbList);
413,260✔
1124
    SHashObj* uHash = NULL;
413,259✔
1125

1126
    size_t numOfExisted = taosArrayGetSize(pExistedUidList);  // len > 0 means there already have uids
413,259✔
1127
    if (numOfExisted > 0) {
413,252!
1128
      uHash = taosHashInit(numOfExisted / 0.7, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BIGINT), false, HASH_NO_LOCK);
×
1129
      if (!uHash) {
×
1130
        qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
1131
        return terrno;
×
1132
      }
1133

1134
      for (int i = 0; i < numOfExisted; i++) {
×
1135
        STUidTagInfo* pTInfo = taosArrayGet(pExistedUidList, i);
×
1136
        if (!pTInfo) {
×
1137
          qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
1138
          return terrno;
×
1139
        }
1140
        int32_t       tempRes = taosHashPut(uHash, &pTInfo->uid, sizeof(uint64_t), &i, sizeof(i));
×
1141
        if (tempRes != TSDB_CODE_SUCCESS && tempRes != TSDB_CODE_DUP_KEY) {
×
1142
          qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(tempRes));
×
1143
          return tempRes;
×
1144
        }
1145
      }
1146
    }
1147

1148
    for (int i = 0; i < numOfTables; i++) {
828,178✔
1149
      char* name = taosArrayGetP(pTbList, i);
414,926✔
1150

1151
      uint64_t uid = 0;
414,930✔
1152
      if (pStoreAPI->metaFn.getTableUidByName(pVnode, name, &uid) == 0) {
414,930✔
1153
        ETableType tbType = TSDB_TABLE_MAX;
413,264✔
1154
        if (pStoreAPI->metaFn.getTableTypeByName(pVnode, name, &tbType) == 0 && tbType == TSDB_CHILD_TABLE) {
413,264!
1155
          if (NULL == uHash || taosHashGet(uHash, &uid, sizeof(uid)) == NULL) {
413,256!
1156
            STUidTagInfo s = {.uid = uid, .name = name, .pTagVal = NULL};
413,256✔
1157
            void*        tmp = taosArrayPush(pExistedUidList, &s);
413,252✔
1158
            if (!tmp) {
413,252!
1159
              return terrno;
×
1160
            }
1161
          }
1162
        } else {
1163
          taosArrayDestroy(pTbList);
10✔
1164
          taosHashCleanup(uHash);
11✔
1165
          return -1;
11✔
1166
        }
1167
      } else {
1168
        //        qWarn("failed to get tableIds from by table name: %s, reason: %s", name, tstrerror(terrno));
1169
        terrno = 0;
1,674✔
1170
      }
1171
    }
1172

1173
    taosHashCleanup(uHash);
413,252✔
1174
    taosArrayDestroy(pTbList);
413,249✔
1175
    return 0;
413,258✔
1176
  }
1177

1178
  return -1;
457,303✔
1179
}
1180

1181
SSDataBlock* createTagValBlockForFilter(SArray* pColList, int32_t numOfTables, SArray* pUidTagList, void* pVnode,
1,357,407✔
1182
                                        SStorageAPI* pStorageAPI) {
1183
  int32_t      code = TSDB_CODE_SUCCESS;
1,357,407✔
1184
  int32_t      lino = 0;
1,357,407✔
1185
  SSDataBlock* pResBlock = NULL;
1,357,407✔
1186
  code = createDataBlock(&pResBlock);
1,357,407✔
1187
  QUERY_CHECK_CODE(code, lino, _end);
1,357,831!
1188

1189
  for (int32_t i = 0; i < taosArrayGetSize(pColList); ++i) {
4,471,258✔
1190
    SColumnInfoData colInfo = {0};
3,112,229✔
1191
    void* tmp = taosArrayGet(pColList, i);
3,112,229✔
1192
    QUERY_CHECK_NULL(tmp, code, lino, _end, terrno);
3,110,206!
1193
    colInfo.info = *(SColumnInfo*)tmp;
3,110,206✔
1194
    code = blockDataAppendColInfo(pResBlock, &colInfo);
3,110,206✔
1195
    QUERY_CHECK_CODE(code, lino, _end);
3,113,427!
1196
  }
1197

1198
  code = blockDataEnsureCapacity(pResBlock, numOfTables);
1,355,781✔
1199
  if (code != TSDB_CODE_SUCCESS) {
1,358,283!
1200
    terrno = code;
×
1201
    blockDataDestroy(pResBlock);
×
1202
    return NULL;
×
1203
  }
1204

1205
  pResBlock->info.rows = numOfTables;
1,358,283✔
1206

1207
  int32_t numOfCols = taosArrayGetSize(pResBlock->pDataBlock);
1,358,283✔
1208

1209
  for (int32_t i = 0; i < numOfTables; i++) {
4,699,862✔
1210
    STUidTagInfo* p1 = taosArrayGet(pUidTagList, i);
3,334,561✔
1211
    QUERY_CHECK_NULL(p1, code, lino, _end, terrno);
3,332,226!
1212

1213
    for (int32_t j = 0; j < numOfCols; j++) {
10,533,714✔
1214
      SColumnInfoData* pColInfo = (SColumnInfoData*)taosArrayGet(pResBlock->pDataBlock, j);
7,191,170✔
1215
      QUERY_CHECK_NULL(pColInfo, code, lino, _end, terrno);
7,184,949!
1216

1217
      if (pColInfo->info.colId == -1) {  // tbname
7,185,191✔
1218
        char str[TSDB_TABLE_FNAME_LEN + VARSTR_HEADER_SIZE] = {0};
430,887✔
1219
        if (p1->name != NULL) {
430,887✔
1220
          STR_TO_VARSTR(str, p1->name);
413,255✔
1221
        } else {  // name is not retrieved during filter
1222
          code = pStorageAPI->metaFn.getTableNameByUid(pVnode, p1->uid, str);
17,632✔
1223
          QUERY_CHECK_CODE(code, lino, _end);
17,681!
1224
        }
1225

1226
        code = colDataSetVal(pColInfo, i, str, false);
430,936✔
1227
        QUERY_CHECK_CODE(code, lino, _end);
430,933!
1228
#if TAG_FILTER_DEBUG
1229
        qDebug("tagfilter uid:%ld, tbname:%s", *uid, str + 2);
1230
#endif
1231
      } else {
1232
        STagVal tagVal = {0};
6,754,304✔
1233
        tagVal.cid = pColInfo->info.colId;
6,754,304✔
1234
        if (p1->pTagVal == NULL) {
6,754,304!
1235
          colDataSetNULL(pColInfo, i);
×
1236
        } else {
1237
          const char* p = pStorageAPI->metaFn.extractTagVal(p1->pTagVal, pColInfo->info.type, &tagVal);
6,754,304✔
1238

1239
          if (p == NULL || (pColInfo->info.type == TSDB_DATA_TYPE_JSON && ((STag*)p)->nTag == 0)) {
6,788,080✔
1240
            colDataSetNULL(pColInfo, i);
3,063✔
1241
          } else if (pColInfo->info.type == TSDB_DATA_TYPE_JSON) {
6,785,017✔
1242
            code = colDataSetVal(pColInfo, i, p, false);
4,860✔
1243
            QUERY_CHECK_CODE(code, lino, _end);
4,860!
1244
          } else if (IS_VAR_DATA_TYPE(pColInfo->info.type)) {
8,542,900!
1245
            char* tmp = taosMemoryMalloc(tagVal.nData + VARSTR_HEADER_SIZE + 1);
1,765,507✔
1246
            QUERY_CHECK_NULL(tmp, code, lino, _end, terrno);
1,762,688!
1247
            varDataSetLen(tmp, tagVal.nData);
1,762,688✔
1248
            memcpy(tmp + VARSTR_HEADER_SIZE, tagVal.pData, tagVal.nData);
1,762,688✔
1249
            code = colDataSetVal(pColInfo, i, tmp, false);
1,762,688✔
1250
#if TAG_FILTER_DEBUG
1251
            qDebug("tagfilter varch:%s", tmp + 2);
1252
#endif
1253
            taosMemoryFree(tmp);
1,760,497!
1254
            QUERY_CHECK_CODE(code, lino, _end);
1,762,743!
1255
          } else {
1256
            code = colDataSetVal(pColInfo, i, (const char*)&tagVal.i64, false);
5,014,650✔
1257
            QUERY_CHECK_CODE(code, lino, _end);
4,999,593!
1258
#if TAG_FILTER_DEBUG
1259
            if (pColInfo->info.type == TSDB_DATA_TYPE_INT) {
1260
              qDebug("tagfilter int:%d", *(int*)(&tagVal.i64));
1261
            } else if (pColInfo->info.type == TSDB_DATA_TYPE_DOUBLE) {
1262
              qDebug("tagfilter double:%f", *(double*)(&tagVal.i64));
1263
            }
1264
#endif
1265
          }
1266
        }
1267
      }
1268
    }
1269
  }
1270

1271
_end:
1,365,301✔
1272
  if (code != TSDB_CODE_SUCCESS) {
1,365,301!
1273
    blockDataDestroy(pResBlock);
×
1274
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
1275
    terrno = code;
×
1276
    return NULL;
×
1277
  }
1278
  return pResBlock;
1,365,301✔
1279
}
1280

1281
static int32_t doSetQualifiedUid(STableListInfo* pListInfo, SArray* pUidList, const SArray* pUidTagList,
1,277,459✔
1282
                                 bool* pResultList, bool addUid) {
1283
  taosArrayClear(pUidList);
1,277,459✔
1284

1285
  STableKeyInfo info = {.uid = 0, .groupId = 0};
1,277,576✔
1286
  int32_t       numOfTables = taosArrayGetSize(pUidTagList);
1,277,576✔
1287
  for (int32_t i = 0; i < numOfTables; ++i) {
4,345,855✔
1288
    if (pResultList[i]) {
3,066,734✔
1289
      STUidTagInfo* tmpTag = (STUidTagInfo*)taosArrayGet(pUidTagList, i);
2,471,328✔
1290
      if (!tmpTag) {
2,469,984!
1291
        qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
1292
        return terrno;
×
1293
      }
1294
      uint64_t uid = tmpTag->uid;
2,469,984✔
1295
      qDebug("tagfilter get uid:%" PRId64 ", res:%d", uid, pResultList[i]);
2,469,984✔
1296

1297
      info.uid = uid;
2,470,000✔
1298
      void* p = taosArrayPush(pListInfo->pTableList, &info);
2,470,000✔
1299
      if (p == NULL) {
2,471,802!
1300
        return terrno;
×
1301
      }
1302

1303
      if (addUid) {
2,471,802!
1304
        void* tmp = taosArrayPush(pUidList, &uid);
×
1305
        if (tmp == NULL) {
×
1306
          return terrno;
×
1307
        }
1308
      }
1309
    }
1310
  }
1311

1312
  return TSDB_CODE_SUCCESS;
1,279,121✔
1313
}
1314

1315
static int32_t copyExistedUids(SArray* pUidTagList, const SArray* pUidList) {
1,313,142✔
1316
  int32_t code = TSDB_CODE_SUCCESS;
1,313,142✔
1317
  int32_t numOfExisted = taosArrayGetSize(pUidList);
1,313,142✔
1318
  if (numOfExisted == 0) {
1,313,424✔
1319
    return code;
1,283,823✔
1320
  }
1321

1322
  for (int32_t i = 0; i < numOfExisted; ++i) {
59,611✔
1323
    uint64_t*    uid = taosArrayGet(pUidList, i);
30,010✔
1324
    if (!uid) {
30,010!
1325
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
1326
      return terrno;
×
1327
    }
1328
    STUidTagInfo info = {.uid = *uid};
30,010✔
1329
    void*        tmp = taosArrayPush(pUidTagList, &info);
30,010✔
1330
    if (!tmp) {
30,010!
1331
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
1332
      return code;
×
1333
    }
1334
  }
1335
  return code;
29,601✔
1336
}
1337

1338
static int32_t doFilterByTagCond(STableListInfo* pListInfo, SArray* pUidList, SNode* pTagCond, void* pVnode,
4,891,753✔
1339
                                 SIdxFltStatus status, SStorageAPI* pAPI, bool addUid, bool* listAdded) {
1340
  *listAdded = false;
4,891,753✔
1341
  if (pTagCond == NULL) {
4,891,753✔
1342
    return TSDB_CODE_SUCCESS;
3,579,970✔
1343
  }
1344

1345
  terrno = TSDB_CODE_SUCCESS;
1,311,783✔
1346

1347
  int32_t      lino = 0;
1,313,938✔
1348
  int32_t      code = TSDB_CODE_SUCCESS;
1,313,938✔
1349
  SArray*      pBlockList = NULL;
1,313,938✔
1350
  SSDataBlock* pResBlock = NULL;
1,313,938✔
1351
  SScalarParam output = {0};
1,313,938✔
1352
  SArray*      pUidTagList = NULL;
1,313,938✔
1353

1354
  tagFilterAssist ctx = {0};
1,313,938✔
1355
  ctx.colHash = taosHashInit(4, taosGetDefaultHashFunction(TSDB_DATA_TYPE_SMALLINT), false, HASH_NO_LOCK);
1,313,938✔
1356
  if (ctx.colHash == NULL) {
1,314,584!
1357
    code = terrno;
×
1358
    QUERY_CHECK_CODE(code, lino, end);
×
1359
  }
1360

1361
  ctx.cInfoList = taosArrayInit(4, sizeof(SColumnInfo));
1,314,584✔
1362
  if (ctx.cInfoList == NULL) {
1,315,040!
1363
    code = terrno;
×
1364
    QUERY_CHECK_CODE(code, lino, end);
×
1365
  }
1366

1367
  nodesRewriteExprPostOrder(&pTagCond, getColumn, (void*)&ctx);
1,315,040✔
1368
  if (TSDB_CODE_SUCCESS != ctx.code) {
1,313,319!
1369
    terrno = code = ctx.code;
×
1370
    goto end;
×
1371
  }
1372

1373
  SDataType type = {.type = TSDB_DATA_TYPE_BOOL, .bytes = sizeof(bool)};
1,313,319✔
1374

1375
  //  int64_t stt = taosGetTimestampUs();
1376
  pUidTagList = taosArrayInit(10, sizeof(STUidTagInfo));
1,313,319✔
1377
  QUERY_CHECK_NULL(pUidTagList, code, lino, end, terrno);
1,313,634!
1378

1379
  code = copyExistedUids(pUidTagList, pUidList);
1,313,634✔
1380
  QUERY_CHECK_CODE(code, lino, end);
1,313,956!
1381

1382
  FilterCondType condType = checkTagCond(pTagCond);
1,313,956✔
1383

1384
  int32_t filter = optimizeTbnameInCond(pVnode, pListInfo->idInfo.suid, pUidTagList, pTagCond, pAPI);
1,313,625✔
1385
  if (filter == 0) {  // tbname in filter is activated, do nothing and return
1,312,140✔
1386
    taosArrayClear(pUidList);
413,259✔
1387

1388
    int32_t numOfRows = taosArrayGetSize(pUidTagList);
413,255✔
1389
    code = taosArrayEnsureCap(pUidList, numOfRows);
413,256✔
1390
    QUERY_CHECK_CODE(code, lino, end);
413,257!
1391

1392
    for (int32_t i = 0; i < numOfRows; ++i) {
826,514✔
1393
      STUidTagInfo* pInfo = taosArrayGet(pUidTagList, i);
413,256✔
1394
      QUERY_CHECK_NULL(pInfo, code, lino, end, terrno);
413,255!
1395
      void*         tmp = taosArrayPush(pUidList, &pInfo->uid);
413,255✔
1396
      QUERY_CHECK_NULL(tmp, code, lino, end, terrno);
413,257!
1397
    }
1398
    terrno = 0;
413,258✔
1399
  } else {
1400
    if ((condType == FILTER_NO_LOGIC || condType == FILTER_AND) && status != SFLT_NOT_INDEX) {
898,881✔
1401
      code = pAPI->metaFn.getTableTagsByUid(pVnode, pListInfo->idInfo.suid, pUidTagList);
10✔
1402
    } else {
1403
      code = pAPI->metaFn.getTableTags(pVnode, pListInfo->idInfo.suid, pUidTagList);
898,871✔
1404
    }
1405
    if (code != TSDB_CODE_SUCCESS) {
901,566!
1406
      qError("failed to get table tags from meta, reason:%s, suid:%" PRIu64, tstrerror(code), pListInfo->idInfo.suid);
×
1407
      terrno = code;
×
1408
      QUERY_CHECK_CODE(code, lino, end);
×
1409
    }
1410
  }
1411

1412
  int32_t numOfTables = taosArrayGetSize(pUidTagList);
1,314,821✔
1413
  if (numOfTables == 0) {
1,313,849✔
1414
    goto end;
35,602✔
1415
  }
1416

1417
  pResBlock = createTagValBlockForFilter(ctx.cInfoList, numOfTables, pUidTagList, pVnode, pAPI);
1,278,247✔
1418
  if (pResBlock == NULL) {
1,278,781!
1419
    code = terrno;
×
1420
    QUERY_CHECK_CODE(code, lino, end);
×
1421
  }
1422

1423
  //  int64_t st1 = taosGetTimestampUs();
1424
  //  qDebug("generate tag block rows:%d, cost:%ld us", rows, st1-st);
1425
  pBlockList = taosArrayInit(2, POINTER_BYTES);
1,278,781✔
1426
  QUERY_CHECK_NULL(pBlockList, code, lino, end, terrno);
1,279,347!
1427

1428
  void* tmp = taosArrayPush(pBlockList, &pResBlock);
1,279,201✔
1429
  QUERY_CHECK_NULL(tmp, code, lino, end, terrno);
1,279,201!
1430

1431
  code = createResultData(&type, numOfTables, &output);
1,279,201✔
1432
  if (code != TSDB_CODE_SUCCESS) {
1,279,362!
1433
    terrno = code;
×
1434
    QUERY_CHECK_CODE(code, lino, end);
×
1435
  }
1436

1437
  code = scalarCalculate(pTagCond, pBlockList, &output);
1,279,362✔
1438
  if (code != TSDB_CODE_SUCCESS) {
1,278,675✔
1439
    qError("failed to calculate scalar, reason:%s", tstrerror(code));
8!
1440
    terrno = code;
8✔
1441
    QUERY_CHECK_CODE(code, lino, end);
8!
1442
  }
1443

1444
  code = doSetQualifiedUid(pListInfo, pUidList, pUidTagList, (bool*)output.columnData->pData, addUid);
1,278,667✔
1445
  if (code != TSDB_CODE_SUCCESS) {
1,278,801!
1446
    terrno = code;
×
1447
    QUERY_CHECK_CODE(code, lino, end);
×
1448
  }
1449
  *listAdded = true;
1,278,821✔
1450

1451
end:
1,314,431✔
1452
  if (code != TSDB_CODE_SUCCESS) {
1,314,431✔
1453
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
8!
1454
  }
1455
  taosHashCleanup(ctx.colHash);
1,314,431✔
1456
  taosArrayDestroy(ctx.cInfoList);
1,314,563✔
1457
  blockDataDestroy(pResBlock);
1,314,942✔
1458
  taosArrayDestroy(pBlockList);
1,315,063✔
1459
  taosArrayDestroyEx(pUidTagList, freeItem);
1,315,034✔
1460

1461
  colDataDestroy(output.columnData);
1,314,662✔
1462
  taosMemoryFreeClear(output.columnData);
1,315,114!
1463
  return code;
1,315,127✔
1464
}
1465

1466
int32_t getTableList(void* pVnode, SScanPhysiNode* pScanNode, SNode* pTagCond, SNode* pTagIndexCond,
4,886,745✔
1467
                     STableListInfo* pListInfo, uint8_t* digest, const char* idstr, SStorageAPI* pStorageAPI) {
1468
  int32_t code = TSDB_CODE_SUCCESS;
4,886,745✔
1469
  int32_t lino = 0;
4,886,745✔
1470
  size_t  numOfTables = 0;
4,886,745✔
1471
  bool    listAdded = false;
4,886,745✔
1472

1473
  pListInfo->idInfo.suid = pScanNode->suid;
4,886,745✔
1474
  pListInfo->idInfo.tableType = pScanNode->tableType;
4,886,745✔
1475

1476
  SArray* pUidList = taosArrayInit(8, sizeof(uint64_t));
4,886,745✔
1477
  QUERY_CHECK_NULL(pUidList, code, lino, _error, terrno);
4,896,441✔
1478

1479
  SIdxFltStatus status = SFLT_NOT_INDEX;
4,889,955✔
1480
  if (pScanNode->tableType != TSDB_SUPER_TABLE) {
4,889,955✔
1481
    pListInfo->idInfo.uid = pScanNode->uid;
747,894✔
1482
    if (pStorageAPI->metaFn.isTableExisted(pVnode, pScanNode->uid)) {
747,894✔
1483
      void* tmp = taosArrayPush(pUidList, &pScanNode->uid);
746,116✔
1484
      QUERY_CHECK_NULL(tmp, code, lino, _error, terrno);
746,114!
1485
    }
1486
    code = doFilterByTagCond(pListInfo, pUidList, pTagCond, pVnode, status, pStorageAPI, false, &listAdded);
747,887✔
1487
    QUERY_CHECK_CODE(code, lino, _end);
747,872!
1488
  } else {
1489
    T_MD5_CTX context = {0};
4,142,061✔
1490

1491
    if (tsTagFilterCache) {
4,142,061!
1492
      // try to retrieve the result from meta cache
1493
      code = genTagFilterDigest(pTagCond, &context);
×
1494
      QUERY_CHECK_CODE(code, lino, _error);
×
1495

1496
      bool acquired = false;
×
1497
      code = pStorageAPI->metaFn.getCachedTableList(pVnode, pScanNode->suid, context.digest, tListLen(context.digest),
×
1498
                                                    pUidList, &acquired);
1499
      QUERY_CHECK_CODE(code, lino, _error);
×
1500

1501
      if (acquired) {
×
1502
        digest[0] = 1;
×
1503
        memcpy(digest + 1, context.digest, tListLen(context.digest));
×
1504
        qDebug("retrieve table uid list from cache, numOfTables:%d", (int32_t)taosArrayGetSize(pUidList));
×
1505
        goto _end;
×
1506
      }
1507
    }
1508

1509
    if (!pTagCond) {  // no tag filter condition exists, let's fetch all tables of this super table
4,142,061✔
1510
      code = pStorageAPI->metaFn.getChildTableList(pVnode, pScanNode->suid, pUidList);
2,856,239✔
1511
      QUERY_CHECK_CODE(code, lino, _error);
2,864,499!
1512
    } else {
1513
      // failed to find the result in the cache, let try to calculate the results
1514
      if (pTagIndexCond) {
1,285,822✔
1515
        void* pIndex = pStorageAPI->metaFn.getInvertIndex(pVnode);
54,153✔
1516

1517
        SIndexMetaArg metaArg = {.metaEx = pVnode,
108,401✔
1518
                                 .idx = pStorageAPI->metaFn.storeGetIndexInfo(pVnode),
54,219✔
1519
                                 .ivtIdx = pIndex,
1520
                                 .suid = pScanNode->uid};
54,182✔
1521

1522
        status = SFLT_NOT_INDEX;
54,182✔
1523
        code = doFilterTag(pTagIndexCond, &metaArg, pUidList, &status, &pStorageAPI->metaFilter);
54,182✔
1524
        if (code != 0 || status == SFLT_NOT_INDEX) {  // temporarily disable it for performance sake
54,186✔
1525
          qDebug("failed to get tableIds from index, suid:%" PRIu64, pScanNode->uid);
54,168✔
1526
        } else {
1527
          qDebug("succ to get filter result, table num: %d", (int)taosArrayGetSize(pUidList));
18!
1528
        }
1529
      }
1530
    }
1531

1532
    code = doFilterByTagCond(pListInfo, pUidList, pTagCond, pVnode, status, pStorageAPI, tsTagFilterCache, &listAdded);
4,150,309✔
1533
    QUERY_CHECK_CODE(code, lino, _end);
4,145,874✔
1534

1535
    // let's add the filter results into meta-cache
1536
    numOfTables = taosArrayGetSize(pUidList);
4,145,866✔
1537

1538
    if (tsTagFilterCache) {
4,143,869✔
1539
      size_t size = numOfTables * sizeof(uint64_t) + sizeof(int32_t);
491✔
1540
      char*  pPayload = taosMemoryMalloc(size);
491!
1541
      QUERY_CHECK_NULL(pPayload, code, lino, _end, terrno);
×
1542

1543
      *(int32_t*)pPayload = numOfTables;
×
1544
      if (numOfTables > 0) {
×
1545
        void* tmp = taosArrayGet(pUidList, 0);
×
1546
        QUERY_CHECK_NULL(tmp, code, lino, _end, terrno);
×
1547
        memcpy(pPayload + sizeof(int32_t), tmp, numOfTables * sizeof(uint64_t));
×
1548
      }
1549

1550
      code = pStorageAPI->metaFn.putCachedTableList(pVnode, pScanNode->suid, context.digest, tListLen(context.digest),
×
1551
                                                    pPayload, size, 1);
1552
      QUERY_CHECK_CODE(code, lino, _error);
×
1553

1554
      digest[0] = 1;
×
1555
      memcpy(digest + 1, context.digest, tListLen(context.digest));
×
1556
    }
1557
  }
1558

1559
_end:
4,891,258✔
1560
  if (!listAdded) {
4,891,258✔
1561
    numOfTables = taosArrayGetSize(pUidList);
3,614,044✔
1562
    for (int i = 0; i < numOfTables; i++) {
13,732,017✔
1563
      void* tmp = taosArrayGet(pUidList, i);
10,116,167✔
1564
      QUERY_CHECK_NULL(tmp, code, lino, _error, terrno);
10,107,301!
1565
      STableKeyInfo info = {.uid = *(uint64_t*)tmp, .groupId = 0};
10,107,301✔
1566

1567
      void* p = taosArrayPush(pListInfo->pTableList, &info);
10,107,301✔
1568
      if (p == NULL) {
10,117,821!
1569
        taosArrayDestroy(pUidList);
×
1570
        return terrno;
×
1571
      }
1572

1573
      qTrace("tagfilter get uid:%" PRIu64 ", %s", info.uid, idstr);
10,117,821✔
1574
    }
1575
  }
1576

1577
_error:
4,893,064✔
1578
  taosArrayDestroy(pUidList);
4,893,064✔
1579
  if (code != TSDB_CODE_SUCCESS) {
4,896,962✔
1580
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
8!
1581
  }
1582
  return code;
4,896,404✔
1583
}
1584

1585
int32_t qGetTableList(int64_t suid, void* pVnode, void* node, SArray** tableList, void* pTaskInfo) {
80✔
1586
  int32_t        code = TSDB_CODE_SUCCESS;
80✔
1587
  int32_t        lino = 0;
80✔
1588
  SSubplan*      pSubplan = (SSubplan*)node;
80✔
1589
  SScanPhysiNode pNode = {0};
80✔
1590
  pNode.suid = suid;
80✔
1591
  pNode.uid = suid;
80✔
1592
  pNode.tableType = TSDB_SUPER_TABLE;
80✔
1593

1594
  STableListInfo* pTableListInfo = tableListCreate();
80✔
1595
  QUERY_CHECK_NULL(pTableListInfo, code, lino, _end, terrno);
80!
1596
  uint8_t         digest[17] = {0};
80✔
1597
  code =
1598
      getTableList(pVnode, &pNode, pSubplan ? pSubplan->pTagCond : NULL, pSubplan ? pSubplan->pTagIndexCond : NULL,
80✔
1599
                   pTableListInfo, digest, "qGetTableList", &((SExecTaskInfo*)pTaskInfo)->storageAPI);
1600
  QUERY_CHECK_CODE(code, lino, _end);
80!
1601
  *tableList = pTableListInfo->pTableList;
80✔
1602
  pTableListInfo->pTableList = NULL;
80✔
1603
  tableListDestroy(pTableListInfo);
80✔
1604

1605
_end:
80✔
1606
  if (code != TSDB_CODE_SUCCESS) {
80!
1607
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
1608
  }
1609
  return code;
80✔
1610
}
1611

1612
size_t getTableTagsBufLen(const SNodeList* pGroups) {
9,152✔
1613
  size_t keyLen = 0;
9,152✔
1614

1615
  SNode* node;
1616
  FOREACH(node, pGroups) {
53,729!
1617
    SExprNode* pExpr = (SExprNode*)node;
44,577✔
1618
    keyLen += pExpr->resType.bytes;
44,577✔
1619
  }
1620

1621
  keyLen += sizeof(int8_t) * LIST_LENGTH(pGroups);
9,152!
1622
  return keyLen;
9,152✔
1623
}
1624

1625
int32_t getGroupIdFromTagsVal(void* pVnode, uint64_t uid, SNodeList* pGroupNode, char* keyBuf, uint64_t* pGroupId,
14✔
1626
                              SStorageAPI* pAPI) {
1627
  SMetaReader mr = {0};
14✔
1628

1629
  pAPI->metaReaderFn.initReader(&mr, pVnode, META_READER_LOCK, &pAPI->metaFn);
14✔
1630
  if (pAPI->metaReaderFn.getEntryGetUidCache(&mr, uid) != 0) {  // table not exist
14!
1631
    pAPI->metaReaderFn.clearReader(&mr);
×
1632
    return TSDB_CODE_PAR_TABLE_NOT_EXIST;
×
1633
  }
1634

1635
  SNodeList* groupNew = NULL;
14✔
1636
  int32_t    code = nodesCloneList(pGroupNode, &groupNew);
14✔
1637
  if (TSDB_CODE_SUCCESS != code) {
14!
1638
    pAPI->metaReaderFn.clearReader(&mr);
×
1639
    return code;
×
1640
  }
1641

1642
  STransTagExprCtx ctx = {.code = 0, .pReader = &mr};
14✔
1643
  nodesRewriteExprsPostOrder(groupNew, doTranslateTagExpr, &ctx);
14✔
1644
  if (TSDB_CODE_SUCCESS != ctx.code) {
14!
1645
    nodesDestroyList(groupNew);
×
1646
    pAPI->metaReaderFn.clearReader(&mr);
×
1647
    return code;
×
1648
  }
1649
  char* isNull = (char*)keyBuf;
14✔
1650
  char* pStart = (char*)keyBuf + sizeof(int8_t) * LIST_LENGTH(pGroupNode);
14!
1651

1652
  SNode*  pNode;
1653
  int32_t index = 0;
14✔
1654
  FOREACH(pNode, groupNew) {
28!
1655
    SNode*  pNew = NULL;
14✔
1656
    int32_t code = scalarCalculateConstants(pNode, &pNew);
14✔
1657
    if (TSDB_CODE_SUCCESS == code) {
14!
1658
      REPLACE_NODE(pNew);
14✔
1659
    } else {
1660
      nodesDestroyList(groupNew);
×
1661
      pAPI->metaReaderFn.clearReader(&mr);
×
1662
      return code;
×
1663
    }
1664

1665
    if (nodeType(pNew) != QUERY_NODE_VALUE) {
14!
1666
      nodesDestroyList(groupNew);
×
1667
      pAPI->metaReaderFn.clearReader(&mr);
×
1668
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR));
×
1669
      return TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR;
×
1670
    }
1671
    SValueNode* pValue = (SValueNode*)pNew;
14✔
1672

1673
    if (pValue->node.resType.type == TSDB_DATA_TYPE_NULL || pValue->isNull) {
14!
1674
      isNull[index++] = 1;
×
1675
      continue;
×
1676
    } else {
1677
      isNull[index++] = 0;
14✔
1678
      char* data = nodesGetValueFromNode(pValue);
14✔
1679
      if (pValue->node.resType.type == TSDB_DATA_TYPE_JSON) {
14!
1680
        if (tTagIsJson(data)) {
×
1681
          terrno = TSDB_CODE_QRY_JSON_IN_GROUP_ERROR;
×
1682
          nodesDestroyList(groupNew);
×
1683
          pAPI->metaReaderFn.clearReader(&mr);
×
1684
          return terrno;
×
1685
        }
1686
        int32_t len = getJsonValueLen(data);
×
1687
        memcpy(pStart, data, len);
×
1688
        pStart += len;
×
1689
      } else if (IS_VAR_DATA_TYPE(pValue->node.resType.type)) {
14!
1690
        memcpy(pStart, data, varDataTLen(data));
2✔
1691
        pStart += varDataTLen(data);
2✔
1692
      } else {
1693
        memcpy(pStart, data, pValue->node.resType.bytes);
12✔
1694
        pStart += pValue->node.resType.bytes;
12✔
1695
      }
1696
    }
1697
  }
1698

1699
  int32_t len = (int32_t)(pStart - (char*)keyBuf);
14✔
1700
  *pGroupId = calcGroupId(keyBuf, len);
14✔
1701

1702
  nodesDestroyList(groupNew);
14✔
1703
  pAPI->metaReaderFn.clearReader(&mr);
14✔
1704
  
1705
  return TSDB_CODE_SUCCESS;
14✔
1706
}
1707

1708
SArray* makeColumnArrayFromList(SNodeList* pNodeList) {
27,961✔
1709
  if (!pNodeList) {
27,961!
1710
    return NULL;
×
1711
  }
1712

1713
  size_t  numOfCols = LIST_LENGTH(pNodeList);
27,961✔
1714
  SArray* pList = taosArrayInit(numOfCols, sizeof(SColumn));
27,961✔
1715
  if (pList == NULL) {
27,964!
1716
    return NULL;
×
1717
  }
1718

1719
  for (int32_t i = 0; i < numOfCols; ++i) {
104,480✔
1720
    SColumnNode* pColNode = (SColumnNode*)nodesListGetNode(pNodeList, i);
76,505✔
1721
    if (!pColNode) {
76,521!
1722
      taosArrayDestroy(pList);
×
1723
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR));
×
1724
      return NULL;
×
1725
    }
1726

1727
    // todo extract method
1728
    SColumn c = {0};
76,521✔
1729
    c.slotId = pColNode->slotId;
76,521✔
1730
    c.colId = pColNode->colId;
76,521✔
1731
    c.type = pColNode->node.resType.type;
76,521✔
1732
    c.bytes = pColNode->node.resType.bytes;
76,521✔
1733
    c.precision = pColNode->node.resType.precision;
76,521✔
1734
    c.scale = pColNode->node.resType.scale;
76,521✔
1735

1736
    void* tmp = taosArrayPush(pList, &c);
76,516✔
1737
    if (!tmp) {
76,516!
1738
      taosArrayDestroy(pList);
×
1739
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
1740
      return NULL;
×
1741
    }
1742
  }
1743

1744
  return pList;
27,975✔
1745
}
1746

1747
int32_t extractColMatchInfo(SNodeList* pNodeList, SDataBlockDescNode* pOutputNodeList, int32_t* numOfOutputCols,
8,966,540✔
1748
                            int32_t type, SColMatchInfo* pMatchInfo) {
1749
  size_t  numOfCols = LIST_LENGTH(pNodeList);
8,966,540!
1750
  int32_t code = TSDB_CODE_SUCCESS;
8,966,540✔
1751
  int32_t lino = 0;
8,966,540✔
1752

1753
  pMatchInfo->matchType = type;
8,966,540✔
1754

1755
  SArray* pList = taosArrayInit(numOfCols, sizeof(SColMatchItem));
8,966,540✔
1756
  if (pList == NULL) {
8,968,122✔
1757
    code = terrno;
922✔
1758
    return code;
×
1759
  }
1760

1761
  for (int32_t i = 0; i < numOfCols; ++i) {
45,559,773✔
1762
    STargetNode* pNode = (STargetNode*)nodesListGetNode(pNodeList, i);
36,576,803✔
1763
    QUERY_CHECK_NULL(pNode, code, lino, _end, terrno);
36,591,256!
1764
    if (nodeType(pNode->pExpr) == QUERY_NODE_COLUMN) {
36,597,656✔
1765
      SColumnNode* pColNode = (SColumnNode*)pNode->pExpr;
36,503,448✔
1766

1767
      SColMatchItem c = {.needOutput = true};
36,503,448✔
1768
      c.colId = pColNode->colId;
36,503,448✔
1769
      c.srcSlotId = pColNode->slotId;
36,503,448✔
1770
      c.dstSlotId = pNode->slotId;
36,503,448✔
1771
      c.isPk = pColNode->isPk;
36,503,448✔
1772
      c.dataType = pColNode->node.resType;
36,503,448✔
1773
      void* tmp = taosArrayPush(pList, &c);
36,498,365✔
1774
      QUERY_CHECK_NULL(tmp, code, lino, _end, terrno);
36,498,365!
1775
    }
1776
  }
1777

1778
  // set the output flag for each column in SColMatchInfo, according to the
1779
  *numOfOutputCols = 0;
8,982,970✔
1780
  int32_t num = LIST_LENGTH(pOutputNodeList->pSlots);
8,982,970✔
1781
  for (int32_t i = 0; i < num; ++i) {
53,126,319✔
1782
    SSlotDescNode* pNode = (SSlotDescNode*)nodesListGetNode(pOutputNodeList->pSlots, i);
44,124,615✔
1783
    QUERY_CHECK_NULL(pNode, code, lino, _end, terrno);
44,279,820!
1784

1785
    // todo: add reserve flag check
1786
    // it is a column reserved for the arithmetic expression calculation
1787
    if (pNode->slotId >= numOfCols) {
44,301,442✔
1788
      (*numOfOutputCols) += 1;
7,709,081✔
1789
      continue;
7,709,081✔
1790
    }
1791

1792
    SColMatchItem* info = NULL;
36,592,361✔
1793
    for (int32_t j = 0; j < taosArrayGetSize(pList); ++j) {
878,979,081✔
1794
      info = taosArrayGet(pList, j);
880,543,254✔
1795
      QUERY_CHECK_NULL(info, code, lino, _end, terrno);
881,676,940✔
1796
      if (info->dstSlotId == pNode->slotId) {
878,550,084✔
1797
        break;
36,163,364✔
1798
      }
1799
    }
1800

1801
    if (pNode->output) {
36,434,268✔
1802
      (*numOfOutputCols) += 1;
36,361,812✔
1803
    } else if (info != NULL) {
72,456✔
1804
      // select distinct tbname from stb where tbname='abc';
1805
      info->needOutput = false;
72,454✔
1806
    }
1807
  }
1808

1809
  pMatchInfo->pList = pList;
9,001,704✔
1810

1811
_end:
9,001,704✔
1812
  if (code != TSDB_CODE_SUCCESS) {
9,001,704!
1813
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
1814
  }
1815
  return code;
8,963,093✔
1816
}
1817

1818
static SResSchema createResSchema(int32_t type, int32_t bytes, int32_t slotId, int32_t scale, int32_t precision,
29,322,870✔
1819
                                  const char* name) {
1820
  SResSchema s = {0};
29,322,870✔
1821
  s.scale = scale;
29,322,870✔
1822
  s.type = type;
29,322,870✔
1823
  s.bytes = bytes;
29,322,870✔
1824
  s.slotId = slotId;
29,322,870✔
1825
  s.precision = precision;
29,322,870✔
1826
  tstrncpy(s.name, name, tListLen(s.name));
29,322,870✔
1827

1828
  return s;
29,322,870✔
1829
}
1830

1831
static SColumn* createColumn(int32_t blockId, int32_t slotId, int32_t colId, SDataType* pType, EColumnType colType) {
27,972,065✔
1832
  SColumn* pCol = taosMemoryCalloc(1, sizeof(SColumn));
27,972,065!
1833
  if (pCol == NULL) {
27,975,317!
1834
    return NULL;
×
1835
  }
1836

1837
  pCol->slotId = slotId;
27,975,317✔
1838
  pCol->colId = colId;
27,975,317✔
1839
  pCol->bytes = pType->bytes;
27,975,317✔
1840
  pCol->type = pType->type;
27,975,317✔
1841
  pCol->scale = pType->scale;
27,975,317✔
1842
  pCol->precision = pType->precision;
27,975,317✔
1843
  pCol->dataBlockId = blockId;
27,975,317✔
1844
  pCol->colType = colType;
27,975,317✔
1845
  return pCol;
27,975,317✔
1846
}
1847

1848
int32_t createExprFromOneNode(SExprInfo* pExp, SNode* pNode, int16_t slotId) {
29,312,665✔
1849
  int32_t code = TSDB_CODE_SUCCESS;
29,312,665✔
1850
  int32_t lino = 0;
29,312,665✔
1851
  pExp->base.numOfParams = 0;
29,312,665✔
1852
  pExp->base.pParam = NULL;
29,312,665✔
1853
  pExp->pExpr = taosMemoryCalloc(1, sizeof(tExprNode));
29,312,665!
1854
  QUERY_CHECK_NULL(pExp->pExpr, code, lino, _end, terrno);
29,333,712!
1855

1856
  pExp->pExpr->_function.num = 1;
29,333,712✔
1857
  pExp->pExpr->_function.functionId = -1;
29,333,712✔
1858

1859
  int32_t type = nodeType(pNode);
29,333,712✔
1860
  // it is a project query, or group by column
1861
  if (type == QUERY_NODE_COLUMN) {
29,333,712✔
1862
    pExp->pExpr->nodeType = QUERY_NODE_COLUMN;
17,913,378✔
1863
    SColumnNode* pColNode = (SColumnNode*)pNode;
17,913,378✔
1864

1865
    pExp->base.pParam = taosMemoryCalloc(1, sizeof(SFunctParam));
17,913,378✔
1866
    QUERY_CHECK_NULL(pExp->base.pParam, code, lino, _end, terrno);
17,912,904!
1867

1868
    pExp->base.numOfParams = 1;
17,912,904✔
1869

1870
    SDataType* pType = &pColNode->node.resType;
17,912,904✔
1871
    pExp->base.resSchema =
1872
        createResSchema(pType->type, pType->bytes, slotId, pType->scale, pType->precision, pColNode->colName);
17,912,904✔
1873

1874
    pExp->base.pParam[0].pCol =
35,811,238✔
1875
        createColumn(pColNode->dataBlockId, pColNode->slotId, pColNode->colId, pType, pColNode->colType);
17,908,532✔
1876
    QUERY_CHECK_NULL(pExp->base.pParam[0].pCol, code, lino, _end, terrno);
17,902,706!
1877

1878
    pExp->base.pParam[0].type = FUNC_PARAM_TYPE_COLUMN;
17,902,706✔
1879
  } else if (type == QUERY_NODE_VALUE) {
11,420,334✔
1880
    pExp->pExpr->nodeType = QUERY_NODE_VALUE;
278,565✔
1881
    SValueNode* pValNode = (SValueNode*)pNode;
278,565✔
1882

1883
    pExp->base.pParam = taosMemoryCalloc(1, sizeof(SFunctParam));
278,565!
1884
    QUERY_CHECK_NULL(pExp->base.pParam, code, lino, _end, terrno);
278,666!
1885

1886
    pExp->base.numOfParams = 1;
278,666✔
1887

1888
    SDataType* pType = &pValNode->node.resType;
278,666✔
1889
    pExp->base.resSchema =
1890
        createResSchema(pType->type, pType->bytes, slotId, pType->scale, pType->precision, pValNode->node.aliasName);
278,666✔
1891
    pExp->base.pParam[0].type = FUNC_PARAM_TYPE_VALUE;
278,596✔
1892
    code = nodesValueNodeToVariant(pValNode, &pExp->base.pParam[0].param);
278,596✔
1893
    QUERY_CHECK_CODE(code, lino, _end);
278,569!
1894
  } else if (type == QUERY_NODE_FUNCTION) {
11,141,769✔
1895
    pExp->pExpr->nodeType = QUERY_NODE_FUNCTION;
10,918,916✔
1896
    SFunctionNode* pFuncNode = (SFunctionNode*)pNode;
10,918,916✔
1897

1898
    SDataType* pType = &pFuncNode->node.resType;
10,918,916✔
1899
    pExp->base.resSchema =
1900
        createResSchema(pType->type, pType->bytes, slotId, pType->scale, pType->precision, pFuncNode->node.aliasName);
10,918,916✔
1901
    tExprNode* pExprNode = pExp->pExpr;
10,921,902✔
1902

1903
    pExprNode->_function.functionId = pFuncNode->funcId;
10,921,902✔
1904
    pExprNode->_function.pFunctNode = pFuncNode;
10,921,902✔
1905
    pExprNode->_function.functionType = pFuncNode->funcType;
10,921,902✔
1906

1907
    tstrncpy(pExprNode->_function.functionName, pFuncNode->functionName, tListLen(pExprNode->_function.functionName));
10,921,902✔
1908

1909
#if 1
1910
    // todo refactor: add the parameter for tbname function
1911
    const char* name = "tbname";
10,921,902✔
1912
    int32_t     len = strlen(name);
10,921,902✔
1913

1914
    if (!pFuncNode->pParameterList && (memcmp(pExprNode->_function.functionName, name, len) == 0) &&
10,921,902✔
1915
        pExprNode->_function.functionName[len] == 0) {
734,134✔
1916
      pFuncNode->pParameterList = NULL;
733,880✔
1917
      int32_t     code = nodesMakeList(&pFuncNode->pParameterList);
733,880✔
1918
      SValueNode* res = NULL;
734,312✔
1919
      if (TSDB_CODE_SUCCESS == code) {
734,312!
1920
        code = nodesMakeNode(QUERY_NODE_VALUE, (SNode**)&res);
734,328✔
1921
      }
1922
      QUERY_CHECK_CODE(code, lino, _end);
734,190!
1923
      res->node.resType = (SDataType){.bytes = sizeof(int64_t), .type = TSDB_DATA_TYPE_BIGINT};
734,190✔
1924
      code = nodesListAppend(pFuncNode->pParameterList, (SNode*)res);
734,190✔
1925
      if (code != TSDB_CODE_SUCCESS) {
734,368✔
1926
        nodesDestroyNode((SNode*)res);
146✔
1927
        res = NULL;
×
1928
      }
1929
      QUERY_CHECK_CODE(code, lino, _end);
734,222!
1930
    }
1931
#endif
1932

1933
    int32_t numOfParam = LIST_LENGTH(pFuncNode->pParameterList);
10,922,244✔
1934

1935
    pExp->base.pParam = taosMemoryCalloc(numOfParam, sizeof(SFunctParam));
10,922,244✔
1936
    QUERY_CHECK_NULL(pExp->base.pParam, code, lino, _end, terrno);
10,924,653!
1937
    pExp->base.numOfParams = numOfParam;
10,924,653✔
1938

1939
    for (int32_t j = 0; j < numOfParam && TSDB_CODE_SUCCESS == code; ++j) {
23,585,048!
1940
      SNode* p1 = nodesListGetNode(pFuncNode->pParameterList, j);
12,660,153✔
1941
      QUERY_CHECK_NULL(p1, code, lino, _end, terrno);
12,661,552!
1942
      if (p1->type == QUERY_NODE_COLUMN) {
12,663,210✔
1943
        SColumnNode* pcn = (SColumnNode*)p1;
10,072,219✔
1944

1945
        pExp->base.pParam[j].type = FUNC_PARAM_TYPE_COLUMN;
10,072,219✔
1946
        pExp->base.pParam[j].pCol =
20,144,071✔
1947
            createColumn(pcn->dataBlockId, pcn->slotId, pcn->colId, &pcn->node.resType, pcn->colType);
10,072,219✔
1948
        QUERY_CHECK_NULL(pExp->base.pParam[j].pCol, code, lino, _end, terrno);
10,071,852✔
1949
      } else if (p1->type == QUERY_NODE_VALUE) {
2,590,991✔
1950
        SValueNode* pvn = (SValueNode*)p1;
2,149,585✔
1951
        pExp->base.pParam[j].type = FUNC_PARAM_TYPE_VALUE;
2,149,585✔
1952
        code = nodesValueNodeToVariant(pvn, &pExp->base.pParam[j].param);
2,149,585✔
1953
        QUERY_CHECK_CODE(code, lino, _end);
2,149,100!
1954
      }
1955
    }
1956
  } else if (type == QUERY_NODE_OPERATOR) {
222,853✔
1957
    pExp->pExpr->nodeType = QUERY_NODE_OPERATOR;
213,456✔
1958
    SOperatorNode* pOpNode = (SOperatorNode*)pNode;
213,456✔
1959

1960
    pExp->base.pParam = taosMemoryCalloc(1, sizeof(SFunctParam));
213,456!
1961
    QUERY_CHECK_NULL(pExp->base.pParam, code, lino, _end, terrno);
213,455!
1962
    pExp->base.numOfParams = 1;
213,455✔
1963

1964
    SDataType* pType = &pOpNode->node.resType;
213,455✔
1965
    pExp->base.resSchema =
1966
        createResSchema(pType->type, pType->bytes, slotId, pType->scale, pType->precision, pOpNode->node.aliasName);
213,455✔
1967
    pExp->pExpr->_optrRoot.pRootNode = pNode;
213,399✔
1968
  } else if (type == QUERY_NODE_CASE_WHEN) {
9,397✔
1969
    pExp->pExpr->nodeType = QUERY_NODE_OPERATOR;
5,052✔
1970
    SCaseWhenNode* pCaseNode = (SCaseWhenNode*)pNode;
5,052✔
1971

1972
    pExp->base.pParam = taosMemoryCalloc(1, sizeof(SFunctParam));
5,052!
1973
    QUERY_CHECK_NULL(pExp->base.pParam, code, lino, _end, terrno);
5,053!
1974
    pExp->base.numOfParams = 1;
5,053✔
1975

1976
    SDataType* pType = &pCaseNode->node.resType;
5,053✔
1977
    pExp->base.resSchema =
1978
        createResSchema(pType->type, pType->bytes, slotId, pType->scale, pType->precision, pCaseNode->node.aliasName);
5,053✔
1979
    pExp->pExpr->_optrRoot.pRootNode = pNode;
5,051✔
1980
  } else if (type == QUERY_NODE_LOGIC_CONDITION) {
4,345✔
1981
    pExp->pExpr->nodeType = QUERY_NODE_OPERATOR;
10✔
1982
    SLogicConditionNode* pCond = (SLogicConditionNode*)pNode;
10✔
1983
    pExp->base.pParam = taosMemoryCalloc(1, sizeof(SFunctParam));
10!
1984
    QUERY_CHECK_NULL(pExp->base.pParam, code, lino, _end, terrno);
10!
1985
    pExp->base.numOfParams = 1;
10✔
1986
    SDataType* pType = &pCond->node.resType;
10✔
1987
    pExp->base.resSchema = createResSchema(pType->type, pType->bytes, slotId, pType->scale, pType->precision, pCond->node.aliasName);
10✔
1988
    pExp->pExpr->_optrRoot.pRootNode = pNode;
10✔
1989
  } else {
1990
    code = TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR;
4,335✔
1991
    QUERY_CHECK_CODE(code, lino, _end);
4,335!
1992
  }
1993

1994
_end:
4,335✔
1995
  if (code != TSDB_CODE_SUCCESS) {
29,328,965!
1996
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
1997
  }
1998
  return code;
29,313,780✔
1999
}
2000

2001
int32_t createExprFromTargetNode(SExprInfo* pExp, STargetNode* pTargetNode) {
29,289,406✔
2002
  return createExprFromOneNode(pExp, pTargetNode->pExpr, pTargetNode->slotId);
29,289,406✔
2003
}
2004

2005
SExprInfo* createExpr(SNodeList* pNodeList, int32_t* numOfExprs) {
2,668✔
2006
  *numOfExprs = LIST_LENGTH(pNodeList);
2,668!
2007
  SExprInfo* pExprs = taosMemoryCalloc(*numOfExprs, sizeof(SExprInfo));
2,668!
2008
  if (!pExprs) {
2,669!
2009
    return NULL;
×
2010
  }
2011

2012
  for (int32_t i = 0; i < (*numOfExprs); ++i) {
22,701✔
2013
    SExprInfo* pExp = &pExprs[i];
20,033✔
2014
    int32_t    code = createExprFromOneNode(pExp, nodesListGetNode(pNodeList, i), i + UD_TAG_COLUMN_INDEX);
20,033✔
2015
    if (code != TSDB_CODE_SUCCESS) {
20,032!
2016
      taosMemoryFreeClear(pExprs);
×
2017
      terrno = code;
×
2018
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
×
2019
      return NULL;
×
2020
    }
2021
  }
2022

2023
  return pExprs;
2,668✔
2024
}
2025

2026
int32_t createExprInfo(SNodeList* pNodeList, SNodeList* pGroupKeys, SExprInfo** pExprInfo, int32_t* numOfExprs) {
11,629,096✔
2027
  QRY_PARAM_CHECK(pExprInfo);
11,629,096!
2028

2029
  int32_t code = 0;
11,629,096✔
2030
  int32_t numOfFuncs = LIST_LENGTH(pNodeList);
11,629,096✔
2031
  int32_t numOfGroupKeys = 0;
11,629,096✔
2032
  if (pGroupKeys != NULL) {
11,629,096✔
2033
    numOfGroupKeys = LIST_LENGTH(pGroupKeys);
377,880✔
2034
  }
2035

2036
  *numOfExprs = numOfFuncs + numOfGroupKeys;
11,629,096✔
2037
  if (*numOfExprs == 0) {
11,629,096✔
2038
    return code;
1,599,587✔
2039
  }
2040

2041
  SExprInfo* pExprs = taosMemoryCalloc(*numOfExprs, sizeof(SExprInfo));
10,029,509!
2042
  if (pExprs == NULL) {
10,033,100!
2043
    return terrno;
×
2044
  }
2045

2046
  for (int32_t i = 0; i < (*numOfExprs); ++i) {
38,928,063✔
2047
    STargetNode* pTargetNode = NULL;
28,890,974✔
2048
    if (i < numOfFuncs) {
28,890,974✔
2049
      pTargetNode = (STargetNode*)nodesListGetNode(pNodeList, i);
28,289,951✔
2050
    } else {
2051
      pTargetNode = (STargetNode*)nodesListGetNode(pGroupKeys, i - numOfFuncs);
601,023✔
2052
    }
2053
    if (!pTargetNode) {
28,907,072!
2054
      destroyExprInfo(pExprs, *numOfExprs);
×
2055
      taosMemoryFreeClear(pExprs);
×
2056
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
2057
      return terrno;
×
2058
    }
2059

2060
    SExprInfo* pExp = &pExprs[i];
28,907,072✔
2061
    code = createExprFromTargetNode(pExp, pTargetNode);
28,907,072✔
2062
    if (code != TSDB_CODE_SUCCESS) {
28,898,074✔
2063
      destroyExprInfo(pExprs, *numOfExprs);
3,111✔
2064
      taosMemoryFreeClear(pExprs);
×
2065
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
×
2066
      return code;
×
2067
    }
2068
  }
2069

2070
  *pExprInfo = pExprs;
10,037,089✔
2071
  return code;
10,037,089✔
2072
}
2073

2074
// set the output buffer for the selectivity + tag query
2075
static int32_t setSelectValueColumnInfo(SqlFunctionCtx* pCtx, int32_t numOfOutput) {
11,288,740✔
2076
  int32_t num = 0;
11,288,740✔
2077
  int32_t code = TSDB_CODE_SUCCESS;
11,288,740✔
2078
  int32_t lino = 0;
11,288,740✔
2079

2080
  SqlFunctionCtx*  p = NULL;
11,288,740✔
2081
  SqlFunctionCtx** pValCtx = taosMemoryCalloc(numOfOutput, POINTER_BYTES);
11,288,740!
2082
  if (pValCtx == NULL) {
11,294,523!
2083
    return terrno;
×
2084
  }
2085

2086
  SHashObj* pSelectFuncs = taosHashInit(8, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BINARY), false, HASH_ENTRY_LOCK);
11,294,523✔
2087
  QUERY_CHECK_NULL(pSelectFuncs, code, lino, _end, terrno);
11,288,106!
2088

2089
  for (int32_t i = 0; i < numOfOutput; ++i) {
39,634,790✔
2090
    const char* pName = pCtx[i].pExpr->pExpr->_function.functionName;
28,479,204✔
2091
    if ((strcmp(pName, "_select_value") == 0) || (strcmp(pName, "_group_key") == 0) ||
28,479,204✔
2092
        (strcmp(pName, "_group_const_value") == 0)) {
27,093,402✔
2093
      pValCtx[num++] = &pCtx[i];
1,501,284✔
2094
    } else if (fmIsSelectFunc(pCtx[i].functionId)) {
26,977,920✔
2095
      void* data = taosHashGet(pSelectFuncs, pName, strlen(pName));
2,451,045✔
2096
      if (taosHashGetSize(pSelectFuncs) != 0 && data == NULL) {
2,441,147✔
2097
        p = NULL;
124,082✔
2098
        break;
124,082✔
2099
      } else {
2100
        int32_t tempRes = taosHashPut(pSelectFuncs, pName, strlen(pName), &num, sizeof(num));
2,318,046✔
2101
        if (tempRes != TSDB_CODE_SUCCESS && tempRes != TSDB_CODE_DUP_KEY) {
2,321,447!
2102
          code = tempRes;
×
2103
          QUERY_CHECK_CODE(code, lino, _end);
×
2104
        }
2105
        p = &pCtx[i];
2,321,447✔
2106
      }
2107
    }
2108
  }
2109
  taosHashCleanup(pSelectFuncs);
11,279,668✔
2110

2111
  if (p != NULL) {
11,290,978✔
2112
    p->subsidiaries.pCtx = pValCtx;
2,043,153✔
2113
    p->subsidiaries.num = num;
2,043,153✔
2114
  } else {
2115
    taosMemoryFreeClear(pValCtx);
9,247,825!
2116
  }
2117

2118
_end:
×
2119
  if (code != TSDB_CODE_SUCCESS) {
11,292,257!
2120
    taosMemoryFreeClear(pValCtx);
×
2121
    taosHashCleanup(pSelectFuncs);
×
2122
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
2123
  }
2124
  return code;
11,283,356✔
2125
}
2126

2127
SqlFunctionCtx* createSqlFunctionCtx(SExprInfo* pExprInfo, int32_t numOfOutput, int32_t** rowEntryInfoOffset,
11,282,043✔
2128
                                     SFunctionStateStore* pStore) {
2129
  int32_t         code = TSDB_CODE_SUCCESS;
11,282,043✔
2130
  int32_t         lino = 0;
11,282,043✔
2131
  SqlFunctionCtx* pFuncCtx = (SqlFunctionCtx*)taosMemoryCalloc(numOfOutput, sizeof(SqlFunctionCtx));
11,282,043!
2132
  if (pFuncCtx == NULL) {
11,282,484!
2133
    return NULL;
×
2134
  }
2135

2136
  *rowEntryInfoOffset = taosMemoryCalloc(numOfOutput, sizeof(int32_t));
11,282,484!
2137
  if (*rowEntryInfoOffset == 0) {
11,293,929!
2138
    taosMemoryFreeClear(pFuncCtx);
×
2139
    return NULL;
×
2140
  }
2141

2142
  for (int32_t i = 0; i < numOfOutput; ++i) {
40,366,932✔
2143
    SExprInfo* pExpr = &pExprInfo[i];
29,064,174✔
2144

2145
    SExprBasicInfo* pFunct = &pExpr->base;
29,064,174✔
2146
    SqlFunctionCtx* pCtx = &pFuncCtx[i];
29,064,174✔
2147

2148
    pCtx->functionId = -1;
29,064,174✔
2149
    pCtx->pExpr = pExpr;
29,064,174✔
2150

2151
    if (pExpr->pExpr->nodeType == QUERY_NODE_FUNCTION) {
29,064,174✔
2152
      SFuncExecEnv env = {0};
10,917,481✔
2153
      pCtx->functionId = pExpr->pExpr->_function.pFunctNode->funcId;
10,917,481✔
2154
      pCtx->isPseudoFunc = fmIsWindowPseudoColumnFunc(pCtx->functionId);
10,917,481✔
2155
      pCtx->isNotNullFunc = fmIsNotNullOutputFunc(pCtx->functionId);
10,911,202✔
2156

2157
      bool isUdaf = fmIsUserDefinedFunc(pCtx->functionId);
10,915,521✔
2158
      if (fmIsAggFunc(pCtx->functionId) || fmIsIndefiniteRowsFunc(pCtx->functionId)) {
18,282,944✔
2159
        if (!isUdaf) {
7,377,701✔
2160
          code = fmGetFuncExecFuncs(pCtx->functionId, &pCtx->fpSet);
7,377,669✔
2161
          QUERY_CHECK_CODE(code, lino, _end);
7,371,145!
2162
        } else {
2163
          char* udfName = pExpr->pExpr->_function.pFunctNode->functionName;
32✔
2164
          pCtx->udfName = taosStrdup(udfName);
32!
2165
          QUERY_CHECK_NULL(pCtx->udfName, code, lino, _end, terrno);
32!
2166

2167
          code = fmGetUdafExecFuncs(pCtx->functionId, &pCtx->fpSet);
32✔
2168
          QUERY_CHECK_CODE(code, lino, _end);
32!
2169
        }
2170
        bool tmp = pCtx->fpSet.getEnv(pExpr->pExpr->_function.pFunctNode, &env);
7,371,177✔
2171
        if (!tmp) {
7,372,560!
2172
          code = terrno;
×
2173
          QUERY_CHECK_CODE(code, lino, _end);
×
2174
        }
2175
      } else {
2176
        code = fmGetScalarFuncExecFuncs(pCtx->functionId, &pCtx->sfp);
3,529,153✔
2177
        if (code != TSDB_CODE_SUCCESS && isUdaf) {
3,530,413!
2178
          code = TSDB_CODE_SUCCESS;
261✔
2179
        }
2180
        QUERY_CHECK_CODE(code, lino, _end);
3,530,413!
2181

2182
        if (pCtx->sfp.getEnv != NULL) {
3,530,413✔
2183
          bool tmp = pCtx->sfp.getEnv(pExpr->pExpr->_function.pFunctNode, &env);
1,856,701✔
2184
          if (!tmp) {
1,855,033✔
2185
            code = terrno;
55✔
2186
            QUERY_CHECK_CODE(code, lino, _end);
×
2187
          }
2188
        }
2189
      }
2190
      pCtx->resDataInfo.interBufSize = env.calcMemSize;
10,903,704✔
2191
    } else if (pExpr->pExpr->nodeType == QUERY_NODE_COLUMN || pExpr->pExpr->nodeType == QUERY_NODE_OPERATOR ||
18,146,693✔
2192
               pExpr->pExpr->nodeType == QUERY_NODE_VALUE) {
278,608!
2193
      // for simple column, the result buffer needs to hold at least one element.
2194
      pCtx->resDataInfo.interBufSize = pFunct->resSchema.bytes;
18,148,521✔
2195
    }
2196

2197
    pCtx->input.numOfInputCols = pFunct->numOfParams;
29,050,397✔
2198
    pCtx->input.pData = taosMemoryCalloc(pFunct->numOfParams, POINTER_BYTES);
29,050,397✔
2199
    QUERY_CHECK_NULL(pCtx->input.pData, code, lino, _end, terrno);
29,071,315!
2200
    pCtx->input.pColumnDataAgg = taosMemoryCalloc(pFunct->numOfParams, POINTER_BYTES);
29,071,315!
2201
    QUERY_CHECK_NULL(pCtx->input.pColumnDataAgg, code, lino, _end, terrno);
29,073,003!
2202

2203
    pCtx->pTsOutput = NULL;
29,073,003✔
2204
    pCtx->resDataInfo.bytes = pFunct->resSchema.bytes;
29,073,003✔
2205
    pCtx->resDataInfo.type = pFunct->resSchema.type;
29,073,003✔
2206
    pCtx->order = TSDB_ORDER_ASC;
29,073,003✔
2207
    pCtx->start.key = INT64_MIN;
29,073,003✔
2208
    pCtx->end.key = INT64_MIN;
29,073,003✔
2209
    pCtx->numOfParams = pExpr->base.numOfParams;
29,073,003✔
2210
    pCtx->param = pFunct->pParam;
29,073,003✔
2211
    pCtx->saveHandle.currentPage = -1;
29,073,003✔
2212
    pCtx->pStore = pStore;
29,073,003✔
2213
    pCtx->hasWindowOrGroup = false;
29,073,003✔
2214
    pCtx->needCleanup = false;
29,073,003✔
2215
  }
2216

2217
  for (int32_t i = 1; i < numOfOutput; ++i) {
29,985,426✔
2218
    (*rowEntryInfoOffset)[i] = (int32_t)((*rowEntryInfoOffset)[i - 1] + sizeof(SResultRowEntryInfo) +
18,682,668✔
2219
                                         pFuncCtx[i - 1].resDataInfo.interBufSize);
18,682,668✔
2220
  }
2221

2222
  code = setSelectValueColumnInfo(pFuncCtx, numOfOutput);
11,302,758✔
2223
  QUERY_CHECK_CODE(code, lino, _end);
11,283,195!
2224

2225
_end:
11,283,195✔
2226
  if (code != TSDB_CODE_SUCCESS) {
11,283,195!
2227
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
2228
    for (int32_t i = 0; i < numOfOutput; ++i) {
×
2229
      taosMemoryFree(pFuncCtx[i].input.pData);
×
2230
      taosMemoryFree(pFuncCtx[i].input.pColumnDataAgg);
×
2231
    }
2232
    taosMemoryFreeClear(*rowEntryInfoOffset);
×
2233
    taosMemoryFreeClear(pFuncCtx);
×
2234

2235
    terrno = code;
×
2236
    return NULL;
×
2237
  }
2238
  return pFuncCtx;
11,283,195✔
2239
}
2240

2241
// NOTE: sources columns are more than the destination SSDatablock columns.
2242
// doFilter in table scan needs every column even its output is false
2243
int32_t relocateColumnData(SSDataBlock* pBlock, const SArray* pColMatchInfo, SArray* pCols, bool outputEveryColumn) {
1,104,988✔
2244
  int32_t code = TSDB_CODE_SUCCESS;
1,104,988✔
2245
  size_t  numOfSrcCols = taosArrayGetSize(pCols);
1,104,988✔
2246

2247
  int32_t i = 0, j = 0;
1,105,136✔
2248
  while (i < numOfSrcCols && j < taosArrayGetSize(pColMatchInfo)) {
2,382,630✔
2249
    SColumnInfoData* p = taosArrayGet(pCols, i);
1,277,890✔
2250
    if (!p) {
1,277,498!
2251
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
2252
      return terrno;
×
2253
    }
2254
    SColMatchItem* pmInfo = taosArrayGet(pColMatchInfo, j);
1,277,498✔
2255
    if (!pmInfo) {
1,277,267!
2256
      return terrno;
×
2257
    }
2258

2259
    if (p->info.colId == pmInfo->colId) {
1,277,399✔
2260
      SColumnInfoData* pDst = taosArrayGet(pBlock->pDataBlock, pmInfo->dstSlotId);
1,249,835✔
2261
      if (!pDst) {
1,249,599!
2262
        return terrno;
×
2263
      }
2264
      code = colDataAssign(pDst, p, pBlock->info.rows, &pBlock->info);
1,249,599✔
2265
      if (code != TSDB_CODE_SUCCESS) {
1,249,905!
2266
        qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
×
2267
        return code;
×
2268
      }
2269
      i++;
1,249,930✔
2270
      j++;
1,249,930✔
2271
    } else if (p->info.colId < pmInfo->colId) {
27,564!
2272
      i++;
27,564✔
2273
    } else {
2274
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR));
×
2275
      return TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR;
×
2276
    }
2277
  }
2278
  return code;
1,104,927✔
2279
}
2280

2281
SInterval extractIntervalInfo(const STableScanPhysiNode* pTableScanNode) {
2,921,858✔
2282
  SInterval interval = {
2,921,858✔
2283
      .interval = pTableScanNode->interval,
2,921,858✔
2284
      .sliding = pTableScanNode->sliding,
2,921,858✔
2285
      .intervalUnit = pTableScanNode->intervalUnit,
2,921,858✔
2286
      .slidingUnit = pTableScanNode->slidingUnit,
2,921,858✔
2287
      .offset = pTableScanNode->offset,
2,921,858✔
2288
      .precision = pTableScanNode->scan.node.pOutputDataBlockDesc->precision,
2,921,858✔
2289
      .timeRange = pTableScanNode->scanRange,
2290
  };
2291
  calcIntervalAutoOffset(&interval);
2,921,858✔
2292

2293
  return interval;
2,922,902✔
2294
}
2295

2296
SColumn extractColumnFromColumnNode(SColumnNode* pColNode) {
751,290✔
2297
  SColumn c = {0};
751,290✔
2298

2299
  c.slotId = pColNode->slotId;
751,290✔
2300
  c.colId = pColNode->colId;
751,290✔
2301
  c.type = pColNode->node.resType.type;
751,290✔
2302
  c.bytes = pColNode->node.resType.bytes;
751,290✔
2303
  c.scale = pColNode->node.resType.scale;
751,290✔
2304
  c.precision = pColNode->node.resType.precision;
751,290✔
2305
  return c;
751,290✔
2306
}
2307

2308
int32_t initQueryTableDataCond(SQueryTableDataCond* pCond, const STableScanPhysiNode* pTableScanNode,
4,916,495✔
2309
                               const SReadHandle* readHandle) {
2310
  pCond->order = pTableScanNode->scanSeq[0] > 0 ? TSDB_ORDER_ASC : TSDB_ORDER_DESC;
4,916,495✔
2311
  pCond->numOfCols = LIST_LENGTH(pTableScanNode->scan.pScanCols);
4,916,495!
2312

2313
  pCond->colList = taosMemoryCalloc(pCond->numOfCols, sizeof(SColumnInfo));
4,916,495!
2314
  if (!pCond->colList) {
4,924,065!
2315
    return terrno;
×
2316
  }
2317
  pCond->pSlotList = taosMemoryMalloc(sizeof(int32_t) * pCond->numOfCols);
4,924,065✔
2318
  if (pCond->pSlotList == NULL) {
4,919,461!
2319
    taosMemoryFreeClear(pCond->colList);
×
2320
    return terrno;
×
2321
  }
2322

2323
  // TODO: get it from stable scan node
2324
  pCond->twindows = pTableScanNode->scanRange;
4,919,461✔
2325
  pCond->suid = pTableScanNode->scan.suid;
4,919,461✔
2326
  pCond->type = TIMEWINDOW_RANGE_CONTAINED;
4,919,461✔
2327
  pCond->startVersion = -1;
4,919,461✔
2328
  pCond->endVersion = -1;
4,919,461✔
2329
  pCond->skipRollup = readHandle->skipRollup;
4,919,461✔
2330

2331
  // allowed read stt file optimization mode
2332
  pCond->notLoadData = (pTableScanNode->dataRequired == FUNC_DATA_REQUIRED_NOT_LOAD) &&
10,007,938✔
2333
                       (pTableScanNode->scan.node.pConditions == NULL) && (pTableScanNode->interval == 0);
4,919,461✔
2334

2335
  int32_t j = 0;
4,919,461✔
2336
  for (int32_t i = 0; i < pCond->numOfCols; ++i) {
28,516,215✔
2337
    STargetNode* pNode = (STargetNode*)nodesListGetNode(pTableScanNode->scan.pScanCols, i);
23,587,198✔
2338
    if (!pNode) {
23,599,864✔
2339
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
3,110!
2340
      return terrno;
3,110✔
2341
    }
2342
    SColumnNode* pColNode = (SColumnNode*)pNode->pExpr;
23,596,754✔
2343
    if (pColNode->colType == COLUMN_TYPE_TAG) {
23,596,754!
2344
      continue;
×
2345
    }
2346

2347
    pCond->colList[j].type = pColNode->node.resType.type;
23,596,754✔
2348
    pCond->colList[j].bytes = pColNode->node.resType.bytes;
23,596,754✔
2349
    pCond->colList[j].colId = pColNode->colId;
23,596,754✔
2350
    pCond->colList[j].pk = pColNode->isPk;
23,596,754✔
2351

2352
    pCond->pSlotList[j] = pNode->slotId;
23,596,754✔
2353
    j += 1;
23,596,754✔
2354
  }
2355

2356
  pCond->numOfCols = j;
4,929,017✔
2357
  return TSDB_CODE_SUCCESS;
4,929,017✔
2358
}
2359

2360
void cleanupQueryTableDataCond(SQueryTableDataCond* pCond) {
6,932,971✔
2361
  taosMemoryFreeClear(pCond->colList);
6,932,971!
2362
  taosMemoryFreeClear(pCond->pSlotList);
6,933,479!
2363
}
6,933,401✔
2364

2365
int32_t convertFillType(int32_t mode) {
560,084✔
2366
  int32_t type = TSDB_FILL_NONE;
560,084✔
2367
  switch (mode) {
560,084!
2368
    case FILL_MODE_PREV:
16,684✔
2369
      type = TSDB_FILL_PREV;
16,684✔
2370
      break;
16,684✔
2371
    case FILL_MODE_NONE:
×
2372
      type = TSDB_FILL_NONE;
×
2373
      break;
×
2374
    case FILL_MODE_NULL:
26,233✔
2375
      type = TSDB_FILL_NULL;
26,233✔
2376
      break;
26,233✔
2377
    case FILL_MODE_NULL_F:
32,940✔
2378
      type = TSDB_FILL_NULL_F;
32,940✔
2379
      break;
32,940✔
2380
    case FILL_MODE_NEXT:
16,289✔
2381
      type = TSDB_FILL_NEXT;
16,289✔
2382
      break;
16,289✔
2383
    case FILL_MODE_VALUE:
149,814✔
2384
      type = TSDB_FILL_SET_VALUE;
149,814✔
2385
      break;
149,814✔
2386
    case FILL_MODE_VALUE_F:
291,961✔
2387
      type = TSDB_FILL_SET_VALUE_F;
291,961✔
2388
      break;
291,961✔
2389
    case FILL_MODE_LINEAR:
16,142✔
2390
      type = TSDB_FILL_LINEAR;
16,142✔
2391
      break;
16,142✔
2392
    case FILL_MODE_NEAR:
10,030✔
2393
      type = TSDB_FILL_NEAR;
10,030✔
2394
      break;
10,030✔
2395
    default:
×
2396
      type = TSDB_FILL_NONE;
×
2397
  }
2398

2399
  return type;
560,084✔
2400
}
2401

2402
void getInitialStartTimeWindow(SInterval* pInterval, TSKEY ts, STimeWindow* w, bool ascQuery) {
34,516,513✔
2403
  if (ascQuery) {
34,516,513✔
2404
    *w = getAlignQueryTimeWindow(pInterval, ts);
34,230,974✔
2405
  } else {
2406
    // the start position of the first time window in the endpoint that spreads beyond the queried last timestamp
2407
    *w = getAlignQueryTimeWindow(pInterval, ts);
285,539✔
2408

2409
    int64_t key = w->skey;
286,420✔
2410
    while (key < ts) {  // moving towards end
908,176✔
2411
      key = getNextTimeWindowStart(pInterval, key, TSDB_ORDER_ASC);
887,121✔
2412
      if (key > ts) {
887,114✔
2413
        break;
265,358✔
2414
      }
2415

2416
      w->skey = key;
621,756✔
2417
    }
2418
    w->ekey = taosTimeAdd(w->skey, pInterval->interval, pInterval->intervalUnit, pInterval->precision, NULL) - 1;
286,413✔
2419
  }
2420
}
34,493,080✔
2421

2422
static STimeWindow doCalculateTimeWindow(int64_t ts, SInterval* pInterval) {
964,439✔
2423
  STimeWindow w = {0};
964,439✔
2424

2425
  w.skey = taosTimeTruncate(ts, pInterval);
964,439✔
2426
  w.ekey = taosTimeGetIntervalEnd(w.skey, pInterval);
964,605✔
2427
  return w;
964,569✔
2428
}
2429

2430
STimeWindow getFirstQualifiedTimeWindow(int64_t ts, STimeWindow* pWindow, SInterval* pInterval, int32_t order) {
289,907✔
2431
  STimeWindow win = *pWindow;
289,907✔
2432
  STimeWindow save = win;
289,907✔
2433
  while (win.skey <= ts && win.ekey >= ts) {
1,269,564✔
2434
    save = win;
979,657✔
2435
    // get previous time window
2436
    getNextTimeWindow(pInterval, &win, order == TSDB_ORDER_ASC ? TSDB_ORDER_DESC : TSDB_ORDER_ASC);
979,657✔
2437
  }
2438

2439
  return save;
289,907✔
2440
}
2441

2442
// get the correct time window according to the handled timestamp
2443
// todo refactor
2444
STimeWindow getActiveTimeWindow(SDiskbasedBuf* pBuf, SResultRowInfo* pResultRowInfo, int64_t ts, SInterval* pInterval,
35,979,792✔
2445
                                int32_t order) {
2446
  STimeWindow w = {0};
35,979,792✔
2447
  if (pResultRowInfo->cur.pageId == -1) {  // the first window, from the previous stored value
35,979,792✔
2448
    getInitialStartTimeWindow(pInterval, ts, &w, (order == TSDB_ORDER_ASC));
34,517,626✔
2449
    return w;
34,493,587✔
2450
  }
2451

2452
  SResultRow* pRow = getResultRowByPos(pBuf, &pResultRowInfo->cur, false);
1,462,166✔
2453
  if (pRow) {
1,463,454!
2454
    w = pRow->win;
1,463,467✔
2455
  }
2456

2457
  // in case of typical time window, we can calculate time window directly.
2458
  if (w.skey > ts || w.ekey < ts) {
1,463,454✔
2459
    w = doCalculateTimeWindow(ts, pInterval);
964,430✔
2460
  }
2461

2462
  if (pInterval->interval != pInterval->sliding) {
1,463,589✔
2463
    // it is an sliding window query, in which sliding value is not equalled to
2464
    // interval value, and we need to find the first qualified time window.
2465
    w = getFirstQualifiedTimeWindow(ts, &w, pInterval, order);
289,907✔
2466
  }
2467

2468
  return w;
1,463,569✔
2469
}
2470

2471
TSKEY getNextTimeWindowStart(const SInterval* pInterval, TSKEY start, int32_t order) {
237,960,340✔
2472
  int32_t factor = GET_FORWARD_DIRECTION_FACTOR(order);
237,960,340✔
2473
  TSKEY   nextStart = taosTimeAdd(start, -1 * pInterval->offset, pInterval->offsetUnit, pInterval->precision, NULL);
237,960,340✔
2474
  nextStart = taosTimeAdd(nextStart, factor * pInterval->sliding, pInterval->slidingUnit, pInterval->precision, NULL);
237,789,538✔
2475
  nextStart = taosTimeAdd(nextStart, pInterval->offset, pInterval->offsetUnit, pInterval->precision, NULL);
237,892,554✔
2476
  return nextStart;
237,517,785✔
2477
}
2478

2479
void getNextTimeWindow(const SInterval* pInterval, STimeWindow* tw, int32_t order) {
237,066,521✔
2480
  tw->skey = getNextTimeWindowStart(pInterval, tw->skey, order);
237,066,521✔
2481
  tw->ekey = taosTimeAdd(tw->skey, pInterval->interval, pInterval->intervalUnit, pInterval->precision, NULL) - 1;
236,643,062✔
2482
}
236,984,046✔
2483

2484
bool hasLimitOffsetInfo(SLimitInfo* pLimitInfo) {
11,803,708✔
2485
  return (pLimitInfo->limit.limit != -1 || pLimitInfo->limit.offset != -1 || pLimitInfo->slimit.limit != -1 ||
23,583,223!
2486
          pLimitInfo->slimit.offset != -1);
11,779,515✔
2487
}
2488

2489
bool hasSlimitOffsetInfo(SLimitInfo* pLimitInfo) {
×
2490
  return (pLimitInfo->slimit.limit != -1 || pLimitInfo->slimit.offset != -1);
×
2491
}
2492

2493
void initLimitInfo(const SNode* pLimit, const SNode* pSLimit, SLimitInfo* pLimitInfo) {
13,998,681✔
2494
  SLimit limit = {.limit = getLimit(pLimit), .offset = getOffset(pLimit)};
13,998,681✔
2495
  SLimit slimit = {.limit = getLimit(pSLimit), .offset = getOffset(pSLimit)};
14,006,934✔
2496

2497
  pLimitInfo->limit = limit;
14,010,028✔
2498
  pLimitInfo->slimit = slimit;
14,010,028✔
2499
  pLimitInfo->remainOffset = limit.offset;
14,010,028✔
2500
  pLimitInfo->remainGroupOffset = slimit.offset;
14,010,028✔
2501
}
14,010,028✔
2502

2503
void resetLimitInfoForNextGroup(SLimitInfo* pLimitInfo) {
2,389,270✔
2504
  pLimitInfo->numOfOutputRows = 0;
2,389,270✔
2505
  pLimitInfo->remainOffset = pLimitInfo->limit.offset;
2,389,270✔
2506
}
2,389,270✔
2507

2508
int32_t tableListGetSize(const STableListInfo* pTableList, int32_t* pRes) {
16,810,832✔
2509
  if (taosArrayGetSize(pTableList->pTableList) != taosHashGetSize(pTableList->map)) {
16,810,832!
2510
    qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR));
×
2511
    return TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR;
×
2512
  }
2513
  (*pRes) = taosArrayGetSize(pTableList->pTableList);
16,822,342✔
2514
  return TSDB_CODE_SUCCESS;
16,818,924✔
2515
}
2516

2517
uint64_t tableListGetSuid(const STableListInfo* pTableList) { return pTableList->idInfo.suid; }
87,026✔
2518

2519
STableKeyInfo* tableListGetInfo(const STableListInfo* pTableList, int32_t index) {
7,454,760✔
2520
  if (taosArrayGetSize(pTableList->pTableList) == 0) {
7,454,760✔
2521
    return NULL;
554✔
2522
  }
2523

2524
  return taosArrayGet(pTableList->pTableList, index);
7,454,658✔
2525
}
2526

2527
int32_t tableListFind(const STableListInfo* pTableList, uint64_t uid, int32_t startIndex) {
181✔
2528
  int32_t numOfTables = taosArrayGetSize(pTableList->pTableList);
181✔
2529
  if (startIndex >= numOfTables) {
180!
2530
    return -1;
×
2531
  }
2532

2533
  for (int32_t i = startIndex; i < numOfTables; ++i) {
2,259!
2534
    STableKeyInfo* p = taosArrayGet(pTableList->pTableList, i);
2,260✔
2535
    if (!p) {
2,259!
2536
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
2537
      return -1;
×
2538
    }
2539
    if (p->uid == uid) {
2,260✔
2540
      return i;
181✔
2541
    }
2542
  }
2543
  return -1;
×
2544
}
2545

2546
void tableListGetSourceTableInfo(const STableListInfo* pTableList, uint64_t* psuid, uint64_t* uid, int32_t* type) {
18,670✔
2547
  *psuid = pTableList->idInfo.suid;
18,670✔
2548
  *uid = pTableList->idInfo.uid;
18,670✔
2549
  *type = pTableList->idInfo.tableType;
18,670✔
2550
}
18,670✔
2551

2552
uint64_t tableListGetTableGroupId(const STableListInfo* pTableList, uint64_t tableUid) {
15,726,395✔
2553
  int32_t* slot = taosHashGet(pTableList->map, &tableUid, sizeof(tableUid));
15,726,395✔
2554
  if (slot == NULL) {
15,730,735!
2555
    return -1;
×
2556
  }
2557

2558
  STableKeyInfo* pKeyInfo = taosArrayGet(pTableList->pTableList, *slot);
15,730,735✔
2559

2560
  return pKeyInfo->groupId;
15,728,617✔
2561
}
2562

2563
// TODO handle the group offset info, fix it, the rule of group output will be broken by this function
2564
int32_t tableListAddTableInfo(STableListInfo* pTableList, uint64_t uid, uint64_t gid) {
10,091✔
2565
  int32_t code = TSDB_CODE_SUCCESS;
10,091✔
2566
  int32_t lino = 0;
10,091✔
2567
  if (pTableList->map == NULL) {
10,091!
2568
    pTableList->map = taosHashInit(32, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BINARY), false, HASH_ENTRY_LOCK);
×
2569
    QUERY_CHECK_NULL(pTableList->map, code, lino, _end, terrno);
×
2570
  }
2571

2572
  STableKeyInfo keyInfo = {.uid = uid, .groupId = gid};
10,091✔
2573
  void*         p = taosHashGet(pTableList->map, &uid, sizeof(uid));
10,091✔
2574
  if (p != NULL) {
10,095✔
2575
    qInfo("table:%" PRId64 " already in tableIdList, ignore it", uid);
1!
2576
    goto _end;
1✔
2577
  }
2578

2579
  void* tmp = taosArrayPush(pTableList->pTableList, &keyInfo);
10,094✔
2580
  QUERY_CHECK_NULL(tmp, code, lino, _end, terrno);
10,094!
2581

2582
  int32_t slot = (int32_t)taosArrayGetSize(pTableList->pTableList) - 1;
10,094✔
2583
  code = taosHashPut(pTableList->map, &uid, sizeof(uid), &slot, sizeof(slot));
10,094✔
2584
  if (code != TSDB_CODE_SUCCESS) {
10,094!
2585
    // we have checked the existence of uid in hash map above
2586
    QUERY_CHECK_CONDITION((code != TSDB_CODE_DUP_KEY), code, lino, _end, TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR);
×
2587
    taosArrayPopTailBatch(pTableList->pTableList, 1);  // let's pop the last element in the array list
×
2588
  }
2589

2590
_end:
10,094✔
2591
  if (code != TSDB_CODE_SUCCESS) {
10,095!
2592
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
2593
  } else {
2594
    qDebug("uid:%" PRIu64 ", groupId:%" PRIu64 " added into table list, slot:%d, total:%d", uid, gid, slot, slot + 1);
10,095✔
2595
  }
2596

2597
  return code;
10,093✔
2598
}
2599

2600
int32_t tableListGetGroupList(const STableListInfo* pTableList, int32_t ordinalGroupIndex, STableKeyInfo** pKeyInfo,
2,887,024✔
2601
                              int32_t* size) {
2602
  int32_t totalGroups = tableListGetOutputGroups(pTableList);
2,887,024✔
2603
  int32_t numOfTables = 0;
2,891,687✔
2604
  int32_t code = tableListGetSize(pTableList, &numOfTables);
2,891,687✔
2605
  if (code != TSDB_CODE_SUCCESS) {
2,889,350!
2606
    qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
×
2607
    return code;
×
2608
  }
2609

2610
  if (ordinalGroupIndex < 0 || ordinalGroupIndex >= totalGroups) {
2,889,350!
2611
    return TSDB_CODE_INVALID_PARA;
×
2612
  }
2613

2614
  // here handle two special cases:
2615
  // 1. only one group exists, and 2. one table exists for each group.
2616
  if (totalGroups == 1) {
2,889,350✔
2617
    *size = numOfTables;
2,888,745✔
2618
    *pKeyInfo = (*size == 0) ? NULL : taosArrayGet(pTableList->pTableList, 0);
2,888,745✔
2619
    return TSDB_CODE_SUCCESS;
2,886,381✔
2620
  } else if (totalGroups == numOfTables) {
605!
2621
    *size = 1;
971✔
2622
    *pKeyInfo = taosArrayGet(pTableList->pTableList, ordinalGroupIndex);
971✔
2623
    return TSDB_CODE_SUCCESS;
971✔
2624
  }
2625

2626
  int32_t offset = pTableList->groupOffset[ordinalGroupIndex];
×
2627
  if (ordinalGroupIndex < totalGroups - 1) {
×
2628
    *size = pTableList->groupOffset[ordinalGroupIndex + 1] - offset;
536✔
2629
  } else {
2630
    *size = numOfTables - offset;
×
2631
  }
2632

2633
  *pKeyInfo = taosArrayGet(pTableList->pTableList, offset);
×
2634
  return TSDB_CODE_SUCCESS;
670✔
2635
}
2636

2637
int32_t tableListGetOutputGroups(const STableListInfo* pTableList) { return pTableList->numOfOuputGroups; }
8,625,727✔
2638

2639
bool oneTableForEachGroup(const STableListInfo* pTableList) { return pTableList->oneTableForEachGroup; }
11,916✔
2640

2641
STableListInfo* tableListCreate() {
4,978,829✔
2642
  STableListInfo* pListInfo = taosMemoryCalloc(1, sizeof(STableListInfo));
4,978,829!
2643
  if (pListInfo == NULL) {
4,989,777!
2644
    return NULL;
×
2645
  }
2646

2647
  pListInfo->remainGroups = NULL;
4,989,777✔
2648
  pListInfo->pTableList = taosArrayInit(4, sizeof(STableKeyInfo));
4,989,777✔
2649
  if (pListInfo->pTableList == NULL) {
4,990,518!
2650
    goto _error;
×
2651
  }
2652

2653
  pListInfo->map = taosHashInit(1024, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BIGINT), false, HASH_ENTRY_LOCK);
4,990,518✔
2654
  if (pListInfo->map == NULL) {
4,989,361!
2655
    goto _error;
×
2656
  }
2657

2658
  pListInfo->numOfOuputGroups = 1;
4,989,361✔
2659
  return pListInfo;
4,989,361✔
2660

2661
_error:
×
2662
  tableListDestroy(pListInfo);
×
2663
  return NULL;
×
2664
}
2665

2666
void tableListDestroy(STableListInfo* pTableListInfo) {
4,991,065✔
2667
  if (pTableListInfo == NULL) {
4,991,065✔
2668
    return;
2✔
2669
  }
2670

2671
  taosArrayDestroy(pTableListInfo->pTableList);
4,991,063✔
2672
  taosMemoryFreeClear(pTableListInfo->groupOffset);
4,991,605!
2673

2674
  taosHashCleanup(pTableListInfo->map);
4,991,605✔
2675
  taosHashCleanup(pTableListInfo->remainGroups);
4,991,159✔
2676
  pTableListInfo->pTableList = NULL;
4,991,466✔
2677
  pTableListInfo->map = NULL;
4,991,466✔
2678
  taosMemoryFree(pTableListInfo);
4,991,466!
2679
}
2680

2681
void tableListClear(STableListInfo* pTableListInfo) {
2,115✔
2682
  if (pTableListInfo == NULL) {
2,115!
2683
    return;
×
2684
  }
2685

2686
  taosArrayClear(pTableListInfo->pTableList);
2,115✔
2687
  taosHashClear(pTableListInfo->map);
2,115✔
2688
  taosHashClear(pTableListInfo->remainGroups);
2,116✔
2689
  taosMemoryFree(pTableListInfo->groupOffset);
2,116!
2690
  pTableListInfo->numOfOuputGroups = 1;
2,116✔
2691
  pTableListInfo->oneTableForEachGroup = false;
2,116✔
2692
}
2693

2694
static int32_t orderbyGroupIdComparFn(const void* p1, const void* p2) {
94,064✔
2695
  STableKeyInfo* pInfo1 = (STableKeyInfo*)p1;
94,064✔
2696
  STableKeyInfo* pInfo2 = (STableKeyInfo*)p2;
94,064✔
2697

2698
  if (pInfo1->groupId == pInfo2->groupId) {
94,064✔
2699
    return 0;
170✔
2700
  } else {
2701
    return pInfo1->groupId < pInfo2->groupId ? -1 : 1;
93,894✔
2702
  }
2703
}
2704

2705
static int32_t sortTableGroup(STableListInfo* pTableListInfo) {
939✔
2706
  taosArraySort(pTableListInfo->pTableList, orderbyGroupIdComparFn);
939✔
2707
  int32_t size = taosArrayGetSize(pTableListInfo->pTableList);
939✔
2708

2709
  SArray* pList = taosArrayInit(4, sizeof(int32_t));
939✔
2710
  if (!pList) {
939!
2711
    return terrno;
×
2712
  }
2713

2714
  STableKeyInfo* pInfo = taosArrayGet(pTableListInfo->pTableList, 0);
939✔
2715
  if (!pInfo) {
939!
2716
    qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
2717
    return terrno;
×
2718
  }
2719
  uint64_t       gid = pInfo->groupId;
939✔
2720

2721
  int32_t start = 0;
939✔
2722
  void*   tmp = taosArrayPush(pList, &start);
938✔
2723
  if (!tmp) {
938!
2724
    qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
2725
    return terrno;
×
2726
  }
2727

2728
  for (int32_t i = 1; i < size; ++i) {
2,983✔
2729
    pInfo = taosArrayGet(pTableListInfo->pTableList, i);
2,045✔
2730
    if (!pInfo) {
2,045✔
2731
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
1!
2732
      return terrno;
1✔
2733
    }
2734
    if (pInfo->groupId != gid) {
2,044✔
2735
      tmp = taosArrayPush(pList, &i);
1,876✔
2736
      if (!tmp) {
1,876!
2737
        qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
2738
        return terrno;
×
2739
      }
2740
      gid = pInfo->groupId;
1,876✔
2741
    }
2742
  }
2743

2744
  pTableListInfo->numOfOuputGroups = taosArrayGetSize(pList);
938✔
2745
  pTableListInfo->groupOffset = taosMemoryMalloc(sizeof(int32_t) * pTableListInfo->numOfOuputGroups);
938!
2746
  if (pTableListInfo->groupOffset == NULL) {
939!
2747
    taosArrayDestroy(pList);
×
2748
    return terrno;
×
2749
  }
2750

2751
  memcpy(pTableListInfo->groupOffset, taosArrayGet(pList, 0), sizeof(int32_t) * pTableListInfo->numOfOuputGroups);
939✔
2752
  taosArrayDestroy(pList);
939✔
2753
  return TSDB_CODE_SUCCESS;
939✔
2754
}
2755

2756
int32_t buildGroupIdMapForAllTables(STableListInfo* pTableListInfo, SReadHandle* pHandle, SScanPhysiNode* pScanNode,
4,675,712✔
2757
                                    SNodeList* group, bool groupSort, uint8_t* digest, SStorageAPI* pAPI) {
2758
  int32_t code = TSDB_CODE_SUCCESS;
4,675,712✔
2759

2760
  bool   groupByTbname = groupbyTbname(group);
4,675,712✔
2761
  size_t numOfTables = taosArrayGetSize(pTableListInfo->pTableList);
4,674,939✔
2762
  if (!numOfTables) {
4,674,641!
2763
    return code;
×
2764
  }
2765
  if (group == NULL || groupByTbname) {
4,674,641✔
2766
    if (tsCountAlwaysReturnValue && QUERY_NODE_PHYSICAL_PLAN_TABLE_SCAN == nodeType(pScanNode) &&
4,610,459✔
2767
        ((STableScanPhysiNode*)pScanNode)->needCountEmptyTable) {
2,632,079✔
2768
      pTableListInfo->remainGroups =
208,529✔
2769
          taosHashInit(numOfTables, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BIGINT), false, HASH_NO_LOCK);
208,540✔
2770
      if (pTableListInfo->remainGroups == NULL) {
208,529!
2771
        return terrno;
×
2772
      }
2773

2774
      for (int i = 0; i < numOfTables; i++) {
729,568✔
2775
        STableKeyInfo* info = taosArrayGet(pTableListInfo->pTableList, i);
520,939✔
2776
        if (!info) {
520,905!
2777
          qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
2778
          return terrno;
×
2779
        }
2780
        info->groupId = groupByTbname ? info->uid : 0;
520,905✔
2781

2782
        int32_t tempRes = taosHashPut(pTableListInfo->remainGroups, &(info->groupId), sizeof(info->groupId),
520,905✔
2783
                                      &(info->uid), sizeof(info->uid));
520,905✔
2784
        if (tempRes != TSDB_CODE_SUCCESS && tempRes != TSDB_CODE_DUP_KEY) {
521,039!
2785
          qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(tempRes));
×
2786
          return tempRes;
×
2787
        }
2788
      }
2789
    } else {
2790
      for (int32_t i = 0; i < numOfTables; i++) {
16,213,390✔
2791
        STableKeyInfo* info = taosArrayGet(pTableListInfo->pTableList, i);
11,812,458✔
2792
        if (!info) {
11,812,257✔
2793
          qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
786!
2794
          return terrno;
786✔
2795
        }
2796
        info->groupId = groupByTbname ? info->uid : 0;
11,811,471✔
2797
      }
2798
    }
2799

2800
    pTableListInfo->oneTableForEachGroup = groupByTbname;
4,609,561✔
2801
    if (numOfTables == 1 && pTableListInfo->idInfo.tableType == TSDB_CHILD_TABLE) {
4,609,561✔
2802
      pTableListInfo->oneTableForEachGroup = true;
448,843✔
2803
    }
2804

2805
    if (groupSort && groupByTbname) {
4,609,561✔
2806
      taosArraySort(pTableListInfo->pTableList, orderbyGroupIdComparFn);
28,645✔
2807
      pTableListInfo->numOfOuputGroups = numOfTables;
28,646✔
2808
    } else if (groupByTbname && pScanNode->groupOrderScan) {
4,580,916✔
2809
      pTableListInfo->numOfOuputGroups = numOfTables;
109✔
2810
    } else {
2811
      pTableListInfo->numOfOuputGroups = 1;
4,580,807✔
2812
    }
2813
  } else {
2814
    bool initRemainGroups = false;
64,182✔
2815
    if (QUERY_NODE_PHYSICAL_PLAN_TABLE_SCAN == nodeType(pScanNode)) {
64,182✔
2816
      STableScanPhysiNode* pTableScanNode = (STableScanPhysiNode*)pScanNode;
63,538✔
2817
      if (tsCountAlwaysReturnValue && pTableScanNode->needCountEmptyTable &&
63,538✔
2818
          !(groupSort || pScanNode->groupOrderScan)) {
13,065!
2819
        initRemainGroups = true;
13,022✔
2820
      }
2821
    }
2822

2823
    code = getColInfoResultForGroupby(pHandle->vnode, group, pTableListInfo, digest, pAPI, initRemainGroups);
64,182✔
2824
    if (code != TSDB_CODE_SUCCESS) {
64,228✔
2825
      return code;
14✔
2826
    }
2827

2828
    if (pScanNode->groupOrderScan) pTableListInfo->numOfOuputGroups = taosArrayGetSize(pTableListInfo->pTableList);
64,214✔
2829

2830
    if (groupSort || pScanNode->groupOrderScan) {
64,214✔
2831
      code = sortTableGroup(pTableListInfo);
933✔
2832
    }
2833
  }
2834

2835
  // add all table entry in the hash map
2836
  size_t size = taosArrayGetSize(pTableListInfo->pTableList);
4,673,782✔
2837
  for (int32_t i = 0; i < size; ++i) {
17,278,796✔
2838
    STableKeyInfo* p = taosArrayGet(pTableListInfo->pTableList, i);
12,592,366✔
2839
    if (!p) {
12,578,554!
2840
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(terrno));
×
2841
      return terrno;
×
2842
    }
2843
    int32_t        tempRes = taosHashPut(pTableListInfo->map, &p->uid, sizeof(uint64_t), &i, sizeof(int32_t));
12,578,554✔
2844
    if (tempRes != TSDB_CODE_SUCCESS && tempRes != TSDB_CODE_DUP_KEY) {
12,605,297!
2845
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(tempRes));
×
2846
      return tempRes;
×
2847
    }
2848
  }
2849

2850
  return code;
4,686,430✔
2851
}
2852

2853
int32_t createScanTableListInfo(SScanPhysiNode* pScanNode, SNodeList* pGroupTags, bool groupSort, SReadHandle* pHandle,
4,888,578✔
2854
                                STableListInfo* pTableListInfo, SNode* pTagCond, SNode* pTagIndexCond,
2855
                                SExecTaskInfo* pTaskInfo) {
2856
  int64_t     st = taosGetTimestampUs();
4,894,924✔
2857
  const char* idStr = GET_TASKID(pTaskInfo);
4,894,924✔
2858

2859
  if (pHandle == NULL) {
4,894,924!
2860
    qError("invalid handle, in creating operator tree, %s", idStr);
×
2861
    return TSDB_CODE_INVALID_PARA;
×
2862
  }
2863

2864
  uint8_t digest[17] = {0};
4,894,924✔
2865
  int32_t code = getTableList(pHandle->vnode, pScanNode, pTagCond, pTagIndexCond, pTableListInfo, digest, idStr,
4,894,924✔
2866
                              &pTaskInfo->storageAPI);
2867
  if (code != TSDB_CODE_SUCCESS) {
4,896,256✔
2868
    qError("failed to getTableList, code: %s", tstrerror(code));
8!
2869
    return code;
8✔
2870
  }
2871

2872
  int32_t numOfTables = taosArrayGetSize(pTableListInfo->pTableList);
4,896,248✔
2873

2874
  int64_t st1 = taosGetTimestampUs();
4,895,846✔
2875
  pTaskInfo->cost.extractListTime = (st1 - st) / 1000.0;
4,895,846✔
2876
  qDebug("extract queried table list completed, %d tables, elapsed time:%.2f ms %s", numOfTables,
4,895,846✔
2877
         pTaskInfo->cost.extractListTime, idStr);
2878

2879
  if (numOfTables == 0) {
4,893,153✔
2880
    qDebug("no table qualified for query, %s" PRIx64, idStr);
216,184✔
2881
    return TSDB_CODE_SUCCESS;
216,134✔
2882
  }
2883

2884
  code = buildGroupIdMapForAllTables(pTableListInfo, pHandle, pScanNode, pGroupTags, groupSort, digest,
4,676,969✔
2885
                                     &pTaskInfo->storageAPI);
2886
  if (code != TSDB_CODE_SUCCESS) {
4,682,677✔
2887
    return code;
14✔
2888
  }
2889

2890
  pTaskInfo->cost.groupIdMapTime = (taosGetTimestampUs() - st1) / 1000.0;
4,682,456✔
2891
  qDebug("generate group id map completed, elapsed time:%.2f ms %s", pTaskInfo->cost.groupIdMapTime, idStr);
4,682,456✔
2892

2893
  return TSDB_CODE_SUCCESS;
4,681,789✔
2894
}
2895

2896
char* getStreamOpName(uint16_t opType) {
2,735,714✔
2897
  switch (opType) {
2,735,714!
2898
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_SCAN:
524,961✔
2899
      return "stream scan";
524,961✔
2900
    case QUERY_NODE_PHYSICAL_PLAN_PROJECT:
31,370✔
2901
      return "project";
31,370✔
2902
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_INTERVAL:
1,353,875✔
2903
      return "interval single";
1,353,875✔
2904
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_FINAL_INTERVAL:
12,887✔
2905
      return "interval final";
12,887✔
2906
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_SEMI_INTERVAL:
32,669✔
2907
      return "interval semi";
32,669✔
2908
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_MID_INTERVAL:
330✔
2909
      return "interval mid";
330✔
2910
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_FILL:
5,757✔
2911
      return "stream fill";
5,757✔
2912
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_SESSION:
10,342✔
2913
      return "session single";
10,342✔
2914
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_SEMI_SESSION:
1,540✔
2915
      return "session semi";
1,540✔
2916
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_FINAL_SESSION:
1,263✔
2917
      return "session final";
1,263✔
2918
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_STATE:
7,464✔
2919
      return "state single";
7,464✔
2920
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_PARTITION:
742,165✔
2921
      return "stream partitionby";
742,165✔
2922
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_EVENT:
840✔
2923
      return "stream event";
840✔
2924
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_COUNT:
10,166✔
2925
      return "stream count";
10,166✔
2926
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_INTERP_FUNC:
7,457✔
2927
      return "stream interp";
7,457✔
2928
    case QUERY_NODE_PHYSICAL_PLAN_STREAM_CONTINUE_INTERVAL:
4,435✔
2929
      return "interval continue";
4,435✔
2930
  }
2931
  return "";
×
2932
}
2933

2934
void printDataBlock(SSDataBlock* pBlock, const char* flag, const char* taskIdStr) {
1,273,076✔
2935
  if (!pBlock) {
1,273,076!
2936
    qDebug("%s===stream===%s: Block is Null", taskIdStr, flag);
×
2937
    return;
×
2938
  } else if (pBlock->info.rows == 0) {
1,273,076✔
2939
    qDebug("%s===stream===%s: Block is Empty. block type %d", taskIdStr, flag, pBlock->info.type);
23,058✔
2940
    return;
23,061✔
2941
  }
2942
  if (qDebugFlag & DEBUG_DEBUG) {
1,250,018✔
2943
    char*   pBuf = NULL;
47,900✔
2944
    int32_t code = dumpBlockData(pBlock, flag, &pBuf, taskIdStr);
47,900✔
2945
    if (code == 0) {
47,898!
2946
      qDebug("%s", pBuf);
47,898!
2947
      taosMemoryFree(pBuf);
47,900!
2948
    }
2949
  }
2950
}
2951

2952
void printSpecDataBlock(SSDataBlock* pBlock, const char* flag, const char* opStr, const char* taskIdStr) {
1,404,970✔
2953
  if (!pBlock) {
1,404,970!
2954
    qDebug("%s===stream===%s %s: Block is Null", taskIdStr, flag, opStr);
×
2955
    return;
×
2956
  } else if (pBlock->info.rows == 0) {
1,404,970✔
2957
    qDebug("%s===stream===%s %s: Block is Empty. block type %d.skey:%" PRId64 ",ekey:%" PRId64 ",version%" PRId64,
12,589✔
2958
           taskIdStr, flag, opStr, pBlock->info.type, pBlock->info.window.skey, pBlock->info.window.ekey,
2959
           pBlock->info.version);
2960
    return;
12,589✔
2961
  }
2962
  if (qDebugFlag & DEBUG_DEBUG) {
1,392,381✔
2963
    char* pBuf = NULL;
59,949✔
2964
    char  flagBuf[64];
2965
    snprintf(flagBuf, sizeof(flagBuf), "%s %s", flag, opStr);
59,949✔
2966
    int32_t code = dumpBlockData(pBlock, flagBuf, &pBuf, taskIdStr);
59,949✔
2967
    if (code == 0) {
59,949!
2968
      qDebug("%s", pBuf);
59,949!
2969
      taosMemoryFree(pBuf);
59,949!
2970
    }
2971
  }
2972
}
2973

2974
TSKEY getStartTsKey(STimeWindow* win, const TSKEY* tsCols) { return tsCols == NULL ? win->skey : tsCols[0]; }
3,775,236!
2975

2976
void updateTimeWindowInfo(SColumnInfoData* pColData, STimeWindow* pWin, int64_t delta) {
400,825,835✔
2977
  int64_t* ts = (int64_t*)pColData->pData;
400,825,835✔
2978

2979
  int64_t duration = pWin->ekey - pWin->skey + delta;
400,825,835✔
2980
  ts[2] = duration;            // set the duration
400,825,835✔
2981
  ts[3] = pWin->skey;          // window start key
400,825,835✔
2982
  ts[4] = pWin->ekey + delta;  // window end key
400,825,835✔
2983
}
400,825,835✔
2984

2985
int32_t compKeys(const SArray* pSortGroupCols, const char* oldkeyBuf, int32_t oldKeysLen, const SSDataBlock* pBlock,
21,361,286✔
2986
                 int32_t rowIndex) {
2987
  SColumnDataAgg* pColAgg = NULL;
21,361,286✔
2988
  const char*     isNull = oldkeyBuf;
21,361,286✔
2989
  const char*     p = oldkeyBuf + sizeof(int8_t) * pSortGroupCols->size;
21,361,286✔
2990

2991
  for (int32_t i = 0; i < pSortGroupCols->size; ++i) {
53,676,107✔
2992
    const SColumn*         pCol = (SColumn*)TARRAY_GET_ELEM(pSortGroupCols, i);
32,797,840✔
2993
    const SColumnInfoData* pColInfoData = TARRAY_GET_ELEM(pBlock->pDataBlock, pCol->slotId);
32,797,840✔
2994
    if (pBlock->pBlockAgg) pColAgg = &pBlock->pBlockAgg[pCol->slotId];
32,797,840!
2995

2996
    if (colDataIsNull(pColInfoData, pBlock->info.rows, rowIndex, pColAgg)) {
65,595,680!
2997
      if (isNull[i] != 1) return 1;
2,184,010✔
2998
    } else {
2999
      if (isNull[i] != 0) return 1;
30,613,830✔
3000
      const char* val = colDataGetData(pColInfoData, rowIndex);
30,599,608!
3001
      if (pCol->type == TSDB_DATA_TYPE_JSON) {
30,599,608!
3002
        int32_t len = getJsonValueLen(val);
×
3003
        if (memcmp(p, val, len) != 0) return 1;
×
3004
        p += len;
×
3005
      } else if (IS_VAR_DATA_TYPE(pCol->type)) {
30,599,608!
3006
        if (memcmp(p, val, varDataTLen(val)) != 0) return 1;
10,407,716✔
3007
        p += varDataTLen(val);
10,271,334✔
3008
      } else {
3009
        if (0 != memcmp(p, val, pCol->bytes)) return 1;
20,191,892✔
3010
        p += pCol->bytes;
19,859,669✔
3011
      }
3012
    }
3013
  }
3014
  if ((int32_t)(p - oldkeyBuf) != oldKeysLen) return 1;
20,878,267✔
3015
  return 0;
20,877,971✔
3016
}
3017

3018
int32_t buildKeys(char* keyBuf, const SArray* pSortGroupCols, const SSDataBlock* pBlock, int32_t rowIndex) {
482,986✔
3019
  uint32_t        colNum = pSortGroupCols->size;
482,986✔
3020
  SColumnDataAgg* pColAgg = NULL;
482,986✔
3021
  char*           isNull = keyBuf;
482,986✔
3022
  char*           p = keyBuf + sizeof(int8_t) * colNum;
482,986✔
3023

3024
  for (int32_t i = 0; i < colNum; ++i) {
1,439,127✔
3025
    const SColumn*         pCol = (SColumn*)TARRAY_GET_ELEM(pSortGroupCols, i);
956,141✔
3026
    const SColumnInfoData* pColInfoData = TARRAY_GET_ELEM(pBlock->pDataBlock, pCol->slotId);
956,141✔
3027
    if (pCol->slotId > pBlock->pDataBlock->size) continue;
956,141!
3028

3029
    if (pBlock->pBlockAgg) pColAgg = &pBlock->pBlockAgg[pCol->slotId];
956,141!
3030

3031
    if (colDataIsNull(pColInfoData, pBlock->info.rows, rowIndex, pColAgg)) {
1,912,282!
3032
      isNull[i] = 1;
34,558✔
3033
    } else {
3034
      isNull[i] = 0;
921,583✔
3035
      const char* val = colDataGetData(pColInfoData, rowIndex);
921,583!
3036
      if (pCol->type == TSDB_DATA_TYPE_JSON) {
921,583!
3037
        int32_t len = getJsonValueLen(val);
×
3038
        memcpy(p, val, len);
×
3039
        p += len;
×
3040
      } else if (IS_VAR_DATA_TYPE(pCol->type)) {
921,583!
3041
        varDataCopy(p, val);
139,656✔
3042
        p += varDataTLen(val);
139,656✔
3043
      } else {
3044
        memcpy(p, val, pCol->bytes);
781,927✔
3045
        p += pCol->bytes;
781,927✔
3046
      }
3047
    }
3048
  }
3049
  return (int32_t)(p - keyBuf);
482,986✔
3050
}
3051

3052
uint64_t calcGroupId(char* pData, int32_t len) {
19,118,706✔
3053
  T_MD5_CTX context;
3054
  tMD5Init(&context);
19,118,706✔
3055
  tMD5Update(&context, (uint8_t*)pData, len);
19,134,500✔
3056
  tMD5Final(&context);
19,249,946✔
3057

3058
  // NOTE: only extract the initial 8 bytes of the final MD5 digest
3059
  uint64_t id = 0;
19,404,648✔
3060
  memcpy(&id, context.digest, sizeof(uint64_t));
19,404,648✔
3061
  if (0 == id) memcpy(&id, context.digest + 8, sizeof(uint64_t));
19,404,648!
3062
  return id;
19,404,648✔
3063
}
3064

3065
SNodeList* makeColsNodeArrFromSortKeys(SNodeList* pSortKeys) {
943✔
3066
  SNode*     node;
3067
  SNodeList* ret = NULL;
943✔
3068
  FOREACH(node, pSortKeys) {
2,879!
3069
    SOrderByExprNode* pSortKey = (SOrderByExprNode*)node;
1,935✔
3070
    int32_t           code = nodesListMakeAppend(&ret, pSortKey->pExpr);
1,935✔
3071
    if (code != TSDB_CODE_SUCCESS) {
1,936!
3072
      qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
×
3073
      terrno = code;
×
3074
      return NULL;
×
3075
    }
3076
  }
3077
  return ret;
944✔
3078
}
3079

3080
int32_t extractKeysLen(const SArray* keys, int32_t* pLen) {
943✔
3081
  int32_t code = TSDB_CODE_SUCCESS;
943✔
3082
  int32_t lino = 0;
943✔
3083
  int32_t len = 0;
943✔
3084
  int32_t keyNum = taosArrayGetSize(keys);
943✔
3085
  for (int32_t i = 0; i < keyNum; ++i) {
2,398✔
3086
    SColumn* pCol = (SColumn*)taosArrayGet(keys, i);
1,455✔
3087
    QUERY_CHECK_NULL(pCol, code, lino, _end, terrno);
1,455!
3088
    len += pCol->bytes;
1,455✔
3089
  }
3090
  len += sizeof(int8_t) * keyNum;  // null flag
943✔
3091
  *pLen = len;
943✔
3092

3093
_end:
943✔
3094
  if (code != TSDB_CODE_SUCCESS) {
943!
3095
    qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
×
3096
  }
3097
  return code;
943✔
3098
}
3099

STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc