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

fix tag filter

This commit is contained in:
yihaoDeng 2022-08-09 09:00:11 +08:00
parent c2d2f554f2
commit 1d274e581a
1 changed files with 23 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
source/libs/index/src/indexFilter.c
View File

@ -395,26 +395,29 @@ static int32_t sifDoIndex(SIFParam *left, SIFParam *right, int8_t operType, SIFP
param.val = buf; param.val = buf;
} }
} else { } else {
if (left->colValType == TSDB_DATA_TYPE_FLOAT) { // int8_t i8; int16_t i16; int32_t i32, uint8_t u8; uint16_t u16; uint32_t u32;
if (right->colValType == TSDB_DATA_TYPE_DOUBLE) { // if (right->colValType == TSDB_DATA_TYPE_TINYINT) {
f = GET_DOUBLE_VAL(right->condValue); // }
param.val = &f; // if (left->colValType == TSDB_DATA_TYPE_FLOAT) {
} else if (right->colValType == TSDB_DATA_TYPE_BIGINT) { // if (right->colValType == TSDB_DATA_TYPE_DOUBLE) {
f = *(int64_t *)(right->condValue); // f = GET_DOUBLE_VAL(right->condValue);
param.val = &f; // param.val = &f;
} else { // } else if (right->colValType == TSDB_DATA_TYPE_BIGINT) {
f = *(int32_t *)(right->condValue); // f = *(int64_t *)(right->condValue);
param.val = &f; // param.val = &f;
} // } else {
} else if (left->colValType == TSDB_DATA_TYPE_DOUBLE) { // f = *(int32_t *)(right->condValue);
if (right->colValType == TSDB_DATA_TYPE_DOUBLE) { // param.val = &f;
d = GET_DOUBLE_VAL(right->condValue); // }
param.val = &d; // } else if (left->colValType == TSDB_DATA_TYPE_DOUBLE) {
} else if (right->colValType == TSDB_DATA_TYPE_BIGINT) { // if (right->colValType == TSDB_DATA_TYPE_DOUBLE) {
d = *(int64_t *)(right->condValue); // d = GET_DOUBLE_VAL(right->condValue);
param.val = &d; // param.val = &d;
} // } else if (right->colValType == TSDB_DATA_TYPE_BIGINT) {
} // d = *(int64_t *)(right->condValue);
// param.val = &d;
// }
// }
} }
ret = metaFilterTableIds(arg->metaEx, &param, output->result); ret = metaFilterTableIds(arg->metaEx, &param, output->result);
} }