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

Add placeholder for ddl_task_id_ in direct load

Browse Source
This commit is contained in:
leftgeek 2024-06-18 01:09:18 +00:00 committed by ob-robot
parent a79ae9405f
commit b6e830cb4f
4 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -81,7 +81,9 @@ OB_DEF_SERIALIZE_SIZE(ObDASDMLBaseRtDef)
// add by dkz
OB_SERIALIZE_MEMBER((ObDASInsRtDef, ObDASDMLBaseRtDef),
need_fetch_conflict_,
direct_insert_task_id_);
direct_insert_task_id_,
use_put_,
ddl_task_id_);
OB_SERIALIZE_MEMBER((ObDASLockRtDef, ObDASDMLBaseRtDef),

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

@ -170,14 +170,16 @@ public:
need_fetch_conflict_(false),
is_duplicated_(false),
direct_insert_task_id_(0),
use_put_(false)
use_put_(false),
ddl_task_id_(0)
{ }
INHERIT_TO_STRING_KV("ObDASBaseRtDef", ObDASDMLBaseRtDef,
K_(need_fetch_conflict),
K_(is_duplicated),
K_(direct_insert_task_id),
K_(use_put));
K_(use_put),
K_(ddl_task_id));
// used to check whether need to fetch_duplicate_key, will set in table_replace_op
bool need_fetch_conflict_;
@ -188,6 +190,7 @@ public:
int64_t direct_insert_task_id_;
// use put, only use in obkv for overlay writting.
bool use_put_;
int64_t ddl_task_id_;
};
typedef DASDMLRtDefArray DASInsRtDefArray;

4
src/storage/access/ob_dml_param.cpp
View File

@ -251,7 +251,9 @@ DEF_TO_STRING(ObDMLBaseParam)
K_(spec_seq_no),
K_(snapshot),
K_(branch_id),
K_(check_schema_version));
K_(direct_insert_task_id),
K_(check_schema_version),
K_(ddl_task_id));
J_OBJ_END();
return pos;
}

4
src/storage/access/ob_dml_param.h
View File

@ -186,7 +186,8 @@ struct ObDMLBaseParam
branch_id_(0),
direct_insert_task_id_(0),
write_flag_(),
check_schema_version_(true)
check_schema_version_(true),
ddl_task_id_(0)
{
}
@ -220,6 +221,7 @@ struct ObDMLBaseParam
// write flag for inner write processing
concurrent_control::ObWriteFlag write_flag_;
bool check_schema_version_;
int64_t ddl_task_id_;
bool is_valid() const { return (timeout_ > 0 && schema_version_ >= 0) && nullptr != store_ctx_guard_; }
bool is_direct_insert() const { return (direct_insert_task_id_ > 0); }
DECLARE_TO_STRING;