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

add user_dbms_scheduler_jobs view

Browse Source
This commit is contained in:
lmjhh 2024-11-04 08:43:54 +00:00 committed by ob-robot
parent c56f51262b
commit e8ff23c18f
5 changed files with 141 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
src/share/inner_table/ob_inner_table_schema.25301_25350.cpp
View File

@ -229,6 +229,57 @@ int ObInnerTableSchema::dba_ob_storage_io_usage_ora_schema(ObTableSchema &table_
return ret;
}
int ObInnerTableSchema::user_scheduler_jobs_ora_schema(ObTableSchema &table_schema)
{
int ret = OB_SUCCESS;
uint64_t column_id = OB_APP_MIN_COLUMN_ID - 1;
//generated fields:
table_schema.set_tenant_id(OB_SYS_TENANT_ID);
table_schema.set_tablegroup_id(OB_INVALID_ID);
table_schema.set_database_id(OB_ORA_SYS_DATABASE_ID);
table_schema.set_table_id(OB_USER_SCHEDULER_JOBS_ORA_TID);
table_schema.set_rowkey_split_pos(0);
table_schema.set_is_use_bloomfilter(false);
table_schema.set_progressive_merge_num(0);
table_schema.set_rowkey_column_num(0);
table_schema.set_load_type(TABLE_LOAD_TYPE_IN_DISK);
table_schema.set_table_type(SYSTEM_VIEW);
table_schema.set_index_type(INDEX_TYPE_IS_NOT);
table_schema.set_def_type(TABLE_DEF_TYPE_INTERNAL);
if (OB_SUCC(ret)) {
if (OB_FAIL(table_schema.set_table_name(OB_USER_SCHEDULER_JOBS_ORA_TNAME))) {
LOG_ERROR("fail to set table_name", K(ret));
}
}
if (OB_SUCC(ret)) {
if (OB_FAIL(table_schema.set_compress_func_name(OB_DEFAULT_COMPRESS_FUNC_NAME))) {
LOG_ERROR("fail to set compress_func_name", K(ret));
}
}
table_schema.set_part_level(PARTITION_LEVEL_ZERO);
table_schema.set_charset_type(ObCharset::get_default_charset());
table_schema.set_collation_type(ObCharset::get_default_collation(ObCharset::get_default_charset()));
if (OB_SUCC(ret)) {
if (OB_FAIL(table_schema.set_view_definition(R"__(SELECT OWNER, JOB_NAME, JOB_SUBNAME, JOB_STYLE, JOB_CREATOR, CLIENT_ID, GLOBAL_UID, PROGRAM_OWNER, PROGRAM_NAME, JOB_TYPE, JOB_ACTION, NUMBER_OF_ARGUMENTS, SCHEDULE_OWNER, SCHEDULE_NAME, SCHEDULE_TYPE, START_DATE, REPEAT_INTERVAL, EVENT_QUEUE_OWNER, EVENT_QUEUE_NAME, EVENT_QUEUE_AGENT, EVENT_CONDITION, EVENT_RULE, FILE_WATCHER_OWNER, FILE_WATCHER_NAME, END_DATE, JOB_CLASS, ENABLED, AUTO_DROP, RESTART_ON_RECOVERY, RESTART_ON_FAILURE, STATE, JOB_PRIORITY, RUN_COUNT, MAX_RUNS, FAILURE_COUNT, MAX_FAILURES, RETRY_COUNT, LAST_START_DATE, LAST_RUN_DURATION, NEXT_RUN_DATE, SCHEDULE_LIMIT, MAX_RUN_DURATION, LOGGING_LEVEL, STORE_OUTPUT, STOP_ON_WINDOW_CLOSE, INSTANCE_STICKINESS, RAISE_EVENTS, SYSTEM, JOB_WEIGHT, NLS_ENV, SOURCE, NUMBER_OF_DESTINATIONS, DESTINATION_OWNER, DESTINATION, CREDENTIAL_OWNER, CREDENTIAL_NAME, INSTANCE_ID, DEFERRED_DROP, ALLOW_RUNS_IN_RESTRICTED_MODE, COMMENTS, FLAGS, RESTARTABLE, CONNECT_CREDENTIAL_OWNER, CONNECT_CREDENTIAL_NAME FROM DBA_SCHEDULER_JOBS WHERE OWNER = SYS_CONTEXT('USERENV','CURRENT_USER') )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
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);
table_schema.set_progressive_merge_round(1);
table_schema.set_storage_format_version(3);
table_schema.set_tablet_id(0);
table_schema.set_micro_index_clustered(false);
table_schema.set_max_used_column_id(column_id);
return ret;
}
} // end namespace share
} // end namespace oceanbase

10
src/share/inner_table/ob_inner_table_schema.h
View File

@ -2166,6 +2166,7 @@ public:
static int proxy_users_schema(share::schema::ObTableSchema &table_schema);
static int dba_ob_services_ora_schema(share::schema::ObTableSchema &table_schema);
static int dba_ob_storage_io_usage_ora_schema(share::schema::ObTableSchema &table_schema);
static int user_scheduler_jobs_ora_schema(share::schema::ObTableSchema &table_schema);
static int gv_ob_sql_audit_ora_schema(share::schema::ObTableSchema &table_schema);
static int v_ob_sql_audit_ora_schema(share::schema::ObTableSchema &table_schema);
static int gv_instance_schema(share::schema::ObTableSchema &table_schema);
@ -5142,6 +5143,7 @@ const schema_create_func sys_view_schema_creators [] = {
ObInnerTableSchema::proxy_users_schema,
ObInnerTableSchema::dba_ob_services_ora_schema,
ObInnerTableSchema::dba_ob_storage_io_usage_ora_schema,
ObInnerTableSchema::user_scheduler_jobs_ora_schema,
ObInnerTableSchema::gv_ob_sql_audit_ora_schema,
ObInnerTableSchema::v_ob_sql_audit_ora_schema,
ObInnerTableSchema::gv_instance_schema,
@ -6931,6 +6933,7 @@ const uint64_t tenant_space_tables [] = {
OB_PROXY_USERS_TID,
OB_DBA_OB_SERVICES_ORA_TID,
OB_DBA_OB_STORAGE_IO_USAGE_ORA_TID,
OB_USER_SCHEDULER_JOBS_ORA_TID,
OB_GV_OB_SQL_AUDIT_ORA_TID,
OB_V_OB_SQL_AUDIT_ORA_TID,
OB_GV_INSTANCE_TID,
@ -9667,6 +9670,7 @@ const char* const tenant_space_table_names [] = {
OB_PROXY_USERS_TNAME,
OB_DBA_OB_SERVICES_ORA_TNAME,
OB_DBA_OB_STORAGE_IO_USAGE_ORA_TNAME,
OB_USER_SCHEDULER_JOBS_ORA_TNAME,
OB_GV_OB_SQL_AUDIT_ORA_TNAME,
OB_V_OB_SQL_AUDIT_ORA_TNAME,
OB_GV_INSTANCE_TNAME,
@ -13660,10 +13664,10 @@ static inline int get_sys_table_lob_aux_schema(const uint64_t tid,
const int64_t OB_CORE_TABLE_COUNT = 4;
const int64_t OB_SYS_TABLE_COUNT = 306;
const int64_t OB_VIRTUAL_TABLE_COUNT = 854;
const int64_t OB_SYS_VIEW_COUNT = 968;
const int64_t OB_SYS_TENANT_TABLE_COUNT = 2133;
const int64_t OB_SYS_VIEW_COUNT = 969;
const int64_t OB_SYS_TENANT_TABLE_COUNT = 2134;
const int64_t OB_CORE_SCHEMA_VERSION = 1;
const int64_t OB_BOOTSTRAP_SCHEMA_VERSION = 2136;
const int64_t OB_BOOTSTRAP_SCHEMA_VERSION = 2137;
} // end namespace share
} // end namespace oceanbase

2
src/share/inner_table/ob_inner_table_schema_constants.h
View File

@ -1866,6 +1866,7 @@ const uint64_t OB_USER_MVREF_STMT_STATS_ORA_TID = 25300; // "USER_MVREF_STMT_STA
const uint64_t OB_PROXY_USERS_TID = 25301; // "PROXY_USERS"
const uint64_t OB_DBA_OB_SERVICES_ORA_TID = 25302; // "DBA_OB_SERVICES_ORA"
const uint64_t OB_DBA_OB_STORAGE_IO_USAGE_ORA_TID = 25303; // "DBA_OB_STORAGE_IO_USAGE_ORA"
const uint64_t OB_USER_SCHEDULER_JOBS_ORA_TID = 25305; // "USER_SCHEDULER_JOBS_ORA"
const uint64_t OB_GV_OB_SQL_AUDIT_ORA_TID = 28002; // "GV$OB_SQL_AUDIT_ORA"
const uint64_t OB_V_OB_SQL_AUDIT_ORA_TID = 28003; // "V$OB_SQL_AUDIT_ORA"
const uint64_t OB_GV_INSTANCE_TID = 28004; // "GV$INSTANCE"
@ -4729,6 +4730,7 @@ const char *const OB_USER_MVREF_STMT_STATS_ORA_TNAME = "USER_MVREF_STMT_STATS";
const char *const OB_PROXY_USERS_TNAME = "PROXY_USERS";
const char *const OB_DBA_OB_SERVICES_ORA_TNAME = "DBA_OB_SERVICES";
const char *const OB_DBA_OB_STORAGE_IO_USAGE_ORA_TNAME = "DBA_OB_STORAGE_IO_USAGE";
const char *const OB_USER_SCHEDULER_JOBS_ORA_TNAME = "USER_SCHEDULER_JOBS";
const char *const OB_GV_OB_SQL_AUDIT_ORA_TNAME = "GV$OB_SQL_AUDIT";
const char *const OB_V_OB_SQL_AUDIT_ORA_TNAME = "V$OB_SQL_AUDIT";
const char *const OB_GV_INSTANCE_TNAME = "GV$INSTANCE";

80
src/share/inner_table/ob_inner_table_schema_def.py
View File

@ -58564,6 +58564,86 @@ def_table_schema(
# 25304: DBA_OB_OBJECT_BALANCE_WEIGHT
def_table_schema(
owner = 'huangrenhuang.hrh',
table_name = 'USER_SCHEDULER_JOBS',
name_postfix = '_ORA',
database_id = 'OB_ORA_SYS_DATABASE_ID',
table_id = '25305',
table_type = 'SYSTEM_VIEW',
rowkey_columns = [],
normal_columns = [],
gm_columns = [],
in_tenant_space = True,
view_definition = """SELECT
OWNER,
JOB_NAME,
JOB_SUBNAME,
JOB_STYLE,
JOB_CREATOR,
CLIENT_ID,
GLOBAL_UID,
PROGRAM_OWNER,
PROGRAM_NAME,
JOB_TYPE,
JOB_ACTION,
NUMBER_OF_ARGUMENTS,
SCHEDULE_OWNER,
SCHEDULE_NAME,
SCHEDULE_TYPE,
START_DATE,
REPEAT_INTERVAL,
EVENT_QUEUE_OWNER,
EVENT_QUEUE_NAME,
EVENT_QUEUE_AGENT,
EVENT_CONDITION,
EVENT_RULE,
FILE_WATCHER_OWNER,
FILE_WATCHER_NAME,
END_DATE,
JOB_CLASS,
ENABLED,
AUTO_DROP,
RESTART_ON_RECOVERY,
RESTART_ON_FAILURE,
STATE,
JOB_PRIORITY,
RUN_COUNT,
MAX_RUNS,
FAILURE_COUNT,
MAX_FAILURES,
RETRY_COUNT,
LAST_START_DATE,
LAST_RUN_DURATION,
NEXT_RUN_DATE,
SCHEDULE_LIMIT,
MAX_RUN_DURATION,
LOGGING_LEVEL,
STORE_OUTPUT,
STOP_ON_WINDOW_CLOSE,
INSTANCE_STICKINESS,
RAISE_EVENTS,
SYSTEM,
JOB_WEIGHT,
NLS_ENV,
SOURCE,
NUMBER_OF_DESTINATIONS,
DESTINATION_OWNER,
DESTINATION,
CREDENTIAL_OWNER,
CREDENTIAL_NAME,
INSTANCE_ID,
DEFERRED_DROP,
ALLOW_RUNS_IN_RESTRICTED_MODE,
COMMENTS,
FLAGS,
RESTARTABLE,
CONNECT_CREDENTIAL_OWNER,
CONNECT_CREDENTIAL_NAME
FROM DBA_SCHEDULER_JOBS WHERE OWNER = SYS_CONTEXT('USERENV','CURRENT_USER')
""".replace("\n", " ")
)
#
# 余留位置（此行之前占位）
# 本区域占位建议：采用真实视图名进行占位

1
src/share/inner_table/table_id_to_name
View File

@ -2564,6 +2564,7 @@
# 25301: PROXY_USERS
# 25302: DBA_OB_SERVICES
# 25303: DBA_OB_STORAGE_IO_USAGE
# 25305: USER_SCHEDULER_JOBS
# 28002: GV$OB_SQL_AUDIT
# 28003: V$OB_SQL_AUDIT
# 28004: GV$INSTANCE