occupy for all_tenant_scheduler_job database_id, user_id

This commit is contained in:
lmjhh 2024-06-17 12:14:08 +00:00 committed by ob-robot
parent 5b7e742f70
commit 461a59b5a9
5 changed files with 110 additions and 0 deletions

View File

@ -4151,6 +4151,44 @@ int ObInnerTableSchema::all_virtual_tenant_scheduler_job_schema(ObTableSchema &t
true, //is_nullable
false); //is_autoincrement
}
if (OB_SUCC(ret)) {
ObObj user_id_default;
user_id_default.set_int(OB_INVALID_ID);
ADD_COLUMN_SCHEMA_T("user_id", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObIntType, //column_type
CS_TYPE_INVALID, //column_collation_type
sizeof(int64_t), //column_length
-1, //column_precision
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
user_id_default,
user_id_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj database_id_default;
database_id_default.set_int(OB_INVALID_ID);
ADD_COLUMN_SCHEMA_T("database_id", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObIntType, //column_type
CS_TYPE_INVALID, //column_collation_type
sizeof(int64_t), //column_length
-1, //column_precision
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
database_id_default,
database_id_default); //default_value
}
table_schema.set_index_using_type(USING_BTREE);
table_schema.set_row_store_type(ENCODING_ROW_STORE);
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);

View File

@ -972,6 +972,36 @@ int ObInnerTableSchema::all_virtual_tenant_scheduler_job_real_agent_ora_schema(O
false); //is_autoincrement
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("USER_ID", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObNumberType, //column_type
CS_TYPE_INVALID, //column_collation_type
38, //column_length
38, //column_precision
0, //column_scale
true, //is_nullable
false); //is_autoincrement
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("DATABASE_ID", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObNumberType, //column_type
CS_TYPE_INVALID, //column_collation_type
38, //column_length
38, //column_precision
0, //column_scale
true, //is_nullable
false); //is_autoincrement
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("GMT_CREATE", //column_name
++column_id, //column_id

View File

@ -8931,6 +8931,44 @@ int ObInnerTableSchema::all_tenant_scheduler_job_schema(ObTableSchema &table_sch
true, //is_nullable
false); //is_autoincrement
}
if (OB_SUCC(ret)) {
ObObj user_id_default;
user_id_default.set_int(OB_INVALID_ID);
ADD_COLUMN_SCHEMA_T("user_id", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObIntType, //column_type
CS_TYPE_INVALID, //column_collation_type
sizeof(int64_t), //column_length
-1, //column_precision
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
user_id_default,
user_id_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj database_id_default;
database_id_default.set_int(OB_INVALID_ID);
ADD_COLUMN_SCHEMA_T("database_id", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObIntType, //column_type
CS_TYPE_INVALID, //column_collation_type
sizeof(int64_t), //column_length
-1, //column_precision
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
database_id_default,
database_id_default); //default_value
}
table_schema.set_index_using_type(USING_BTREE);
table_schema.set_row_store_type(ENCODING_ROW_STORE);
table_schema.set_store_format(OB_STORE_FORMAT_DYNAMIC_MYSQL);

View File

@ -4430,6 +4430,8 @@ def_table_schema(
('credential_name', 'varchar:128', 'true'),
('destination_name', 'varchar:128', 'true'),
('interval_ts', 'int', 'true'),
('user_id', 'int', 'true', 'OB_INVALID_ID'),
('database_id', 'int', 'true', 'OB_INVALID_ID')
],
)

View File

@ -6047,6 +6047,8 @@ comments varchar(128) YES NULL
credential_name varchar(128) YES NULL
destination_name varchar(128) YES NULL
interval_ts bigint(20) YES NULL
user_id bigint(20) YES -1
database_id bigint(20) YES -1
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_tenant_scheduler_job;
IF(count(*) >= 0, 1, 0)
1