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

fix misuse check_table_be_modified in transformer

Browse Source
This commit is contained in:
obdev
2022-11-25 12:35:41 +00:00
committed by wangzelin.wzl
parent 4c7f5e9d18
commit 49a02f3304
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -247,13 +247,22 @@ int ObTransformJoinElimination::check_eliminate_delupd_table_valid(const ObDelUp
int ret = OB_SUCCESS;
bool is_modified = false;
is_valid = true;
ObSEArray<const ObDmlTableInfo*, 2> table_infos;
if (OB_ISNULL(del_up_stmt)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("get unexpected null stmt", K(ret));
} else if (OB_FAIL(del_up_stmt->check_table_be_modified(table_id, is_modified))) {
LOG_WARN("failed to check table be modified", K(ret));
} else if (is_modified){
is_valid = false;
} else if (OB_FAIL(del_up_stmt->get_dml_table_infos(table_infos))) {
LOG_WARN("failed to get dml table infos", K(ret));
} else {
for (int64_t i = 0; OB_SUCC(ret) && is_valid && i < table_infos.count(); ++i) {
const ObDmlTableInfo* table_info = table_infos.at(i);
if (OB_ISNULL(table_info)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("get null table info", K(ret), K(i), K(table_infos));
} else {
is_valid = table_info->table_id_ != table_id;
}
}
}
return ret;
}