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

[CP] [Fix] obkv same rk in batch

Browse Source
This commit is contained in:
obdev
2024-02-06 19:03:36 +00:00
committed by ob-robot
parent b8bc3b4c6b
commit fce9821684
3 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/observer/table/ob_table_context.h
View File

@ -556,6 +556,7 @@ public:
column_infos_(alloc), column_infos_(alloc),
alloc_(alloc) alloc_(alloc)
{ {
das_ctdef_.is_table_api_ = true;
} }
TO_STRING_KV(K_(das_ctdef), TO_STRING_KV(K_(das_ctdef),
K_(related_ctdefs)); K_(related_ctdefs));
@ -595,6 +596,7 @@ public:
related_ins_ctdefs_(alloc), related_ins_ctdefs_(alloc),
alloc_(alloc) alloc_(alloc)
{ {
das_ctdef_.is_table_api_ = true;
} }
TO_STRING_KV(K_(full_row), TO_STRING_KV(K_(full_row),
K_(delta_row), K_(delta_row),
@ -651,6 +653,7 @@ public:
related_ctdefs_(alloc), related_ctdefs_(alloc),
alloc_(alloc) alloc_(alloc)
{ {
das_ctdef_.is_table_api_ = true;
} }
TO_STRING_KV(K_(das_ctdef), TO_STRING_KV(K_(das_ctdef),
K_(related_ctdefs)); K_(related_ctdefs));
@ -742,6 +745,7 @@ public:
das_ctdef_(alloc), das_ctdef_(alloc),
alloc_(alloc) alloc_(alloc)
{ {
das_ctdef_.is_table_api_ = true;
} }
TO_STRING_KV(K_(das_ctdef)); TO_STRING_KV(K_(das_ctdef));
ObDASLockCtDef das_ctdef_; ObDASLockCtDef das_ctdef_;

4
src/sql/das/ob_das_dml_ctx_define.h
View File

@ -51,6 +51,7 @@ public:
K_(is_ignore), K_(is_ignore),
K_(is_batch_stmt), K_(is_batch_stmt),
K_(is_insert_up), K_(is_insert_up),
K_(is_table_api),
K_(tz_info), K_(tz_info),
K_(table_param), K_(table_param),
K_(encrypt_meta)); K_(encrypt_meta));
@ -74,7 +75,8 @@ public:
uint64_t is_ignore_ : 1; uint64_t is_ignore_ : 1;
uint64_t is_batch_stmt_ : 1; uint64_t is_batch_stmt_ : 1;
uint64_t is_insert_up_ : 1; uint64_t is_insert_up_ : 1;
uint64_t reserved_ : 61; uint64_t is_table_api_ : 1;
uint64_t reserved_ : 59;
}; };
}; };
protected: protected:

3
src/sql/engine/dml/ob_dml_service.cpp
View File

@ -1163,6 +1163,9 @@ int ObDMLService::init_dml_param(const ObDASDMLBaseCtDef &base_ctdef,
if (base_ctdef.is_insert_up_) { if (base_ctdef.is_insert_up_) {
dml_param.write_flag_.set_is_insert_up(); dml_param.write_flag_.set_is_insert_up();
} }
if (base_ctdef.is_table_api_) {
dml_param.write_flag_.set_is_table_api();
}
if (dml_param.table_param_->get_data_table().is_storage_index_table() if (dml_param.table_param_->get_data_table().is_storage_index_table()
&& !dml_param.table_param_->get_data_table().can_read_index()) { && !dml_param.table_param_->get_data_table().can_read_index()) {
dml_param.write_flag_.set_is_write_only_index(); dml_param.write_flag_.set_is_write_only_index();