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

use macro block cnt from table stat to compute space usage for system view

Browse Source
This commit is contained in:
hiddenbomb 2023-10-12 09:10:26 +00:00 committed by ob-robot
parent 8cd726482d
commit 9f814a2db7
4 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/share/inner_table/ob_inner_table_schema.20001_20050.cpp
View File

@ -410,7 +410,7 @@ int ObInnerTableSchema::tables_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 /*+ leading(a) no_use_nl(ts)*/ cast('def' as char(512)) as TABLE_CATALOG, cast(b.database_name as char(64)) as TABLE_SCHEMA, cast(a.table_name as char(64)) as TABLE_NAME, cast(case when (a.database_id = 201002 or a.table_type = 1) then 'SYSTEM VIEW' when a.table_type in (0, 2) then 'SYSTEM TABLE' when a.table_type = 4 then 'VIEW' else 'BASE TABLE' end as char(64)) as TABLE_TYPE, cast(case when a.table_type in (0,3,5,6,7,11,12,13) then 'InnoDB' else 'MEMORY' end as char(64)) as ENGINE, cast(NULL as unsigned) as VERSION, cast(a.store_format as char(10)) as ROW_FORMAT, cast( coalesce(ts.row_cnt,0) as unsigned) as TABLE_ROWS, cast( coalesce(ts.avg_row_len,0) as unsigned) as AVG_ROW_LENGTH, cast( coalesce(ts.data_size,0) as unsigned) as DATA_LENGTH, cast(NULL as unsigned) as MAX_DATA_LENGTH, cast(NULL as unsigned) as INDEX_LENGTH, cast(NULL as unsigned) as DATA_FREE, cast(NULL as unsigned) as AUTO_INCREMENT, cast(a.gmt_create as datetime) as CREATE_TIME, cast(a.gmt_modified as datetime) as UPDATE_TIME, cast(NULL as datetime) as CHECK_TIME, cast(d.collation as char(32)) as TABLE_COLLATION, cast(NULL as unsigned) as CHECKSUM, cast(NULL as char(255)) as CREATE_OPTIONS, cast(case when a.table_type = 4 then 'VIEW' else a.comment end as char(2048)) as TABLE_COMMENT from ( select cast(0 as signed) as tenant_id, c.database_id, c.table_id, c.table_name, c.collation_type, c.table_type, usec_to_time(d.schema_version) as gmt_create, usec_to_time(c.schema_version) as gmt_modified, c.comment, c.store_format from oceanbase.__all_virtual_core_all_table c join oceanbase.__all_virtual_core_all_table d on c.tenant_id = d.tenant_id and d.table_name = '__all_core_table' where c.tenant_id = effective_tenant_id() union all select tenant_id, database_id, table_id, table_name, collation_type, table_type, gmt_create, gmt_modified, comment, store_format from oceanbase.__all_table) a join oceanbase.__all_database b on a.database_id = b.database_id and a.tenant_id = b.tenant_id join oceanbase.__tenant_virtual_collation d on a.collation_type = d.collation_type left join ( select tenant_id, table_id, row_cnt, avg_row_len, row_cnt * avg_row_len as data_size from oceanbase.__all_table_stat where partition_id = -1 or partition_id = table_id) ts on a.table_id = ts.table_id and a.tenant_id = ts.tenant_id where a.tenant_id = 0 and a.table_type in (0, 1, 2, 3, 4, 14) and b.database_name != '__recyclebin' and b.in_recyclebin = 0 and 0 = sys_privilege_check('table_acc', effective_tenant_id(), b.database_name, a.table_name) )__"))) {
if (OB_FAIL(table_schema.set_view_definition(R"__( select /*+ leading(a) no_use_nl(ts)*/ cast('def' as char(512)) as TABLE_CATALOG, cast(b.database_name as char(64)) as TABLE_SCHEMA, cast(a.table_name as char(64)) as TABLE_NAME, cast(case when (a.database_id = 201002 or a.table_type = 1) then 'SYSTEM VIEW' when a.table_type in (0, 2) then 'SYSTEM TABLE' when a.table_type = 4 then 'VIEW' else 'BASE TABLE' end as char(64)) as TABLE_TYPE, cast(case when a.table_type in (0,3,5,6,7,11,12,13) then 'InnoDB' else 'MEMORY' end as char(64)) as ENGINE, cast(NULL as unsigned) as VERSION, cast(a.store_format as char(10)) as ROW_FORMAT, cast( coalesce(ts.row_cnt,0) as unsigned) as TABLE_ROWS, cast( coalesce(ts.avg_row_len,0) as unsigned) as AVG_ROW_LENGTH, cast( coalesce(ts.data_size,0) as unsigned) as DATA_LENGTH, cast(NULL as unsigned) as MAX_DATA_LENGTH, cast(NULL as unsigned) as INDEX_LENGTH, cast(NULL as unsigned) as DATA_FREE, cast(NULL as unsigned) as AUTO_INCREMENT, cast(a.gmt_create as datetime) as CREATE_TIME, cast(a.gmt_modified as datetime) as UPDATE_TIME, cast(NULL as datetime) as CHECK_TIME, cast(d.collation as char(32)) as TABLE_COLLATION, cast(NULL as unsigned) as CHECKSUM, cast(NULL as char(255)) as CREATE_OPTIONS, cast(case when a.table_type = 4 then 'VIEW' else a.comment end as char(2048)) as TABLE_COMMENT from ( select cast(0 as signed) as tenant_id, c.database_id, c.table_id, c.table_name, c.collation_type, c.table_type, usec_to_time(d.schema_version) as gmt_create, usec_to_time(c.schema_version) as gmt_modified, c.comment, c.store_format from oceanbase.__all_virtual_core_all_table c join oceanbase.__all_virtual_core_all_table d on c.tenant_id = d.tenant_id and d.table_name = '__all_core_table' where c.tenant_id = effective_tenant_id() union all select tenant_id, database_id, table_id, table_name, collation_type, table_type, gmt_create, gmt_modified, comment, store_format from oceanbase.__all_table) a join oceanbase.__all_database b on a.database_id = b.database_id and a.tenant_id = b.tenant_id join oceanbase.__tenant_virtual_collation d on a.collation_type = d.collation_type left join ( select tenant_id, table_id, row_cnt, avg_row_len, (macro_blk_cnt * 2 * 1024 * 1024) as data_size from oceanbase.__all_table_stat where partition_id = -1 or partition_id = table_id) ts on a.table_id = ts.table_id and a.tenant_id = ts.tenant_id where a.tenant_id = 0 and a.table_type in (0, 1, 2, 3, 4, 14) and b.database_name != '__recyclebin' and b.in_recyclebin = 0 and 0 = sys_privilege_check('table_acc', effective_tenant_id(), b.database_name, a.table_name) )__"))) {
LOG_ERROR("fail to set view_definition", K(ret));
}
}

4
src/share/inner_table/ob_inner_table_schema.25001_25050.cpp
View File

File diff suppressed because one or more lines are too long

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

@ -13841,7 +13841,7 @@ def_table_schema(
table_id,
row_cnt,
avg_row_len,
row_cnt * avg_row_len as data_size
(macro_blk_cnt * 2 * 1024 * 1024) as data_size
from oceanbase.__all_table_stat
where partition_id = -1 or partition_id = table_id) ts
on a.table_id = ts.table_id
@ -35113,7 +35113,7 @@ def_table_schema(
LEFT JOIN (
SELECT TENANT_ID,
TABLE_ID,
ROW_CNT * AVG_ROW_LEN AS DATA_SIZE
(MACRO_BLK_CNT * 2 * 1024 * 1024) AS DATA_SIZE
FROM SYS.ALL_VIRTUAL_TABLE_STAT_REAL_AGENT
WHERE PARTITION_ID = -1 OR PARTITION_ID = TABLE_ID) TS
ON T.TABLE_ID = TS.TABLE_ID
@ -35143,7 +35143,7 @@ def_table_schema(
SELECT TENANT_ID,
TABLE_ID,
PARTITION_ID,
(ROW_CNT * AVG_ROW_LEN) AS DATA_SIZE
(MACRO_BLK_CNT * 2 * 1024 * 1024) AS DATA_SIZE
FROM SYS.ALL_VIRTUAL_TABLE_STAT_REAL_AGENT) TS
ON P.TABLE_ID = TS.TABLE_ID
AND P.PART_ID = TS.PARTITION_ID
@ -35177,7 +35177,7 @@ def_table_schema(
SELECT TENANT_ID,
TABLE_ID,
PARTITION_ID,
(ROW_CNT * AVG_ROW_LEN) AS DATA_SIZE
(MACRO_BLK_CNT * 2 * 1024 * 1024) AS DATA_SIZE
FROM SYS.ALL_VIRTUAL_TABLE_STAT_REAL_AGENT) TS
ON SUBP.TABLE_ID = TS.TABLE_ID
AND SUBP.SUB_PART_ID = TS.PARTITION_ID
@ -35270,7 +35270,7 @@ def_table_schema(
LEFT JOIN (
SELECT TENANT_ID,
TABLE_ID,
ROW_CNT * AVG_ROW_LEN AS DATA_SIZE
(MACRO_BLK_CNT * 2 * 1024 * 1024) AS DATA_SIZE
FROM SYS.ALL_VIRTUAL_TABLE_STAT_REAL_AGENT
WHERE PARTITION_ID = -1 OR PARTITION_ID = TABLE_ID) TS
ON T.TABLE_ID = TS.TABLE_ID
@ -35300,7 +35300,7 @@ def_table_schema(
SELECT TENANT_ID,
TABLE_ID,
PARTITION_ID,
(ROW_CNT * AVG_ROW_LEN) AS DATA_SIZE
(MACRO_BLK_CNT * 2 * 1024 * 1024) AS DATA_SIZE
FROM SYS.ALL_VIRTUAL_TABLE_STAT_REAL_AGENT) TS
ON P.TABLE_ID = TS.TABLE_ID
AND P.PART_ID = TS.PARTITION_ID
@ -35334,7 +35334,7 @@ def_table_schema(
SELECT TENANT_ID,
TABLE_ID,
PARTITION_ID,
(ROW_CNT * AVG_ROW_LEN) AS DATA_SIZE
(MACRO_BLK_CNT * 2 * 1024 * 1024) AS DATA_SIZE
FROM SYS.ALL_VIRTUAL_TABLE_STAT_REAL_AGENT) TS
ON SUBP.TABLE_ID = TS.TABLE_ID
AND SUBP.SUB_PART_ID = TS.PARTITION_ID

4
tools/deploy/mysql_test/test_suite/information_schema/r/mysql/information_schema_desc.result
View File

File diff suppressed because one or more lines are too long