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

fix on condition contain subquery bug

Browse Source
This commit is contained in:
obdev
2022-11-08 10:05:30 +00:00
committed by wangzelin.wzl
parent b27c6c9730
commit c15ddf7c6d
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/optimizer/ob_log_plan.cpp
View File

@ -1515,6 +1515,9 @@ int ObLogPlan::generate_inner_join_detectors(const ObIArray<TableItem*> &table_i
LOG_WARN("failed to push back qual", K(ret)); LOG_WARN("failed to push back qual", K(ret));
} else if (OB_FAIL(detector->join_info_.table_set_.add_members(expr->get_relation_ids()))) { } else if (OB_FAIL(detector->join_info_.table_set_.add_members(expr->get_relation_ids()))) {
LOG_WARN("failed to add members", K(ret)); LOG_WARN("failed to add members", K(ret));
} else if (expr->has_flag(CNT_SUB_QUERY) &&
OB_FAIL(detector->join_info_.table_set_.add_members(all_table_ids))) {
LOG_WARN("failed to add members", K(ret));
} else if (OB_FAIL(inner_join_detectors.push_back(detector))) { } else if (OB_FAIL(inner_join_detectors.push_back(detector))) {
LOG_WARN("failed to push back detector", K(ret)); LOG_WARN("failed to push back detector", K(ret));
} else { } else {
@ -1537,6 +1540,9 @@ int ObLogPlan::generate_inner_join_detectors(const ObIArray<TableItem*> &table_i
} else if (expr->has_flag(IS_JOIN_COND) && } else if (expr->has_flag(IS_JOIN_COND) &&
OB_FAIL(detector->join_info_.equal_join_conditions_.push_back(expr))) { OB_FAIL(detector->join_info_.equal_join_conditions_.push_back(expr))) {
LOG_WARN("failed to push back qual", K(ret)); LOG_WARN("failed to push back qual", K(ret));
} else if (expr->has_flag(CNT_SUB_QUERY) &&
OB_FAIL(detector->join_info_.table_set_.add_members(all_table_ids))) {
LOG_WARN("failed to add members", K(ret));
} }
} }
//3. 生成inner join的冲突规则 //3. 生成inner join的冲突规则