[master] add new column for __all_clone_job and __all_clone_job_history
This commit is contained in:
@ -10469,6 +10469,44 @@ int ObInnerTableSchema::all_virtual_clone_job_schema(ObTableSchema &table_schema
|
|||||||
true, //is_nullable
|
true, //is_nullable
|
||||||
false); //is_autoincrement
|
false); //is_autoincrement
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ObObj data_version_default;
|
||||||
|
data_version_default.set_uint64(0);
|
||||||
|
ADD_COLUMN_SCHEMA_T("data_version", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObUInt64Type, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
sizeof(uint64_t), //column_length
|
||||||
|
-1, //column_precision
|
||||||
|
-1, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false, //is_autoincrement
|
||||||
|
data_version_default,
|
||||||
|
data_version_default); //default_value
|
||||||
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ObObj min_cluster_version_default;
|
||||||
|
min_cluster_version_default.set_uint64(0);
|
||||||
|
ADD_COLUMN_SCHEMA_T("min_cluster_version", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObUInt64Type, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
sizeof(uint64_t), //column_length
|
||||||
|
-1, //column_precision
|
||||||
|
-1, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false, //is_autoincrement
|
||||||
|
min_cluster_version_default,
|
||||||
|
min_cluster_version_default); //default_value
|
||||||
|
}
|
||||||
table_schema.set_index_using_type(USING_BTREE);
|
table_schema.set_index_using_type(USING_BTREE);
|
||||||
table_schema.set_row_store_type(ENCODING_ROW_STORE);
|
table_schema.set_row_store_type(ENCODING_ROW_STORE);
|
||||||
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);
|
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);
|
||||||
@ -10840,6 +10878,44 @@ int ObInnerTableSchema::all_virtual_clone_job_history_schema(ObTableSchema &tabl
|
|||||||
true, //is_nullable
|
true, //is_nullable
|
||||||
false); //is_autoincrement
|
false); //is_autoincrement
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ObObj data_version_default;
|
||||||
|
data_version_default.set_uint64(0);
|
||||||
|
ADD_COLUMN_SCHEMA_T("data_version", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObUInt64Type, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
sizeof(uint64_t), //column_length
|
||||||
|
-1, //column_precision
|
||||||
|
-1, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false, //is_autoincrement
|
||||||
|
data_version_default,
|
||||||
|
data_version_default); //default_value
|
||||||
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ObObj min_cluster_version_default;
|
||||||
|
min_cluster_version_default.set_uint64(0);
|
||||||
|
ADD_COLUMN_SCHEMA_T("min_cluster_version", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObUInt64Type, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
sizeof(uint64_t), //column_length
|
||||||
|
-1, //column_precision
|
||||||
|
-1, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false, //is_autoincrement
|
||||||
|
min_cluster_version_default,
|
||||||
|
min_cluster_version_default); //default_value
|
||||||
|
}
|
||||||
table_schema.set_index_using_type(USING_BTREE);
|
table_schema.set_index_using_type(USING_BTREE);
|
||||||
table_schema.set_row_store_type(ENCODING_ROW_STORE);
|
table_schema.set_row_store_type(ENCODING_ROW_STORE);
|
||||||
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);
|
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);
|
||||||
|
|||||||
@ -10853,6 +10853,44 @@ int ObInnerTableSchema::all_clone_job_schema(ObTableSchema &table_schema)
|
|||||||
true, //is_nullable
|
true, //is_nullable
|
||||||
false); //is_autoincrement
|
false); //is_autoincrement
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ObObj data_version_default;
|
||||||
|
data_version_default.set_uint64(0);
|
||||||
|
ADD_COLUMN_SCHEMA_T("data_version", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObUInt64Type, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
sizeof(uint64_t), //column_length
|
||||||
|
-1, //column_precision
|
||||||
|
-1, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false, //is_autoincrement
|
||||||
|
data_version_default,
|
||||||
|
data_version_default); //default_value
|
||||||
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ObObj min_cluster_version_default;
|
||||||
|
min_cluster_version_default.set_uint64(0);
|
||||||
|
ADD_COLUMN_SCHEMA_T("min_cluster_version", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObUInt64Type, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
sizeof(uint64_t), //column_length
|
||||||
|
-1, //column_precision
|
||||||
|
-1, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false, //is_autoincrement
|
||||||
|
min_cluster_version_default,
|
||||||
|
min_cluster_version_default); //default_value
|
||||||
|
}
|
||||||
table_schema.set_index_using_type(USING_BTREE);
|
table_schema.set_index_using_type(USING_BTREE);
|
||||||
table_schema.set_row_store_type(ENCODING_ROW_STORE);
|
table_schema.set_row_store_type(ENCODING_ROW_STORE);
|
||||||
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);
|
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);
|
||||||
@ -11240,6 +11278,44 @@ int ObInnerTableSchema::all_clone_job_history_schema(ObTableSchema &table_schema
|
|||||||
true, //is_nullable
|
true, //is_nullable
|
||||||
false); //is_autoincrement
|
false); //is_autoincrement
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ObObj data_version_default;
|
||||||
|
data_version_default.set_uint64(0);
|
||||||
|
ADD_COLUMN_SCHEMA_T("data_version", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObUInt64Type, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
sizeof(uint64_t), //column_length
|
||||||
|
-1, //column_precision
|
||||||
|
-1, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false, //is_autoincrement
|
||||||
|
data_version_default,
|
||||||
|
data_version_default); //default_value
|
||||||
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ObObj min_cluster_version_default;
|
||||||
|
min_cluster_version_default.set_uint64(0);
|
||||||
|
ADD_COLUMN_SCHEMA_T("min_cluster_version", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObUInt64Type, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
sizeof(uint64_t), //column_length
|
||||||
|
-1, //column_precision
|
||||||
|
-1, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false, //is_autoincrement
|
||||||
|
min_cluster_version_default,
|
||||||
|
min_cluster_version_default); //default_value
|
||||||
|
}
|
||||||
table_schema.set_index_using_type(USING_BTREE);
|
table_schema.set_index_using_type(USING_BTREE);
|
||||||
table_schema.set_row_store_type(ENCODING_ROW_STORE);
|
table_schema.set_row_store_type(ENCODING_ROW_STORE);
|
||||||
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);
|
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);
|
||||||
|
|||||||
@ -6814,6 +6814,8 @@ def_table_schema(
|
|||||||
('clone_finished_time', 'timestamp', 'true'),
|
('clone_finished_time', 'timestamp', 'true'),
|
||||||
('ret_code', 'int', 'true'),
|
('ret_code', 'int', 'true'),
|
||||||
('error_msg', 'varchar:OB_MAX_ERROR_MSG_LEN', 'true'),
|
('error_msg', 'varchar:OB_MAX_ERROR_MSG_LEN', 'true'),
|
||||||
|
('data_version', 'uint', 'false', '0'),
|
||||||
|
('min_cluster_version', 'uint', 'false', '0'),
|
||||||
],
|
],
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -6848,6 +6850,8 @@ all_clone_job_history_def = dict(
|
|||||||
('clone_finished_time', 'timestamp', 'false'),
|
('clone_finished_time', 'timestamp', 'false'),
|
||||||
('ret_code', 'int', 'true'),
|
('ret_code', 'int', 'true'),
|
||||||
('error_msg', 'varchar:OB_MAX_ERROR_MSG_LEN', 'true'),
|
('error_msg', 'varchar:OB_MAX_ERROR_MSG_LEN', 'true'),
|
||||||
|
('data_version', 'uint', 'false', '0'),
|
||||||
|
('min_cluster_version', 'uint', 'false', '0'),
|
||||||
],
|
],
|
||||||
)
|
)
|
||||||
def_table_schema(**all_clone_job_history_def)
|
def_table_schema(**all_clone_job_history_def)
|
||||||
|
|||||||
@ -4665,6 +4665,8 @@ clone_start_time timestamp(6) NO NULL
|
|||||||
clone_finished_time timestamp(6) YES NULL
|
clone_finished_time timestamp(6) YES NULL
|
||||||
ret_code bigint(20) YES NULL
|
ret_code bigint(20) YES NULL
|
||||||
error_msg varchar(512) YES NULL
|
error_msg varchar(512) YES NULL
|
||||||
|
data_version bigint(20) unsigned NO 0
|
||||||
|
min_cluster_version bigint(20) unsigned NO 0
|
||||||
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_clone_job;
|
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_clone_job;
|
||||||
IF(count(*) >= 0, 1, 0)
|
IF(count(*) >= 0, 1, 0)
|
||||||
1
|
1
|
||||||
@ -4691,6 +4693,8 @@ clone_start_time timestamp(6) NO NULL
|
|||||||
clone_finished_time timestamp(6) NO NULL
|
clone_finished_time timestamp(6) NO NULL
|
||||||
ret_code bigint(20) YES NULL
|
ret_code bigint(20) YES NULL
|
||||||
error_msg varchar(512) YES NULL
|
error_msg varchar(512) YES NULL
|
||||||
|
data_version bigint(20) unsigned NO 0
|
||||||
|
min_cluster_version bigint(20) unsigned NO 0
|
||||||
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_clone_job_history;
|
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_clone_job_history;
|
||||||
IF(count(*) >= 0, 1, 0)
|
IF(count(*) >= 0, 1, 0)
|
||||||
1
|
1
|
||||||
|
|||||||
@ -9081,6 +9081,8 @@ clone_start_time timestamp(6) NO NULL
|
|||||||
clone_finished_time timestamp(6) YES NULL
|
clone_finished_time timestamp(6) YES NULL
|
||||||
ret_code bigint(20) YES NULL
|
ret_code bigint(20) YES NULL
|
||||||
error_msg varchar(512) YES NULL
|
error_msg varchar(512) YES NULL
|
||||||
|
data_version bigint(20) unsigned NO 0
|
||||||
|
min_cluster_version bigint(20) unsigned NO 0
|
||||||
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_clone_job;
|
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_clone_job;
|
||||||
IF(count(*) >= 0, 1, 0)
|
IF(count(*) >= 0, 1, 0)
|
||||||
1
|
1
|
||||||
@ -9107,6 +9109,8 @@ clone_start_time timestamp(6) NO NULL
|
|||||||
clone_finished_time timestamp(6) NO NULL
|
clone_finished_time timestamp(6) NO NULL
|
||||||
ret_code bigint(20) YES NULL
|
ret_code bigint(20) YES NULL
|
||||||
error_msg varchar(512) YES NULL
|
error_msg varchar(512) YES NULL
|
||||||
|
data_version bigint(20) unsigned NO 0
|
||||||
|
min_cluster_version bigint(20) unsigned NO 0
|
||||||
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_clone_job_history;
|
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_clone_job_history;
|
||||||
IF(count(*) >= 0, 1, 0)
|
IF(count(*) >= 0, 1, 0)
|
||||||
1
|
1
|
||||||
|
|||||||
Reference in New Issue
Block a user