fix(tsdb): set correct initial value

This commit is contained in:
Haojun Liao 2024-04-12 23:32:47 +08:00
parent 54cef11436
commit 46fd0cb0b5
1 changed files with 15 additions and 1 deletions

View File

@ -137,7 +137,21 @@ int32_t initRowKey(SRowKey* pKey, int64_t ts, int32_t numOfPks, int32_t type, in
if (numOfPks > 0) { if (numOfPks > 0) {
pKey->pks[0].type = type; pKey->pks[0].type = type;
if (IS_NUMERIC_TYPE(pKey->pks[0].type)) { if (IS_NUMERIC_TYPE(pKey->pks[0].type)) {
pKey->pks[0].val = asc? INT64_MIN:INT64_MAX; if (asc) {
switch(pKey->pks[0].type) {
case TSDB_DATA_TYPE_BIGINT:pKey->pks[0].val = INT64_MIN;break;
case TSDB_DATA_TYPE_INT:pKey->pks[0].val = INT32_MIN;break;
case TSDB_DATA_TYPE_SMALLINT:pKey->pks[0].val = INT16_MIN;break;
case TSDB_DATA_TYPE_TINYINT:pKey->pks[0].val = INT8_MIN;break;
}
} else {
switch(pKey->pks[0].type) {
case TSDB_DATA_TYPE_BIGINT:pKey->pks[0].val = INT64_MAX;break;
case TSDB_DATA_TYPE_INT:pKey->pks[0].val = INT32_MAX;break;
case TSDB_DATA_TYPE_SMALLINT:pKey->pks[0].val = INT16_MAX;break;
case TSDB_DATA_TYPE_TINYINT:pKey->pks[0].val = INT8_MAX;break;
}
}
} else { } else {
pKey->pks[0].pData = taosMemoryCalloc(1, len); pKey->pks[0].pData = taosMemoryCalloc(1, len);
pKey->pks[0].nData = 0; pKey->pks[0].nData = 0;