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

insert overwrite place holer

Browse Source
This commit is contained in:
Minionyh
2024-06-17 23:25:34 +00:00
committed by ob-robot
parent abd19d5cb3
commit 66d79d2e7a
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/sql/engine/ob_physical_plan.cpp
View File

@ -140,7 +140,8 @@ ObPhysicalPlan::ObPhysicalPlan(MemoryContext &mem_context /* = CURRENT_CONTEXT *
udf_has_dml_stmt_(false), udf_has_dml_stmt_(false),
mview_ids_(&allocator_), mview_ids_(&allocator_),
enable_inc_direct_load_(false), enable_inc_direct_load_(false),
enable_replace_(false) enable_replace_(false),
insert_overwrite_(false)
{ {
} }
@ -240,6 +241,7 @@ void ObPhysicalPlan::reset()
mview_ids_.reset(); mview_ids_.reset();
enable_inc_direct_load_ = false; enable_inc_direct_load_ = false;
enable_replace_ = false; enable_replace_ = false;
insert_overwrite_ = false;
} }
void ObPhysicalPlan::destroy() void ObPhysicalPlan::destroy()
{ {
@ -812,7 +814,8 @@ OB_SERIALIZE_MEMBER(ObPhysicalPlan,
mview_ids_, mview_ids_,
enable_inc_direct_load_, enable_inc_direct_load_,
enable_replace_, enable_replace_,
immediate_refresh_external_table_ids_); immediate_refresh_external_table_ids_,
insert_overwrite_);
int ObPhysicalPlan::set_table_locations(const ObTablePartitionInfoArray &infos, int ObPhysicalPlan::set_table_locations(const ObTablePartitionInfoArray &infos,
ObSchemaGetterGuard &schema_guard) ObSchemaGetterGuard &schema_guard)

1
src/sql/engine/ob_physical_plan.h
View File

@ -702,6 +702,7 @@ private:
common::ObFixedArray<uint64_t, common::ObIAllocator> mview_ids_; common::ObFixedArray<uint64_t, common::ObIAllocator> mview_ids_;
bool enable_inc_direct_load_; // for incremental direct load bool enable_inc_direct_load_; // for incremental direct load
bool enable_replace_; // for incremental direct load bool enable_replace_; // for incremental direct load
bool insert_overwrite_; // for insert overwrite
}; };
inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id) inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id)