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

[BUGFIX] fix merge join cmp expr wrong

Browse Source
This commit is contained in:
skylhd
2023-07-21 10:48:41 +00:00
committed by ob-robot
parent b2db80b767
commit a0b872153a
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/sql/engine/join/ob_merge_join_op.cpp
View File

@ -815,8 +815,10 @@ int ObMergeJoinOp::calc_equal_conds(int64_t &cmp_res)
OB_SUCC(ret) && 0 == cmp_res && i < MY_SPEC.equal_cond_infos_.count(); OB_SUCC(ret) && 0 == cmp_res && i < MY_SPEC.equal_cond_infos_.count();
i++) { i++) {
const ObMergeJoinSpec::EqualConditionInfo &equal_cond = MY_SPEC.equal_cond_infos_.at(i); const ObMergeJoinSpec::EqualConditionInfo &equal_cond = MY_SPEC.equal_cond_infos_.at(i);
ObExpr *l_expr = equal_cond.expr_->args_[0]; ObExpr *l_expr = equal_cond.is_opposite_ ? equal_cond.expr_->args_[1]
ObExpr *r_expr = equal_cond.expr_->args_[1]; : equal_cond.expr_->args_[0];
ObExpr *r_expr = equal_cond.is_opposite_ ? equal_cond.expr_->args_[0]
: equal_cond.expr_->args_[1];
ObDatum *l_datum = NULL; ObDatum *l_datum = NULL;
ObDatum *r_datum = NULL; ObDatum *r_datum = NULL;
if (OB_FAIL(l_expr->eval(eval_ctx_, l_datum)) if (OB_FAIL(l_expr->eval(eval_ctx_, l_datum))
@ -832,9 +834,6 @@ int ObMergeJoinOp::calc_equal_conds(int64_t &cmp_res)
} else if (cmp_ret != 0) { } else if (cmp_ret != 0) {
cmp_res = cmp_ret; cmp_res = cmp_ret;
cmp_res *= MY_SPEC.merge_directions_.at(i); cmp_res *= MY_SPEC.merge_directions_.at(i);
if (equal_cond.is_opposite_) {
cmp_res *= -1;
}
} }
} }
} }