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

revert test code in ob_table_location.cpp

Browse Source
This commit is contained in:
coolfishchen
2023-08-08 07:48:57 +00:00
committed by ob-robot
parent 07797ba2e0
commit 9eabf48afa
1 changed files with 17 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/sql/optimizer/ob_table_location.cpp
View File

@ -1009,23 +1009,23 @@ int ObTableLocation::init_table_location(ObExecContext &exec_ctx,
} }
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
bool is_weak_read = false; bool is_weak_read = false;
//if (OB_FAIL(get_is_weak_read(stmt, if (OB_FAIL(get_is_weak_read(stmt,
// exec_ctx.get_my_session(), exec_ctx.get_my_session(),
// exec_ctx.get_sql_ctx(), exec_ctx.get_sql_ctx(),
// is_weak_read))) { is_weak_read))) {
// LOG_WARN("get is weak read failed", K(ret)); LOG_WARN("get is weak read failed", K(ret));
//} else } else if (ObDuplicateScope::DUPLICATE_SCOPE_NONE != table_schema->get_duplicate_scope()) {
if (ObDuplicateScope::DUPLICATE_SCOPE_NONE != table_schema->get_duplicate_scope()) {
loc_meta_.is_dup_table_ = 1; loc_meta_.is_dup_table_ = 1;
} }
if (is_dml_table) { if (OB_SUCC(ret)) {
loc_meta_.select_leader_ = 1; if (is_dml_table) {
} else if (!is_weak_read) { loc_meta_.select_leader_ = 1;
loc_meta_.select_leader_ = loc_meta_.is_dup_table_ ? 0 : 1; } else if (!is_weak_read) {
} else { loc_meta_.select_leader_ = loc_meta_.is_dup_table_ ? 0 : 1;
loc_meta_.select_leader_ = 0; } else {
loc_meta_.is_weak_read_ = 1; loc_meta_.select_leader_ = 0;
loc_meta_.is_weak_read_ = 1;
}
} }
} }
if (OB_SUCC(ret) && PARTITION_LEVEL_TWO == table_schema->get_part_level()) { if (OB_SUCC(ret) && PARTITION_LEVEL_TWO == table_schema->get_part_level()) {
@ -1348,6 +1348,8 @@ int ObTableLocation::get_is_weak_read(const ObDMLStmt &dml_stmt,
dml_stmt.get_query_ctx()->is_contain_select_for_update_ || dml_stmt.get_query_ctx()->is_contain_select_for_update_ ||
dml_stmt.get_query_ctx()->is_contain_inner_table_) { dml_stmt.get_query_ctx()->is_contain_inner_table_) {
is_weak_read = false; is_weak_read = false;
} else if (share::ObTenantEnv::get_tenant() == nullptr) { //table api can't invoke MTL_IS_PRIMARY_TENANT
is_weak_read = false;
} else if (!MTL_IS_PRIMARY_TENANT()) { } else if (!MTL_IS_PRIMARY_TENANT()) {
is_weak_read = true; is_weak_read = true;
} else { } else {