Skip to content

O
oceanbase

FDD-WEB / oceanbase
与 Fork 源项目一致

Fork自 DP.peng / oceanbase

通知 1
Star 0
Fork 0
O
oceanbase

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 70335895 编写于 作者: O obdev 提交者： wangzelin.wzl
浏览文件
操作

revert incatnation column modified

上级 b65be850
展开全部 隐藏空白更改
内联 并排
Showing with 78 addition and 36 deletion
src/share/inner_table/ob_inner_table_schema.21101_21150.cpp
浏览文件 @ 70335895
......@@ -609,7 +609,7 @@ int ObInnerTableSchema::cdb_ob_archivelog_piece_files_schema(ObTableSchema &tabl
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 TENANT_ID, DEST_ID, ROUND_ID, PIECE_ID, DEST_NO, STATUS, START_SCN, CASE WHEN START_SCN = 0 THEN '' ELSE SCN_TO_TIMESTAMP(START_SCN) END AS START_SCN_DISPLAY, CHECKPOINT_SCN, CASE WHEN CHECKPOINT_SCN = 0 THEN '' ELSE SCN_TO_TIMESTAMP(CHECKPOINT_SCN) END AS CHECKPOINT_SCN_DISPLAY, MAX_SCN, END_SCN, COMPATIBLE, UNIT_SIZE, COMPRESSION, INPUT_BYTES, CASE WHEN INPUT_BYTES >= 1024*1024*1024*1024*1024 THEN CONCAT(ROUND(INPUT_BYTES/1024/1024/1024/1024/1024,2), 'PB') WHEN INPUT_BYTES >= 1024*1024*1024*1024 THEN CONCAT(ROUND(INPUT_BYTES/1024/1024/1024/1024,2), 'TB') WHEN INPUT_BYTES >= 1024*1024*1024 THEN CONCAT(ROUND(INPUT_BYTES/1024/1024/1024,2), 'GB') ELSE CONCAT(ROUND(INPUT_BYTES/1024/1024,2), 'MB') END AS INPUT_BYTES_DISPLAY, OUTPUT_BYTES, CASE WHEN OUTPUT_BYTES >= 1024*1024*1024*1024*1024 THEN CONCAT(ROUND(OUTPUT_BYTES/1024/1024/1024/1024/1024,2), 'PB') WHEN OUTPUT_BYTES >= 1024*1024*1024*1024 THEN CONCAT(ROUND(OUTPUT_BYTES/1024/1024/1024/1024,2), 'TB') WHEN OUTPUT_BYTES >= 1024*1024*1024 THEN CONCAT(ROUND(OUTPUT_BYTES/1024/1024/1024,2), 'GB') ELSE CONCAT(ROUND(OUTPUT_BYTES/1024/1024,2), 'MB') END AS OUTPUT_BYTES_DISPLAY, CASE WHEN INPUT_BYTES = 0 THEN 0 ELSE ROUND(OUTPUT_BYTES / INPUT_BYTES, 2) END AS COMPRESSION_RATIO, FILE_STATUS, PATH FROM OCEANBASE.__ALL_VIRTUAL_LOG_ARCHIVE_PIECE_FILES )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, DEST_ID, ROUND_ID, PIECE_ID, INCARNATION, DEST_NO, STATUS, START_SCN, CASE WHEN START_SCN = 0 THEN '' ELSE SCN_TO_TIMESTAMP(START_SCN) END AS START_SCN_DISPLAY, CHECKPOINT_SCN, CASE WHEN CHECKPOINT_SCN = 0 THEN '' ELSE SCN_TO_TIMESTAMP(CHECKPOINT_SCN) END AS CHECKPOINT_SCN_DISPLAY, MAX_SCN, END_SCN, COMPATIBLE, UNIT_SIZE, COMPRESSION, INPUT_BYTES, CASE WHEN INPUT_BYTES >= 1024*1024*1024*1024*1024 THEN CONCAT(ROUND(INPUT_BYTES/1024/1024/1024/1024/1024,2), 'PB') WHEN INPUT_BYTES >= 1024*1024*1024*1024 THEN CONCAT(ROUND(INPUT_BYTES/1024/1024/1024/1024,2), 'TB') WHEN INPUT_BYTES >= 1024*1024*1024 THEN CONCAT(ROUND(INPUT_BYTES/1024/1024/1024,2), 'GB') ELSE CONCAT(ROUND(INPUT_BYTES/1024/1024,2), 'MB') END AS INPUT_BYTES_DISPLAY, OUTPUT_BYTES, CASE WHEN OUTPUT_BYTES >= 1024*1024*1024*1024*1024 THEN CONCAT(ROUND(OUTPUT_BYTES/1024/1024/1024/1024/1024,2), 'PB') WHEN OUTPUT_BYTES >= 1024*1024*1024*1024 THEN CONCAT(ROUND(OUTPUT_BYTES/1024/1024/1024/1024,2), 'TB') WHEN OUTPUT_BYTES >= 1024*1024*1024 THEN CONCAT(ROUND(OUTPUT_BYTES/1024/1024/1024,2), 'GB') ELSE CONCAT(ROUND(OUTPUT_BYTES/1024/1024,2), 'MB') END AS OUTPUT_BYTES_DISPLAY, CASE WHEN INPUT_BYTES = 0 THEN 0 ELSE ROUND(OUTPUT_BYTES / INPUT_BYTES, 2) END AS COMPRESSION_RATIO, FILE_STATUS, PATH FROM OCEANBASE.__ALL_VIRTUAL_LOG_ARCHIVE_PIECE_FILES )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......@@ -659,7 +659,7 @@ int ObInnerTableSchema::cdb_ob_backup_set_files_schema(ObTableSchema &table_sche
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 TENANT_ID, BACKUP_SET_ID, DEST_ID, BACKUP_TYPE, PREV_FULL_BACKUP_SET_ID, PREV_INC_BACKUP_SET_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, FILE_STATUS, CASE WHEN END_TS = 0 THEN 0 ELSE ROUND((END_TS - START_TS)/1000/1000,0) END AS ELAPSED_SECONDES, PLUS_ARCHIVELOG, START_REPLAY_SCN, CASE WHEN START_REPLAY_SCN = 0 THEN '' ELSE SCN_TO_TIMESTAMP(START_REPLAY_SCN) END AS START_REPLAY_SCN_DISPLAY, MIN_RESTORE_SCN, CASE WHEN MIN_RESTORE_SCN = 0 THEN '' ELSE SCN_TO_TIMESTAMP(MIN_RESTORE_SCN) END AS MIN_RESTORE_SCN_DISPLAY, INPUT_BYTES, OUTPUT_BYTES, CASE WHEN END_TS = 0 THEN 0 ELSE OUTPUT_BYTES / ((END_TS - START_TS)/1000/1000) END AS OUTPUT_RATE_BYTES, EXTRA_BYTES AS EXTRA_META_BYTES, TABLET_COUNT, FINISH_TABLET_COUNT, MACRO_BLOCK_COUNT, FINISH_MACRO_BLOCK_COUNT, FILE_COUNT, META_TURN_ID, DATA_TURN_ID, RESULT, COMMENT, ENCRYPTION_MODE, PASSWD, TENANT_COMPATIBLE, BACKUP_COMPATIBLE, PATH FROM OCEANBASE.__ALL_VIRTUAL_BACKUP_SET_FILES )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, BACKUP_SET_ID, DEST_ID, INCARNATION, BACKUP_TYPE, PREV_FULL_BACKUP_SET_ID, PREV_INC_BACKUP_SET_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, FILE_STATUS, CASE WHEN END_TS = 0 THEN 0 ELSE ROUND((END_TS - START_TS)/1000/1000,0) END AS ELAPSED_SECONDES, PLUS_ARCHIVELOG, START_REPLAY_SCN, CASE WHEN START_REPLAY_SCN = 0 THEN '' ELSE SCN_TO_TIMESTAMP(START_REPLAY_SCN) END AS START_REPLAY_SCN_DISPLAY, MIN_RESTORE_SCN, CASE WHEN MIN_RESTORE_SCN = 0 THEN '' ELSE SCN_TO_TIMESTAMP(MIN_RESTORE_SCN) END AS MIN_RESTORE_SCN_DISPLAY, INPUT_BYTES, OUTPUT_BYTES, CASE WHEN END_TS = 0 THEN 0 ELSE OUTPUT_BYTES / ((END_TS - START_TS)/1000/1000) END AS OUTPUT_RATE_BYTES, EXTRA_BYTES AS EXTRA_META_BYTES, TABLET_COUNT, FINISH_TABLET_COUNT, MACRO_BLOCK_COUNT, FINISH_MACRO_BLOCK_COUNT, FILE_COUNT, META_TURN_ID, DATA_TURN_ID, RESULT, COMMENT, ENCRYPTION_MODE, PASSWD, TENANT_COMPATIBLE, BACKUP_COMPATIBLE, PATH FROM OCEANBASE.__ALL_VIRTUAL_BACKUP_SET_FILES )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......
src/share/inner_table/ob_inner_table_schema.21151_21200.cpp
浏览文件 @ 70335895
......@@ -159,7 +159,7 @@ int ObInnerTableSchema::cdb_ob_backup_jobs_schema(ObTableSchema &table_schema)
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 TENANT_ID, JOB_ID, BACKUP_SET_ID, INITIATOR_TENANT_ID, INITIATOR_JOB_ID, EXECUTOR_TENANT_ID, PLUS_ARCHIVELOG, BACKUP_TYPE, JOB_LEVEL, ENCRYPTION_MODE, PASSWD, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, RESULT, COMMENT, DESCRIPTION, PATH FROM OCEANBASE.__all_virtual_backup_job )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, JOB_ID, INCARNATION, BACKUP_SET_ID, INITIATOR_TENANT_ID, INITIATOR_JOB_ID, EXECUTOR_TENANT_ID, PLUS_ARCHIVELOG, BACKUP_TYPE, JOB_LEVEL, ENCRYPTION_MODE, PASSWD, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, RESULT, COMMENT, DESCRIPTION, PATH FROM OCEANBASE.__all_virtual_backup_job )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......@@ -209,7 +209,7 @@ int ObInnerTableSchema::cdb_ob_backup_job_history_schema(ObTableSchema &table_sc
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 TENANT_ID, JOB_ID, BACKUP_SET_ID, INITIATOR_TENANT_ID, INITIATOR_JOB_ID, EXECUTOR_TENANT_ID, PLUS_ARCHIVELOG, BACKUP_TYPE, JOB_LEVEL, ENCRYPTION_MODE, PASSWD, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, RESULT, COMMENT, DESCRIPTION, PATH FROM OCEANBASE.__ALL_VIRTUAL_BACKUP_JOB_HISTORY )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, JOB_ID, INCARNATION, BACKUP_SET_ID, INITIATOR_TENANT_ID, INITIATOR_JOB_ID, EXECUTOR_TENANT_ID, PLUS_ARCHIVELOG, BACKUP_TYPE, JOB_LEVEL, ENCRYPTION_MODE, PASSWD, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, RESULT, COMMENT, DESCRIPTION, PATH FROM OCEANBASE.__ALL_VIRTUAL_BACKUP_JOB_HISTORY )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......@@ -259,7 +259,7 @@ int ObInnerTableSchema::cdb_ob_backup_tasks_schema(ObTableSchema &table_schema)
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 TENANT_ID, TASK_ID, JOB_ID, BACKUP_SET_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, START_SCN, END_SCN, USER_LS_START_SCN, ENCRYPTION_MODE, PASSWD, INPUT_BYTES, OUTPUT_BYTES, CASE WHEN END_TS = 0 THEN 0 ELSE OUTPUT_BYTES / ((END_TS - START_TS)/1000/1000) END AS OUTPUT_RATE_BYTES, EXTRA_BYTES AS EXTRA_META_BYTES, TABLET_COUNT, FINISH_TABLET_COUNT, MACRO_BLOCK_COUNT, FINISH_MACRO_BLOCK_COUNT, FILE_COUNT, META_TURN_ID, DATA_TURN_ID, RESULT, COMMENT, PATH FROM OCEANBASE.__all_virtual_backup_task )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, TASK_ID, JOB_ID, INCARNATION, BACKUP_SET_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, START_SCN, END_SCN, USER_LS_START_SCN, ENCRYPTION_MODE, PASSWD, INPUT_BYTES, OUTPUT_BYTES, CASE WHEN END_TS = 0 THEN 0 ELSE OUTPUT_BYTES / ((END_TS - START_TS)/1000/1000) END AS OUTPUT_RATE_BYTES, EXTRA_BYTES AS EXTRA_META_BYTES, TABLET_COUNT, FINISH_TABLET_COUNT, MACRO_BLOCK_COUNT, FINISH_MACRO_BLOCK_COUNT, FILE_COUNT, META_TURN_ID, DATA_TURN_ID, RESULT, COMMENT, PATH FROM OCEANBASE.__all_virtual_backup_task )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......@@ -309,7 +309,7 @@ int ObInnerTableSchema::cdb_ob_backup_task_history_schema(ObTableSchema &table_s
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 TENANT_ID, TASK_ID, JOB_ID, BACKUP_SET_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, START_SCN, END_SCN, USER_LS_START_SCN, ENCRYPTION_MODE, PASSWD, INPUT_BYTES, OUTPUT_BYTES, CASE WHEN END_TS = 0 THEN 0 ELSE OUTPUT_BYTES / ((END_TS - START_TS)/1000/1000) END AS OUTPUT_RATE_BYTES, EXTRA_BYTES AS EXTRA_META_BYTES, TABLET_COUNT, FINISH_TABLET_COUNT, MACRO_BLOCK_COUNT, FINISH_MACRO_BLOCK_COUNT, FILE_COUNT, META_TURN_ID, DATA_TURN_ID, RESULT, COMMENT, PATH FROM OCEANBASE.__ALL_VIRTUAL_BACKUP_TASK_HISTORY )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, TASK_ID, JOB_ID, INCARNATION, BACKUP_SET_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, START_SCN, END_SCN, USER_LS_START_SCN, ENCRYPTION_MODE, PASSWD, INPUT_BYTES, OUTPUT_BYTES, CASE WHEN END_TS = 0 THEN 0 ELSE OUTPUT_BYTES / ((END_TS - START_TS)/1000/1000) END AS OUTPUT_RATE_BYTES, EXTRA_BYTES AS EXTRA_META_BYTES, TABLET_COUNT, FINISH_TABLET_COUNT, MACRO_BLOCK_COUNT, FINISH_MACRO_BLOCK_COUNT, FILE_COUNT, META_TURN_ID, DATA_TURN_ID, RESULT, COMMENT, PATH FROM OCEANBASE.__ALL_VIRTUAL_BACKUP_TASK_HISTORY )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......
src/share/inner_table/ob_inner_table_schema.21201_21250.cpp
浏览文件 @ 70335895
......@@ -2159,7 +2159,7 @@ int ObInnerTableSchema::cdb_ob_backup_delete_jobs_schema(ObTableSchema &table_sc
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 TENANT_ID, JOB_ID, INITIATOR_TENANT_ID, INITIATOR_JOB_ID, EXECUTOR_TENANT_ID, TYPE, USEC_TO_TIME(PARAMETER) AS PARAMETER, JOB_LEVEL, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, TASK_COUNT, SUCCESS_TASK_COUNT, RESULT, COMMENT FROM oceanbase.__all_virtual_backup_delete_job )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, JOB_ID, INCARNATION, INITIATOR_TENANT_ID, INITIATOR_JOB_ID, EXECUTOR_TENANT_ID, TYPE, USEC_TO_TIME(PARAMETER) AS PARAMETER, JOB_LEVEL, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, TASK_COUNT, SUCCESS_TASK_COUNT, RESULT, COMMENT FROM oceanbase.__all_virtual_backup_delete_job )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......@@ -2209,7 +2209,7 @@ int ObInnerTableSchema::cdb_ob_backup_delete_job_history_schema(ObTableSchema &t
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 TENANT_ID, JOB_ID, INITIATOR_TENANT_ID, INITIATOR_JOB_ID, EXECUTOR_TENANT_ID, TYPE, USEC_TO_TIME(PARAMETER) AS PARAMETER, JOB_LEVEL, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, TASK_COUNT, SUCCESS_TASK_COUNT, RESULT, COMMENT FROM oceanbase.__all_virtual_backup_delete_job_history )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, JOB_ID, INCARNATION, INITIATOR_TENANT_ID, INITIATOR_JOB_ID, EXECUTOR_TENANT_ID, TYPE, USEC_TO_TIME(PARAMETER) AS PARAMETER, JOB_LEVEL, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, TASK_COUNT, SUCCESS_TASK_COUNT, RESULT, COMMENT FROM oceanbase.__all_virtual_backup_delete_job_history )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......@@ -2259,7 +2259,7 @@ int ObInnerTableSchema::cdb_ob_backup_delete_tasks_schema(ObTableSchema &table_s
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 TENANT_ID, TASK_ID, JOB_ID, TASK_TYPE, ID, ROUND_ID, DEST_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, TOTAL_LS_COUNT, FINISH_LS_COUNT, RESULT, COMMENT, PATH FROM oceanbase.__all_virtual_backup_delete_task )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, TASK_ID, INCARNATION, JOB_ID, TASK_TYPE, ID, ROUND_ID, DEST_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, TOTAL_LS_COUNT, FINISH_LS_COUNT, RESULT, COMMENT, PATH FROM oceanbase.__all_virtual_backup_delete_task )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......@@ -2309,7 +2309,7 @@ int ObInnerTableSchema::cdb_ob_backup_delete_task_history_schema(ObTableSchema &
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 TENANT_ID, TASK_ID, JOB_ID, TASK_TYPE, ID, ROUND_ID, DEST_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, TOTAL_LS_COUNT, FINISH_LS_COUNT, RESULT, COMMENT, PATH FROM oceanbase.__all_virtual_backup_delete_task_history )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, TASK_ID, INCARNATION, JOB_ID, TASK_TYPE, ID, ROUND_ID, DEST_ID, USEC_TO_TIME(START_TS) AS START_TIMESTAMP, CASE WHEN END_TS = 0 THEN '' ELSE USEC_TO_TIME(END_TS) END AS END_TIMESTAMP, STATUS, TOTAL_LS_COUNT, FINISH_LS_COUNT, RESULT, COMMENT, PATH FROM oceanbase.__all_virtual_backup_delete_task_history )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
......
src/share/inner_table/ob_inner_table_schema_def.py
浏览文件 @ 70335895
......@@ -13928,6 +13928,7 @@ def_table_schema(
DEST_ID,
ROUND_ID,
PIECE_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -13996,6 +13997,7 @@ def_table_schema(
TENANT_ID,
BACKUP_SET_ID,
DEST_ID,
INCARNATION,
BACKUP_TYPE,
PREV_FULL_BACKUP_SET_ID,
PREV_INC_BACKUP_SET_ID,
......@@ -14269,6 +14271,7 @@ def_table_schema(
SELECT
TENANT_ID,
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
......@@ -14306,6 +14309,7 @@ def_table_schema(
SELECT
TENANT_ID,
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
......@@ -14344,6 +14348,7 @@ def_table_schema(
TENANT_ID,
TASK_ID,
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
USEC_TO_TIME(START_TS) AS START_TIMESTAMP,
CASE
......@@ -14394,6 +14399,7 @@ def_table_schema(
TENANT_ID,
TASK_ID,
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
USEC_TO_TIME(START_TS) AS START_TIMESTAMP,
CASE
......@@ -19591,6 +19597,7 @@ def_table_schema(
SELECT
TENANT_ID,
JOB_ID,
INCARNATION,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
EXECUTOR_TENANT_ID,
......@@ -19625,6 +19632,7 @@ def_table_schema(
SELECT
TENANT_ID,
JOB_ID,
INCARNATION,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
EXECUTOR_TENANT_ID,
......@@ -19659,6 +19667,7 @@ def_table_schema(
SELECT
TENANT_ID,
TASK_ID,
INCARNATION,
JOB_ID,
TASK_TYPE,
ID,
......@@ -19693,6 +19702,7 @@ def_table_schema(
SELECT
TENANT_ID,
TASK_ID,
INCARNATION,
JOB_ID,
TASK_TYPE,
ID,
......@@ -20440,6 +20450,7 @@ def_table_schema(
view_definition = """
SELECT
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
......@@ -20479,6 +20490,7 @@ def_table_schema(
view_definition = """
SELECT
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
......@@ -20519,6 +20531,7 @@ def_table_schema(
SELECT
TASK_ID,
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
USEC_TO_TIME(START_TS) AS START_TIMESTAMP,
CASE
......@@ -20571,6 +20584,7 @@ def_table_schema(
SELECT
TASK_ID,
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
USEC_TO_TIME(START_TS) AS START_TIMESTAMP,
CASE
......@@ -20623,6 +20637,7 @@ def_table_schema(
SELECT
BACKUP_SET_ID,
DEST_ID,
INCARNATION,
BACKUP_TYPE,
PREV_FULL_BACKUP_SET_ID,
PREV_INC_BACKUP_SET_ID,
......@@ -21131,6 +21146,7 @@ def_table_schema(
view_definition = """
SELECT
JOB_ID,
INCARNATION,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
EXECUTOR_TENANT_ID,
......@@ -21167,6 +21183,7 @@ def_table_schema(
view_definition = """
SELECT
JOB_ID,
INCARNATION,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
EXECUTOR_TENANT_ID,
......@@ -21203,6 +21220,7 @@ def_table_schema(
view_definition = """
SELECT
TASK_ID,
INCARNATION,
JOB_ID,
TASK_TYPE,
ID,
......@@ -21239,6 +21257,7 @@ def_table_schema(
view_definition = """
SELECT
TASK_ID,
INCARNATION,
JOB_ID,
TASK_TYPE,
ID,
......@@ -21525,6 +21544,7 @@ def_table_schema(
SELECT
DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -21618,6 +21638,7 @@ def_table_schema(
SELECT
DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -21696,6 +21717,7 @@ def_table_schema(
(
SELECT DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -21717,6 +21739,7 @@ SELECT DEST_ID,
UNION
SELECT DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
'STOP' AS STATUS,
START_SCN,
......@@ -21753,6 +21776,7 @@ def_table_schema(
DEST_ID,
ROUND_ID,
PIECE_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -21863,6 +21887,7 @@ def_table_schema(
TENANT_ID,
DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -21955,6 +21980,7 @@ def_table_schema(
TENANT_ID,
DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -22034,6 +22060,7 @@ def_table_schema(
SELECT TENANT_ID,
DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -22056,6 +22083,7 @@ UNION
SELECT TENANT_ID,
DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
'STOP' AS STATUS,
START_SCN,
......@@ -38359,6 +38387,7 @@ def_table_schema(
"""
SELECT
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
......@@ -38400,6 +38429,7 @@ def_table_schema(
view_definition = """
SELECT
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
......@@ -38442,6 +38472,7 @@ def_table_schema(
SELECT
TASK_ID,
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
TO_CHAR(START_TS / (1000 * 60 * 60 * 24 * 1000) + TO_DATE('1970-01-01 08:00:00', 'yyyy-mm-dd hh:mi:ss'), 'yyyy-mm-dd hh24:mi:ss') AS START_TIMESTAMP,
CASE
......@@ -38496,6 +38527,7 @@ def_table_schema(
SELECT
TASK_ID,
JOB_ID,
INCARNATION,
BACKUP_SET_ID,
TO_CHAR(START_TS / (1000 * 60 * 60 * 24 * 1000) + TO_DATE('1970-01-01 08:00:00', 'yyyy-mm-dd hh:mi:ss'), 'yyyy-mm-dd hh24:mi:ss') AS START_TIMESTAMP,
CASE
......@@ -38550,6 +38582,7 @@ def_table_schema(
SELECT
BACKUP_SET_ID,
DEST_ID,
INCARNATION,
BACKUP_TYPE,
PREV_FULL_BACKUP_SET_ID,
PREV_INC_BACKUP_SET_ID,
......@@ -38878,6 +38911,7 @@ def_table_schema(
view_definition = """
SELECT
JOB_ID,
INCARNATION,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
EXECUTOR_TENANT_ID,
......@@ -38916,6 +38950,7 @@ def_table_schema(
view_definition = """
SELECT
JOB_ID,
INCARNATION,
INITIATOR_TENANT_ID,
INITIATOR_JOB_ID,
EXECUTOR_TENANT_ID,
......@@ -38954,6 +38989,7 @@ def_table_schema(
view_definition = """
SELECT
TASK_ID,
INCARNATION,
JOB_ID,
TASK_TYPE,
ID,
......@@ -38992,6 +39028,7 @@ def_table_schema(
view_definition = """
SELECT
TASK_ID,
INCARNATION,
JOB_ID,
TASK_TYPE,
ID,
......@@ -39219,6 +39256,7 @@ def_table_schema(
SELECT
DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -39304,6 +39342,7 @@ def_table_schema(
SELECT
DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -39372,6 +39411,7 @@ def_table_schema(
(
SELECT DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
......@@ -39393,6 +39433,7 @@ SELECT DEST_ID,
UNION
SELECT DEST_ID,
ROUND_ID,
INCARNATION,
DEST_NO,
'STOP' AS STATUS,
START_SCN,
......@@ -39431,6 +39472,7 @@ def_table_schema(
DEST_ID,
ROUND_ID,
PIECE_ID,
INCARNATION,
DEST_NO,
STATUS,
START_SCN,
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或