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

Fix full outer join with for update causing core

Browse Source
This commit is contained in:
ChangerR
2022-12-21 08:11:36 +00:00
committed by ob-robot
parent 6e47b8c0ac
commit f3c0d164ed
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/rewrite/ob_transform_pre_process.cpp
View File

@ -5381,6 +5381,7 @@ int ObTransformPreProcess::switch_left_outer_to_semi_join(ObSelectStmt *&sub_stm
LOG_WARN("failed to assign to condition exprs.", K(ret)); LOG_WARN("failed to assign to condition exprs.", K(ret));
} else { } else {
FromItem from_item; FromItem from_item;
TableItem* right_table_item = NULL;
from_item.is_joined_ = joined_table->right_table_->type_ == TableItem::JOINED_TABLE; from_item.is_joined_ = joined_table->right_table_->type_ == TableItem::JOINED_TABLE;
from_item.table_id_ = joined_table->right_table_->table_id_; from_item.table_id_ = joined_table->right_table_->table_id_;
semi_info->join_type_ = LEFT_ANTI_JOIN; semi_info->join_type_ = LEFT_ANTI_JOIN;
@ -5388,6 +5389,10 @@ int ObTransformPreProcess::switch_left_outer_to_semi_join(ObSelectStmt *&sub_stm
semi_info->semi_id_ = sub_stmt->get_query_ctx()->available_tb_id_--; semi_info->semi_id_ = sub_stmt->get_query_ctx()->available_tb_id_--;
if (OB_FAIL(from_items.push_back(from_item))) { if (OB_FAIL(from_items.push_back(from_item))) {
LOG_WARN("failed to push back from item", K(ret)); LOG_WARN("failed to push back from item", K(ret));
} else if (OB_ISNULL(right_table_item = sub_stmt->get_table_item_by_id(semi_info->right_table_id_))) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected null pointer.", K(ret));
} else if (OB_FALSE_IT(right_table_item->for_update_ = false)) {
} else if (from_item.is_joined_) { } else if (from_item.is_joined_) {
JoinedTable *table = static_cast<JoinedTable*>(joined_table->right_table_); JoinedTable *table = static_cast<JoinedTable*>(joined_table->right_table_);
ret = semi_info->left_table_ids_.assign(table->single_table_ids_); ret = semi_info->left_table_ids_.assign(table->single_table_ids_);