fix(query): fix max/min/sum null input output behavior to 0 rows
This commit is contained in:
parent
c087a8d551
commit
b4a8408030
|
@ -612,8 +612,7 @@ int32_t sumFunction(SqlFunctionCtx* pCtx) {
|
||||||
SSumRes* pSumRes = GET_ROWCELL_INTERBUF(GET_RES_INFO(pCtx));
|
SSumRes* pSumRes = GET_ROWCELL_INTERBUF(GET_RES_INFO(pCtx));
|
||||||
|
|
||||||
if (IS_NULL_TYPE(type)) {
|
if (IS_NULL_TYPE(type)) {
|
||||||
GET_RES_INFO(pCtx)->isNullRes = 1;
|
numOfElem = 0;
|
||||||
numOfElem = 1;
|
|
||||||
goto _sum_over;
|
goto _sum_over;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1172,8 +1171,7 @@ int32_t doMinMaxHelper(SqlFunctionCtx* pCtx, int32_t isMinFunc) {
|
||||||
SMinmaxResInfo* pBuf = GET_ROWCELL_INTERBUF(pResInfo);
|
SMinmaxResInfo* pBuf = GET_ROWCELL_INTERBUF(pResInfo);
|
||||||
|
|
||||||
if (IS_NULL_TYPE(type)) {
|
if (IS_NULL_TYPE(type)) {
|
||||||
GET_RES_INFO(pCtx)->isNullRes = 1;
|
numOfElems = 0;
|
||||||
numOfElems = 1;
|
|
||||||
goto _min_max_over;
|
goto _min_max_over;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue