hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] [to #2024112100105225790] fix: filter deleted elements in SET expr

Browse Source
This commit is contained in:
0xacc 2024-11-28 08:15:47 +00:00 committed by ob-robot
parent dc7271c444
commit dcfc697086
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/sql/engine/expr/ob_expr_multiset.cpp
View File

@ -217,21 +217,26 @@ int ObExprMultiSet::calc_ms_one_distinct(common::ObIAllocator *coll_allocator,
int ret = OB_SUCCESS;
LocalNTSHashMap dmap_c;
int res_cnt = 0;
int64_t real_count = 0;
ObObj objs[count];
for (int64_t i = 0; i < count; ++i) {
objs[i] = input_data[i];
// skip deleted element
if (ObMaxType != input_data[i].get_type()) {
objs[real_count] = input_data[i];
real_count += 1;
}
}
if (0 == count) {
if (0 == real_count) {
// do nothing
} else if (OB_ISNULL(objs)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("objs array is null", K(count));
LOG_WARN("objs array is null", K(count), K(real_count));
} else {
if (OB_FAIL(dmap_c.create(count, ObModIds::OB_SQL_HASH_SET))) {
LOG_WARN("fail create hash map", K(count), K(ret));
if (OB_FAIL(dmap_c.create(real_count, ObModIds::OB_SQL_HASH_SET))) {
LOG_WARN("fail create hash map", K(real_count), K(ret));
} else {
const ObObj *elem = NULL;
for (int64_t i = 0; OB_SUCC(ret) && i < count; ++i) {
for (int64_t i = 0; OB_SUCC(ret) && i < real_count; ++i) {
elem = objs + i;
ret = dmap_c.set_refactored(*elem, i);
if (OB_HASH_EXIST == ret) {