Merge pull request #21736 from taosdata/fix/TD-24790
fix: fix fill double type column with scalar expression error
This commit is contained in:
commit
205e79ad28
|
@ -3075,13 +3075,13 @@ static bool needFill(SNode* pNode) {
|
|||
|
||||
static int32_t convertFillValue(STranslateContext* pCxt, SDataType dt, SNodeList* pValues, int32_t index) {
|
||||
SListCell* pCell = nodesListGetCell(pValues, index);
|
||||
if (dataTypeEqual(&dt, &((SExprNode*)pCell->pNode)->resType)) {
|
||||
if (dataTypeEqual(&dt, &((SExprNode*)pCell->pNode)->resType) && (QUERY_NODE_VALUE == nodeType(pCell->pNode))) {
|
||||
return TSDB_CODE_SUCCESS;
|
||||
}
|
||||
SNode* pCaseFunc = NULL;
|
||||
int32_t code = createCastFunc(pCxt, pCell->pNode, dt, &pCaseFunc);
|
||||
SNode* pCastFunc = NULL;
|
||||
int32_t code = createCastFunc(pCxt, pCell->pNode, dt, &pCastFunc);
|
||||
if (TSDB_CODE_SUCCESS == code) {
|
||||
code = scalarCalculateConstants(pCaseFunc, &pCell->pNode);
|
||||
code = scalarCalculateConstants(pCastFunc, &pCell->pNode);
|
||||
}
|
||||
if (TSDB_CODE_SUCCESS == code && QUERY_NODE_VALUE != nodeType(pCell->pNode)) {
|
||||
code = generateSyntaxErrMsgExt(&pCxt->msgBuf, TSDB_CODE_PAR_WRONG_VALUE_TYPE, "Fill value can only accept constant");
|
||||
|
|
|
@ -226,6 +226,7 @@ class TDTestCase:
|
|||
tdSql.checkData(3, 0, 12)
|
||||
|
||||
## test fill value with scalar expression
|
||||
# data types
|
||||
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(value, 1 + 2)")
|
||||
tdSql.checkRows(4)
|
||||
tdSql.checkData(0, 0, 3)
|
||||
|
@ -233,6 +234,49 @@ class TDTestCase:
|
|||
tdSql.checkData(2, 0, 3)
|
||||
tdSql.checkData(3, 0, 3)
|
||||
|
||||
tdSql.query(f"select interp(c1) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(value, 1 + 2)")
|
||||
tdSql.checkRows(4)
|
||||
tdSql.checkData(0, 0, 3)
|
||||
tdSql.checkData(1, 0, 3)
|
||||
tdSql.checkData(2, 0, 3)
|
||||
tdSql.checkData(3, 0, 3)
|
||||
|
||||
tdSql.query(f"select interp(c2) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(value, 1 + 2)")
|
||||
tdSql.checkRows(4)
|
||||
tdSql.checkData(0, 0, 3)
|
||||
tdSql.checkData(1, 0, 3)
|
||||
tdSql.checkData(2, 0, 3)
|
||||
tdSql.checkData(3, 0, 3)
|
||||
|
||||
tdSql.query(f"select interp(c3) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(value, 1 + 2)")
|
||||
tdSql.checkRows(4)
|
||||
tdSql.checkData(0, 0, 3)
|
||||
tdSql.checkData(1, 0, 3)
|
||||
tdSql.checkData(2, 0, 3)
|
||||
tdSql.checkData(3, 0, 3)
|
||||
|
||||
tdSql.query(f"select interp(c4) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(value, 1 + 2)")
|
||||
tdSql.checkRows(4)
|
||||
tdSql.checkData(0, 0, 3.0)
|
||||
tdSql.checkData(1, 0, 3.0)
|
||||
tdSql.checkData(2, 0, 3.0)
|
||||
tdSql.checkData(3, 0, 3.0)
|
||||
|
||||
tdSql.query(f"select interp(c5) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(value, 1 + 2)")
|
||||
tdSql.checkRows(4)
|
||||
tdSql.checkData(0, 0, 3.0)
|
||||
tdSql.checkData(1, 0, 3.0)
|
||||
tdSql.checkData(2, 0, 3.0)
|
||||
tdSql.checkData(3, 0, 3.0)
|
||||
|
||||
tdSql.query(f"select interp(c6) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(value, 1 + 2)")
|
||||
tdSql.checkRows(4)
|
||||
tdSql.checkData(0, 0, True)
|
||||
tdSql.checkData(1, 0, True)
|
||||
tdSql.checkData(2, 0, True)
|
||||
tdSql.checkData(3, 0, True)
|
||||
|
||||
# expr types
|
||||
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(value, 1.0 + 2.0)")
|
||||
tdSql.checkRows(4)
|
||||
tdSql.checkData(0, 0, 3)
|
||||
|
@ -275,6 +319,7 @@ class TDTestCase:
|
|||
tdSql.checkData(2, 0, 3)
|
||||
tdSql.checkData(3, 0, 3)
|
||||
|
||||
|
||||
tdLog.printNoPrefix("==========step5:fill prev")
|
||||
|
||||
## {. . .}
|
||||
|
|
Loading…
Reference in New Issue