Skip to content

Commit

Permalink
Frontend V4.3
Browse files Browse the repository at this point in the history
  • Loading branch information
@Djoongaar
Djoongaar committed Oct 26, 2023
1 parent ec0b5b8 commit 8632b36
Show file tree
Hide file tree
Showing 10 changed files with 775 additions and 139 deletions.
249 changes: 233 additions & 16 deletions data/import_queries.sql
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,8 @@ INSERT INTO import_queries_version_order VALUES
('pg_profile','3.9','pg_profile','3.8'),
('pg_profile','4.0','pg_profile','3.9'),
('pg_profile','4.1','pg_profile','4.0'),
('pg_profile','4.2','pg_profile','4.1')
('pg_profile','4.2','pg_profile','4.1'),
('pg_profile','4.3','pg_profile','4.2')
;

/* ==== Data importing queries ==== */
Expand Down Expand Up @@ -648,7 +649,8 @@ INSERT INTO import_queries VALUES
'last_autovacuum,last_analyze,last_autoanalyze,vacuum_count,autovacuum_count,'
'analyze_count,autoanalyze_count,heap_blks_read,heap_blks_hit,idx_blks_read,'
'idx_blks_hit,toast_blks_read,toast_blks_hit,tidx_blks_read,tidx_blks_hit,'
'relsize,relsize_diff,relpages_bytes,relpages_bytes_diff)'
'relsize,relsize_diff,relpages_bytes,relpages_bytes_diff,last_seq_scan,'
'last_idx_scan,n_tup_newpage_upd)'
'SELECT '
'srv_map.local_srv_id, '
'dt.sample_id, '
Expand Down Expand Up @@ -686,7 +688,10 @@ INSERT INTO import_queries VALUES
'dt.relsize, '
'dt.relsize_diff, '
'dt.relpages_bytes, '
'dt.relpages_bytes_diff '
'dt.relpages_bytes_diff, '
'dt.last_seq_scan, '
'dt.last_idx_scan, '
'dt.n_tup_newpage_upd '
'FROM %1$s imp '
'CROSS JOIN json_to_record(imp.row_data) AS '
'dt ( '
Expand Down Expand Up @@ -726,7 +731,10 @@ INSERT INTO import_queries VALUES
'relsize bigint, '
'relsize_diff bigint, '
'relpages_bytes bigint, '
'relpages_bytes_diff bigint '
'relpages_bytes_diff bigint, '
'last_seq_scan timestamp with time zone,'
'last_idx_scan timestamp with time zone,'
'n_tup_newpage_upd bigint '
') '
'JOIN tmp_srv_map srv_map ON '
'(srv_map.imp_srv_id = dt.server_id) '
Expand All @@ -750,7 +758,7 @@ INSERT INTO import_queries VALUES
('pg_profile','0.3.1', 1,'sample_stat_indexes',
'INSERT INTO sample_stat_indexes (server_id,sample_id,datid,indexrelid,tablespaceid,'
'idx_scan,idx_tup_read,idx_tup_fetch,idx_blks_read,idx_blks_hit,relsize,'
'relsize_diff,indisunique,relpages_bytes,relpages_bytes_diff)'
'relsize_diff,indisunique,relpages_bytes,relpages_bytes_diff,last_idx_scan)'
'SELECT '
'srv_map.local_srv_id, '
'dt.sample_id, '
Expand All @@ -766,7 +774,8 @@ INSERT INTO import_queries VALUES
'dt.relsize_diff, '
'dt.indisunique, '
'dt.relpages_bytes, '
'dt.relpages_bytes_diff '
'dt.relpages_bytes_diff, '
'dt.last_idx_scan '
'FROM %1$s imp '
'CROSS JOIN json_to_record(imp.row_data) AS '
'dt ( '
Expand All @@ -784,7 +793,8 @@ INSERT INTO import_queries VALUES
'relsize_diff bigint, '
'indisunique boolean, '
'relpages_bytes bigint, '
'relpages_bytes_diff bigint'
'relpages_bytes_diff bigint, '
'last_idx_scan timestamp with time zone'
') '
'JOIN tmp_srv_map srv_map ON '
'(srv_map.imp_srv_id = dt.server_id) '
Expand Down Expand Up @@ -1258,7 +1268,7 @@ INSERT INTO import_queries VALUES
'autovacuum_count,analyze_count,autoanalyze_count,heap_blks_read,heap_blks_hit,'
'idx_blks_read,idx_blks_hit,toast_blks_read,toast_blks_hit,tidx_blks_read,'
'tidx_blks_hit,relsize,relsize_diff,tablespaceid,reltoastrelid,relkind,in_sample,'
'relpages_bytes, relpages_bytes_diff)'
'relpages_bytes,relpages_bytes_diff,last_seq_scan,last_idx_scan,n_tup_newpage_upd)'
'SELECT '
'srv_map.local_srv_id, '
'dt.sample_id, '
Expand Down Expand Up @@ -1301,7 +1311,10 @@ INSERT INTO import_queries VALUES
'dt.relkind, '
'COALESCE(dt.in_sample, false), '
'dt.relpages_bytes, '
'dt.relpages_bytes_diff '
'dt.relpages_bytes_diff, '
'dt.last_seq_scan, '
'dt.last_idx_scan, '
'dt.n_tup_newpage_upd '
'FROM %1$s imp '
'CROSS JOIN json_to_record(imp.row_data) AS '
'dt ( '
Expand Down Expand Up @@ -1346,7 +1359,10 @@ INSERT INTO import_queries VALUES
'relkind character(1), '
'in_sample boolean, '
'relpages_bytes bigint, '
'relpages_bytes_diff bigint '
'relpages_bytes_diff bigint, '
'last_seq_scan timestamp with time zone,'
'last_idx_scan timestamp with time zone,'
'n_tup_newpage_upd bigint '
') '
'JOIN tmp_srv_map srv_map ON '
'(srv_map.imp_srv_id = dt.server_id) '
Expand All @@ -1359,7 +1375,7 @@ INSERT INTO import_queries VALUES
'seq_scan,seq_tup_read,idx_scan,idx_tup_fetch,n_tup_ins,n_tup_upd,n_tup_del,'
'n_tup_hot_upd,vacuum_count,autovacuum_count,analyze_count,autoanalyze_count,'
'heap_blks_read,heap_blks_hit,idx_blks_read,idx_blks_hit,toast_blks_read,'
'toast_blks_hit,tidx_blks_read,tidx_blks_hit,relsize_diff)'
'toast_blks_hit,tidx_blks_read,tidx_blks_hit,relsize_diff,n_tup_newpage_upd)'
'SELECT '
'srv_map.local_srv_id, '
'dt.sample_id, '
Expand All @@ -1386,7 +1402,8 @@ INSERT INTO import_queries VALUES
'dt.toast_blks_hit, '
'dt.tidx_blks_read, '
'dt.tidx_blks_hit, '
'dt.relsize_diff '
'dt.relsize_diff, '
'dt.n_tup_newpage_upd '
'FROM %1$s imp '
'CROSS JOIN json_to_record(imp.row_data) AS '
'dt ( '
Expand Down Expand Up @@ -1415,7 +1432,8 @@ INSERT INTO import_queries VALUES
'toast_blks_hit bigint, '
'tidx_blks_read bigint, '
'tidx_blks_hit bigint, '
'relsize_diff bigint '
'relsize_diff bigint, '
'n_tup_newpage_upd bigint '
') '
'JOIN tmp_srv_map srv_map ON '
'(srv_map.imp_srv_id = dt.server_id) '
Expand All @@ -1427,7 +1445,7 @@ INSERT INTO import_queries VALUES
'INSERT INTO last_stat_indexes (server_id,sample_id,datid,relid,indexrelid,'
'schemaname,relname,indexrelname,idx_scan,idx_tup_read,idx_tup_fetch,'
'idx_blks_read,idx_blks_hit,relsize,relsize_diff,tablespaceid,indisunique,'
'in_sample,relpages_bytes,relpages_bytes_diff)'
'in_sample,relpages_bytes,relpages_bytes_diff,last_idx_scan)'
'SELECT '
'srv_map.local_srv_id, '
'dt.sample_id, '
Expand All @@ -1448,7 +1466,8 @@ INSERT INTO import_queries VALUES
'dt.indisunique, '
'COALESCE(dt.in_sample, false), '
'dt.relpages_bytes, '
'dt.relpages_bytes_diff '
'dt.relpages_bytes_diff, '
'dt.last_idx_scan '
'FROM %1$s imp '
'CROSS JOIN json_to_record(imp.row_data) AS '
'dt ( '
Expand All @@ -1471,7 +1490,8 @@ INSERT INTO import_queries VALUES
'indisunique boolean, '
'in_sample boolean, '
'relpages_bytes bigint, '
'relpages_bytes_diff bigint'
'relpages_bytes_diff bigint, '
'last_idx_scan timestamp with time zone'
') '
'JOIN tmp_srv_map srv_map ON '
'(srv_map.imp_srv_id = dt.server_id) '
Expand Down Expand Up @@ -2384,3 +2404,200 @@ INSERT INTO import_queries VALUES
'WHERE ld.server_id IS NULL AND imp.section_id = $1 '
)
;
/*
* Support import from pg_profile 4.3
*/
INSERT INTO import_queries VALUES
('pg_profile','4.3', 1,'sample_stat_io',
'INSERT INTO sample_stat_io (server_id,sample_id,backend_type,object,context,reads,'
'read_time,writes,write_time,writebacks,writeback_time,extends,extend_time,'
'op_bytes,hits,evictions,reuses,fsyncs,fsync_time,stats_reset'
') '
'SELECT '
'srv_map.local_srv_id, '
'dt.sample_id, '
'dt.backend_type, '
'dt.object, '
'dt.context, '
'dt.reads, '
'dt.read_time, '
'dt.writes, '
'dt.write_time, '
'dt.writebacks, '
'dt.writeback_time, '
'dt.extends, '
'dt.extend_time, '
'dt.op_bytes, '
'dt.hits, '
'dt.evictions, '
'dt.reuses, '
'dt.fsyncs, '
'dt.fsync_time, '
'dt.stats_reset '
'FROM %1$s imp '
'CROSS JOIN json_to_record(imp.row_data) AS '
'dt ( '
'server_id integer, '
'sample_id integer, '
'backend_type text, '
'object text, '
'context text, '
'reads bigint, '
'read_time double precision, '
'writes bigint, '
'write_time double precision, '
'writebacks bigint, '
'writeback_time double precision, '
'extends bigint, '
'extend_time double precision, '
'op_bytes bigint, '
'hits bigint, '
'evictions bigint, '
'reuses bigint, '
'fsyncs bigint, '
'fsync_time double precision, '
'stats_reset timestamp with time zone '
') '
'JOIN tmp_srv_map srv_map ON '
'(srv_map.imp_srv_id = dt.server_id) '
'LEFT OUTER JOIN sample_stat_io ld ON '
'(ld.server_id, ld.sample_id, ld.backend_type, ld.object, ld.context) = '
'(srv_map.local_srv_id, dt.sample_id, dt.backend_type, dt.object, dt.context) '
'WHERE ld.server_id IS NULL AND imp.section_id = $1 '
),
('pg_profile','4.3', 1,'last_stat_io',
'INSERT INTO last_stat_io (server_id,sample_id,backend_type,object,context,reads,'
'read_time,writes,write_time,writebacks,writeback_time,extends,extend_time,'
'op_bytes,hits,evictions,reuses,fsyncs,fsync_time,stats_reset'
') '
'SELECT '
'srv_map.local_srv_id, '
'dt.sample_id, '
'dt.backend_type, '
'dt.object, '
'dt.context, '
'dt.reads, '
'dt.read_time, '
'dt.writes, '
'dt.write_time, '
'dt.writebacks, '
'dt.writeback_time, '
'dt.extends, '
'dt.extend_time, '
'dt.op_bytes, '
'dt.hits, '
'dt.evictions, '
'dt.reuses, '
'dt.fsyncs, '
'dt.fsync_time, '
'dt.stats_reset '
'FROM %1$s imp '
'CROSS JOIN json_to_record(imp.row_data) AS '
'dt ( '
'server_id integer, '
'sample_id integer, '
'backend_type text, '
'object text, '
'context text, '
'reads bigint, '
'read_time double precision, '
'writes bigint, '
'write_time double precision, '
'writebacks bigint, '
'writeback_time double precision, '
'extends bigint, '
'extend_time double precision, '
'op_bytes bigint, '
'hits bigint, '
'evictions bigint, '
'reuses bigint, '
'fsyncs bigint, '
'fsync_time double precision, '
'stats_reset timestamp with time zone '
') '
'JOIN tmp_srv_map srv_map ON '
'(srv_map.imp_srv_id = dt.server_id) '
'LEFT OUTER JOIN last_stat_io ld ON '
'(ld.server_id, ld.sample_id, ld.backend_type, ld.object, ld.context) = '
'(srv_map.local_srv_id, dt.sample_id, dt.backend_type, dt.object, dt.context) '
'WHERE ld.server_id IS NULL AND imp.section_id = $1 '
),
('pg_profile','4.3', 1,'sample_stat_slru',
'INSERT INTO sample_stat_slru (server_id,sample_id,name,blks_zeroed,'
'blks_hit,blks_read,blks_written,blks_exists,flushes,truncates,'
'stats_reset'
') '
'SELECT '
'srv_map.local_srv_id, '
'dt.sample_id, '
'dt.name, '
'dt.blks_zeroed, '
'dt.blks_hit, '
'dt.blks_read, '
'dt.blks_written, '
'dt.blks_exists, '
'dt.flushes, '
'dt.truncates, '
'dt.stats_reset '
'FROM %1$s imp '
'CROSS JOIN json_to_record(imp.row_data) AS '
'dt ( '
'server_id integer, '
'sample_id integer, '
'name text, '
'blks_zeroed bigint, '
'blks_hit bigint, '
'blks_read bigint, '
'blks_written bigint, '
'blks_exists bigint, '
'flushes bigint, '
'truncates bigint, '
'stats_reset timestamp with time zone '
') '
'JOIN tmp_srv_map srv_map ON '
'(srv_map.imp_srv_id = dt.server_id) '
'LEFT OUTER JOIN sample_stat_slru ld ON '
'(ld.server_id, ld.sample_id, ld.name) = '
'(srv_map.local_srv_id, dt.sample_id, dt.name) '
'WHERE ld.server_id IS NULL AND imp.section_id = $1 '
),
('pg_profile','4.3', 1,'last_stat_slru',
'INSERT INTO last_stat_slru (server_id,sample_id,name,blks_zeroed,'
'blks_hit,blks_read,blks_written,blks_exists,flushes,truncates,'
'stats_reset'
') '
'SELECT '
'srv_map.local_srv_id, '
'dt.sample_id, '
'dt.name, '
'dt.blks_zeroed, '
'dt.blks_hit, '
'dt.blks_read, '
'dt.blks_written, '
'dt.blks_exists, '
'dt.flushes, '
'dt.truncates, '
'dt.stats_reset '
'FROM %1$s imp '
'CROSS JOIN json_to_record(imp.row_data) AS '
'dt ( '
'server_id integer, '
'sample_id integer, '
'name text, '
'blks_zeroed bigint, '
'blks_hit bigint, '
'blks_read bigint, '
'blks_written bigint, '
'blks_exists bigint, '
'flushes bigint, '
'truncates bigint, '
'stats_reset timestamp with time zone '
') '
'JOIN tmp_srv_map srv_map ON '
'(srv_map.imp_srv_id = dt.server_id) '
'LEFT OUTER JOIN last_stat_slru ld ON '
'(ld.server_id, ld.sample_id, ld.name) = '
'(srv_map.local_srv_id, dt.sample_id, dt.name) '
'WHERE ld.server_id IS NULL AND imp.section_id = $1 '
)
;
Loading

0 comments on commit 8632b36

Please sign in to comment.