select 1 FROM pg_available_extensions where name = 'pg_qs' and default_version = '2.8' and installed_version != '2.8';

[ Date: 2025-10-21 21:50:43 - Database: azure_sys - User: azuresu - Remote: [local] - Application: psql ]

SELECT version(); SELECT ns.nspname, t.oid, t.typname, t.typtype, t.typnotnull, t.elemtypoid FROM ( -- Arrays have typtype=b - this subquery identifies them by their typreceive and converts their typtype to a -- We first do this for the type (innerest-most subquery), and then for its element type -- This also returns the array element, range subtype and domain base type as elemtypoid SELECT typ.oid, typ.typnamespace, typ.typname, typ.typtype, typ.typrelid, typ.typnotnull, typ.relkind, elemtyp.oid AS elemtypoid, elemtyp.typname AS elemtypname, elemcls.relkind AS elemrelkind, CASE WHEN elemproc.proname = 'array_recv' THEN 'a' ELSE elemtyp.typtype END AS elemtyptype FROM ( SELECT typ.oid, typnamespace, typname, typrelid, typnotnull, relkind, typelem AS elemoid, CASE WHEN proc.proname = 'array_recv' THEN 'a' ELSE typ.typtype END AS typtype, CASE WHEN proc.proname = 'array_recv' THEN typ.typelem WHEN typ.typtype = 'r' THEN rngsubtype WHEN typ.typtype = 'm' THEN ( SELECT rngtypid FROM pg_range WHERE rngmultitypid = typ.oid) WHEN typ.typtype = 'd' THEN typ.typbasetype END AS elemtypoid FROM pg_type AS typ LEFT JOIN pg_class AS cls ON (cls.oid = typ.typrelid) LEFT JOIN pg_proc AS proc ON proc.oid = typ.typreceive LEFT JOIN pg_range ON (pg_range.rngtypid = typ.oid)) AS typ LEFT JOIN pg_type AS elemtyp ON elemtyp.oid = elemtypoid LEFT JOIN pg_class AS elemcls ON (elemcls.oid = elemtyp.typrelid) LEFT JOIN pg_proc AS elemproc ON elemproc.oid = elemtyp.typreceive) AS t JOIN pg_namespace AS ns ON (ns.oid = typnamespace) WHERE typtype IN ('b', 'r', 'm', 'e', 'd') OR -- Base, range, multirange, enum, domain (typtype = 'c' AND relkind = 'c') OR -- User-defined free-standing composites (not table composites) by default (typtype = 'p' AND typname IN ('record', 'void')) OR -- Some special supported pseudo-types (typtype = 'a' AND ( -- Array of... elemtyptype IN ('b', 'r', 'm', 'e', 'd') OR -- Array of base, range, multirange, enum, domain (elemtyptype = 'p' AND elemtypname IN ('record', 'void')) OR -- Arrays of special supported pseudo-types (elemtyptype = 'c' AND elemrelkind = 'c') -- Array of user-defined free-standing composites (not table composites) by default )) ORDER BY CASE WHEN typtype IN ('b', 'e', 'p') THEN 0 -- First base types, enums, pseudo-types WHEN typtype = 'r' THEN 1 -- Ranges after WHEN typtype = 'm' THEN 2 -- Multiranges after WHEN typtype = 'c' THEN 3 -- Composites after WHEN typtype = 'd' AND elemtyptype <> 'a' THEN 4 -- Domains over non-arrays after WHEN typtype = 'a' THEN 5 -- Arrays after WHEN typtype = 'd' AND elemtyptype = 'a' THEN 6 -- Domains over arrays last END; -- Load field definitions for (free-standing) composite types SELECT typ.oid, att.attname, att.atttypid FROM pg_type AS typ JOIN pg_namespace AS ns ON (ns.oid = typ.typnamespace) JOIN pg_class AS cls ON (cls.oid = typ.typrelid) JOIN pg_attribute AS att ON (att.attrelid = typ.typrelid) WHERE (typ.typtype = 'c' AND cls.relkind = 'c') AND attnum > 0 AND -- Don't load system attributes NOT attisdropped ORDER BY typ.oid, att.attnum; -- Load enum fields SELECT pg_type.oid, enumlabel FROM pg_enum JOIN pg_type ON pg_type.oid = enumtypid ORDER BY oid, enumsortorder;

[ Date: 2025-10-21 21:44:38 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] ]

SELECT 1 FROM pg_extension WHERE extowner != 10 AND extname = 'pgms_wait_sampling';

[ Date: 2025-10-21 21:50:42 - Database: azure_sys - User: azuresu - Remote: [local] - Application: psql ]

SELECT version(); SELECT ns.nspname, t.oid, t.typname, t.typtype, t.typnotnull, t.elemtypoid FROM ( -- Arrays have typtype=b - this subquery identifies them by their typreceive and converts their typtype to a -- We first do this for the type (innerest-most subquery), and then for its element type -- This also returns the array element, range subtype and domain base type as elemtypoid SELECT typ.oid, typ.typnamespace, typ.typname, typ.typtype, typ.typrelid, typ.typnotnull, typ.relkind, elemtyp.oid AS elemtypoid, elemtyp.typname AS elemtypname, elemcls.relkind AS elemrelkind, CASE WHEN elemproc.proname = 'array_recv' THEN 'a' ELSE elemtyp.typtype END AS elemtyptype FROM ( SELECT typ.oid, typnamespace, typname, typrelid, typnotnull, relkind, typelem AS elemoid, CASE WHEN proc.proname = 'array_recv' THEN 'a' ELSE typ.typtype END AS typtype, CASE WHEN proc.proname = 'array_recv' THEN typ.typelem WHEN typ.typtype = 'r' THEN rngsubtype WHEN typ.typtype = 'm' THEN ( SELECT rngtypid FROM pg_range WHERE rngmultitypid = typ.oid) WHEN typ.typtype = 'd' THEN typ.typbasetype END AS elemtypoid FROM pg_type AS typ LEFT JOIN pg_class AS cls ON (cls.oid = typ.typrelid) LEFT JOIN pg_proc AS proc ON proc.oid = typ.typreceive LEFT JOIN pg_range ON (pg_range.rngtypid = typ.oid)) AS typ LEFT JOIN pg_type AS elemtyp ON elemtyp.oid = elemtypoid LEFT JOIN pg_class AS elemcls ON (elemcls.oid = elemtyp.typrelid) LEFT JOIN pg_proc AS elemproc ON elemproc.oid = elemtyp.typreceive) AS t JOIN pg_namespace AS ns ON (ns.oid = typnamespace) WHERE typtype IN ('b', 'r', 'm', 'e', 'd') OR -- Base, range, multirange, enum, domain (typtype = 'c' AND relkind = 'c') OR -- User-defined free-standing composites (not table composites) by default (typtype = 'p' AND typname IN ('record', 'void')) OR -- Some special supported pseudo-types (typtype = 'a' AND ( -- Array of... elemtyptype IN ('b', 'r', 'm', 'e', 'd') OR -- Array of base, range, multirange, enum, domain (elemtyptype = 'p' AND elemtypname IN ('record', 'void')) OR -- Arrays of special supported pseudo-types (elemtyptype = 'c' AND elemrelkind = 'c') -- Array of user-defined free-standing composites (not table composites) by default )) ORDER BY CASE WHEN typtype IN ('b', 'e', 'p') THEN 0 -- First base types, enums, pseudo-types WHEN typtype = 'r' THEN 1 -- Ranges after WHEN typtype = 'm' THEN 2 -- Multiranges after WHEN typtype = 'c' THEN 3 -- Composites after WHEN typtype = 'd' AND elemtyptype <> 'a' THEN 4 -- Domains over non-arrays after WHEN typtype = 'a' THEN 5 -- Arrays after WHEN typtype = 'd' AND elemtyptype = 'a' THEN 6 -- Domains over arrays last END; -- Load field definitions for (free-standing) composite types SELECT typ.oid, att.attname, att.atttypid FROM pg_type AS typ JOIN pg_namespace AS ns ON (ns.oid = typ.typnamespace) JOIN pg_class AS cls ON (cls.oid = typ.typrelid) JOIN pg_attribute AS att ON (att.attrelid = typ.typrelid) WHERE (typ.typtype = 'c' AND cls.relkind = 'c') AND attnum > 0 AND -- Don't load system attributes NOT attisdropped ORDER BY typ.oid, att.attnum; -- Load enum fields SELECT pg_type.oid, enumlabel FROM pg_enum JOIN pg_type ON pg_type.oid = enumtypid ORDER BY oid, enumsortorder;

[ Date: 2025-10-21 22:03:09 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] ]

select 1 FROM pg_available_extensions where name = 'pg_qs' and default_version = '2.8' and installed_version != '2.8';

[ Date: 2025-10-21 22:03:00 - Database: azure_sys - User: azuresu - Remote: [local] - Application: psql ]

SELECT version(); SELECT ns.nspname, t.oid, t.typname, t.typtype, t.typnotnull, t.elemtypoid FROM ( -- Arrays have typtype=b - this subquery identifies them by their typreceive and converts their typtype to a -- We first do this for the type (innerest-most subquery), and then for its element type -- This also returns the array element, range subtype and domain base type as elemtypoid SELECT typ.oid, typ.typnamespace, typ.typname, typ.typtype, typ.typrelid, typ.typnotnull, typ.relkind, elemtyp.oid AS elemtypoid, elemtyp.typname AS elemtypname, elemcls.relkind AS elemrelkind, CASE WHEN elemproc.proname = 'array_recv' THEN 'a' ELSE elemtyp.typtype END AS elemtyptype FROM ( SELECT typ.oid, typnamespace, typname, typrelid, typnotnull, relkind, typelem AS elemoid, CASE WHEN proc.proname = 'array_recv' THEN 'a' ELSE typ.typtype END AS typtype, CASE WHEN proc.proname = 'array_recv' THEN typ.typelem WHEN typ.typtype = 'r' THEN rngsubtype WHEN typ.typtype = 'm' THEN ( SELECT rngtypid FROM pg_range WHERE rngmultitypid = typ.oid) WHEN typ.typtype = 'd' THEN typ.typbasetype END AS elemtypoid FROM pg_type AS typ LEFT JOIN pg_class AS cls ON (cls.oid = typ.typrelid) LEFT JOIN pg_proc AS proc ON proc.oid = typ.typreceive LEFT JOIN pg_range ON (pg_range.rngtypid = typ.oid)) AS typ LEFT JOIN pg_type AS elemtyp ON elemtyp.oid = elemtypoid LEFT JOIN pg_class AS elemcls ON (elemcls.oid = elemtyp.typrelid) LEFT JOIN pg_proc AS elemproc ON elemproc.oid = elemtyp.typreceive) AS t JOIN pg_namespace AS ns ON (ns.oid = typnamespace) WHERE typtype IN ('b', 'r', 'm', 'e', 'd') OR -- Base, range, multirange, enum, domain (typtype = 'c' AND relkind = 'c') OR -- User-defined free-standing composites (not table composites) by default (typtype = 'p' AND typname IN ('record', 'void')) OR -- Some special supported pseudo-types (typtype = 'a' AND ( -- Array of... elemtyptype IN ('b', 'r', 'm', 'e', 'd') OR -- Array of base, range, multirange, enum, domain (elemtyptype = 'p' AND elemtypname IN ('record', 'void')) OR -- Arrays of special supported pseudo-types (elemtyptype = 'c' AND elemrelkind = 'c') -- Array of user-defined free-standing composites (not table composites) by default )) ORDER BY CASE WHEN typtype IN ('b', 'e', 'p') THEN 0 -- First base types, enums, pseudo-types WHEN typtype = 'r' THEN 1 -- Ranges after WHEN typtype = 'm' THEN 2 -- Multiranges after WHEN typtype = 'c' THEN 3 -- Composites after WHEN typtype = 'd' AND elemtyptype <> 'a' THEN 4 -- Domains over non-arrays after WHEN typtype = 'a' THEN 5 -- Arrays after WHEN typtype = 'd' AND elemtyptype = 'a' THEN 6 -- Domains over arrays last END; -- Load field definitions for (free-standing) composite types SELECT typ.oid, att.attname, att.atttypid FROM pg_type AS typ JOIN pg_namespace AS ns ON (ns.oid = typ.typnamespace) JOIN pg_class AS cls ON (cls.oid = typ.typrelid) JOIN pg_attribute AS att ON (att.attrelid = typ.typrelid) WHERE (typ.typtype = 'c' AND cls.relkind = 'c') AND attnum > 0 AND -- Don't load system attributes NOT attisdropped ORDER BY typ.oid, att.attnum; -- Load enum fields SELECT pg_type.oid, enumlabel FROM pg_enum JOIN pg_type ON pg_type.oid = enumtypid ORDER BY oid, enumsortorder;

[ Date: 2025-10-21 22:03:09 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] ]

SELECT 1 FROM pg_extension WHERE extowner != 10 AND extname = 'pgms_wait_sampling';

[ Date: 2025-10-21 22:02:59 - Database: azure_sys - User: azuresu - Remote: [local] - Application: psql ]

SELECT version(); SELECT ns.nspname, t.oid, t.typname, t.typtype, t.typnotnull, t.elemtypoid FROM ( -- Arrays have typtype=b - this subquery identifies them by their typreceive and converts their typtype to a -- We first do this for the type (innerest-most subquery), and then for its element type -- This also returns the array element, range subtype and domain base type as elemtypoid SELECT typ.oid, typ.typnamespace, typ.typname, typ.typtype, typ.typrelid, typ.typnotnull, typ.relkind, elemtyp.oid AS elemtypoid, elemtyp.typname AS elemtypname, elemcls.relkind AS elemrelkind, CASE WHEN elemproc.proname = 'array_recv' THEN 'a' ELSE elemtyp.typtype END AS elemtyptype FROM ( SELECT typ.oid, typnamespace, typname, typrelid, typnotnull, relkind, typelem AS elemoid, CASE WHEN proc.proname = 'array_recv' THEN 'a' ELSE typ.typtype END AS typtype, CASE WHEN proc.proname = 'array_recv' THEN typ.typelem WHEN typ.typtype = 'r' THEN rngsubtype WHEN typ.typtype = 'm' THEN ( SELECT rngtypid FROM pg_range WHERE rngmultitypid = typ.oid) WHEN typ.typtype = 'd' THEN typ.typbasetype END AS elemtypoid FROM pg_type AS typ LEFT JOIN pg_class AS cls ON (cls.oid = typ.typrelid) LEFT JOIN pg_proc AS proc ON proc.oid = typ.typreceive LEFT JOIN pg_range ON (pg_range.rngtypid = typ.oid)) AS typ LEFT JOIN pg_type AS elemtyp ON elemtyp.oid = elemtypoid LEFT JOIN pg_class AS elemcls ON (elemcls.oid = elemtyp.typrelid) LEFT JOIN pg_proc AS elemproc ON elemproc.oid = elemtyp.typreceive) AS t JOIN pg_namespace AS ns ON (ns.oid = typnamespace) WHERE typtype IN ('b', 'r', 'm', 'e', 'd') OR -- Base, range, multirange, enum, domain (typtype = 'c' AND relkind = 'c') OR -- User-defined free-standing composites (not table composites) by default (typtype = 'p' AND typname IN ('record', 'void')) OR -- Some special supported pseudo-types (typtype = 'a' AND ( -- Array of... elemtyptype IN ('b', 'r', 'm', 'e', 'd') OR -- Array of base, range, multirange, enum, domain (elemtyptype = 'p' AND elemtypname IN ('record', 'void')) OR -- Arrays of special supported pseudo-types (elemtyptype = 'c' AND elemrelkind = 'c') -- Array of user-defined free-standing composites (not table composites) by default )) ORDER BY CASE WHEN typtype IN ('b', 'e', 'p') THEN 0 -- First base types, enums, pseudo-types WHEN typtype = 'r' THEN 1 -- Ranges after WHEN typtype = 'm' THEN 2 -- Multiranges after WHEN typtype = 'c' THEN 3 -- Composites after WHEN typtype = 'd' AND elemtyptype <> 'a' THEN 4 -- Domains over non-arrays after WHEN typtype = 'a' THEN 5 -- Arrays after WHEN typtype = 'd' AND elemtyptype = 'a' THEN 6 -- Domains over arrays last END; -- Load field definitions for (free-standing) composite types SELECT typ.oid, att.attname, att.atttypid FROM pg_type AS typ JOIN pg_namespace AS ns ON (ns.oid = typ.typnamespace) JOIN pg_class AS cls ON (cls.oid = typ.typrelid) JOIN pg_attribute AS att ON (att.attrelid = typ.typrelid) WHERE (typ.typtype = 'c' AND cls.relkind = 'c') AND attnum > 0 AND -- Don't load system attributes NOT attisdropped ORDER BY typ.oid, att.attnum; -- Load enum fields SELECT pg_type.oid, enumlabel FROM pg_enum JOIN pg_type ON pg_type.oid = enumtypid ORDER BY oid, enumsortorder;

[ Date: 2025-10-21 21:44:39 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] ]

SELECT version(); SELECT ns.nspname, t.oid, t.typname, t.typtype, t.typnotnull, t.elemtypoid FROM ( -- Arrays have typtype=b - this subquery identifies them by their typreceive and converts their typtype to a -- We first do this for the type (innerest-most subquery), and then for its element type -- This also returns the array element, range subtype and domain base type as elemtypoid SELECT typ.oid, typ.typnamespace, typ.typname, typ.typtype, typ.typrelid, typ.typnotnull, typ.relkind, elemtyp.oid AS elemtypoid, elemtyp.typname AS elemtypname, elemcls.relkind AS elemrelkind, CASE WHEN elemproc.proname = 'array_recv' THEN 'a' ELSE elemtyp.typtype END AS elemtyptype FROM ( SELECT typ.oid, typnamespace, typname, typrelid, typnotnull, relkind, typelem AS elemoid, CASE WHEN proc.proname = 'array_recv' THEN 'a' ELSE typ.typtype END AS typtype, CASE WHEN proc.proname = 'array_recv' THEN typ.typelem WHEN typ.typtype = 'r' THEN rngsubtype WHEN typ.typtype = 'm' THEN ( SELECT rngtypid FROM pg_range WHERE rngmultitypid = typ.oid) WHEN typ.typtype = 'd' THEN typ.typbasetype END AS elemtypoid FROM pg_type AS typ LEFT JOIN pg_class AS cls ON (cls.oid = typ.typrelid) LEFT JOIN pg_proc AS proc ON proc.oid = typ.typreceive LEFT JOIN pg_range ON (pg_range.rngtypid = typ.oid)) AS typ LEFT JOIN pg_type AS elemtyp ON elemtyp.oid = elemtypoid LEFT JOIN pg_class AS elemcls ON (elemcls.oid = elemtyp.typrelid) LEFT JOIN pg_proc AS elemproc ON elemproc.oid = elemtyp.typreceive) AS t JOIN pg_namespace AS ns ON (ns.oid = typnamespace) WHERE typtype IN ('b', 'r', 'm', 'e', 'd') OR -- Base, range, multirange, enum, domain (typtype = 'c' AND relkind = 'c') OR -- User-defined free-standing composites (not table composites) by default (typtype = 'p' AND typname IN ('record', 'void')) OR -- Some special supported pseudo-types (typtype = 'a' AND ( -- Array of... elemtyptype IN ('b', 'r', 'm', 'e', 'd') OR -- Array of base, range, multirange, enum, domain (elemtyptype = 'p' AND elemtypname IN ('record', 'void')) OR -- Arrays of special supported pseudo-types (elemtyptype = 'c' AND elemrelkind = 'c') -- Array of user-defined free-standing composites (not table composites) by default )) ORDER BY CASE WHEN typtype IN ('b', 'e', 'p') THEN 0 -- First base types, enums, pseudo-types WHEN typtype = 'r' THEN 1 -- Ranges after WHEN typtype = 'm' THEN 2 -- Multiranges after WHEN typtype = 'c' THEN 3 -- Composites after WHEN typtype = 'd' AND elemtyptype <> 'a' THEN 4 -- Domains over non-arrays after WHEN typtype = 'a' THEN 5 -- Arrays after WHEN typtype = 'd' AND elemtyptype = 'a' THEN 6 -- Domains over arrays last END; -- Load field definitions for (free-standing) composite types SELECT typ.oid, att.attname, att.atttypid FROM pg_type AS typ JOIN pg_namespace AS ns ON (ns.oid = typ.typnamespace) JOIN pg_class AS cls ON (cls.oid = typ.typrelid) JOIN pg_attribute AS att ON (att.attrelid = typ.typrelid) WHERE (typ.typtype = 'c' AND cls.relkind = 'c') AND attnum > 0 AND -- Don't load system attributes NOT attisdropped ORDER BY typ.oid, att.attnum; -- Load enum fields SELECT pg_type.oid, enumlabel FROM pg_enum JOIN pg_type ON pg_type.oid = enumtypid ORDER BY oid, enumsortorder;

[ Date: 2025-10-21 21:44:39 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] ]

SELECT version(); SELECT ns.nspname, t.oid, t.typname, t.typtype, t.typnotnull, t.elemtypoid FROM ( -- Arrays have typtype=b - this subquery identifies them by their typreceive and converts their typtype to a -- We first do this for the type (innerest-most subquery), and then for its element type -- This also returns the array element, range subtype and domain base type as elemtypoid SELECT typ.oid, typ.typnamespace, typ.typname, typ.typtype, typ.typrelid, typ.typnotnull, typ.relkind, elemtyp.oid AS elemtypoid, elemtyp.typname AS elemtypname, elemcls.relkind AS elemrelkind, CASE WHEN elemproc.proname = 'array_recv' THEN 'a' ELSE elemtyp.typtype END AS elemtyptype FROM ( SELECT typ.oid, typnamespace, typname, typrelid, typnotnull, relkind, typelem AS elemoid, CASE WHEN proc.proname = 'array_recv' THEN 'a' ELSE typ.typtype END AS typtype, CASE WHEN proc.proname = 'array_recv' THEN typ.typelem WHEN typ.typtype = 'r' THEN rngsubtype WHEN typ.typtype = 'm' THEN ( SELECT rngtypid FROM pg_range WHERE rngmultitypid = typ.oid) WHEN typ.typtype = 'd' THEN typ.typbasetype END AS elemtypoid FROM pg_type AS typ LEFT JOIN pg_class AS cls ON (cls.oid = typ.typrelid) LEFT JOIN pg_proc AS proc ON proc.oid = typ.typreceive LEFT JOIN pg_range ON (pg_range.rngtypid = typ.oid)) AS typ LEFT JOIN pg_type AS elemtyp ON elemtyp.oid = elemtypoid LEFT JOIN pg_class AS elemcls ON (elemcls.oid = elemtyp.typrelid) LEFT JOIN pg_proc AS elemproc ON elemproc.oid = elemtyp.typreceive) AS t JOIN pg_namespace AS ns ON (ns.oid = typnamespace) WHERE typtype IN ('b', 'r', 'm', 'e', 'd') OR -- Base, range, multirange, enum, domain (typtype = 'c' AND relkind = 'c') OR -- User-defined free-standing composites (not table composites) by default (typtype = 'p' AND typname IN ('record', 'void')) OR -- Some special supported pseudo-types (typtype = 'a' AND ( -- Array of... elemtyptype IN ('b', 'r', 'm', 'e', 'd') OR -- Array of base, range, multirange, enum, domain (elemtyptype = 'p' AND elemtypname IN ('record', 'void')) OR -- Arrays of special supported pseudo-types (elemtyptype = 'c' AND elemrelkind = 'c') -- Array of user-defined free-standing composites (not table composites) by default )) ORDER BY CASE WHEN typtype IN ('b', 'e', 'p') THEN 0 -- First base types, enums, pseudo-types WHEN typtype = 'r' THEN 1 -- Ranges after WHEN typtype = 'm' THEN 2 -- Multiranges after WHEN typtype = 'c' THEN 3 -- Composites after WHEN typtype = 'd' AND elemtyptype <> 'a' THEN 4 -- Domains over non-arrays after WHEN typtype = 'a' THEN 5 -- Arrays after WHEN typtype = 'd' AND elemtyptype = 'a' THEN 6 -- Domains over arrays last END; -- Load field definitions for (free-standing) composite types SELECT typ.oid, att.attname, att.atttypid FROM pg_type AS typ JOIN pg_namespace AS ns ON (ns.oid = typ.typnamespace) JOIN pg_class AS cls ON (cls.oid = typ.typrelid) JOIN pg_attribute AS att ON (att.attrelid = typ.typrelid) WHERE (typ.typtype = 'c' AND cls.relkind = 'c') AND attnum > 0 AND -- Don't load system attributes NOT attisdropped ORDER BY typ.oid, att.attnum; -- Load enum fields SELECT pg_type.oid, enumlabel FROM pg_enum JOIN pg_type ON pg_type.oid = enumtypid ORDER BY oid, enumsortorder;

[ Date: 2025-10-21 22:03:10 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-21 18:29:36 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-21 06:23:54 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-21 20:14:32 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

CREATE EXTENSION IF NOT EXISTS tablefunc SCHEMA public;

[ Date: 2025-10-21 21:50:42 - Database: azure_sys - User: azuresu - Remote: [local] - Application: psql ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-21 20:08:51 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;

[ Date: 2025-10-21 21:50:50 - Database: azure_sys - User: azuresu - Remote: 169.254.128.1 - Application: [unknown] - Bind query: yes ]

With slots_info AS ( SELECT slot.slot_name, slot.active, slot.slot_type, stat.write_lsn, stat.flush_lsn, stat.sync_state, slot.restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END as wal_retention_from_restart_lsn, stat.replay_lsn, CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END as replay_lsn_else_restart_lsn, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name ( CASE WHEN stat.replay_lsn IS NULL THEN slot.restart_lsn ELSE stat.replay_lsn END) END as must_retain_wal_file, CASE WHEN pg_is_in_recovery() THEN NULL ELSE ( CASE WHEN stat.replay_lsn IS NULL THEN NULL ELSE pg_catalog.pg_wal_lsn_diff (pg_catalog.pg_current_wal_lsn (), slot.restart_lsn)::bigint END) END as wal_retention_from_replay_lsn FROM pg_catalog.pg_replication_slots slot LEFT JOIN pg_catalog.pg_stat_replication stat ON slot.active_pid = stat.pid ), standby_and_walreplica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name LIKE 'azure_standby%' or slot_name like 'wal_replica%' ), read_replica_slot_info as ( SELECT * FROM slots_info where slot_type = 'physical' and slot_name not LIKE 'azure_standby%' and slot_name not like 'wal_replica%' ) SELECT ( SELECT row_to_json(t1) logical_slots FROM ( SELECT ( SELECT count(*) as active FROM slots_info where slot_type = 'logical' and active = true), ( SELECT count(*) as inactive FROM slots_info where slot_type = 'logical' and active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM slots_info where slot_type = 'logical' order by replay_lsn_else_restart_lsn) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) read_replica_slots FROM ( SELECT ( SELECT count(*) as active FROM read_replica_slot_info where active = true), ( SELECT count(*) as inactive FROM read_replica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM read_replica_slot_info order by replay_lsn_else_restart_lsn limit 4) as t) as lagging_order) as t1), ( SELECT row_to_json(t1) standby_and_walreplica_slots FROM ( SELECT ( SELECT count(*) as active FROM standby_and_walreplica_slot_info where active = true), ( SELECT count(*) as inactive FROM standby_and_walreplica_slot_info where active <> true), ( SELECT jsonb_agg(row_to_json(t)) FROM ( SELECT * FROM standby_and_walreplica_slot_info) as t) as lagging_order) as t1), ( Select row_to_json(t)::text as checkpoint_info FROM ( Select ( SELECT trunc(MAX(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - xact_start))) AS max_age FROM pg_stat_activity) oldest_live_tx_age, trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - checkpoint_time)) as seconds_after_last_checkpoint, timeline_id, checkpoint_lsn, TO_CHAR(checkpoint_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as checkpoint_time, CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (checkpoint_lsn) END AS checkpoint_wal_file, redo_lsn, redo_wal_file, buffers_alloc, block_size, now() - stats_reset stats_reset from pg_catalog.pg_control_checkpoint (), pg_stat_bgwriter, ( SELECT cast(current_setting('block_size') AS integer) AS block_size) as sub_query) as t), ( Select row_to_json(t)::text as archiver_info FROM ( Select trunc(EXTRACT(EPOCH FROM CURRENT_TIMESTAMP - last_archived_time)) last_archival, (last_failed_wal IS NULL OR last_failed_wal <= last_archived_wal) is_archiving, trunc( CASE WHEN archived_count = 0 OR EXTRACT(EPOCH FROM age(now(), stats_reset)) = 0 THEN 0 ELSE CAST(archived_count AS numeric) * 60 / EXTRACT(EPOCH FROM age(now(), stats_reset)) END) wals_archived_per_minute, last_archived_wal, TO_CHAR(last_archived_time at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS') as last_archived_time, last_failed_wal, archived_count, failed_count, now() - stats_reset as stats_reset from pg_catalog.pg_stat_archiver) as t), ( Select row_to_json(t)::text as wal_upload_related_details FROM ( SELECT ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (pg_catalog.pg_current_wal_lsn ()) END as current), ( SELECT CASE WHEN pg_is_in_recovery() THEN NULL ELSE pg_catalog.pg_walfile_name (flush_lsn) END as quorum_committed FROM slots_info where slot_type = 'physical' and sync_state = 'quorum' order by flush_lsn desc limit 1), ( SELECT CAST(pg_catalog.current_setting('azure.enforce_ha_quorom') AS boolean) AS enforce_ha_quorom), ( SELECT pg_catalog.current_setting('synchronous_standby_names') AS synchronous_standby_names), ( SELECT CAST(pg_catalog.pg_is_in_recovery() AS boolean) AS pg_is_in_recovery)) as t), ( select TO_CHAR(pg_catalog.now() at time zone 'utc', 'YYYY-MM-DD HH24:MI:SS')) as time_fetched;