service_name placeholder

This commit is contained in:
linqiucen
2024-02-26 11:22:31 +00:00
committed by ob-robot
parent e24f98638b
commit 47206f879a
7 changed files with 42 additions and 0 deletions

View File

@ -452,6 +452,10 @@ bool ObShowProcesslist::FillScanner::operator()(sql::ObSQLSessionMgr::Key key, O
cur_row_->cells_[cell_idx].set_null(); cur_row_->cells_[cell_idx].set_null();
break; break;
} }
case SERVICE_NAME: {
cur_row_->cells_[cell_idx].set_null();
break;
}
default: { default: {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
SERVER_LOG(WARN, "invalid column id", K(ret), K(cell_idx), SERVER_LOG(WARN, "invalid column id", K(ret), K(cell_idx),

View File

@ -80,6 +80,7 @@ private:
OUT_BYTES, OUT_BYTES,
USER_CLIENT_PORT, USER_CLIENT_PORT,
PROXY_USER_NAME, PROXY_USER_NAME,
SERVICE_NAME,
}; };
class FillScanner class FillScanner
{ {

View File

@ -2056,6 +2056,21 @@ int ObInnerTableSchema::all_virtual_processlist_schema(ObTableSchema &table_sche
true, //is_nullable true, //is_nullable
false); //is_autoincrement false); //is_autoincrement
} }
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("service_name", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObVarcharType, //column_type
CS_TYPE_INVALID, //column_collation_type
64, //column_length
-1, //column_precision
-1, //column_scale
true, //is_nullable
false); //is_autoincrement
}
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
table_schema.get_part_option().set_part_num(1); table_schema.get_part_option().set_part_num(1);
table_schema.set_part_level(PARTITION_LEVEL_ONE); table_schema.set_part_level(PARTITION_LEVEL_ONE);

View File

@ -9048,6 +9048,21 @@ int ObInnerTableSchema::all_virtual_processlist_ora_schema(ObTableSchema &table_
true, //is_nullable true, //is_nullable
false); //is_autoincrement false); //is_autoincrement
} }
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("SERVICE_NAME", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObVarcharType, //column_type
CS_TYPE_UTF8MB4_BIN, //column_collation_type
64, //column_length
2, //column_precision
-1, //column_scale
true, //is_nullable
false); //is_autoincrement
}
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
table_schema.get_part_option().set_part_num(1); table_schema.get_part_option().set_part_num(1);
table_schema.set_part_level(PARTITION_LEVEL_ONE); table_schema.set_part_level(PARTITION_LEVEL_ONE);

View File

@ -6915,6 +6915,7 @@ def_table_schema(**all_tenant_snapshot_ls_replica_history_def)
# 513 : __all_user_proxy_info_history # 513 : __all_user_proxy_info_history
# 514 : __all_user_proxy_role_info # 514 : __all_user_proxy_role_info
# 515 : __all_user_proxy_role_info_history # 515 : __all_user_proxy_role_info_history
# 516 : __all_service
# 余留位置(此行之前占位) # 余留位置(此行之前占位)
# 本区域占位建议:采用真实表名进行占位 # 本区域占位建议:采用真实表名进行占位
@ -7168,6 +7169,7 @@ def_table_schema(
('out_bytes', 'bigint'), ('out_bytes', 'bigint'),
('user_client_port', 'int', 'false', '0'), ('user_client_port', 'int', 'false', '0'),
('proxy_user', 'varchar:OB_MAX_USER_NAME_LENGTH_STORE', 'true'), ('proxy_user', 'varchar:OB_MAX_USER_NAME_LENGTH_STORE', 'true'),
('service_name', 'varchar:64', 'true'),
], ],
partition_columns = ['svr_ip', 'svr_port'], partition_columns = ['svr_ip', 'svr_port'],
vtable_route_policy = 'distributed', vtable_route_policy = 'distributed',
@ -32856,6 +32858,8 @@ def_table_schema(
# 21545: V$OB_COMPATIBILITY_CONTROL # 21545: V$OB_COMPATIBILITY_CONTROL
# 21546: DBA_OB_RSRC_DIRECTIVES # 21546: DBA_OB_RSRC_DIRECTIVES
# 21547: CDB_OB_RSRC_DIRECTIVES # 21547: CDB_OB_RSRC_DIRECTIVES
# 21548: DBA_OB_SERVICES
# 21549: CDB_OB_SERVICES
# #
# 余留位置(此行之前占位) # 余留位置(此行之前占位)
# 本区域占位建议:采用真实视图名进行占位 # 本区域占位建议:采用真实视图名进行占位
@ -52686,6 +52690,7 @@ def_table_schema(
) )
# 25301: PROXY_USERS # 25301: PROXY_USERS
# 25302: DBA_OB_SERVICES
# #
# 余留位置(此行之前占位) # 余留位置(此行之前占位)

View File

@ -128,6 +128,7 @@ in_bytes bigint(20) NO NULL
out_bytes bigint(20) NO NULL out_bytes bigint(20) NO NULL
user_client_port bigint(20) NO 0 user_client_port bigint(20) NO 0
proxy_user varchar(128) YES NULL proxy_user varchar(128) YES NULL
service_name varchar(64) YES NULL
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_processlist; select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_processlist;
IF(count(*) >= 0, 1, 0) IF(count(*) >= 0, 1, 0)
1 1

View File

@ -129,6 +129,7 @@ in_bytes bigint(20) NO NULL
out_bytes bigint(20) NO NULL out_bytes bigint(20) NO NULL
user_client_port bigint(20) NO 0 user_client_port bigint(20) NO 0
proxy_user varchar(128) YES NULL proxy_user varchar(128) YES NULL
service_name varchar(64) YES NULL
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_processlist; select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_processlist;
IF(count(*) >= 0, 1, 0) IF(count(*) >= 0, 1, 0)
1 1