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

modify the name of IO data in ash

Browse Source
This commit is contained in:
obdev 2024-10-25 09:48:34 +00:00 committed by ob-robot
parent dfe2b1a6e4
commit 7148f27a0e
14 changed files with 151 additions and 151 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/observer/virtual_table/ob_virtual_ash.cpp
View File

@ -361,19 +361,19 @@ int ObVirtualASH::convert_node_to_row(const ActiveSessionStat &node, ObNewRow *&
cells[cell_idx].set_null();
break;
}
case IO_READ_COUNT: {
case DELTA_READ_IO_REQUESTS: {
cells[cell_idx].set_null();
break;
}
case IO_READ_SIZE: {
case DELTA_READ_IO_BYTES: {
cells[cell_idx].set_null();
break;
}
case IO_WRITE_COUNT: {
case DELTA_WRITE_IO_REQUESTS: {
cells[cell_idx].set_null();
break;
}
case IO_WRITE_SIZE: {
case DELTA_WRITE_IO_BYTES: {
cells[cell_idx].set_null();
break;
}

8
src/observer/virtual_table/ob_virtual_ash.h
View File

@ -99,10 +99,10 @@ protected:
STMT_TYPE,
TABLET_ID,
PROXY_SID,
IO_READ_COUNT,
IO_READ_SIZE,
IO_WRITE_COUNT,
IO_WRITE_SIZE,
DELTA_READ_IO_REQUESTS,
DELTA_READ_IO_BYTES,
DELTA_WRITE_IO_REQUESTS,
DELTA_WRITE_IO_BYTES,
};
DISALLOW_COPY_AND_ASSIGN(ObVirtualASH);
share::ObActiveSessHistList::Iterator iterator_;

80
src/share/inner_table/ob_inner_table_schema.12301_12350.cpp
View File

@ -1444,9 +1444,9 @@ int ObInnerTableSchema::all_virtual_ash_schema(ObTableSchema &table_schema)
}
if (OB_SUCC(ret)) {
ObObj io_read_count_default;
io_read_count_default.set_int(0);
ADD_COLUMN_SCHEMA_T("IO_READ_COUNT", //column_name
ObObj delta_read_io_requests_default;
delta_read_io_requests_default.set_int(0);
ADD_COLUMN_SCHEMA_T("DELTA_READ_IO_REQUESTS", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -1458,14 +1458,14 @@ int ObInnerTableSchema::all_virtual_ash_schema(ObTableSchema &table_schema)
-1, //column_scale
false, //is_nullable
false, //is_autoincrement
io_read_count_default,
io_read_count_default); //default_value
delta_read_io_requests_default,
delta_read_io_requests_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj io_read_size_default;
io_read_size_default.set_int(0);
ADD_COLUMN_SCHEMA_T("IO_READ_SIZE", //column_name
ObObj delta_read_io_bytes_default;
delta_read_io_bytes_default.set_int(0);
ADD_COLUMN_SCHEMA_T("DELTA_READ_IO_BYTES", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -1477,14 +1477,14 @@ int ObInnerTableSchema::all_virtual_ash_schema(ObTableSchema &table_schema)
-1, //column_scale
false, //is_nullable
false, //is_autoincrement
io_read_size_default,
io_read_size_default); //default_value
delta_read_io_bytes_default,
delta_read_io_bytes_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj io_write_count_default;
io_write_count_default.set_int(0);
ADD_COLUMN_SCHEMA_T("IO_WRITE_COUNT", //column_name
ObObj delta_write_io_requests_default;
delta_write_io_requests_default.set_int(0);
ADD_COLUMN_SCHEMA_T("DELTA_WRITE_IO_REQUESTS", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -1496,14 +1496,14 @@ int ObInnerTableSchema::all_virtual_ash_schema(ObTableSchema &table_schema)
-1, //column_scale
false, //is_nullable
false, //is_autoincrement
io_write_count_default,
io_write_count_default); //default_value
delta_write_io_requests_default,
delta_write_io_requests_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj io_write_size_default;
io_write_size_default.set_int(0);
ADD_COLUMN_SCHEMA_T("IO_WRITE_SIZE", //column_name
ObObj delta_write_io_bytes_default;
delta_write_io_bytes_default.set_int(0);
ADD_COLUMN_SCHEMA_T("DELTA_WRITE_IO_BYTES", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -1515,8 +1515,8 @@ int ObInnerTableSchema::all_virtual_ash_schema(ObTableSchema &table_schema)
-1, //column_scale
false, //is_nullable
false, //is_autoincrement
io_write_size_default,
io_write_size_default); //default_value
delta_write_io_bytes_default,
delta_write_io_bytes_default); //default_value
}
if (OB_SUCC(ret)) {
table_schema.get_part_option().set_part_num(1);
@ -2591,9 +2591,9 @@ int ObInnerTableSchema::all_virtual_ash_all_virtual_ash_i1_schema(ObTableSchema
}
if (OB_SUCC(ret)) {
ObObj io_read_count_default;
io_read_count_default.set_int(0);
ADD_COLUMN_SCHEMA_T_WITH_COLUMN_FLAGS("IO_READ_COUNT", //column_name
ObObj delta_read_io_requests_default;
delta_read_io_requests_default.set_int(0);
ADD_COLUMN_SCHEMA_T_WITH_COLUMN_FLAGS("DELTA_READ_IO_REQUESTS", //column_name
column_id + 58, //column_id
0, //rowkey_id
0, //index_id
@ -2605,16 +2605,16 @@ int ObInnerTableSchema::all_virtual_ash_all_virtual_ash_i1_schema(ObTableSchema
-1, //column_scale
false, //is_nullable
false, //is_autoincrement
io_read_count_default,
io_read_count_default, //default_value
delta_read_io_requests_default,
delta_read_io_requests_default, //default_value
false, //is_hidden
true); //is_storing_column
}
if (OB_SUCC(ret)) {
ObObj io_read_size_default;
io_read_size_default.set_int(0);
ADD_COLUMN_SCHEMA_T_WITH_COLUMN_FLAGS("IO_READ_SIZE", //column_name
ObObj delta_read_io_bytes_default;
delta_read_io_bytes_default.set_int(0);
ADD_COLUMN_SCHEMA_T_WITH_COLUMN_FLAGS("DELTA_READ_IO_BYTES", //column_name
column_id + 59, //column_id
0, //rowkey_id
0, //index_id
@ -2626,16 +2626,16 @@ int ObInnerTableSchema::all_virtual_ash_all_virtual_ash_i1_schema(ObTableSchema
-1, //column_scale
false, //is_nullable
false, //is_autoincrement
io_read_size_default,
io_read_size_default, //default_value
delta_read_io_bytes_default,
delta_read_io_bytes_default, //default_value
false, //is_hidden
true); //is_storing_column
}
if (OB_SUCC(ret)) {
ObObj io_write_count_default;
io_write_count_default.set_int(0);
ADD_COLUMN_SCHEMA_T_WITH_COLUMN_FLAGS("IO_WRITE_COUNT", //column_name
ObObj delta_write_io_requests_default;
delta_write_io_requests_default.set_int(0);
ADD_COLUMN_SCHEMA_T_WITH_COLUMN_FLAGS("DELTA_WRITE_IO_REQUESTS", //column_name
column_id + 60, //column_id
0, //rowkey_id
0, //index_id
@ -2647,16 +2647,16 @@ int ObInnerTableSchema::all_virtual_ash_all_virtual_ash_i1_schema(ObTableSchema
-1, //column_scale
false, //is_nullable
false, //is_autoincrement
io_write_count_default,
io_write_count_default, //default_value
delta_write_io_requests_default,
delta_write_io_requests_default, //default_value
false, //is_hidden
true); //is_storing_column
}
if (OB_SUCC(ret)) {
ObObj io_write_size_default;
io_write_size_default.set_int(0);
ADD_COLUMN_SCHEMA_T_WITH_COLUMN_FLAGS("IO_WRITE_SIZE", //column_name
ObObj delta_write_io_bytes_default;
delta_write_io_bytes_default.set_int(0);
ADD_COLUMN_SCHEMA_T_WITH_COLUMN_FLAGS("DELTA_WRITE_IO_BYTES", //column_name
column_id + 61, //column_id
0, //rowkey_id
0, //index_id
@ -2668,8 +2668,8 @@ int ObInnerTableSchema::all_virtual_ash_all_virtual_ash_i1_schema(ObTableSchema
-1, //column_scale
false, //is_nullable
false, //is_autoincrement
io_write_size_default,
io_write_size_default, //default_value
delta_write_io_bytes_default,
delta_write_io_bytes_default, //default_value
false, //is_hidden
true); //is_storing_column
}

40
src/share/inner_table/ob_inner_table_schema.12351_12400.cpp
View File

@ -7757,9 +7757,9 @@ int ObInnerTableSchema::all_virtual_wr_active_session_history_schema(ObTableSche
}
if (OB_SUCC(ret)) {
ObObj io_read_count_default;
io_read_count_default.set_int(0);
ADD_COLUMN_SCHEMA_T("io_read_count", //column_name
ObObj delta_read_io_requests_default;
delta_read_io_requests_default.set_int(0);
ADD_COLUMN_SCHEMA_T("delta_read_io_requests", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -7771,14 +7771,14 @@ int ObInnerTableSchema::all_virtual_wr_active_session_history_schema(ObTableSche
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
io_read_count_default,
io_read_count_default); //default_value
delta_read_io_requests_default,
delta_read_io_requests_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj io_read_size_default;
io_read_size_default.set_int(0);
ADD_COLUMN_SCHEMA_T("io_read_size", //column_name
ObObj delta_read_io_bytes_default;
delta_read_io_bytes_default.set_int(0);
ADD_COLUMN_SCHEMA_T("delta_read_io_bytes", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -7790,14 +7790,14 @@ int ObInnerTableSchema::all_virtual_wr_active_session_history_schema(ObTableSche
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
io_read_size_default,
io_read_size_default); //default_value
delta_read_io_bytes_default,
delta_read_io_bytes_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj io_write_count_default;
io_write_count_default.set_int(0);
ADD_COLUMN_SCHEMA_T("io_write_count", //column_name
ObObj delta_write_io_requests_default;
delta_write_io_requests_default.set_int(0);
ADD_COLUMN_SCHEMA_T("delta_write_io_requests", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -7809,14 +7809,14 @@ int ObInnerTableSchema::all_virtual_wr_active_session_history_schema(ObTableSche
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
io_write_count_default,
io_write_count_default); //default_value
delta_write_io_requests_default,
delta_write_io_requests_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj io_write_size_default;
io_write_size_default.set_int(0);
ADD_COLUMN_SCHEMA_T("io_write_size", //column_name
ObObj delta_write_io_bytes_default;
delta_write_io_bytes_default.set_int(0);
ADD_COLUMN_SCHEMA_T("delta_write_io_bytes", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -7828,8 +7828,8 @@ int ObInnerTableSchema::all_virtual_wr_active_session_history_schema(ObTableSche
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
io_write_size_default,
io_write_size_default); //default_value
delta_write_io_bytes_default,
delta_write_io_bytes_default); //default_value
}
table_schema.set_index_using_type(USING_BTREE);
table_schema.set_row_store_type(ENCODING_ROW_STORE);

16
src/share/inner_table/ob_inner_table_schema.15201_15250.cpp
View File

@ -14460,7 +14460,7 @@ int ObInnerTableSchema::all_virtual_ash_ora_schema(ObTableSchema &table_schema)
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("IO_READ_COUNT", //column_name
ADD_COLUMN_SCHEMA("DELTA_READ_IO_REQUESTS", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -14475,7 +14475,7 @@ int ObInnerTableSchema::all_virtual_ash_ora_schema(ObTableSchema &table_schema)
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("IO_READ_SIZE", //column_name
ADD_COLUMN_SCHEMA("DELTA_READ_IO_BYTES", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -14490,7 +14490,7 @@ int ObInnerTableSchema::all_virtual_ash_ora_schema(ObTableSchema &table_schema)
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("IO_WRITE_COUNT", //column_name
ADD_COLUMN_SCHEMA("DELTA_WRITE_IO_REQUESTS", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -14505,7 +14505,7 @@ int ObInnerTableSchema::all_virtual_ash_ora_schema(ObTableSchema &table_schema)
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("IO_WRITE_SIZE", //column_name
ADD_COLUMN_SCHEMA("DELTA_WRITE_IO_BYTES", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -15562,7 +15562,7 @@ int ObInnerTableSchema::all_virtual_ash_ora_all_virtual_ash_i1_schema(ObTableSch
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA_WITH_COLUMN_FLAGS("IO_READ_COUNT", //column_name
ADD_COLUMN_SCHEMA_WITH_COLUMN_FLAGS("DELTA_READ_IO_REQUESTS", //column_name
column_id + 58, //column_id
0, //rowkey_id
0, //index_id
@ -15579,7 +15579,7 @@ int ObInnerTableSchema::all_virtual_ash_ora_all_virtual_ash_i1_schema(ObTableSch
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA_WITH_COLUMN_FLAGS("IO_READ_SIZE", //column_name
ADD_COLUMN_SCHEMA_WITH_COLUMN_FLAGS("DELTA_READ_IO_BYTES", //column_name
column_id + 59, //column_id
0, //rowkey_id
0, //index_id
@ -15596,7 +15596,7 @@ int ObInnerTableSchema::all_virtual_ash_ora_all_virtual_ash_i1_schema(ObTableSch
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA_WITH_COLUMN_FLAGS("IO_WRITE_COUNT", //column_name
ADD_COLUMN_SCHEMA_WITH_COLUMN_FLAGS("DELTA_WRITE_IO_REQUESTS", //column_name
column_id + 60, //column_id
0, //rowkey_id
0, //index_id
@ -15613,7 +15613,7 @@ int ObInnerTableSchema::all_virtual_ash_ora_all_virtual_ash_i1_schema(ObTableSch
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA_WITH_COLUMN_FLAGS("IO_WRITE_SIZE", //column_name
ADD_COLUMN_SCHEMA_WITH_COLUMN_FLAGS("DELTA_WRITE_IO_BYTES", //column_name
column_id + 61, //column_id
0, //rowkey_id
0, //index_id

8
src/share/inner_table/ob_inner_table_schema.15251_15300.cpp
View File

@ -11840,7 +11840,7 @@ int ObInnerTableSchema::all_virtual_wr_active_session_history_ora_schema(ObTable
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("IO_READ_COUNT", //column_name
ADD_COLUMN_SCHEMA("DELTA_READ_IO_REQUESTS", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -11855,7 +11855,7 @@ int ObInnerTableSchema::all_virtual_wr_active_session_history_ora_schema(ObTable
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("IO_READ_SIZE", //column_name
ADD_COLUMN_SCHEMA("DELTA_READ_IO_BYTES", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -11870,7 +11870,7 @@ int ObInnerTableSchema::all_virtual_wr_active_session_history_ora_schema(ObTable
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("IO_WRITE_COUNT", //column_name
ADD_COLUMN_SCHEMA("DELTA_WRITE_IO_REQUESTS", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -11885,7 +11885,7 @@ int ObInnerTableSchema::all_virtual_wr_active_session_history_ora_schema(ObTable
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("IO_WRITE_SIZE", //column_name
ADD_COLUMN_SCHEMA("DELTA_WRITE_IO_BYTES", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id

4
src/share/inner_table/ob_inner_table_schema.21351_21400.cpp
View File

@ -1845,7 +1845,7 @@ int ObInnerTableSchema::dba_wr_active_session_history_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 ASH.CLUSTER_ID AS CLUSTER_ID, ASH.TENANT_ID AS TENANT_ID, ASH.SNAP_ID AS SNAP_ID, ASH.SVR_IP AS SVR_IP, ASH.SVR_PORT AS SVR_PORT, ASH.SAMPLE_ID AS SAMPLE_ID, ASH.SESSION_ID AS SESSION_ID, ASH.SAMPLE_TIME AS SAMPLE_TIME, ASH.USER_ID AS USER_ID, ASH.SESSION_TYPE AS SESSION_TYPE, CAST(IF (ASH.EVENT_NO = 0, 'ON CPU', 'WAITING') AS CHAR(7)) AS SESSION_STATE, ASH.SQL_ID AS SQL_ID, ASH.TRACE_ID AS TRACE_ID, ASH.EVENT_NO AS EVENT_NO, ASH.EVENT_ID AS EVENT_ID, ASH.TIME_WAITED AS TIME_WAITED, ASH.P1 AS P1, ASH.P2 AS P2, ASH.P3 AS P3, ASH.SQL_PLAN_LINE_ID AS SQL_PLAN_LINE_ID, ASH.GROUP_ID AS GROUP_ID, ASH.TX_ID AS TX_ID, ASH.BLOCKING_SESSION_ID AS BLOCKING_SESSION_ID, ASH.TIME_MODEL AS TIME_MODEL, CAST(CASE WHEN (ASH.TIME_MODEL & 1) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PARSE, CAST(CASE WHEN (ASH.TIME_MODEL & 2) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PL_PARSE, CAST(CASE WHEN (ASH.TIME_MODEL & 4) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLAN_CACHE, CAST(CASE WHEN (ASH.TIME_MODEL & 8) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SQL_OPTIMIZE, CAST(CASE WHEN (ASH.TIME_MODEL & 16) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SQL_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 32) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PX_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 64) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SEQUENCE_LOAD, CAST(CASE WHEN (ASH.TIME_MODEL & 128) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_COMMITTING, CAST(CASE WHEN (ASH.TIME_MODEL & 256) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_STORAGE_READ, CAST(CASE WHEN (ASH.TIME_MODEL & 512) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_STORAGE_WRITE, CAST(CASE WHEN (ASH.TIME_MODEL & 1024) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_REMOTE_DAS_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 2048) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLSQL_COMPILATION, CAST(CASE WHEN (ASH.TIME_MODEL & 4096) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLSQL_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 8192) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_FILTER_ROWS, ASH.PROGRAM AS PROGRAM, ASH.MODULE AS MODULE, ASH.ACTION AS ACTION, ASH.CLIENT_ID AS CLIENT_ID, ASH.BACKTRACE AS BACKTRACE, ASH.PLAN_ID AS PLAN_ID, ASH.TM_DELTA_TIME AS TM_DELTA_TIME, ASH.TM_DELTA_CPU_TIME AS TM_DELTA_CPU_TIME, ASH.TM_DELTA_DB_TIME AS TM_DELTA_DB_TIME, ASH.TOP_LEVEL_SQL_ID AS TOP_LEVEL_SQL_ID, ASH.PLSQL_ENTRY_OBJECT_ID AS PLSQL_ENTRY_OBJECT_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_ID AS PLSQL_ENTRY_SUBPROGRAM_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_NAME AS PLSQL_ENTRY_SUBPROGRAM_NAME, ASH.PLSQL_OBJECT_ID AS PLSQL_OBJECT_ID, ASH.PLSQL_SUBPROGRAM_ID AS PLSQL_SUBPROGRAM_ID, ASH.PLSQL_SUBPROGRAM_NAME AS PLSQL_SUBPROGRAM_NAME, ASH.IO_READ_COUNT AS IO_READ_COUNT, ASH.IO_READ_SIZE AS IO_READ_SIZE, ASH.IO_WRITE_COUNT AS IO_WRITE_COUNT, ASH.IO_WRITE_SIZE AS IO_WRITE_SIZE FROM ( OCEANBASE.__ALL_VIRTUAL_WR_ACTIVE_SESSION_HISTORY ASH JOIN OCEANBASE.__ALL_VIRTUAL_WR_SNAPSHOT SNAP ON ASH.CLUSTER_ID = SNAP.CLUSTER_ID AND ASH.TENANT_ID = SNAP.TENANT_ID AND ASH.SNAP_ID = SNAP.SNAP_ID ) WHERE ASH.TENANT_ID = EFFECTIVE_TENANT_ID() AND SNAP.STATUS = 0; )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT ASH.CLUSTER_ID AS CLUSTER_ID, ASH.TENANT_ID AS TENANT_ID, ASH.SNAP_ID AS SNAP_ID, ASH.SVR_IP AS SVR_IP, ASH.SVR_PORT AS SVR_PORT, ASH.SAMPLE_ID AS SAMPLE_ID, ASH.SESSION_ID AS SESSION_ID, ASH.SAMPLE_TIME AS SAMPLE_TIME, ASH.USER_ID AS USER_ID, ASH.SESSION_TYPE AS SESSION_TYPE, CAST(IF (ASH.EVENT_NO = 0, 'ON CPU', 'WAITING') AS CHAR(7)) AS SESSION_STATE, ASH.SQL_ID AS SQL_ID, ASH.TRACE_ID AS TRACE_ID, ASH.EVENT_NO AS EVENT_NO, ASH.EVENT_ID AS EVENT_ID, ASH.TIME_WAITED AS TIME_WAITED, ASH.P1 AS P1, ASH.P2 AS P2, ASH.P3 AS P3, ASH.SQL_PLAN_LINE_ID AS SQL_PLAN_LINE_ID, ASH.GROUP_ID AS GROUP_ID, ASH.TX_ID AS TX_ID, ASH.BLOCKING_SESSION_ID AS BLOCKING_SESSION_ID, ASH.TIME_MODEL AS TIME_MODEL, CAST(CASE WHEN (ASH.TIME_MODEL & 1) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PARSE, CAST(CASE WHEN (ASH.TIME_MODEL & 2) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PL_PARSE, CAST(CASE WHEN (ASH.TIME_MODEL & 4) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLAN_CACHE, CAST(CASE WHEN (ASH.TIME_MODEL & 8) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SQL_OPTIMIZE, CAST(CASE WHEN (ASH.TIME_MODEL & 16) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SQL_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 32) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PX_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 64) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SEQUENCE_LOAD, CAST(CASE WHEN (ASH.TIME_MODEL & 128) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_COMMITTING, CAST(CASE WHEN (ASH.TIME_MODEL & 256) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_STORAGE_READ, CAST(CASE WHEN (ASH.TIME_MODEL & 512) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_STORAGE_WRITE, CAST(CASE WHEN (ASH.TIME_MODEL & 1024) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_REMOTE_DAS_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 2048) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLSQL_COMPILATION, CAST(CASE WHEN (ASH.TIME_MODEL & 4096) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLSQL_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 8192) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_FILTER_ROWS, ASH.PROGRAM AS PROGRAM, ASH.MODULE AS MODULE, ASH.ACTION AS ACTION, ASH.CLIENT_ID AS CLIENT_ID, ASH.BACKTRACE AS BACKTRACE, ASH.PLAN_ID AS PLAN_ID, ASH.TM_DELTA_TIME AS TM_DELTA_TIME, ASH.TM_DELTA_CPU_TIME AS TM_DELTA_CPU_TIME, ASH.TM_DELTA_DB_TIME AS TM_DELTA_DB_TIME, ASH.TOP_LEVEL_SQL_ID AS TOP_LEVEL_SQL_ID, ASH.PLSQL_ENTRY_OBJECT_ID AS PLSQL_ENTRY_OBJECT_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_ID AS PLSQL_ENTRY_SUBPROGRAM_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_NAME AS PLSQL_ENTRY_SUBPROGRAM_NAME, ASH.PLSQL_OBJECT_ID AS PLSQL_OBJECT_ID, ASH.PLSQL_SUBPROGRAM_ID AS PLSQL_SUBPROGRAM_ID, ASH.PLSQL_SUBPROGRAM_NAME AS PLSQL_SUBPROGRAM_NAME, ASH.DELTA_READ_IO_REQUESTS AS DELTA_READ_IO_REQUESTS, ASH.DELTA_READ_IO_BYTES AS DELTA_READ_IO_BYTES, ASH.DELTA_WRITE_IO_REQUESTS AS DELTA_WRITE_IO_REQUESTS, ASH.DELTA_WRITE_IO_BYTES AS DELTA_WRITE_IO_BYTES FROM ( OCEANBASE.__ALL_VIRTUAL_WR_ACTIVE_SESSION_HISTORY ASH JOIN OCEANBASE.__ALL_VIRTUAL_WR_SNAPSHOT SNAP ON ASH.CLUSTER_ID = SNAP.CLUSTER_ID AND ASH.TENANT_ID = SNAP.TENANT_ID AND ASH.SNAP_ID = SNAP.SNAP_ID ) WHERE ASH.TENANT_ID = EFFECTIVE_TENANT_ID() AND SNAP.STATUS = 0; )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}
@ -1896,7 +1896,7 @@ int ObInnerTableSchema::cdb_wr_active_session_history_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 ASH.CLUSTER_ID AS CLUSTER_ID, ASH.TENANT_ID AS TENANT_ID, ASH.SNAP_ID AS SNAP_ID, ASH.SVR_IP AS SVR_IP, ASH.SVR_PORT AS SVR_PORT, ASH.SAMPLE_ID AS SAMPLE_ID, ASH.SESSION_ID AS SESSION_ID, ASH.SAMPLE_TIME AS SAMPLE_TIME, ASH.USER_ID AS USER_ID, ASH.SESSION_TYPE AS SESSION_TYPE, CAST(IF (ASH.EVENT_NO = 0, 'ON CPU', 'WAITING') AS CHAR(7)) AS SESSION_STATE, ASH.SQL_ID AS SQL_ID, ASH.TRACE_ID AS TRACE_ID, ASH.EVENT_NO AS EVENT_NO, ASH.EVENT_ID AS EVENT_ID, ASH.TIME_WAITED AS TIME_WAITED, ASH.P1 AS P1, ASH.P2 AS P2, ASH.P3 AS P3, ASH.SQL_PLAN_LINE_ID AS SQL_PLAN_LINE_ID, ASH.GROUP_ID AS GROUP_ID, ASH.TX_ID AS TX_ID, ASH.BLOCKING_SESSION_ID AS BLOCKING_SESSION_ID, ASH.TIME_MODEL AS TIME_MODEL, CAST(CASE WHEN (ASH.TIME_MODEL & 1) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PARSE, CAST(CASE WHEN (ASH.TIME_MODEL & 2) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PL_PARSE, CAST(CASE WHEN (ASH.TIME_MODEL & 4) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLAN_CACHE, CAST(CASE WHEN (ASH.TIME_MODEL & 8) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SQL_OPTIMIZE, CAST(CASE WHEN (ASH.TIME_MODEL & 16) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SQL_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 32) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PX_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 64) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SEQUENCE_LOAD, CAST(CASE WHEN (ASH.TIME_MODEL & 128) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_COMMITTING, CAST(CASE WHEN (ASH.TIME_MODEL & 256) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_STORAGE_READ, CAST(CASE WHEN (ASH.TIME_MODEL & 512) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_STORAGE_WRITE, CAST(CASE WHEN (ASH.TIME_MODEL & 1024) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_REMOTE_DAS_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 2048) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLSQL_COMPILATION, CAST(CASE WHEN (ASH.TIME_MODEL & 4096) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLSQL_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 8192) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_FILTER_ROWS, ASH.PROGRAM AS PROGRAM, ASH.MODULE AS MODULE, ASH.ACTION AS ACTION, ASH.CLIENT_ID AS CLIENT_ID, ASH.BACKTRACE AS BACKTRACE, ASH.PLAN_ID AS PLAN_ID, ASH.TM_DELTA_TIME AS TM_DELTA_TIME, ASH.TM_DELTA_CPU_TIME AS TM_DELTA_CPU_TIME, ASH.TM_DELTA_DB_TIME AS TM_DELTA_DB_TIME, ASH.TOP_LEVEL_SQL_ID AS TOP_LEVEL_SQL_ID, ASH.PLSQL_ENTRY_OBJECT_ID AS PLSQL_ENTRY_OBJECT_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_ID AS PLSQL_ENTRY_SUBPROGRAM_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_NAME AS PLSQL_ENTRY_SUBPROGRAM_NAME, ASH.PLSQL_OBJECT_ID AS PLSQL_OBJECT_ID, ASH.PLSQL_SUBPROGRAM_ID AS PLSQL_SUBPROGRAM_ID, ASH.PLSQL_SUBPROGRAM_NAME AS PLSQL_SUBPROGRAM_NAME, ASH.IO_READ_COUNT AS IO_READ_COUNT, ASH.IO_READ_SIZE AS IO_READ_SIZE, ASH.IO_WRITE_COUNT AS IO_WRITE_COUNT, ASH.IO_WRITE_SIZE AS IO_WRITE_SIZE FROM ( OCEANBASE.__ALL_VIRTUAL_WR_ACTIVE_SESSION_HISTORY ASH JOIN OCEANBASE.__ALL_VIRTUAL_WR_SNAPSHOT SNAP ON ASH.CLUSTER_ID = SNAP.CLUSTER_ID AND ASH.TENANT_ID = SNAP.TENANT_ID AND ASH.SNAP_ID = SNAP.SNAP_ID ) WHERE SNAP.STATUS = 0; )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT ASH.CLUSTER_ID AS CLUSTER_ID, ASH.TENANT_ID AS TENANT_ID, ASH.SNAP_ID AS SNAP_ID, ASH.SVR_IP AS SVR_IP, ASH.SVR_PORT AS SVR_PORT, ASH.SAMPLE_ID AS SAMPLE_ID, ASH.SESSION_ID AS SESSION_ID, ASH.SAMPLE_TIME AS SAMPLE_TIME, ASH.USER_ID AS USER_ID, ASH.SESSION_TYPE AS SESSION_TYPE, CAST(IF (ASH.EVENT_NO = 0, 'ON CPU', 'WAITING') AS CHAR(7)) AS SESSION_STATE, ASH.SQL_ID AS SQL_ID, ASH.TRACE_ID AS TRACE_ID, ASH.EVENT_NO AS EVENT_NO, ASH.EVENT_ID AS EVENT_ID, ASH.TIME_WAITED AS TIME_WAITED, ASH.P1 AS P1, ASH.P2 AS P2, ASH.P3 AS P3, ASH.SQL_PLAN_LINE_ID AS SQL_PLAN_LINE_ID, ASH.GROUP_ID AS GROUP_ID, ASH.TX_ID AS TX_ID, ASH.BLOCKING_SESSION_ID AS BLOCKING_SESSION_ID, ASH.TIME_MODEL AS TIME_MODEL, CAST(CASE WHEN (ASH.TIME_MODEL & 1) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PARSE, CAST(CASE WHEN (ASH.TIME_MODEL & 2) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PL_PARSE, CAST(CASE WHEN (ASH.TIME_MODEL & 4) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLAN_CACHE, CAST(CASE WHEN (ASH.TIME_MODEL & 8) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SQL_OPTIMIZE, CAST(CASE WHEN (ASH.TIME_MODEL & 16) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SQL_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 32) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PX_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 64) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_SEQUENCE_LOAD, CAST(CASE WHEN (ASH.TIME_MODEL & 128) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_COMMITTING, CAST(CASE WHEN (ASH.TIME_MODEL & 256) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_STORAGE_READ, CAST(CASE WHEN (ASH.TIME_MODEL & 512) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_STORAGE_WRITE, CAST(CASE WHEN (ASH.TIME_MODEL & 1024) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_REMOTE_DAS_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 2048) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLSQL_COMPILATION, CAST(CASE WHEN (ASH.TIME_MODEL & 4096) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_PLSQL_EXECUTION, CAST(CASE WHEN (ASH.TIME_MODEL & 8192) > 0 THEN 'Y' ELSE 'N' END AS CHAR(1)) AS IN_FILTER_ROWS, ASH.PROGRAM AS PROGRAM, ASH.MODULE AS MODULE, ASH.ACTION AS ACTION, ASH.CLIENT_ID AS CLIENT_ID, ASH.BACKTRACE AS BACKTRACE, ASH.PLAN_ID AS PLAN_ID, ASH.TM_DELTA_TIME AS TM_DELTA_TIME, ASH.TM_DELTA_CPU_TIME AS TM_DELTA_CPU_TIME, ASH.TM_DELTA_DB_TIME AS TM_DELTA_DB_TIME, ASH.TOP_LEVEL_SQL_ID AS TOP_LEVEL_SQL_ID, ASH.PLSQL_ENTRY_OBJECT_ID AS PLSQL_ENTRY_OBJECT_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_ID AS PLSQL_ENTRY_SUBPROGRAM_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_NAME AS PLSQL_ENTRY_SUBPROGRAM_NAME, ASH.PLSQL_OBJECT_ID AS PLSQL_OBJECT_ID, ASH.PLSQL_SUBPROGRAM_ID AS PLSQL_SUBPROGRAM_ID, ASH.PLSQL_SUBPROGRAM_NAME AS PLSQL_SUBPROGRAM_NAME, ASH.DELTA_READ_IO_REQUESTS AS DELTA_READ_IO_REQUESTS, ASH.DELTA_READ_IO_BYTES AS DELTA_READ_IO_BYTES, ASH.DELTA_WRITE_IO_REQUESTS AS DELTA_WRITE_IO_REQUESTS, ASH.DELTA_WRITE_IO_BYTES AS DELTA_WRITE_IO_BYTES FROM ( OCEANBASE.__ALL_VIRTUAL_WR_ACTIVE_SESSION_HISTORY ASH JOIN OCEANBASE.__ALL_VIRTUAL_WR_SNAPSHOT SNAP ON ASH.CLUSTER_ID = SNAP.CLUSTER_ID AND ASH.TENANT_ID = SNAP.TENANT_ID AND ASH.SNAP_ID = SNAP.SNAP_ID ) WHERE SNAP.STATUS = 0; )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}

2
src/share/inner_table/ob_inner_table_schema.25201_25250.cpp
View File

@ -1437,7 +1437,7 @@ int ObInnerTableSchema::dba_wr_active_session_history_ora_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 ASH.CLUSTER_ID AS CLUSTER_ID, ASH.TENANT_ID AS TENANT_ID, ASH.SNAP_ID AS SNAP_ID, ASH.SVR_IP AS SVR_IP, ASH.SVR_PORT AS SVR_PORT, ASH.SAMPLE_ID AS SAMPLE_ID, ASH.SESSION_ID AS SESSION_ID, ASH.SAMPLE_TIME AS SAMPLE_TIME, ASH.USER_ID AS USER_ID, ASH.SESSION_TYPE AS SESSION_TYPE, CAST(DECODE(ASH.EVENT_NO, 0, 'ON CPU', 'WAITING') AS VARCHAR2(7)) AS SESSION_STATE, ASH.SQL_ID AS SQL_ID, ASH.TRACE_ID AS TRACE_ID, ASH.EVENT_NO AS EVENT_NO, ASH.EVENT_ID AS EVENT_ID, ASH.TIME_WAITED AS TIME_WAITED, ASH.P1 AS P1, ASH.P2 AS P2, ASH.P3 AS P3, ASH.SQL_PLAN_LINE_ID AS SQL_PLAN_LINE_ID, ASH.GROUP_ID AS GROUP_ID, ASH.TX_ID AS TX_ID, ASH.BLOCKING_SESSION_ID AS BLOCKING_SESSION_ID, ASH.TIME_MODEL AS TIME_MODEL, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 1) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PARSE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 2) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PL_PARSE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 4) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PLAN_CACHE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 8) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_SQL_OPTIMIZE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 16) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_SQL_EXECUTION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 32) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PX_EXECUTION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 64) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_SEQUENCE_LOAD, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 128) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_COMMITTING, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 256) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_STORAGE_READ, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 512) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_STORAGE_WRITE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 1024) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_REMOTE_DAS_EXECUTION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 2048) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PLSQL_COMPILATION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 4096) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PLSQL_EXECUTION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 8192) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_FILTER_ROWS, ASH.PROGRAM AS PROGRAM, ASH.MODULE AS MODULE, ASH.ACTION AS ACTION, ASH.CLIENT_ID AS CLIENT_ID, ASH.BACKTRACE AS BACKTRACE, ASH.PLAN_ID AS PLAN_ID, ASH.TM_DELTA_TIME AS TM_DELTA_TIME, ASH.TM_DELTA_CPU_TIME AS TM_DELTA_CPU_TIME, ASH.TM_DELTA_DB_TIME AS TM_DELTA_DB_TIME, ASH.TOP_LEVEL_SQL_ID AS TOP_LEVEL_SQL_ID, ASH.PLSQL_ENTRY_OBJECT_ID AS PLSQL_ENTRY_OBJECT_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_ID AS PLSQL_ENTRY_SUBPROGRAM_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_NAME AS PLSQL_ENTRY_SUBPROGRAM_NAME, ASH.PLSQL_OBJECT_ID AS PLSQL_OBJECT_ID, ASH.PLSQL_SUBPROGRAM_ID AS PLSQL_SUBPROGRAM_ID, ASH.PLSQL_SUBPROGRAM_NAME AS PLSQL_SUBPROGRAM_NAME, ASH.IO_READ_COUNT AS IO_READ_COUNT, ASH.IO_READ_SIZE AS IO_READ_SIZE, ASH.IO_WRITE_COUNT AS IO_WRITE_COUNT, ASH.IO_WRITE_SIZE AS IO_WRITE_SIZE FROM SYS.ALL_VIRTUAL_WR_ACTIVE_SESSION_HISTORY ASH, SYS.ALL_VIRTUAL_WR_SNAPSHOT SNAP WHERE ASH.TENANT_ID = EFFECTIVE_TENANT_ID() AND ASH.CLUSTER_ID = SNAP.CLUSTER_ID AND ASH.TENANT_ID = SNAP.TENANT_ID AND ASH.SNAP_ID = SNAP.SNAP_ID AND SNAP.STATUS = 0; )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT ASH.CLUSTER_ID AS CLUSTER_ID, ASH.TENANT_ID AS TENANT_ID, ASH.SNAP_ID AS SNAP_ID, ASH.SVR_IP AS SVR_IP, ASH.SVR_PORT AS SVR_PORT, ASH.SAMPLE_ID AS SAMPLE_ID, ASH.SESSION_ID AS SESSION_ID, ASH.SAMPLE_TIME AS SAMPLE_TIME, ASH.USER_ID AS USER_ID, ASH.SESSION_TYPE AS SESSION_TYPE, CAST(DECODE(ASH.EVENT_NO, 0, 'ON CPU', 'WAITING') AS VARCHAR2(7)) AS SESSION_STATE, ASH.SQL_ID AS SQL_ID, ASH.TRACE_ID AS TRACE_ID, ASH.EVENT_NO AS EVENT_NO, ASH.EVENT_ID AS EVENT_ID, ASH.TIME_WAITED AS TIME_WAITED, ASH.P1 AS P1, ASH.P2 AS P2, ASH.P3 AS P3, ASH.SQL_PLAN_LINE_ID AS SQL_PLAN_LINE_ID, ASH.GROUP_ID AS GROUP_ID, ASH.TX_ID AS TX_ID, ASH.BLOCKING_SESSION_ID AS BLOCKING_SESSION_ID, ASH.TIME_MODEL AS TIME_MODEL, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 1) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PARSE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 2) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PL_PARSE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 4) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PLAN_CACHE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 8) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_SQL_OPTIMIZE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 16) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_SQL_EXECUTION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 32) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PX_EXECUTION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 64) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_SEQUENCE_LOAD, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 128) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_COMMITTING, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 256) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_STORAGE_READ, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 512) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_STORAGE_WRITE, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 1024) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_REMOTE_DAS_EXECUTION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 2048) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PLSQL_COMPILATION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 4096) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_PLSQL_EXECUTION, CAST(CASE WHEN BITAND(ASH.TIME_MODEL , 8192) > 0 THEN 'Y' ELSE 'N' END AS VARCHAR2(1)) AS IN_FILTER_ROWS, ASH.PROGRAM AS PROGRAM, ASH.MODULE AS MODULE, ASH.ACTION AS ACTION, ASH.CLIENT_ID AS CLIENT_ID, ASH.BACKTRACE AS BACKTRACE, ASH.PLAN_ID AS PLAN_ID, ASH.TM_DELTA_TIME AS TM_DELTA_TIME, ASH.TM_DELTA_CPU_TIME AS TM_DELTA_CPU_TIME, ASH.TM_DELTA_DB_TIME AS TM_DELTA_DB_TIME, ASH.TOP_LEVEL_SQL_ID AS TOP_LEVEL_SQL_ID, ASH.PLSQL_ENTRY_OBJECT_ID AS PLSQL_ENTRY_OBJECT_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_ID AS PLSQL_ENTRY_SUBPROGRAM_ID, ASH.PLSQL_ENTRY_SUBPROGRAM_NAME AS PLSQL_ENTRY_SUBPROGRAM_NAME, ASH.PLSQL_OBJECT_ID AS PLSQL_OBJECT_ID, ASH.PLSQL_SUBPROGRAM_ID AS PLSQL_SUBPROGRAM_ID, ASH.PLSQL_SUBPROGRAM_NAME AS PLSQL_SUBPROGRAM_NAME, ASH.DELTA_READ_IO_REQUESTS AS DELTA_READ_IO_REQUESTS, ASH.DELTA_READ_IO_BYTES AS DELTA_READ_IO_BYTES, ASH.DELTA_WRITE_IO_REQUESTS AS DELTA_WRITE_IO_REQUESTS, ASH.DELTA_WRITE_IO_BYTES AS DELTA_WRITE_IO_BYTES FROM SYS.ALL_VIRTUAL_WR_ACTIVE_SESSION_HISTORY ASH, SYS.ALL_VIRTUAL_WR_SNAPSHOT SNAP WHERE ASH.TENANT_ID = EFFECTIVE_TENANT_ID() AND ASH.CLUSTER_ID = SNAP.CLUSTER_ID AND ASH.TENANT_ID = SNAP.TENANT_ID AND ASH.SNAP_ID = SNAP.SNAP_ID AND SNAP.STATUS = 0; )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}

40
src/share/inner_table/ob_inner_table_schema.451_500.cpp
View File

@ -1914,9 +1914,9 @@ int ObInnerTableSchema::wr_active_session_history_schema(ObTableSchema &table_sc
}
if (OB_SUCC(ret)) {
ObObj io_read_count_default;
io_read_count_default.set_int(0);
ADD_COLUMN_SCHEMA_T("io_read_count", //column_name
ObObj delta_read_io_requests_default;
delta_read_io_requests_default.set_int(0);
ADD_COLUMN_SCHEMA_T("delta_read_io_requests", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -1928,14 +1928,14 @@ int ObInnerTableSchema::wr_active_session_history_schema(ObTableSchema &table_sc
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
io_read_count_default,
io_read_count_default); //default_value
delta_read_io_requests_default,
delta_read_io_requests_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj io_read_size_default;
io_read_size_default.set_int(0);
ADD_COLUMN_SCHEMA_T("io_read_size", //column_name
ObObj delta_read_io_bytes_default;
delta_read_io_bytes_default.set_int(0);
ADD_COLUMN_SCHEMA_T("delta_read_io_bytes", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -1947,14 +1947,14 @@ int ObInnerTableSchema::wr_active_session_history_schema(ObTableSchema &table_sc
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
io_read_size_default,
io_read_size_default); //default_value
delta_read_io_bytes_default,
delta_read_io_bytes_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj io_write_count_default;
io_write_count_default.set_int(0);
ADD_COLUMN_SCHEMA_T("io_write_count", //column_name
ObObj delta_write_io_requests_default;
delta_write_io_requests_default.set_int(0);
ADD_COLUMN_SCHEMA_T("delta_write_io_requests", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -1966,14 +1966,14 @@ int ObInnerTableSchema::wr_active_session_history_schema(ObTableSchema &table_sc
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
io_write_count_default,
io_write_count_default); //default_value
delta_write_io_requests_default,
delta_write_io_requests_default); //default_value
}
if (OB_SUCC(ret)) {
ObObj io_write_size_default;
io_write_size_default.set_int(0);
ADD_COLUMN_SCHEMA_T("io_write_size", //column_name
ObObj delta_write_io_bytes_default;
delta_write_io_bytes_default.set_int(0);
ADD_COLUMN_SCHEMA_T("delta_write_io_bytes", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
@ -1985,8 +1985,8 @@ int ObInnerTableSchema::wr_active_session_history_schema(ObTableSchema &table_sc
-1, //column_scale
true, //is_nullable
false, //is_autoincrement
io_write_size_default,
io_write_size_default); //default_value
delta_write_io_bytes_default,
delta_write_io_bytes_default); //default_value
}
table_schema.set_index_using_type(USING_BTREE);
table_schema.set_row_store_type(ENCODING_ROW_STORE);

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

@ -6062,10 +6062,10 @@ def_table_schema(
('stmt_type', 'int', 'true'),
('tablet_id', 'int', 'true'),
('proxy_sid', 'int', 'true'),
('io_read_count', 'int', 'true', '0'),
('io_read_size', 'int', 'true', '0'),
('io_write_count', 'int', 'true', '0'),
('io_write_size', 'int', 'true', '0')
('delta_read_io_requests', 'int', 'true', '0'),
('delta_read_io_bytes', 'int', 'true', '0'),
('delta_write_io_requests', 'int', 'true', '0'),
('delta_write_io_bytes', 'int', 'true', '0')
],
)
@ -12890,10 +12890,10 @@ def_table_schema(
('STMT_TYPE', 'int', 'true'),
('TABLET_ID', 'int', 'true'),
('PROXY_SID', 'int', 'true'),
('IO_READ_COUNT', 'int', 'false', '0'),
('IO_READ_SIZE', 'int', 'false', '0'),
('IO_WRITE_COUNT', 'int', 'false', '0'),
('IO_WRITE_SIZE', 'int', 'false', '0')
('DELTA_READ_IO_REQUESTS', 'int', 'false', '0'),
('DELTA_READ_IO_BYTES', 'int', 'false', '0'),
('DELTA_WRITE_IO_REQUESTS', 'int', 'false', '0'),
('DELTA_WRITE_IO_BYTES', 'int', 'false', '0')
],
partition_columns = ['SVR_IP', 'SVR_PORT'],
vtable_route_policy = 'distributed',
@ -31959,10 +31959,10 @@ def_table_schema(
ASH.PLSQL_OBJECT_ID AS PLSQL_OBJECT_ID,
ASH.PLSQL_SUBPROGRAM_ID AS PLSQL_SUBPROGRAM_ID,
ASH.PLSQL_SUBPROGRAM_NAME AS PLSQL_SUBPROGRAM_NAME,
ASH.IO_READ_COUNT AS IO_READ_COUNT,
ASH.IO_READ_SIZE AS IO_READ_SIZE,
ASH.IO_WRITE_COUNT AS IO_WRITE_COUNT,
ASH.IO_WRITE_SIZE AS IO_WRITE_SIZE
ASH.DELTA_READ_IO_REQUESTS AS DELTA_READ_IO_REQUESTS,
ASH.DELTA_READ_IO_BYTES AS DELTA_READ_IO_BYTES,
ASH.DELTA_WRITE_IO_REQUESTS AS DELTA_WRITE_IO_REQUESTS,
ASH.DELTA_WRITE_IO_BYTES AS DELTA_WRITE_IO_BYTES
FROM
(
OCEANBASE.__ALL_VIRTUAL_WR_ACTIVE_SESSION_HISTORY ASH
@ -32042,10 +32042,10 @@ def_table_schema(
ASH.PLSQL_OBJECT_ID AS PLSQL_OBJECT_ID,
ASH.PLSQL_SUBPROGRAM_ID AS PLSQL_SUBPROGRAM_ID,
ASH.PLSQL_SUBPROGRAM_NAME AS PLSQL_SUBPROGRAM_NAME,
ASH.IO_READ_COUNT AS IO_READ_COUNT,
ASH.IO_READ_SIZE AS IO_READ_SIZE,
ASH.IO_WRITE_COUNT AS IO_WRITE_COUNT,
ASH.IO_WRITE_SIZE AS IO_WRITE_SIZE
ASH.DELTA_READ_IO_REQUESTS AS DELTA_READ_IO_REQUESTS,
ASH.DELTA_READ_IO_BYTES AS DELTA_READ_IO_BYTES,
ASH.DELTA_WRITE_IO_REQUESTS AS DELTA_WRITE_IO_REQUESTS,
ASH.DELTA_WRITE_IO_BYTES AS DELTA_WRITE_IO_BYTES
FROM
(
OCEANBASE.__ALL_VIRTUAL_WR_ACTIVE_SESSION_HISTORY ASH
@ -56011,10 +56011,10 @@ def_table_schema(
ASH.PLSQL_OBJECT_ID AS PLSQL_OBJECT_ID,
ASH.PLSQL_SUBPROGRAM_ID AS PLSQL_SUBPROGRAM_ID,
ASH.PLSQL_SUBPROGRAM_NAME AS PLSQL_SUBPROGRAM_NAME,
ASH.IO_READ_COUNT AS IO_READ_COUNT,
ASH.IO_READ_SIZE AS IO_READ_SIZE,
ASH.IO_WRITE_COUNT AS IO_WRITE_COUNT,
ASH.IO_WRITE_SIZE AS IO_WRITE_SIZE
ASH.DELTA_READ_IO_REQUESTS AS DELTA_READ_IO_REQUESTS,
ASH.DELTA_READ_IO_BYTES AS DELTA_READ_IO_BYTES,
ASH.DELTA_WRITE_IO_REQUESTS AS DELTA_WRITE_IO_REQUESTS,
ASH.DELTA_WRITE_IO_BYTES AS DELTA_WRITE_IO_BYTES
FROM
SYS.ALL_VIRTUAL_WR_ACTIVE_SESSION_HISTORY ASH,
SYS.ALL_VIRTUAL_WR_SNAPSHOT SNAP

8
tools/deploy/mysql_test/test_suite/inner_table/r/mysql/desc_sys_views_in_mysql.result
View File

@ -5175,10 +5175,10 @@ PLSQL_ENTRY_SUBPROGRAM_NAME varchar(32) YES NULL
PLSQL_OBJECT_ID bigint(20) YES NULL
PLSQL_SUBPROGRAM_ID bigint(20) YES NULL
PLSQL_SUBPROGRAM_NAME varchar(32) YES NULL
IO_READ_COUNT bigint(20) YES
IO_READ_SIZE bigint(20) YES
IO_WRITE_COUNT bigint(20) YES
IO_WRITE_SIZE bigint(20) YES
DELTA_READ_IO_REQUESTS bigint(20) YES
DELTA_READ_IO_BYTES bigint(20) YES
DELTA_WRITE_IO_REQUESTS bigint(20) YES
DELTA_WRITE_IO_BYTES bigint(20) YES
select /*+QUERY_TIMEOUT(60000000)*/ count(*) as cnt from (select * from oceanbase.DBA_WR_ACTIVE_SESSION_HISTORY limit 1);
cnt
1

16
tools/deploy/mysql_test/test_suite/inner_table/r/mysql/desc_sys_views_in_sys.result
View File

@ -7179,10 +7179,10 @@ PLSQL_ENTRY_SUBPROGRAM_NAME varchar(32) YES NULL
PLSQL_OBJECT_ID bigint(20) YES NULL
PLSQL_SUBPROGRAM_ID bigint(20) YES NULL
PLSQL_SUBPROGRAM_NAME varchar(32) YES NULL
IO_READ_COUNT bigint(20) YES
IO_READ_SIZE bigint(20) YES
IO_WRITE_COUNT bigint(20) YES
IO_WRITE_SIZE bigint(20) YES
DELTA_READ_IO_REQUESTS bigint(20) YES
DELTA_READ_IO_BYTES bigint(20) YES
DELTA_WRITE_IO_REQUESTS bigint(20) YES
DELTA_WRITE_IO_BYTES bigint(20) YES
select /*+QUERY_TIMEOUT(60000000)*/ count(*) as cnt from (select * from oceanbase.DBA_WR_ACTIVE_SESSION_HISTORY limit 1);
cnt
1
@ -7242,10 +7242,10 @@ PLSQL_ENTRY_SUBPROGRAM_NAME varchar(32) YES NULL
PLSQL_OBJECT_ID bigint(20) YES NULL
PLSQL_SUBPROGRAM_ID bigint(20) YES NULL
PLSQL_SUBPROGRAM_NAME varchar(32) YES NULL
IO_READ_COUNT bigint(20) YES
IO_READ_SIZE bigint(20) YES
IO_WRITE_COUNT bigint(20) YES
IO_WRITE_SIZE bigint(20) YES
DELTA_READ_IO_REQUESTS bigint(20) YES
DELTA_READ_IO_BYTES bigint(20) YES
DELTA_WRITE_IO_REQUESTS bigint(20) YES
DELTA_WRITE_IO_BYTES bigint(20) YES
select /*+QUERY_TIMEOUT(60000000)*/ count(*) as cnt from (select * from oceanbase.CDB_WR_ACTIVE_SESSION_HISTORY limit 1);
cnt
1

16
tools/deploy/mysql_test/test_suite/inner_table/r/mysql/desc_virtual_table_in_mysql.result
View File

@ -3179,10 +3179,10 @@ THREAD_ID bigint(20) YES NULL
STMT_TYPE bigint(20) YES NULL
TABLET_ID bigint(20) YES NULL
PROXY_SID bigint(20) YES NULL
IO_READ_COUNT bigint(20) NO 0
IO_READ_SIZE bigint(20) NO 0
IO_WRITE_COUNT bigint(20) NO 0
IO_WRITE_SIZE bigint(20) NO 0
DELTA_READ_IO_REQUESTS bigint(20) NO 0
DELTA_READ_IO_BYTES bigint(20) NO 0
DELTA_WRITE_IO_REQUESTS bigint(20) NO 0
DELTA_WRITE_IO_BYTES bigint(20) NO 0
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_ash;
IF(count(*) >= 0, 1, 0)
1
@ -3977,10 +3977,10 @@ thread_id bigint(20) YES NULL
stmt_type bigint(20) YES NULL
tablet_id bigint(20) YES NULL
proxy_sid bigint(20) YES NULL
io_read_count bigint(20) YES 0
io_read_size bigint(20) YES 0
io_write_count bigint(20) YES 0
io_write_size bigint(20) YES 0
delta_read_io_requests bigint(20) YES 0
delta_read_io_bytes bigint(20) YES 0
delta_write_io_requests bigint(20) YES 0
delta_write_io_bytes bigint(20) YES 0
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_wr_active_session_history;
IF(count(*) >= 0, 1, 0)
1

16
tools/deploy/mysql_test/test_suite/inner_table/r/mysql/desc_virtual_table_in_sys.result
View File

@ -6863,10 +6863,10 @@ THREAD_ID bigint(20) YES NULL
STMT_TYPE bigint(20) YES NULL
TABLET_ID bigint(20) YES NULL
PROXY_SID bigint(20) YES NULL
IO_READ_COUNT bigint(20) NO 0
IO_READ_SIZE bigint(20) NO 0
IO_WRITE_COUNT bigint(20) NO 0
IO_WRITE_SIZE bigint(20) NO 0
DELTA_READ_IO_REQUESTS bigint(20) NO 0
DELTA_READ_IO_BYTES bigint(20) NO 0
DELTA_WRITE_IO_REQUESTS bigint(20) NO 0
DELTA_WRITE_IO_BYTES bigint(20) NO 0
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_ash;
IF(count(*) >= 0, 1, 0)
1
@ -8274,10 +8274,10 @@ thread_id bigint(20) YES NULL
stmt_type bigint(20) YES NULL
tablet_id bigint(20) YES NULL
proxy_sid bigint(20) YES NULL
io_read_count bigint(20) YES 0
io_read_size bigint(20) YES 0
io_write_count bigint(20) YES 0
io_write_size bigint(20) YES 0
delta_read_io_requests bigint(20) YES 0
delta_read_io_bytes bigint(20) YES 0
delta_write_io_requests bigint(20) YES 0
delta_write_io_bytes bigint(20) YES 0
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_wr_active_session_history;
IF(count(*) >= 0, 1, 0)
1