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

Fix anti join elimination bug

Browse Source
This commit is contained in:
xianyu-w
2023-06-02 12:41:48 +00:00
committed by ob-robot
parent 9a3c3206f7
commit 3571680ad0
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/sql/rewrite/ob_transform_join_elimination.cpp
View File

@ -2948,14 +2948,16 @@ int ObTransformJoinElimination::trans_semi_condition_exprs(ObDMLStmt *stmt,
}
/*将所有改写的condition转成NOT(join_cond1) OR NOT(join_cond2) OR ...
OR LNNVL(expr1) OR LNNVL(expr2) OR ...*/
if (OB_SUCC(ret) && !new_conditions.empty()) {
ObRawExpr *or_expr = NULL;
if (OB_FAIL(ObRawExprUtils::build_or_exprs(*ctx_->expr_factory_, new_conditions, or_expr))) {
if (OB_SUCC(ret) ) {
ObRawExpr *filter_expr = NULL;
if (!new_conditions.empty() && OB_FAIL(ObRawExprUtils::build_or_exprs(*ctx_->expr_factory_, new_conditions, filter_expr))) {
LOG_WARN("make or expr failed", K(ret));
} else if (OB_ISNULL(or_expr)) {
} else if (new_conditions.empty() && OB_FAIL(ObRawExprUtils::build_const_bool_expr(ctx_->expr_factory_, filter_expr, false))) {
LOG_WARN("make or expr failed", K(ret));
} else if (OB_ISNULL(filter_expr)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("or expr is null", K(ret));
} else if (OB_FAIL(stmt->get_condition_exprs().push_back(or_expr))) {
} else if (OB_FAIL(stmt->get_condition_exprs().push_back(filter_expr))) {
LOG_WARN("failed to push back cond", K(ret));
} else {/*do nothing*/}
} else {/*do nothing*/}