xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/TD-31802

This commit is contained in:
54liuyao 2024-08-30 15:42:59 +08:00
parent dd1ab39eb0 912d987184
commit 5370b47468
88 changed files with 1837 additions and 116 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/dnode/vnode/src/tsdb/tsdbCache.c
View File

@ -2258,6 +2258,7 @@ static int32_t lastIterOpen(SFSLastIter *iter, STFileSet *pFileSet, STsdb *pTsdb
int32_t code = 0;
destroySttBlockReader(pr->pLDataIterArray, NULL);
pr->pLDataIterArray = taosArrayInit(4, POINTER_BYTES);
if (pr->pLDataIterArray == NULL) return terrno;
SMergeTreeConf conf = {
.uid = uid,

8
source/dnode/vnode/src/tsdb/tsdbRead2.c
View File

@ -723,6 +723,7 @@ static int32_t loadFileBlockBrinInfo(STsdbReader* pReader, SArray* pIndexList, S
while (1) {
int32_t code = getNextBrinRecord(&iter, &pRecord);
if (code != TSDB_CODE_SUCCESS) {
clearBrinBlockIter(&iter);
return code;
}
@ -757,12 +758,14 @@ static int32_t loadFileBlockBrinInfo(STsdbReader* pReader, SArray* pIndexList, S
if (!(pRecord->suid == pReader->info.suid && uid == pRecord->uid)) {
tsdbError("tsdb failed at: %s:%d", __func__, __LINE__);
clearBrinBlockIter(&iter);
return TSDB_CODE_INTERNAL_ERROR;
}
STableBlockScanInfo* pScanInfo = NULL;
code = getTableBlockScanInfo(pReader->status.pTableMap, uid, &pScanInfo, pReader->idStr);
if (code != TSDB_CODE_SUCCESS) {
clearBrinBlockIter(&iter);
return code;
}
@ -807,6 +810,7 @@ static int32_t loadFileBlockBrinInfo(STsdbReader* pReader, SArray* pIndexList, S
if (pScanInfo->pBlockList == NULL) {
pScanInfo->pBlockList = taosArrayInit(4, sizeof(SFileDataBlockInfo));
if (pScanInfo->pBlockList == NULL) {
clearBrinBlockIter(&iter);
return TSDB_CODE_OUT_OF_MEMORY;
}
}
@ -814,6 +818,7 @@ static int32_t loadFileBlockBrinInfo(STsdbReader* pReader, SArray* pIndexList, S
if (pScanInfo->pBlockIdxList == NULL) {
pScanInfo->pBlockIdxList = taosArrayInit(4, sizeof(STableDataBlockIdx));
if (pScanInfo->pBlockIdxList == NULL) {
clearBrinBlockIter(&iter);
return TSDB_CODE_OUT_OF_MEMORY;
}
}
@ -822,6 +827,7 @@ static int32_t loadFileBlockBrinInfo(STsdbReader* pReader, SArray* pIndexList, S
recordToBlockInfo(&blockInfo, pRecord);
void* p1 = taosArrayPush(pScanInfo->pBlockList, &blockInfo);
if (p1 == NULL) {
clearBrinBlockIter(&iter);
return TSDB_CODE_OUT_OF_MEMORY;
}
@ -840,6 +846,7 @@ static int32_t loadFileBlockBrinInfo(STsdbReader* pReader, SArray* pIndexList, S
} else {
STableBlockScanInfo** p = taosArrayGetLast(pTableScanInfoList);
if (p == NULL) {
clearBrinBlockIter(&iter);
return TSDB_CODE_INVALID_PARA;
}
@ -849,6 +856,7 @@ static int32_t loadFileBlockBrinInfo(STsdbReader* pReader, SArray* pIndexList, S
}
if (p1 == NULL) {
clearBrinBlockIter(&iter);
return TSDB_CODE_OUT_OF_MEMORY;
}
}

56
source/libs/executor/src/sortoperator.c
View File

@ -254,17 +254,17 @@ static int32_t getSortedBlockData(SSortHandle* pHandle, SSDataBlock* pDataBlock,
SSortOperatorInfo* pInfo, SSDataBlock** pResBlock) {
QRY_OPTR_CHECK(pResBlock);
blockDataCleanup(pDataBlock);
int32_t lino = 0;
int32_t code = 0;
SSDataBlock* p = NULL;
int32_t code = tsortGetSortedDataBlock(pHandle, &p);
code = tsortGetSortedDataBlock(pHandle, &p);
if (p == NULL || (code != 0)) {
return code;
}
code = blockDataEnsureCapacity(p, capacity);
if (code) {
return code;
}
QUERY_CHECK_CODE(code, lino, _error);
STupleHandle* pTupleHandle;
while (1) {
@ -273,51 +273,40 @@ static int32_t getSortedBlockData(SSortHandle* pHandle, SSDataBlock* pDataBlock,
} else {
code = tsortNextTuple(pHandle, &pTupleHandle);
}
if (pTupleHandle == NULL || code != 0) {
lino = __LINE__;
break;
}
code = appendOneRowToDataBlock(p, pTupleHandle);
if (code) {
return code;
}
QUERY_CHECK_CODE(code, lino, _error);
if (p->info.rows >= capacity) {
break;
}
}
if (TSDB_CODE_SUCCESS != code) {
return code;
}
QUERY_CHECK_CODE(code, lino, _error);
if (p->info.rows > 0) {
code = blockDataEnsureCapacity(pDataBlock, capacity);
if (code) {
return code;
}
QUERY_CHECK_CODE(code, lino, _error);
// todo extract function to handle this
int32_t numOfCols = taosArrayGetSize(pColMatchInfo);
for (int32_t i = 0; i < numOfCols; ++i) {
SColMatchItem* pmInfo = taosArrayGet(pColMatchInfo, i);
if (pmInfo == NULL) {
return terrno;
}
QUERY_CHECK_NULL(pmInfo, code, lino, _error, terrno);
SColumnInfoData* pSrc = taosArrayGet(p->pDataBlock, pmInfo->srcSlotId);
if (pSrc == NULL) {
return terrno;
}
QUERY_CHECK_NULL(pSrc, code, lino, _error, terrno);
SColumnInfoData* pDst = taosArrayGet(pDataBlock->pDataBlock, pmInfo->dstSlotId);
if (pDst == NULL) {
return terrno;
}
QUERY_CHECK_NULL(pDst, code, lino, _error, terrno);
code = colDataAssign(pDst, pSrc, p->info.rows, &pDataBlock->info);
if (code) {
return code;
}
QUERY_CHECK_CODE(code, lino, _error);
}
pDataBlock->info.dataLoad = 1;
@ -329,6 +318,12 @@ static int32_t getSortedBlockData(SSortHandle* pHandle, SSDataBlock* pDataBlock,
blockDataDestroy(p);
*pResBlock = (pDataBlock->info.rows > 0) ? pDataBlock : NULL;
return code;
_error:
qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
blockDataDestroy(p);
return code;
}
int32_t loadNextDataBlock(void* param, SSDataBlock** ppBlock) {
@ -384,13 +379,13 @@ int32_t doOpenSortOperator(SOperatorInfo* pOperator) {
code = tsortOpen(pInfo->pSortHandle);
if (code != TSDB_CODE_SUCCESS) {
T_LONG_JMP(pTaskInfo->env, code);
pTaskInfo->code = code;
} else {
pOperator->cost.openCost = (taosGetTimestampUs() - pInfo->startTs) / 1000.0;
pOperator->status = OP_RES_TO_RETURN;
OPTR_SET_OPENED(pOperator);
}
pOperator->cost.openCost = (taosGetTimestampUs() - pInfo->startTs) / 1000.0;
pOperator->status = OP_RES_TO_RETURN;
OPTR_SET_OPENED(pOperator);
return code;
}
@ -735,6 +730,7 @@ int32_t doGroupSort(SOperatorInfo* pOperator, SSDataBlock** pResBlock) {
qError("%s failed at line %d since %s", __func__, __LINE__, tstrerror(code));
T_LONG_JMP(pOperator->pTaskInfo->env, code);
}
code = getGroupSortedBlockData(pInfo->pCurrSortHandle, pInfo->binfo.pRes, pOperator->resultInfo.capacity,
pInfo->matchInfo.pList, pInfo, &pBlock);
if (pBlock != NULL && (code == 0)) {

31
source/libs/executor/src/tsort.c
View File

@ -286,23 +286,19 @@ int32_t tsortCreateSortHandle(SArray* pSortInfo, int32_t type, int32_t pageSize,
SSDataBlock* pBlock, const char* idstr, uint64_t pqMaxRows, uint32_t pqMaxTupleLength,
uint32_t pqSortBufSize, SSortHandle** pHandle) {
int32_t code = 0;
*pHandle = NULL;
int32_t lino = 0;
QRY_OPTR_CHECK(pHandle);
SSortHandle* pSortHandle = taosMemoryCalloc(1, sizeof(SSortHandle));
if (pSortHandle == NULL) {
return TSDB_CODE_OUT_OF_MEMORY;
}
QUERY_CHECK_NULL(pSortHandle, code, lino, _err, terrno);
pSortHandle->type = type;
pSortHandle->pageSize = pageSize;
pSortHandle->numOfPages = numOfPages;
pSortHandle->pSortInfo = taosArrayDup(pSortInfo, NULL);
if (pSortHandle->pSortInfo == NULL) {
return terrno;
}
QUERY_CHECK_NULL(pSortHandle->pSortInfo, code, lino, _err, terrno);
pSortHandle->loops = 0;
pSortHandle->pqMaxTupleLength = pqMaxTupleLength;
if (pqMaxRows != 0) {
pSortHandle->pqSortBufSize = pqSortBufSize;
@ -312,18 +308,13 @@ int32_t tsortCreateSortHandle(SArray* pSortInfo, int32_t type, int32_t pageSize,
pSortHandle->forceUsePQSort = false;
if (pBlock != NULL) {
code = createOneDataBlock(pBlock, false, &pSortHandle->pDataBlock);
if (code) {
goto _err;
}
QUERY_CHECK_CODE(code, lino, _err);
}
pSortHandle->mergeLimit = -1;
pSortHandle->pOrderedSource = taosArrayInit(4, POINTER_BYTES);
if (pSortHandle->pOrderedSource == NULL) {
code = terrno;
goto _err;
}
QUERY_CHECK_NULL(pSortHandle->pOrderedSource, code, lino, _err, terrno);
pSortHandle->cmpParam.orderInfo = pSortInfo;
pSortHandle->cmpParam.cmpGroupId = false;
@ -346,17 +337,17 @@ int32_t tsortCreateSortHandle(SArray* pSortInfo, int32_t type, int32_t pageSize,
if (idstr != NULL) {
pSortHandle->idStr = taosStrdup(idstr);
if (pSortHandle->idStr == NULL) {
code = TSDB_CODE_OUT_OF_MEMORY;
goto _err;
}
QUERY_CHECK_NULL(pSortHandle->idStr, code, lino, _err, terrno);
}
*pHandle = pSortHandle;
return code;
_err:
tsortDestroySortHandle(pSortHandle);
qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
if (pSortHandle) {
tsortDestroySortHandle(pSortHandle);
}
return code;
}

8
source/libs/function/src/builtins.c
View File

@ -2426,8 +2426,12 @@ static int32_t translateToIso8601(SFunctionNode* pFunc, char* pErrBuf, int32_t l
// param1
if (numOfParams == 2) {
SValueNode* pValue = (SValueNode*)nodesListGetNode(pFunc->pParameterList, 1);
SNode* pNode = (SNode*)nodesListGetNode(pFunc->pParameterList, 1);
if (QUERY_NODE_VALUE != nodeType(pNode)) {
return buildFuncErrMsg(pErrBuf, len, TSDB_CODE_FUNC_FUNTION_ERROR, "Not supported timzone format");
}
SValueNode* pValue = (SValueNode*)pNode;
if (!validateTimezoneFormat(pValue)) {
return buildFuncErrMsg(pErrBuf, len, TSDB_CODE_FUNC_FUNTION_ERROR, "Invalid timzone format");
}

2
source/libs/nodes/src/nodesUtilFuncs.c
View File

@ -1089,6 +1089,8 @@ void nodesDestroyNode(SNode* pNode) {
if (pStmt->destroyParseFileCxt) {
pStmt->destroyParseFileCxt(&pStmt->pParFileCxt);
}
(void)taosCloseFile(&pStmt->fp);
break;
}
case QUERY_NODE_CREATE_DATABASE_STMT:

2
source/libs/scalar/src/filter.c
View File

@ -5113,7 +5113,7 @@ int32_t fltOptimizeNodes(SFilterInfo *pInfo, SNode **pNode, SFltTreeStat *pStat)
FLT_ERR_JRET(fltSclCollectOperators(*pNode, sclOpList));
SArray *colRangeList = taosArrayInit(16, sizeof(SFltSclColumnRange));
if (NULL == colRangeList) {
FLT_ERR_RET(terrno);
FLT_ERR_JRET(terrno);
}
FLT_ERR_JRET(fltSclProcessCNF(sclOpList, colRangeList));
pInfo->sclCtx.fltSclRange = colRangeList;

3
source/libs/scalar/src/sclfunc.c
View File

@ -766,6 +766,9 @@ static int32_t tlrtrim(char *input, char *remInput, char *output, int32_t inputT
if (remLen == 0 || remLen > orgLen) {
(void)memcpy(varDataVal(output), orgStr, orgLen);
varDataSetLen(output, orgLen);
if (needFree) {
taosMemoryFree(remStr);
}
return TSDB_CODE_SUCCESS;
}

13
source/libs/stream/src/streamTask.c
View File

@ -310,6 +310,7 @@ void tFreeStreamTask(SStreamTask* pTask) {
}
void streamFreeTaskState(SStreamTask* pTask, int8_t remove) {
stDebug("s-task:0x%x start to free task state/backend", pTask->id.taskId);
if (pTask->pState != NULL) {
stDebug("s-task:0x%x start to free task state", pTask->id.taskId);
streamStateClose(pTask->pState, remove);
@ -319,8 +320,11 @@ void streamFreeTaskState(SStreamTask* pTask, int8_t remove) {
pTask->pBackend = NULL;
pTask->pState = NULL;
} else {
stDebug("s-task:0x%x task state is NULL, may del backend:%s", pTask->id.taskId,
pTask->backendPath ? pTask->backendPath : "NULL");
if (remove) {
if (pTask->backendPath != NULL) {
stDebug("s-task:0x%x task state is NULL, do del backend:%s", pTask->id.taskId, pTask->backendPath);
taosRemoveDir(pTask->backendPath);
}
}
@ -373,11 +377,11 @@ int32_t streamTaskSetBackendPath(SStreamTask* pTask) {
int32_t taskId = 0;
if (pTask->info.fillHistory) {
streamId = pTask->hTaskInfo.id.taskId;
taskId = pTask->hTaskInfo.id.taskId;
} else {
streamId = pTask->streamTaskId.taskId;
streamId = pTask->streamTaskId.streamId;
taskId = pTask->streamTaskId.taskId;
} else {
streamId = pTask->id.streamId;
taskId = pTask->id.taskId;
}
char id[128] = {0};
@ -393,6 +397,7 @@ int32_t streamTaskSetBackendPath(SStreamTask* pTask) {
}
(void)sprintf(pTask->backendPath, "%s%s%s", pTask->pMeta->path, TD_DIRSEP, id);
stDebug("s-task:%s set backend path:%s", pTask->id.idStr, pTask->backendPath);
return 0;
}

28
source/libs/transport/src/transCli.c
View File

@ -253,20 +253,20 @@ static void cliWalkCb(uv_handle_t* handle, void* arg);
#define CONN_PERSIST_TIME(para) ((para) <= 90000 ? 90000 : (para))
#define CONN_GET_INST_LABEL(conn) (((STrans*)(((SCliThrd*)(conn)->hostThrd)->pTransInst))->label)
#define CONN_GET_MSGCTX_BY_AHANDLE(conn, ahandle) \
do { \
int i = 0, sz = transQueueSize(&conn->cliMsgs); \
for (; i < sz; i++) { \
pMsg = transQueueGet(&conn->cliMsgs, i); \
if (pMsg->ctx != NULL && (uint64_t)pMsg->ctx->ahandle == ahandle) { \
break; \
} \
} \
if (i == sz) { \
pMsg = NULL; \
} else { \
pMsg = transQueueRm(&conn->cliMsgs, i); \
} \
#define CONN_GET_MSGCTX_BY_AHANDLE(conn, ahandle) \
do { \
int i = 0, sz = transQueueSize(&conn->cliMsgs); \
for (; i < sz; i++) { \
pMsg = transQueueGet(&conn->cliMsgs, i); \
if (pMsg->msg.msgType != TDMT_SCH_DROP_TASK && pMsg->ctx != NULL && (uint64_t)pMsg->ctx->ahandle == ahandle) { \
break; \
} \
} \
if (i == sz) { \
pMsg = NULL; \
} else { \
pMsg = transQueueRm(&conn->cliMsgs, i); \
} \
} while (0)
#define CONN_GET_NEXT_SENDMSG(conn) \

11
source/util/src/tlrucache.c
View File

@ -374,6 +374,7 @@ static LRUStatus taosLRUCacheShardInsertEntry(SLRUCacheShard *shard, SLRUEntry *
LRUStatus status = TAOS_LRU_STATUS_OK;
SArray *lastReferenceList = taosArrayInit(16, POINTER_BYTES);
if (!lastReferenceList) {
taosLRUEntryFree(e);
return TAOS_LRU_STATUS_FAIL;
}
@ -385,13 +386,12 @@ static LRUStatus taosLRUCacheShardInsertEntry(SLRUCacheShard *shard, SLRUEntry *
TAOS_LRU_ENTRY_SET_IN_CACHE(e, false);
if (handle == NULL) {
if (!taosArrayPush(lastReferenceList, &e)) {
(void)taosThreadMutexUnlock(&shard->mutex);
taosLRUEntryFree(e);
return status;
goto _exit;
}
} else {
if (freeOnFail) {
taosMemoryFree(e);
taosLRUEntryFree(e);
*handle = NULL;
}
@ -410,9 +410,9 @@ static LRUStatus taosLRUCacheShardInsertEntry(SLRUCacheShard *shard, SLRUEntry *
shard->usage -= old->totalCharge;
if (!taosArrayPush(lastReferenceList, &old)) {
(void)taosThreadMutexUnlock(&shard->mutex);
taosLRUEntryFree(e);
taosLRUEntryFree(old);
return status;
goto _exit;
}
}
}
@ -427,6 +427,7 @@ static LRUStatus taosLRUCacheShardInsertEntry(SLRUCacheShard *shard, SLRUEntry *
}
}
_exit:
(void)taosThreadMutexUnlock(&shard->mutex);
for (int i = 0; i < taosArrayGetSize(lastReferenceList); ++i) {

65
tests/army/query/function/ans/ascii.csv
View File

@ -46,4 +46,67 @@
228
117
112
110
110
116
116
39
108
120
108
120
108
116
104
116
116
104
108
120
108
120
108
116
104
116
116
104
110
228
117
112
110
110
97
228
110
97
110
228
117
112
110
110
97
228
110
97
110
112
110
112
228
117
112
112
112
112
110
112
110
112
228
117
112
112
112
112

1 104
46 228
47 117
48 112
49 110
50 116
51 116
52 39
53 108
54 120
55 108
56 120
57 108
58 116
59 104
60 116
61 116
62 104
63 108
64 120
65 108
66 120
67 108
68 116
69 104
70 116
71 116
72 104
73 110
74 228
75 117
76 112
77 110
78 110
79 97
80 228
81 110
82 97
83 110
84 228
85 117
86 112
87 110
88 110
89 97
90 228
91 110
92 97
93 110
94 112
95 110
96 112
97 228
98 117
99 112
100 112
101 112
102 112
103 110
104 112
105 110
106 112
107 228
108 117
109 112
110 112
111 112
112 112

6
tests/army/query/function/ans/char.csv
View File

@ -36,4 +36,8 @@ MMMMM
NNNNN
OOOOO
PPPPP
QQQQQ
QQQQQ
M
MM
{
M{

1 M
36 NNNNN
37 OOOOO
38 PPPPP
39 QQQQQ
40 M
41 MM
42 {
43 M{

46
tests/army/query/function/ans/char_length.csv
View File

@ -46,4 +46,48 @@
10
6
7
5
5
4
2
6
5
5
10
6
7
5
5
5
10
5
5
5
10
6
7
5
5
5
10
5
5
5
6
5
5
10
6
7
6
7
5
5
6
5
5
10
6
7
6
7
5

1 5
46 10
47 6
48 7
49 5
50 4
51 2
52 6
53 5
54 5
55 10
56 6
57 7
58 5
59 5
60 5
61 10
62 5
63 5
64 5
65 10
66 6
67 7
68 5
69 5
70 5
71 10
72 5
73 5
74 5
75 6
76 5
77 5
78 10
79 6
80 7
81 6
82 7
83 5
84 5
85 6
86 5
87 5
88 10
89 6
90 7
91 6
92 7
93 5

25
tests/army/query/function/ans/dayofweek.csv
View File

@ -73,4 +73,27 @@
6
6
6
6
6
4
4
2
6
6
6
6
6
6
6
6
6
6
6
6
6
6
6
6
6
6
6
6

1 4
73 6
74 6
75 6
76 6
77 4
78 4
79 2
80 6
81 6
82 6
83 6
84 6
85 6
86 6
87 6
88 6
89 6
90 6
91 6
92 6
93 6
94 6
95 6
96 6
97 6
98 6
99 6

23
tests/army/query/function/ans/degrees.csv
View File

@ -42,4 +42,25 @@
57.295779513082323
81.028468454139556
99.239201175922574
114.591559026164646
114.591559026164646
180
610.200029957721426
491.254034090376820
561.212164701962479
643.603479905018958
613.408634263739941
487.472513516777667
549.810284033650078
628.076328902558998
643.202411196955836
592.266466706882511
610.200029957721426
491.254034090376820
561.212164701962479
643.603479905018958
613.408634263739941
487.472513516777667
549.810284033650078
628.076328902558998
643.202411196955836
592.266466706882511

1 0.000000000000000
42 57.295779513082323
43 81.028468454139556
44 99.239201175922574
45 114.591559026164646
46 180
47 610.200029957721426
48 491.254034090376820
49 561.212164701962479
50 643.603479905018958
51 613.408634263739941
52 487.472513516777667
53 549.810284033650078
54 628.076328902558998
55 643.202411196955836
56 592.266466706882511
57 610.200029957721426
58 491.254034090376820
59 561.212164701962479
60 643.603479905018958
61 613.408634263739941
62 487.472513516777667
63 549.810284033650078
64 628.076328902558998
65 643.202411196955836
66 592.266466706882511

24
tests/army/query/function/ans/exp.csv
View File

@ -41,4 +41,26 @@
4.113250378782928
5.652233674034091
7.389056098930650
3814279.104760214220732
3814279.104760214220732
7.38905609893065
1.6487212707001282
42192.578453635847836
5292.258432380726845
17943.802618770550907
75583.992598717435612
44622.804904812772293
4954.246535954979663
14705.836248958077704
57641.604897186582093
75056.754435561466380
30853.327779395312973
42192.578453635847836
5292.258432380726845
17943.802618770550907
75583.992598717435612
44622.804904812772293
4954.246535954979663
14705.836248958077704
57641.604897186582093
75056.754435561466380
30853.327779395312973

1 1.000000000000000
41 4.113250378782928
42 5.652233674034091
43 7.389056098930650
44 3814279.104760214220732
45 7.38905609893065
46 1.6487212707001282
47 42192.578453635847836
48 5292.258432380726845
49 17943.802618770550907
50 75583.992598717435612
51 44622.804904812772293
52 4954.246535954979663
53 14705.836248958077704
54 57641.604897186582093
55 75056.754435561466380
56 30853.327779395312973
57 42192.578453635847836
58 5292.258432380726845
59 17943.802618770550907
60 75583.992598717435612
61 44622.804904812772293
62 4954.246535954979663
63 14705.836248958077704
64 57641.604897186582093
65 75056.754435561466380
66 30853.327779395312973

24
tests/army/query/function/ans/ln.csv
View File

@ -38,4 +38,26 @@
1.005052538742381
1.098612288668110
-0.226079864157595
2.000000000000000
2.000000000000000
2.302585092994046
1.144729885849400
2.365559856336680
2.148734409997751
2.281872059185575
2.418855857000369
2.370804362614190
2.141006941277850
2.261346315560232
2.394434736880126
2.418232501568406
2.335729681253415
2.365559856336680
2.148734409997751
2.281872059185575
2.418855857000369
2.370804362614190
2.141006941277850
2.261346315560232
2.394434736880126
2.418232501568406
2.335729681253415

1 4.605170185988092
38 1.005052538742381
39 1.098612288668110
40 -0.226079864157595
41 2.000000000000000
42 2.302585092994046
43 1.144729885849400
44 2.365559856336680
45 2.148734409997751
46 2.281872059185575
47 2.418855857000369
48 2.370804362614190
49 2.141006941277850
50 2.261346315560232
51 2.394434736880126
52 2.418232501568406
53 2.335729681253415
54 2.365559856336680
55 2.148734409997751
56 2.281872059185575
57 2.418855857000369
58 2.370804362614190
59 2.141006941277850
60 2.261346315560232
61 2.394434736880126
62 2.418232501568406
63 2.335729681253415

22
tests/army/query/function/ans/mod.csv
View File

@ -48,3 +48,25 @@
3.310891102586806e+00
3.350522322288470e+00
3.215120509901375e+00
1
1
0
1
2
0
1
2
0
1
2
0
0
1
2
0
1
2
0
1
2
0

1 1.550000000000001
48 3.310891102586806e+00
49 3.350522322288470e+00
50 3.215120509901375e+00
51 1
52 1
53 0
54 1
55 2
56 0
57 1
58 2
59 0
60 1
61 2
62 0
63 0
64 1
65 2
66 0
67 1
68 2
69 0
70 1
71 2
72 0

3
tests/army/query/function/ans/pi.csv
View File

@ -24,4 +24,5 @@
3.141592653589793
9.869604401089358
1.772453850905516
3
3
3.141592653589793

1 3.141592653589793
24 3.141592653589793
25 9.869604401089358
26 1.772453850905516
27 3
28 3.141592653589793

84
tests/army/query/function/ans/position.csv
View File

@ -90,3 +90,87 @@
1
1
1.000000000000000e+00
1
0
1
1
0
0
0
0
4
0
0
0
0
0
0
0
0
0
4
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0
4
0
0
0
0
0
0
0
4
0
4
0
0
0
0
0
0
0
4
0
4
0
0
5
0
0
0
0
0
0
4
0
0
5
0
0
0
0
0
0

1 1
90 1
91 1
92 1.000000000000000e+00
93 1
94 0
95 1
96 1
97 0
98 0
99 0
100 0
101 4
102 0
103 0
104 0
105 0
106 0
107 0
108 0
109 0
110 0
111 4
112 0
113 0
114 0
115 0
116 0
117 0
118 0
119 0
120 0
121 0
122 0
123 0
124 0
125 0
126 0
127 0
128 0
129 0
130 0
131 0
132 0
133 0
134 0
135 0
136 0
137 4
138 0
139 0
140 0
141 0
142 0
143 0
144 0
145 4
146 0
147 4
148 0
149 0
150 0
151 0
152 0
153 0
154 0
155 4
156 0
157 4
158 0
159 0
160 5
161 0
162 0
163 0
164 0
165 0
166 0
167 4
168 0
169 0
170 5
171 0
172 0
173 0
174 0
175 0
176 0

23
tests/army/query/function/ans/radians.csv
View File

@ -42,4 +42,25 @@
0.017453292519943
0.024682682989769
0.030229989403904
0.034906585039887
0.034906585039887
3.141592653589793
0.185877558679493
0.149644536324422
0.170955001564425
0.196052831414414
0.186854955444309
0.148492619284422
0.167481790094528
0.191322990739406
0.195930658899406
0.180414682914441
0.185877558679493
0.149644536324422
0.170955001564425
0.196052831414414
0.186854955444309
0.148492619284422
0.167481790094528
0.191322990739406
0.195930658899406
0.180414682914441

1 0.000000000000000
42 0.017453292519943
43 0.024682682989769
44 0.030229989403904
45 0.034906585039887
46 3.141592653589793
47 0.185877558679493
48 0.149644536324422
49 0.170955001564425
50 0.196052831414414
51 0.186854955444309
52 0.148492619284422
53 0.167481790094528
54 0.191322990739406
55 0.195930658899406
56 0.180414682914441
57 0.185877558679493
58 0.149644536324422
59 0.170955001564425
60 0.196052831414414
61 0.186854955444309
62 0.148492619284422
63 0.167481790094528
64 0.191322990739406
65 0.195930658899406
66 0.180414682914441

104
tests/army/query/function/ans/repeat.csv
View File

@ -56,4 +56,106 @@ var1
var1var1
var1var1var1
var1var1var1var1
var1var1var1var1var1
var1var1var1var1var1
taos
taostaos
lililililili
xxx
lililililili
xxx
lililililili
taostaostaos
hahahahahaha
taostaostaos
taostaostaos
hahahahahaha
lililililili
xxx
lililililili
xxx
lililililili
taostaostaos
hahahahahaha
taostaostaos
taostaostaos
hahahahahaha
novelnovelnovel
一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
updateupdateupdate
prisionprisionprision
novelnovelnovel
novelnovelnovel
againagainagain
一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
novelnovelnovel
againagainagain
novelnovelnovel
一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
updateupdateupdate
prisionprisionprision
novelnovelnovel
novelnovelnovel
againagainagain
一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
novelnovelnovel
againagainagain
novelnovelnovel
personpersonperson
novelnovelnovel
plateplateplate
一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
updateupdateupdate
prisionprisionprision
personpersonperson
prisionprisionprision
plateplateplate
novelnovelnovel
personpersonperson
novelnovelnovel
plateplateplate
一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
updateupdateupdate
prisionprisionprision
personpersonperson
prisionprisionprision
plateplateplate
lili
x
lili
x
lili
taos
haha
taos
taos
haha
lili
x
lili
x
lili
taos
haha
taos
taos
haha
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again

1 hello
56 var1var1
57 var1var1var1
58 var1var1var1var1
59 var1var1var1var1var1
60 taos
61 taostaos
62 lililililili
63 xxx
64 lililililili
65 xxx
66 lililililili
67 taostaostaos
68 hahahahahaha
69 taostaostaos
70 taostaostaos
71 hahahahahaha
72 lililililili
73 xxx
74 lililililili
75 xxx
76 lililililili
77 taostaostaos
78 hahahahahaha
79 taostaostaos
80 taostaostaos
81 hahahahahaha
82 novelnovelnovel
83 一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
84 updateupdateupdate
85 prisionprisionprision
86 novelnovelnovel
87 novelnovelnovel
88 againagainagain
89 一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
90 novelnovelnovel
91 againagainagain
92 novelnovelnovel
93 一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
94 updateupdateupdate
95 prisionprisionprision
96 novelnovelnovel
97 novelnovelnovel
98 againagainagain
99 一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
100 novelnovelnovel
101 againagainagain
102 novelnovelnovel
103 personpersonperson
104 novelnovelnovel
105 plateplateplate
106 一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
107 updateupdateupdate
108 prisionprisionprision
109 personpersonperson
110 prisionprisionprision
111 plateplateplate
112 novelnovelnovel
113 personpersonperson
114 novelnovelnovel
115 plateplateplate
116 一二三四五六七八九十一二三四五六七八九十一二三四五六七八九十
117 updateupdateupdate
118 prisionprisionprision
119 personpersonperson
120 prisionprisionprision
121 plateplateplate
122 lili
123 x
124 lili
125 x
126 lili
127 taos
128 haha
129 taos
130 taos
131 haha
132 lili
133 x
134 lili
135 x
136 lili
137 taos
138 haha
139 taos
140 taos
141 haha
142 novel
143 一二三四五六七八九十
144 update
145 prision
146 novel
147 novel
148 again
149 一二三四五六七八九十
150 novel
151 again
152 novel
153 一二三四五六七八九十
154 update
155 prision
156 novel
157 novel
158 again
159 一二三四五六七八九十
160 novel
161 again

107
tests/army/query/function/ans/replace.csv
View File

@ -368,4 +368,109 @@ e二三四五六七abcdefghijk213124123
一二三四五六七abcdefghijk213124123
一二三四五六七abcdefghijk213124123
一二三四五六七abcdefghijk213124123
一二三四五六七abcdefghijk213124123
一二三四五六七abcdefghijk213124123
eebbccdd
aabbccdd
南京
北南
南京taos
novel
一二三四五六七八九十
update
prision
novtl
novel
again
一二三四五六七八九十
novel
again
novel
一二三四五六七八九十
update
prision
novtl
novel
again
一二三四五六七八九十
novel
again
novtl
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novtl
again
novtl
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novtl
again
novel
person
novel
plate
一二三四五六七八九十
update
prision
person
prision
plate
novel
person
novel
plate
一二三四五六七八九十
update
prision
person
prision
plate
novtl
person
novel
platt
一二三四五六七八九十
update
prision
person
prision
plate
novtl
person
novel
platt
一二三四五六七八九十
update
prision
person
prision
plate
novel
一二三四五六七八九十
update
prision
nov一二三四五六七八九十l
novel
again
一二三四五六七八九十
novel
again
novel
一二三四五六七八九十
update
prision
nov一二三四五六七八九十l
novel
again
一二三四五六七八九十
novel
again

1 bbbb
368 一二三四五六七abcdefghijk213124123
369 一二三四五六七abcdefghijk213124123
370 一二三四五六七abcdefghijk213124123
371 一二三四五六七abcdefghijk213124123
372 eebbccdd
373 aabbccdd
374 南京
375 北南
376 南京taos
377 novel
378 一二三四五六七八九十
379 update
380 prision
381 novtl
382 novel
383 again
384 一二三四五六七八九十
385 novel
386 again
387 novel
388 一二三四五六七八九十
389 update
390 prision
391 novtl
392 novel
393 again
394 一二三四五六七八九十
395 novel
396 again
397 novtl
398 一二三四五六七八九十
399 update
400 prision
401 novel
402 novel
403 again
404 一二三四五六七八九十
405 novtl
406 again
407 novtl
408 一二三四五六七八九十
409 update
410 prision
411 novel
412 novel
413 again
414 一二三四五六七八九十
415 novtl
416 again
417 novel
418 person
419 novel
420 plate
421 一二三四五六七八九十
422 update
423 prision
424 person
425 prision
426 plate
427 novel
428 person
429 novel
430 plate
431 一二三四五六七八九十
432 update
433 prision
434 person
435 prision
436 plate
437 novtl
438 person
439 novel
440 platt
441 一二三四五六七八九十
442 update
443 prision
444 person
445 prision
446 plate
447 novtl
448 person
449 novel
450 platt
451 一二三四五六七八九十
452 update
453 prision
454 person
455 prision
456 plate
457 novel
458 一二三四五六七八九十
459 update
460 prision
461 nov一二三四五六七八九十l
462 novel
463 again
464 一二三四五六七八九十
465 novel
466 again
467 novel
468 一二三四五六七八九十
469 update
470 prision
471 nov一二三四五六七八九十l
472 novel
473 again
474 一二三四五六七八九十
475 novel
476 again

31
tests/army/query/function/ans/round.csv
View File

@ -62,4 +62,33 @@
9.6000004
11.0000000
11.1999998
10.3000002
10.3000002
10.55
10.55
10.6
11
11
10
0
-10.6
99
11
9
10
11
11
9
10
11
11
10
11
9
10
11
11
9
10
11
11
10

1 10.550000000000001
62 9.6000004
63 11.0000000
64 11.1999998
65 10.3000002
66 10.55
67 10.55
68 10.6
69 11
70 11
71 10
72 0
73 -10.6
74 99
75 11
76 9
77 10
78 11
79 11
80 9
81 10
82 11
83 11
84 10
85 11
86 9
87 10
88 11
89 11
90 9
91 10
92 11
93 11
94 10

26
tests/army/query/function/ans/sign.csv
View File

@ -43,4 +43,28 @@
1.000000000000000
1.000000000000000
1.000000000000000
0
0
1
1
-1
-1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1

1 0
43 1.000000000000000
44 1.000000000000000
45 1.000000000000000
46 0
47 1
48 1
49 -1
50 -1
51 1
52 1
53 1
54 1
55 1
56 1
57 1
58 1
59 1
60 1
61 1
62 1
63 1
64 1
65 1
66 1
67 1
68 1
69 1
70 1

6
tests/army/query/function/ans/stddev.csv
View File

@ -30,4 +30,8 @@
8.077747210701755
8.077747210701755
8.077747210701755
8.077747210701755
8.077747210701755
2886.751331514371941
2886.751331514371941
1.154339668872967
1.154339668872967

1 1.154339668872968
30 8.077747210701755
31 8.077747210701755
32 8.077747210701755
33 8.077747210701755
34 2886.751331514371941
35 2886.751331514371941
36 1.154339668872967
37 1.154339668872967

49
tests/army/query/function/ans/substr.csv
View File

@ -445,4 +445,51 @@ bc一二三abc一二三a
rision
rision
bc一二三abc一二三a
二三123321三二一
二三123321三二一
dengine
e
tde
dengine
e
中国
中国t
novel
perso
novel
plate
一二三四五
updat
prisi
perso
prisi
plate
novel
perso
novel
plate
一二三四五
updat
prisi
perso
prisi
plate
novel
一二三四五
updat
prisi
novel
novel
again
一二三四五
novel
again
novel
一二三四五
updat
prisi
novel
novel
again
一二三四五
novel
again

1 Hello.World!
445 rision
446 rision
447 bc一二三abc一二三a
448 二三123321三二一
449 dengine
450 e
451 tde
452 dengine
453 e
454 中国
455 中国t
456 novel
457 perso
458 novel
459 plate
460 一二三四五
461 updat
462 prisi
463 perso
464 prisi
465 plate
466 novel
467 perso
468 novel
469 plate
470 一二三四五
471 updat
472 prisi
473 perso
474 prisi
475 plate
476 novel
477 一二三四五
478 updat
479 prisi
480 novel
481 novel
482 again
483 一二三四五
484 novel
485 again
486 novel
487 一二三四五
488 updat
489 prisi
490 novel
491 novel
492 again
493 一二三四五
494 novel
495 again

106
tests/army/query/function/ans/substr_idx.csv
View File

@ -188,4 +188,108 @@ a一二三a一二三bbcfp
一二三123321三二一
一二三123321三二一
一二三123321三二一
一二三123321三二一
一二三123321三二一
www.taosdata
taosdata.com
中国.科学
北京。涛思
novel
一二三四五六七八九十
update
prision
novel
novel
ag
一二三四五六七八九十
novel
ag
novel
一二三四五六七八九十
update
prision
novel
novel
ag
一二三四五六七八九十
novel
ag
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again
novel
person
novel
plate
一二三四五六七八九十
update
prision
person
prision
plate
novel
person
novel
plate
一二三四五六七八九十
update
prision
person
prision
plate
novel
person
novel
plate
一二三四五六七八九十
update
prision
person
prision
plate
novel
person
novel
plate
一二三四五六七八九十
update
prision
person
prision
plate

1 1abcd;2abcd
188 一二三123321三二一
189 一二三123321三二一
190 一二三123321三二一
191 一二三123321三二一
192 www.taosdata
193 taosdata.com
194 中国.科学
195 北京。涛思
196 novel
197 一二三四五六七八九十
198 update
199 prision
200 novel
201 novel
202 ag
203 一二三四五六七八九十
204 novel
205 ag
206 novel
207 一二三四五六七八九十
208 update
209 prision
210 novel
211 novel
212 ag
213 一二三四五六七八九十
214 novel
215 ag
216 novel
217 一二三四五六七八九十
218 update
219 prision
220 novel
221 novel
222 again
223 一二三四五六七八九十
224 novel
225 again
226 novel
227 一二三四五六七八九十
228 update
229 prision
230 novel
231 novel
232 again
233 一二三四五六七八九十
234 novel
235 again
236 novel
237 一二三四五六七八九十
238 update
239 prision
240 novel
241 novel
242 again
243 一二三四五六七八九十
244 novel
245 again
246 novel
247 一二三四五六七八九十
248 update
249 prision
250 novel
251 novel
252 again
253 一二三四五六七八九十
254 novel
255 again
256 novel
257 person
258 novel
259 plate
260 一二三四五六七八九十
261 update
262 prision
263 person
264 prision
265 plate
266 novel
267 person
268 novel
269 plate
270 一二三四五六七八九十
271 update
272 prision
273 person
274 prision
275 plate
276 novel
277 person
278 novel
279 plate
280 一二三四五六七八九十
281 update
282 prision
283 person
284 prision
285 plate
286 novel
287 person
288 novel
289 plate
290 一二三四五六七八九十
291 update
292 prision
293 person
294 prision
295 plate

38
tests/army/query/function/ans/timediff.csv
View File

@ -295,4 +295,40 @@
372
372
372
372
372
-10
31536000
3000
43200
720
30
4
2592000000
2592000
2592000
60
60
79774389
-79774389
79774389
-79774389
-220769589123
-220766589123
-220763589123
-220760589123
-220757589123
-220754589123
-220751589123
-220748589123
-220745589123
-220742589123
-220769589123
-220766589123
-220763589123
-220760589123
-220757589123
-220754589123
-220751589123
-220748589123
-220745589123
-220742589123

1 -1000
295 372
296 372
297 372
298 372
299 -10
300 31536000
301 3000
302 43200
303 720
304 30
305 4
306 2592000000
307 2592000
308 2592000
309 60
310 60
311 79774389
312 -79774389
313 79774389
314 -79774389
315 -220769589123
316 -220766589123
317 -220763589123
318 -220760589123
319 -220757589123
320 -220754589123
321 -220751589123
322 -220748589123
323 -220745589123
324 -220742589123
325 -220769589123
326 -220766589123
327 -220763589123
328 -220760589123
329 -220757589123
330 -220754589123
331 -220751589123
332 -220748589123
333 -220745589123
334 -220742589123

99
tests/army/query/function/ans/trim.csv
View File

@ -353,4 +353,101 @@ bbcfp三a
三abbcfp三a
三abbcfp三a
三abbcfp三a
三abbcfp三a
三abbcfp三a
A
涛思
b bbb
aaa
aaa abab aaaa
abab aaaa
京涛思数据科技有限公司北
bei京涛思数据科技有限公司北
aaa abab aaaa
aaa abab
aaa abab
北京涛思数据科技有限公司
北京涛思数据科技有限公司bei
aaa abab aaaa
aaa abab aaaa
abab
京涛思数据科技有限公司
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again
novel
person
novel
plate
一二三四五六七八九十
update
prision
person
prision
plate
novel
person
novel
plate
一二三四五六七八九十
update
prision
person
prision
plate
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again
novel
一二三四五六七八九十
update
prision
novel
novel
again
一二三四五六七八九十
novel
again
novel
person
novel
plat
一二三四五六七八九十
update
prision
person
prision
plate
novel
person
novel
plat
一二三四五六七八九十
update
prision
person
prision
plate

1 foo
353 三abbcfp三a
354 三abbcfp三a
355 三abbcfp三a
356 三abbcfp三a
357 A
358 涛思
359 b bbb
360 aaa
361 aaa abab aaaa
362 abab aaaa
363 京涛思数据科技有限公司北
364 bei京涛思数据科技有限公司北
365 aaa abab aaaa
366 aaa abab
367 aaa abab
368 北京涛思数据科技有限公司
369 北京涛思数据科技有限公司bei
370 aaa abab aaaa
371 aaa abab aaaa
372 abab
373 京涛思数据科技有限公司
374 novel
375 一二三四五六七八九十
376 update
377 prision
378 novel
379 novel
380 again
381 一二三四五六七八九十
382 novel
383 again
384 novel
385 一二三四五六七八九十
386 update
387 prision
388 novel
389 novel
390 again
391 一二三四五六七八九十
392 novel
393 again
394 novel
395 person
396 novel
397 plate
398 一二三四五六七八九十
399 update
400 prision
401 person
402 prision
403 plate
404 novel
405 person
406 novel
407 plate
408 一二三四五六七八九十
409 update
410 prision
411 person
412 prision
413 plate
414 novel
415 一二三四五六七八九十
416 update
417 prision
418 novel
419 novel
420 again
421 一二三四五六七八九十
422 novel
423 again
424 novel
425 一二三四五六七八九十
426 update
427 prision
428 novel
429 novel
430 again
431 一二三四五六七八九十
432 novel
433 again
434 novel
435 person
436 novel
437 plat
438 一二三四五六七八九十
439 update
440 prision
441 person
442 prision
443 plate
444 novel
445 person
446 novel
447 plat
448 一二三四五六七八九十
449 update
450 prision
451 person
452 prision
453 plate

49
tests/army/query/function/ans/trunc.csv
View File

@ -79,4 +79,51 @@
9.5000000
10.8999996
11.1999998
10.3000002
10.3000002
99.99
99.99
99.9
99
90
0
99
10.6
8.5
9.7
11.2
10.7
8.5
9.5
10.9
11.2
10.3
10.6
8.5
9.7
11.2
10.7
8.5
9.5
10.9
11.2
10.3
10.6
8.5
9.7
11.2
10.7
8.5
9.5
10.9
11.2
10.3
10.6
8.5
9.7
11.2
10.7
8.5
9.5
10.9
11.2
10.3

1 10.550000000000001
79 9.5000000
80 10.8999996
81 11.1999998
82 10.3000002
83 99.99
84 99.99
85 99.9
86 99
87 90
88 0
89 99
90 10.6
91 8.5
92 9.7
93 11.2
94 10.7
95 8.5
96 9.5
97 10.9
98 11.2
99 10.3
100 10.6
101 8.5
102 9.7
103 11.2
104 10.7
105 8.5
106 9.5
107 10.9
108 11.2
109 10.3
110 10.6
111 8.5
112 9.7
113 11.2
114 10.7
115 8.5
116 9.5
117 10.9
118 11.2
119 10.3
120 10.6
121 8.5
122 9.7
123 11.2
124 10.7
125 8.5
126 9.5
127 10.9
128 11.2
129 10.3

6
tests/army/query/function/ans/varpop.csv
View File

@ -30,4 +30,8 @@
65.250000000000000
65.250000000000000
65.250000000000000
65.250000000000000
65.250000000000000
8333333.250000000000000
8333333.250000000000000
1.332500071133751
1.332500071133751

1 1.332500071133753
30 65.250000000000000
31 65.250000000000000
32 65.250000000000000
33 65.250000000000000
34 8333333.250000000000000
35 8333333.250000000000000
36 1.332500071133751
37 1.332500071133751

33
tests/army/query/function/ans/week.csv
View File

@ -140,4 +140,35 @@
28
28
28
28
28
0
0
0
52
52
0
0
52
52
3
52
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28

1 0
140 28
141 28
142 28
143 28
144 0
145 0
146 0
147 52
148 52
149 0
150 0
151 52
152 52
153 3
154 52
155 28
156 28
157 28
158 28
159 28
160 28
161 28
162 28
163 28
164 28
165 28
166 28
167 28
168 28
169 28
170 28
171 28
172 28
173 28
174 28

26
tests/army/query/function/ans/weekday.csv
View File

@ -73,4 +73,28 @@
4
4
4
4
4
2
2
0
2
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4

1 2
73 4
74 4
75 4
76 4
77 2
78 2
79 0
80 2
81 4
82 4
83 4
84 4
85 4
86 4
87 4
88 4
89 4
90 4
91 4
92 4
93 4
94 4
95 4
96 4
97 4
98 4
99 4
100 4

25
tests/army/query/function/ans/weekofyear.csv
View File

@ -73,4 +73,27 @@
28
28
28
28
28
1
4
29
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28
28

1 1
73 28
74 28
75 28
76 28
77 1
78 4
79 29
80 28
81 28
82 28
83 28
84 28
85 28
86 28
87 28
88 28
89 28
90 28
91 28
92 28
93 28
94 28
95 28
96 28
97 28
98 28
99 28

5
tests/army/query/function/in/ascii.err Normal file
View File

@ -0,0 +1,5 @@
select ascii();
select ascii(123);
select ascii(1);
select ascii(2);
select ascii(1.5);

11
tests/army/query/function/in/ascii.in
View File

@ -14,4 +14,13 @@ select ASCII(concat(nch1,var1)) from ts_4893.meters order by ts limit 5;
select ASCII(cast(nch1 as varchar)) from ts_4893.meters order by ts limit 5;
select pow(ASCII(nch1), 2) from ts_4893.meters order by ts limit 5;
select sqrt(ASCII(nch1)) from ts_4893.meters order by ts limit 5;
select cast(ASCII(nch1) as int) from ts_4893.meters order by ts limit 5;
select cast(ASCII(nch1) as int) from ts_4893.meters order by ts limit 5;
select ascii('taos');
select ascii('t');
select ascii('\'');
select ascii(name) from ts_4893.d0 order by ts limit 10;
select ascii(name) from ts_4893.meters order by ts limit 10;
select ascii(nch1) from ts_4893.d0 order by ts limit 10;
select ascii(nch1) from ts_4893.meters order by ts limit 10;
select ascii(var1) from ts_4893.d0 order by ts limit 10;
select ascii(var1) from ts_4893.meters order by ts limit 10;

1
tests/army/query/function/in/char.err Normal file
View File

@ -0,0 +1 @@
select char();

4
tests/army/query/function/in/char.in
View File

@ -9,3 +9,7 @@ select cast(CHAR(49) as int);
select CHAR(id + 77) from ts_4893.meters order by ts limit 5;;
select CONCAT(CHAR(id + 77),CHAR(id + 77),CHAR(id + 77)) from ts_4893.meters limit 5;
select CHAR(id+77, id+77, id+77, id+77, id+77) from ts_4893.meters limit 5;
select char(77);
select char(77 * 256 + 77);
select char('123');
select char(77, NULL, '123');

5
tests/army/query/function/in/char_length.err Normal file
View File

@ -0,0 +1,5 @@
select char_length();
select char_length('tao's');
select char_length(123.45);
select char_length(123.45.67);
select char_length('a', 'b');

10
tests/army/query/function/in/char_length.in
View File

@ -14,4 +14,12 @@ select CHAR_LENGTH(concat(nch1,var1)) from ts_4893.meters order by ts limit 5;
select CHAR_LENGTH(cast(nch1 as varchar)) from ts_4893.meters order by ts limit 5;
select pow(CHAR_LENGTH(nch1), 2) from ts_4893.meters order by ts limit 5;
select sqrt(CHAR_LENGTH(nch1)) from ts_4893.meters order by ts limit 5;
select cast(CHAR_LENGTH(nch1) as int) from ts_4893.meters order by ts limit 5;
select cast(CHAR_LENGTH(nch1) as int) from ts_4893.meters order by ts limit 5;
select char_length('taos');
select char_length('涛思');
select char_length('涛思taos');
select char_length('tao\'s');
select char_length(nch1) from ts_4893.d0 limit 10;
select char_length(nch1) from ts_4893.meters limit 10;
select char_length(var1) from ts_4893.d0 limit 10;
select char_length(var1) from ts_4893.meters limit 10;

2
tests/army/query/function/in/dayofweek.err Normal file
View File

@ -0,0 +1,2 @@
select dayofweek();
select dayofweek('2020-01-01',1);

7
tests/army/query/function/in/dayofweek.in
View File

@ -10,4 +10,9 @@ select DAYOFWEEK('2000-01-06 00:00:00');
select DAYOFWEEK('2000-01-06 00:00:00') from ts_4893.meters order by ts limit 10;
select DAYOFWEEK(1725095657);
select DAYOFWEEK(1725095657) from ts_4893.meters order by ts limit 10;
select DAYOFWEEK(ts) from ts_4893.meters order by ts limit 10;
select DAYOFWEEK(ts) from ts_4893.meters order by ts limit 10;
select dayofweek('2020-01-01');
select dayofweek(1721020666);
select dayofweek(1721020666229);
select dayofweek(ts) from ts_4893.d0 order by ts limit 10;
select dayofweek(ts) from ts_4893.meters order by ts limit 10;

2
tests/army/query/function/in/degrees.err Normal file
View File

@ -0,0 +1,2 @@
select degrees();
select degrees('abc');

5
tests/army/query/function/in/degrees.in
View File

@ -26,4 +26,7 @@ select abs(DEGREES(10));
select pow(DEGREES(10), 2);
select sqrt(DEGREES(10));
select cast(DEGREES(10) as int);
select DEGREES(sqrt(id)) from ts_4893.meters order by ts limit 5;
select DEGREES(sqrt(id)) from ts_4893.meters order by ts limit 5;
select degrees(pi());
select degrees(current) from ts_4893.d0 order by ts limit 10;
select degrees(current) from ts_4893.meters order by ts limit 10;

2
tests/army/query/function/in/exp.err Normal file
View File

@ -0,0 +1,2 @@
select exp();
select exp('1');

6
tests/army/query/function/in/exp.in
View File

@ -25,4 +25,8 @@ select pow(EXP(10), 2);
select sqrt(EXP(10));
select cast(EXP(10) as int);
select EXP(sqrt(id)) from ts_4893.meters order by ts limit 5;
select EXP(EXP(EXP(EXP(0))));
select EXP(EXP(EXP(EXP(0))));
select exp(2);
select exp(0.5);
select exp(current) from ts_4893.d0 order by ts limit 10;
select exp(current) from ts_4893.meters order by ts limit 10;

2
tests/army/query/function/in/ln.err Normal file
View File

@ -0,0 +1,2 @@
select ln();
select ln('1');

6
tests/army/query/function/in/ln.in
View File

@ -22,4 +22,8 @@ select sqrt(LN(10));
select cast(LN(10) as int);
select LN(sqrt(id) + 1) from ts_4893.meters order by ts limit 5;
select LN(LN(LN(LN(10000))));
select LN(EXP(2));
select LN(EXP(2));
select ln(10);
select ln(pi());
select ln(current) from ts_4893.d0 order by ts limit 10;
select ln(current) from ts_4893.meters order by ts limit 10;

6
tests/army/query/function/in/mod.err Normal file
View File

@ -0,0 +1,6 @@
select mod();
select mod(, 2);
select mod(10, );
select mod(10, 'a');
select mod('abc', 3);
select mod(10, 3, 1);

6
tests/army/query/function/in/mod.in
View File

@ -11,4 +11,8 @@ select MOD(MOD(MOD(MOD(MOD(MOD(MOD(123456789.123456789, -1), -2), -3), -4), -5),
select MOD(87654321.123456789, id + 1) from ts_4893.meters order by ts limit 10;
select MOD(current, id + 1) from ts_4893.meters order by ts limit 10;
select MOD(current, 1) from ts_4893.meters order by ts limit 10;
select MOD(sqrt(current), abs(id + 1)) from ts_4893.meters order by ts limit 10;
select MOD(sqrt(current), abs(id + 1)) from ts_4893.meters order by ts limit 10;
select mod(10, -3);
select mod(10, 3);
select mod(id, 3) from ts_4893.d0 order by ts limit 10;
select mod(id, 3) from ts_4893.meters order by ts limit 10;

2
tests/army/query/function/in/pi.err Normal file
View File

@ -0,0 +1,2 @@
select pi('111');
select pi(123);

3
tests/army/query/function/in/pi.in
View File

@ -16,4 +16,5 @@ select pi() + id from ts_4893.meters order by ts limit 5;
select abs(pi());
select pow(pi(), 2);
select sqrt(pi());
select cast(pi() as int);
select cast(pi() as int);
select pi();

5
tests/army/query/function/in/position.err Normal file
View File

@ -0,0 +1,5 @@
select position('t' in);
select position(in 'taos');
select position(1 in 2213);
select position(1 in '2213');
select position('1' in 2213);

14
tests/army/query/function/in/position.in
View File

@ -25,4 +25,16 @@ select POSITION(var2 IN 'abcdefghijklmn') from ts_4893.meters where POSITION(var
select POSITION(nch2 IN '一二三四五六七八九十') from ts_4893.meters where POSITION(nch2 IN '一二三四五六七八九十') != 0 order by ts limit 5;
select POSITION(var2 IN '一二三四五六七八九十') from ts_4893.meters where POSITION(var2 IN '一二三四五六七八九十') != 0 order by ts limit 5;
select ABS(POSITION('aaa' IN 'aaaaaaaaa'));
select POW(POSITION('aaa' IN 'aaaaaaaaa'), 2);
select POW(POSITION('aaa' IN 'aaaaaaaaa'), 2);
select position('t' in 'taos');
select position('ustc' in 'taos');
select position('' in '');
select position('' in 'taos');
select position(nch2 in nch1) from ts_4893.d0 order by ts limit 10;
select position(nch2 in nch1) from ts_4893.meters order by ts limit 10;
select position(nch2 in var1) from ts_4893.d0 order by ts limit 10;
select position(nch2 in var1) from ts_4893.meters order by ts limit 10;
select position(var2 in nch1) from ts_4893.d0 order by ts limit 10;
select position(var2 in nch1) from ts_4893.meters order by ts limit 10;
select position(var2 in var1) from ts_4893.d0 order by ts limit 10;
select position(var2 in var1) from ts_4893.meters order by ts limit 10;

2
tests/army/query/function/in/radians.err Normal file
View File

@ -0,0 +1,2 @@
select radians();
select radians('abc');

5
tests/army/query/function/in/radians.in
View File

@ -26,4 +26,7 @@ select abs(RADIANS(10));
select pow(RADIANS(10), 2);
select sqrt(RADIANS(10));
select cast(RADIANS(10) as int);
select RADIANS(sqrt(id)) from ts_4893.meters order by ts limit 5;
select RADIANS(sqrt(id)) from ts_4893.meters order by ts limit 5;
select radians(180);
select radians(current) from ts_4893.d0 order by ts limit 10;
select radians(current) from ts_4893.meters order by ts limit 10;

11
tests/army/query/function/in/repeat.err Normal file
View File

@ -0,0 +1,11 @@
select repeat();
select repeat('taos', );
select repeat(, 3);
select repeat('taos');
select repeat(1);
select repeat(taos, 1);
select repeat(123, 2);
select repeat('taos', 1.5);
select repeat('taos', 1.4);
select repeat('taos', 12, 3);
select repeat(id, 3) from ts_4893.meters;

14
tests/army/query/function/in/repeat.in
View File

@ -16,4 +16,16 @@ select position(var1 in repeat(nch1,6)) from ts_4893.meters where nch1 = var1 or
select repeat(nch1, id) from ts_4893.meters where id > 0 order by ts limit 5;
select repeat(var1, id) from ts_4893.meters where id > 0 order by ts limit 5;
select repeat('nch1', id) from ts_4893.meters where id > 0 order by ts limit 5;
select repeat('var1', id) from ts_4893.meters where id > 0 order by ts limit 5;
select repeat('var1', id) from ts_4893.meters where id > 0 order by ts limit 5;
select repeat('taos', 1);
select repeat('taos', 2);
select repeat(name, 3) from ts_4893.d0 order by ts limit 10;
select repeat(name, 3) from ts_4893.meters order by ts limit 10;
select repeat(nch1, 3) from ts_4893.d0 order by ts limit 10;
select repeat(nch1, 3) from ts_4893.meters order by ts limit 10;
select repeat(var1, 3) from ts_4893.d0 order by ts limit 10;
select repeat(var1, 3) from ts_4893.meters order by ts limit 10;
select repeat(name, groupid) from ts_4893.d0 order by ts limit 10;
select repeat(name, groupid) from ts_4893.meters order by ts limit 10;
select repeat(nch1, groupid) from ts_4893.d0 order by ts limit 10;
select repeat(nch1, groupid) from ts_4893.meters order by ts limit 10;

7
tests/army/query/function/in/replace.err Normal file
View File

@ -0,0 +1,7 @@
select replace();
select replace('aabbccdd', , 'ee');
select replace('aabbccdd', 'aa', );
select replace(, 'aa', 'ee');
select replace(123345, 1, 'ee');
select replace('aabbccdd', 1, 'ee');
select replace('aabbccdd', 'a', 1);

17
tests/army/query/function/in/replace.in
View File

@ -80,4 +80,19 @@ select replace('一二三四五六七abcdefghijk213124123', var2, 'var2') from t
select replace('一二三四五六七abcdefghijk213124123', var2, 'var2') from ts_4893.meters where position(var2 IN '一二三四五六七abcdefghijk213124123') = 0 order by ts limit 5;
select replace('一二三四五六七abcdefghijk213124123', var2, nch2) from ts_4893.meters order by ts limit 5;
select replace('一二三四五六七abcdefghijk213124123', var2, nch2) from ts_4893.meters where position(var2 IN '一二三四五六七abcdefghijk213124123') != 0 order by ts limit 5;
select replace('一二三四五六七abcdefghijk213124123', var2, nch2) from ts_4893.meters where position(var2 IN '一二三四五六七abcdefghijk213124123') = 0 order by ts limit 5;
select replace('一二三四五六七abcdefghijk213124123', var2, nch2) from ts_4893.meters where position(var2 IN '一二三四五六七abcdefghijk213124123') = 0 order by ts limit 5;
select replace('aabbccdd','aa', 'ee');
select replace('aabbccdd','AA', 'ee');
select replace('北京','北' , '南');
select replace('北京','京' , '南');
select replace('北京taos','北' , '南');
select replace(nch1, nch2, 't') from ts_4893.d0 order by ts limit 10;
select replace(nch1, nch2, 't') from ts_4893.meters order by ts limit 10;
select replace(nch1, var2, 't') from ts_4893.d0 order by ts limit 10;
select replace(nch1, var2, 't') from ts_4893.meters order by ts limit 10;
select replace(var1, nch2, 't') from ts_4893.d0 order by ts limit 10;
select replace(var1, nch2, 't') from ts_4893.meters order by ts limit 10;
select replace(var1, var2, 't') from ts_4893.d0 order by ts limit 10;
select replace(var1, var2, 't') from ts_4893.meters order by ts limit 10;
select replace(nch1, nch2, var1) from ts_4893.d0 order by ts limit 10;
select replace(nch1, nch2, var1) from ts_4893.meters order by ts limit 10;

5
tests/army/query/function/in/round.err Normal file
View File

@ -0,0 +1,5 @@
select round();
select round(10, );
select round(, 2);
select round('abc', 2);
select round(123.23, 'a');

11
tests/army/query/function/in/round.in
View File

@ -17,3 +17,14 @@ select ROUND(current) from ts_4893.meters order by ts limit 20;
select ROUND(87654321.123456789, id) from ts_4893.meters order by ts limit 10;
select ROUND(current, id) from ts_4893.meters order by ts limit 10;
select ROUND(current, 1) from ts_4893.meters order by ts limit 10;
select round(10.55, 3);
select round(10.55, 2);
select round(10.55, 1);
select round(10.55, 0);
select round(10.55);
select round(10.55, -1);
select round(10.55, -10);
select round(-10.55, 1);
select round(99, 1);
select round(current) from ts_4893.d0 order by ts limit 10;
select round(current) from ts_4893.meters order by ts limit 10;

3
tests/army/query/function/in/sign.err Normal file
View File

@ -0,0 +1,3 @@
select sign();
select sign('abc');
select sign(10, 1);

8
tests/army/query/function/in/sign.in
View File

@ -27,4 +27,10 @@ select pow(SIGN(10), 2);
select sqrt(SIGN(10));
select cast(SIGN(10) as int);
select SIGN(sqrt(id)) from ts_4893.meters order by ts limit 5;
select SIGN(SIGN(SIGN(SIGN(0))));
select SIGN(SIGN(SIGN(SIGN(0))));
select sign(1);
select sign(10);
select sign(-1);
select sign(-10);
select sign(current) from ts_4893.d0 order by ts limit 10;
select sign(current) from ts_4893.meters order by ts limit 10;

8
tests/army/query/function/in/stddev.err Normal file
View File

@ -0,0 +1,8 @@
select stddev_pop() from ts_4893.d0;
select stddev_pop(ts) from ts_4893.d0;
select stddev_pop(name) from ts_4893.d0;
select stddev_pop(id, current) from ts_4893.d0;
select stddev_pop() from ts_4893.meters;
select stddev_pop(ts) from ts_4893.meters;
select stddev_pop(name) from ts_4893.meters;
select stddev_pop(id, current) from ts_4893.meters;

4
tests/army/query/function/in/stddev.in
View File

@ -4,3 +4,7 @@ select STDDEV(id) from ts_4893.meters;
select STDDEV(id) from ts_4893.meters interval(1d) limit 10;
select STDDEV(id) from ts_4893.meters where id > 100;
select STDDEV(id) from ts_4893.meters interval(1d) order by 1 limit 10;
select stddev_pop(id) from ts_4893.d0;
select stddev_pop(id) from ts_4893.meters;
select stddev_pop(current) from ts_4893.d0;
select stddev_pop(current) from ts_4893.meters;

3
tests/army/query/function/in/substr.err Normal file
View File

@ -0,0 +1,3 @@
select substring();
select substring('abc');
select substring(10, 1);

13
tests/army/query/function/in/substr.in
View File

@ -125,4 +125,15 @@ select SUBSTR(var1 FROM sign(id) FOR 20) from ts_4893.meters where char_length(v
select SUBSTR(nch1, 2, id) from ts_4893.meters where char_length(nch1) > 6 order by ts limit 5;
select SUBSTR(nch1 FROM 2 FOR id) from ts_4893.meters where char_length(nch1) > 6 order by ts limit 5;
select SUBSTR(var1, 2, id) from ts_4893.meters where char_length(var1) > 6 order by ts limit 5;
select SUBSTR(var1 FROM 2 FOR id) from ts_4893.meters where char_length(var1) > 6 order by ts limit 5;
select SUBSTR(var1 FROM 2 FOR id) from ts_4893.meters where char_length(var1) > 6 order by ts limit 5;
select substring('tdengine', 2);
select substring('tdengine', 8);
select substring('tdengine', 1, 3);
select substring('tdengine', 2, 99);
select substring('tdengine', -1, 10);
select substring('中国', 1, 3);
select substring('中国tdengine', 1, 3);
select substring(var1, 1, 5) from ts_4893.d0 order by ts limit 10;
select substring(var1, 1, 5) from ts_4893.meters order by ts limit 10;
select substring(nch1, 1, 5) from ts_4893.d0 order by ts limit 10;
select substring(nch1, 1, 5) from ts_4893.meters order by ts limit 10;

8
tests/army/query/function/in/substr_idx.err Normal file
View File

@ -0,0 +1,8 @@
select substring_index();
select substring_index(, '.', 2);
select substring_index('www.taosdata.com', , 2);
select substring_index('www.taosdata.com', '.', );
select substring_index(123456789, '7', 1);
select substring_index('www.taosdata.com', c, 0);
select substring_index('www.taosdata.com', '.', '2');
select substring_index('www.taosdata.com', '.', 2, 3);

14
tests/army/query/function/in/substr_idx.in
View File

@ -77,3 +77,17 @@ select substring_index(nch1, '123', id) from ts_4893.meters where position('123'
select substring_index(var1, '123', 1) from ts_4893.meters where position('123' in var1) > 1 order by ts limit 5;
select substring_index(var1, '123', -1) from ts_4893.meters where position('123' in var1) > 1 order by ts limit 5;
select substring_index(var1, '123', id) from ts_4893.meters where position('123' in var1) > 1 order by ts limit 5;
select substring_index('www.taosdata.com', '.', 2);
select substring_index('www.taosdata.com', '.', -2);
select substring_index('中国.科学.www.taosdata.com', '.', 2);
select substring_index('北京。涛思。数据。科技', '。', 2);
select substring_index(nch1, 'a', 2) from ts_4893.d0 order by ts limit 10;
select substring_index(nch1, 'a', 2) from ts_4893.meters order by ts limit 10;
select substring_index(nch1, nch2, 2) from ts_4893.d0 order by ts limit 10;
select substring_index(nch1, nch2, 2) from ts_4893.meters order by ts limit 10;
select substring_index(nch1, var2, 2) from ts_4893.d0 order by ts limit 10;
select substring_index(nch1, var2, 2) from ts_4893.meters order by ts limit 10;
select substring_index(var1, nch2, 2) from ts_4893.d0 order by ts limit 10;
select substring_index(var1, nch2, 2) from ts_4893.meters order by ts limit 10;
select substring_index(var1, var2, 2) from ts_4893.d0 order by ts limit 10;
select substring_index(var1, var2, 2) from ts_4893.meters order by ts limit 10;

5
tests/army/query/function/in/timediff.err Normal file
View File

@ -0,0 +1,5 @@
select timediff();
select timediff(, '2022-01-01 08:00:01',1s);
select timediff('2022-01-01 08:00:00', ,1s);
select timediff('2022-01-01 08:00:00', '2022-01-01 08:00:01',);
select timediff(1720769589123, 1720769529123, 2s);

20
tests/army/query/function/in/timediff.in
View File

@ -70,4 +70,22 @@ select TIMEDIFF(1725095657, ts, 1h) from ts_4893.meters order by ts limit 10;
select TIMEDIFF(ts, 1725095657, 1d) from ts_4893.meters order by ts limit 10;
select TIMEDIFF(1725095657, ts, 1d) from ts_4893.meters order by ts limit 10;
select TIMEDIFF(ts, 1725095657, 1w) from ts_4893.meters order by ts limit 10;
select TIMEDIFF(1725095657, ts, 1w) from ts_4893.meters order by ts limit 10;
select TIMEDIFF(1725095657, ts, 1w) from ts_4893.meters order by ts limit 10;
select timediff('2022-01-01 08:00:00', '2022-01-01 08:00:10',1s);
select timediff('2023-01-01 08:00:00', '2022-01-01 08:00:00',1s);
select timediff('2022-01-01 08:00:03', '2022-01-01 08:00:00',1a);
select timediff('2022-01-31 08:00:00', '2022-01-01 08:00:00',1m);
select timediff('2022-01-31 08:00:00', '2022-01-01 08:00:00',1h);
select timediff('2022-01-31 08:00:00', '2022-01-01 08:00:00',1d);
select timediff('2022-01-31 08:00:00', '2022-01-01 08:00:00',1w);
select timediff('2022-01-31 08:00:00', '2022-01-01 08:00:00');
select timediff('2022-01-31 08:00:0', '2022-01-01 08:00:00',1s);
select timediff('2022-01-31', '2022-01-01',1s);
select timediff(1720769589, 1720769529, 1s);
select timediff(1720769589123, 1720769529123, 1s);
select timediff(1720769589, '2022-01-01 08:00:00', 1s);
select timediff('2022-01-01 08:00:00', 1720769589, 1s);
select timediff(1720769589231, '2022-01-01 08:00:00', 1s);
select timediff('2022-01-01 08:00:00', 1720769589123, 1s);
select timediff(ts, 1720769589123, 1a) from ts_4893.d0 order by ts limit 10;
select timediff(ts, 1720769589123, 1a) from ts_4893.meters order by ts limit 10;

3
tests/army/query/function/in/trim.err Normal file
View File

@ -0,0 +1,3 @@
select trim();
select trim(123);
select trim(both 1 from 123);

25
tests/army/query/function/in/trim.in
View File

@ -98,3 +98,28 @@ select trim(var2 from '三abbcfp三a') from ts_4893.meters where position(var2 i
select trim(both var2 from '三abbcfp三a') from ts_4893.meters where position(var2 in '三abbcfp三a') = 0 order by ts limit 5;
select trim(leading var2 from '三abbcfp三a') from ts_4893.meters where position(var2 in '三abbcfp三a') = 0 order by ts limit 5;
select trim(trailing var2 from '三abbcfp三a') from ts_4893.meters where position(var2 in '三abbcfp三a') = 0 order by ts limit 5;
select trim(' A ');
select trim(' 涛思 ');
select trim('a' FROM 'aaab bbba');
select trim(LEADING FROM ' aaa ');
select trim(LEADING 'a' FROM ' aaa abab aaaa ');
select trim(LEADING 'a' FROM 'aaa abab aaaa ');
select trim(LEADING '北' FROM '北京涛思数据科技有限公司北');
select trim(LEADING '北' FROM '北bei京涛思数据科技有限公司北');
select trim(TRAILING FROM ' aaa abab aaaa ');
select trim(TRAILING 'a' FROM 'aaa abab aaaa');
select trim(TRAILING 'a' FROM ' aaa abab aaaa');
select trim(TRAILING '北' FROM '北京涛思数据科技有限公司北') as sub;
select trim(TRAILING '北' FROM '北京涛思数据科技有限公司bei北');
select trim(BOTH FROM ' aaa abab aaaa ');
select trim(BOTH 'a' FROM ' aaa abab aaaa ');
select trim(BOTH 'a' FROM 'aaa abab aaaa');
select trim(BOTH '北' FROM '北京涛思数据科技有限公司北');
select trim(nch2 from nch1) from ts_4893.d0 order by ts limit 10;
select trim(nch2 from nch1) from ts_4893.meters order by ts limit 10;
select trim(nch2 from var1) from ts_4893.d0 order by ts limit 10;
select trim(nch2 from var1) from ts_4893.meters order by ts limit 10;
select trim(var2 from nch1) from ts_4893.d0 order by ts limit 10;
select trim(var2 from nch1) from ts_4893.meters order by ts limit 10;
select trim(var2 from var1) from ts_4893.d0 order by ts limit 10;
select trim(var2 from var1) from ts_4893.meters order by ts limit 10;

6
tests/army/query/function/in/trunc.err Normal file
View File

@ -0,0 +1,6 @@
select truncate();
select truncate(99.99,);
select truncate(, 3);
select truncate(99.99);
select truncate('12', 2);
select truncate(12, '1');

9
tests/army/query/function/in/trunc.in
View File

@ -26,3 +26,12 @@ select TRUNC(TRUNC(TRUNC(TRUNC(TRUNC(TRUNC(TRUNC(123456789.123456789, -1), -2),
select TRUNC(87654321.123456789, id) from ts_4893.meters order by ts limit 10;
select TRUNC(current, id) from ts_4893.meters order by ts limit 10;
select TRUNC(current, 1) from ts_4893.meters order by ts limit 10;
select truncate(99.99, 3);
select truncate(99.99, 2);
select truncate(99.99, 1);
select truncate(99.99, 0);
select truncate(99.99, -1);
select truncate(99.99, -10);
select truncate(99, 1);
select truncate(current, 1) from ts_4893.d0 order by ts limit 10;
select truncate(current, 1) from ts_4893.meters order by ts limit 10;

8
tests/army/query/function/in/varpop.err Normal file
View File

@ -0,0 +1,8 @@
select var_pop() from ts_4893.d0;
select var_pop(ts) from ts_4893.d0;
select var_pop(name) from ts_4893.d0;
select var_pop(id, current) from ts_4893.d0;
select var_pop() from ts_4893.meters;
select var_pop(ts) from ts_4893.meters;
select var_pop(name) from ts_4893.meters;
select var_pop(id, current) from ts_4893.meters;

4
tests/army/query/function/in/varpop.in
View File

@ -4,3 +4,7 @@ select VAR_POP(id) from ts_4893.meters;
select VAR_POP(id) from ts_4893.meters interval(1d) limit 10;
select VAR_POP(id) from ts_4893.meters where id > 100;
select VAR_POP(id) from ts_4893.meters interval(1d) order by 1 limit 10;
select var_pop(id) from ts_4893.d0;
select var_pop(id) from ts_4893.meters;
select var_pop(current) from ts_4893.d0;
select var_pop(current) from ts_4893.meters;

6
tests/army/query/function/in/week.err Normal file
View File

@ -0,0 +1,6 @@
select week();
select week(, 0);
select week('2000-01-01', );
select week('2000-01-01', -1);
select week('2000-01-01', 8);
select week('2000-01-01', 1.0);

13
tests/army/query/function/in/week.in
View File

@ -60,3 +60,16 @@ select WEEK(ts, 4) from ts_4893.meters order by ts limit 10;
select WEEK(ts, 5) from ts_4893.meters order by ts limit 10;
select WEEK(ts, 6) from ts_4893.meters order by ts limit 10;
select WEEK(ts, 7) from ts_4893.meters order by ts limit 10;
select week(123);
select week('2000-01-01',0);
select week('2000-01-01',1);
select week('2000-01-01',2);
select week('2000-01-01',3);
select week('2000-01-01',4);
select week('2000-01-01',5);
select week('2000-01-01',6);
select week('2000-01-01',7);
select week(1721020591,0);
select week('2020-01-01 00:00:00', 2);
select week(ts) from ts_4893.d0 order by ts limit 10;
select week(ts) from ts_4893.meters order by ts limit 10;

2
tests/army/query/function/in/weekday.err Normal file
View File

@ -0,0 +1,2 @@
select weekday();
select weekday('01/01/2020', 2);

8
tests/army/query/function/in/weekday.in
View File

@ -10,4 +10,10 @@ select WEEKDAY('2000-01-06 00:00:00');
select WEEKDAY('2000-01-06 00:00:00') from ts_4893.meters order by ts limit 10;
select WEEKDAY(1725095657);
select WEEKDAY(1725095657) from ts_4893.meters order by ts limit 10;
select WEEKDAY(ts) from ts_4893.meters order by ts limit 10;
select WEEKDAY(ts) from ts_4893.meters order by ts limit 10;
select weekday('2020-01-01');
select weekday(1721020591);
select weekday(1721020666229);
select weekday('2020-01-01 00:00:00');
select weekday(ts) from ts_4893.d0 order by ts limit 10;
select weekday(ts) from ts_4893.meters order by ts limit 10;

2
tests/army/query/function/in/weekofyear.err Normal file
View File

@ -0,0 +1,2 @@
select weekofyear();
select weekofyear('2020-01-01',1);

7
tests/army/query/function/in/weekofyear.in
View File

@ -10,4 +10,9 @@ select WEEKOFYEAR('2000-01-06 00:00:00');
select WEEKOFYEAR('2000-01-06 00:00:00') from ts_4893.meters order by ts limit 10;
select WEEKOFYEAR(1725095657);
select WEEKOFYEAR(1725095657) from ts_4893.meters order by ts limit 10;
select WEEKOFYEAR(ts) from ts_4893.meters order by ts limit 10;
select WEEKOFYEAR(ts) from ts_4893.meters order by ts limit 10;
select weekofyear('2020-01-01');
select weekofyear(1721020666);
select weekofyear(1721020666229);
select weekofyear(ts) from ts_4893.d0 order by ts limit 10;
select weekofyear(ts) from ts_4893.meters order by ts limit 10;

384
tests/army/query/function/test_function.py
View File

@ -71,59 +71,443 @@ class TDTestCase(TBase):
tdSql.checkDataCsvByLine(sql_statement, ansFile)
# 清空 sql_statement 以便处理下一条语句
sql_statement = ''
err_file_path = etool.curFile(__file__, f"in/{testCase}.err")
if not os.path.isfile(err_file_path):
return None
with open(err_file_path, 'r') as err_file:
err_statement = ''
for line in err_file:
if not line.strip() or line.strip().startswith('--'):
continue
err_statement += line.strip()
if err_statement.endswith(';'):
tdSql.error(err_statement)
err_statement = ''
def test_pi(self):
self.test_normal_query("pi")
def test_round(self):
self.test_normal_query("round")
tdSql.query("select round(10, null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select round(null, 2);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_exp(self):
self.test_normal_query("exp")
tdSql.query("select exp(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_trunc(self):
self.test_normal_query("trunc")
tdSql.query("select truncate(99.99, null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select truncate(null, 3);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_ln(self):
self.test_normal_query("ln")
tdSql.query("select ln(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_mod(self):
self.test_normal_query("mod")
tdSql.query("select mod(null, 2);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select mod(10, null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select mod(10, 0);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_sign(self):
self.test_normal_query("sign")
tdSql.query("select sign(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_degrees(self):
self.test_normal_query("degrees")
tdSql.query("select degrees(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_radians(self):
self.test_normal_query("radians")
tdSql.query("select radians(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_char_length(self):
self.test_normal_query("char_length")
tdSql.query("select char_length(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_char(self):
self.test_normal_query("char")
tdSql.query("select char(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, '')
tdSql.query("select char('ustc');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, chr(0))
result1 = [[chr(0)], [chr(1)], [chr(2)], [chr(3)], [chr(4)], [chr(5)], [chr(6)], [chr(7)], [chr(8)], [chr(9)]]
tdSql.checkDataMem("select char(id) from ts_4893.d0 limit 10;", result1)
tdSql.checkDataMem("select char(id) from ts_4893.meters limit 10;", result1)
result2 = [[chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)]]
tdSql.checkDataMem("select char(nch1) from ts_4893.d0 limit 10;", result2)
tdSql.checkDataMem("select char(nch1) from ts_4893.meters limit 10;", result2)
tdSql.checkDataMem("select char(var1) from ts_4893.d0 limit 10;", result2)
tdSql.checkDataMem("select char(var1) from ts_4893.meters limit 10;", result2)
def test_ascii(self):
self.test_normal_query("ascii")
tdSql.query("select ascii(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_position(self):
self.test_normal_query("position")
tdSql.query("select position('t' in null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select position(null in 'taos');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_replace(self):
self.test_normal_query("replace")
tdSql.query("select replace(null, 'aa', 'ee');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select replace('aabbccdd', null, 'ee');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_repeat(self):
self.test_normal_query("repeat")
tdSql.query("select repeat('taos', null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select repeat(null, 3);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select repeat('taos', 0);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, '')
def test_substr(self):
self.test_normal_query("substr")
tdSql.query("select substring('tdengine', null, 3);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select substring(null, 1, 3);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select substring('tdengine', 1, null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select substring('tdengine', 0);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, '')
tdSql.query("select substring('tdengine', 10);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, '')
tdSql.query("select substring('tdengine', 1, 0);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, '')
tdSql.query("select substring('tdengine', 1, -1);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, '')
def test_substr_idx(self):
self.test_normal_query("substr_idx")
tdSql.query("select substring_index(null, '.', 2);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select substring_index('www.taosdata.com', null, 2);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select substring_index('www.taosdata.com', '.', null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select substring_index('www.taosdata.com', '.', 0);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, '')
def test_trim(self):
self.test_normal_query("trim")
tdSql.query("select trim(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_timediff(self):
self.test_normal_query("timediff")
tdSql.query("select timediff(null, '2022-01-01 08:00:01',1s);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select timediff('2022-01-01 08:00:00', null,1s);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select timediff('2022/01/31', '2022/01/01',1s);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select timediff('20220131', '20220101',1s);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select timediff('22/01/31', '22/01/01',1s);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select timediff('01/31/22', '01/01/22',1s);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select timediff('31-JAN-22', '01-JAN-22',1s);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select timediff('22/01/31', '22/01/01');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select timediff('www', 'ttt');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_week(self):
self.test_normal_query("week")
tdSql.query("select week(null, 0);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select week('abc');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select week('1721020591', 0);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select week('1721020666229', 0);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select week('01/01/2020', 2);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select week('20200101', 2);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select week('20/01/01', 2);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select week('11/01/31', 2);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select week('01-JAN-20', 2);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_weekday(self):
self.test_normal_query("weekday")
tdSql.query("select weekday(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekday('1721020591');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekday('1721020666229');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekday('abc');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekday('01/01/2020');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekday('20200101');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekday('20/01/01');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekday('11/01/32');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekday('01-JAN-20');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_weekofyear(self):
self.test_normal_query("weekofyear")
tdSql.query("select weekofyear(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekofyear('1721020591');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekofyear('1721020666229');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekofyear('abc');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekofyear('01/01/2020');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekofyear('20200101');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekofyear('20/01/01');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekofyear('11/01/31');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select weekofyear('01-JAN-20');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_dayofweek(self):
self.test_normal_query("dayofweek")
tdSql.query("select dayofweek(null);")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select dayofweek('1721020591');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select dayofweek('1721020666229');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select dayofweek('abc');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select dayofweek('01/01/2020');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select dayofweek('20200101');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select dayofweek('20/01/01');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select dayofweek('11/01/31');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select dayofweek('01-JAN-20');")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_stddev(self):
self.test_normal_query("stddev")
tdSql.query("select stddev_pop(null) from ts_4893.d0;")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select stddev_pop(null) from ts_4893.meters;")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
def test_varpop(self):
self.test_normal_query("varpop")
tdSql.query("select var_pop(null) from ts_4893.d0;")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select var_pop(null) from ts_4893.meters;")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
# run
def run(self):
tdLog.debug(f"start to excute {__file__}")

1
tests/system-test/2-query/To_iso8601.py
View File

@ -146,6 +146,7 @@ class TDTestCase:
err_param = [1.5,'a','c2']
for i in err_param:
tdSql.error(f"select to_iso8601({i}) from db.ntb")
tdSql.error(f"select to_iso8601(ts, timezone()) from db.stb")
tdSql.query("select to_iso8601(now) from db.stb")
tdSql.checkRows(3)
tdSql.query("select to_iso8601(now()) from db.stb")