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

[CP] serial create table return valid table id when table exist

Browse Source
This commit is contained in:
fanfangzhou
2024-07-04 05:46:45 +00:00
committed by ob-robot
parent 6a701acb85
commit 91319fe104
3 changed files with 34 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/sql/engine/cmd/ob_table_executor.cpp
View File

@ -415,7 +415,15 @@ int ObCreateTableExecutor::execute_ctas(ObExecContext &ctx,
LOG_WARN("schema_guard reset failed", K(ret));
} else if (OB_FAIL(common_rpc_proxy->create_table(create_table_arg, create_table_res))) { //2, 建表;
LOG_WARN("rpc proxy create table failed", K(ret), "dst", common_rpc_proxy->get_server());
} else if (OB_INVALID_ID != create_table_res.table_id_) { //如果表已存在则后续的查询插入不进行
} else if (!(OB_INVALID_ID == create_table_res.table_id_
|| (OB_INVALID_ID != create_table_res.table_id_
&& true == create_table_res.do_nothing_)) ) { //如果表已存在则后续的查询插入不进行
// 1. for old rs
// when table_exist, table_id == invalid_id, and do_nothing will alway be false
// 2. for new rs
// do_nothing is true when table_exist
// --> when table_id == invalid, both old and new rs no table create
// --> when table_id != invalid, both old and new rs do_nothing_ correct
if (OB_INVALID_VERSION == create_table_res.schema_version_) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("get unexpected schema version", K(ret), K(create_table_res));