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

fix get load level in ObDirectLoadOptimizerCtx

Browse Source
This commit is contained in:
medcll 2024-12-23 03:18:36 +00:00 committed by ob-robot
parent c89e22b9ba
commit 782c9bda6e
1 changed files with 9 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/sql/optimizer/ob_direct_load_optimizer_ctx.cpp
View File

@ -178,21 +178,15 @@ int ObDirectLoadOptimizerCtx::init_direct_load_ctx(
}
}
if (OB_SUCC(ret)) {
table_id_ = table_id;
dup_action_ = insert_mode_ == ObDirectLoadInsertMode::INC_REPLACE ?
ObLoadDupActionType::LOAD_REPLACE : ObLoadDupActionType::LOAD_STOP_ON_DUP;
ObIArray<ObTablePartitionInfo *> & table_partition_infos = optimizer_ctx.get_table_partition_info();
for (int64_t i = 0; OB_SUCC(ret) && i < table_partition_infos.count(); ++i) {
const ObTablePartitionInfo *info = table_partition_infos.at(i);
if (OB_ISNULL(info)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpect null table partition info", K(ret));
} else if (info->get_ref_table_id() == table_id) {
load_level_ = info->get_table_location().get_part_hint_ids().empty()
? ObDirectLoadLevel::TABLE
: ObDirectLoadLevel::PARTITION;
break;
}
const TableItem *table_item = stmt.get_table_item(0);
if (OB_ISNULL(table_item)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("table item is nullptr", KR(ret));
} else {
table_id_ = table_item->ref_id_;
load_level_ = table_item->part_ids_.empty() ? ObDirectLoadLevel::TABLE : ObDirectLoadLevel::PARTITION;
dup_action_ = insert_mode_ == ObDirectLoadInsertMode::INC_REPLACE ?
ObLoadDupActionType::LOAD_REPLACE : ObLoadDupActionType::LOAD_STOP_ON_DUP;
}
}
if (OB_SUCC(ret)) {