Merge pull request #9 from NikolayS/activity

new report: Current Activity

Author: NikolayS

.circleci/config.yml

@@ -35,4 +35,5 @@ jobs:
             #echo "\set postgres_dba_wide false" > ~/.psqlrc
             #for f in ~/postgres_dba/sql/*; do psql test -f "$f">/dev/null; done
             diff -b test/regression/1_basic.out <(psql test -f warmup.psql -f ~/postgres_dba/sql/1_basic.sql | grep Role)
-            diff -b test/regression/a1_alignment_padding.out <(psql test -f warmup.psql -f ~/postgres_dba/sql/a1_alignment_padding.sql | grep align)
+            diff -b test/regression/p1_alignment_padding.out <(psql test -f warmup.psql -f ~/postgres_dba/sql/p1_alignment_padding.sql | grep align)
+            diff -b test/regression/a1_activity.out <(psql test -f warmup.psql -f ~/postgres_dba/sql/a1_activity.sql | grep User)

README.md

@@ -1,5 +1,4 @@
 [![CircleCI](https://circleci.com/gh/NikolayS/postgres_dba.svg?style=svg)](https://circleci.com/gh/NikolayS/postgres_dba)
-
 # postgres_dba (PostgresDBA)
 
 The missing set of useful tools for Postgres DBA and mere mortals.

sql/a1_activity.sql

@@ -0,0 +1,17 @@
+--Current Activity: count of current connections grouped by database, user name, state
+select
+  coalesce(usename, '** ALL users **') as "User",
+  coalesce(datname, '** ALL databases **') as "DB",
+  coalesce(state, '** ALL states **') as "Current State",
+  count(*) as "Count",
+  count(*) filter (where state_change < now() - interval '1 minute') as "State changed >1m ago",
+  count(*) filter (where state_change < now() - interval '1 hour') as "State changed >1h ago"
+from pg_stat_activity
+group by grouping sets ((datname, usename, state), (usename, state), ())
+order by
+  usename is null desc,
+  datname is null desc,
+  2 asc,
+  3 asc,
+  count(*) desc
+;

sql/a1_alignment_padding.sql renamed to sql/p1_alignment_padding.sql

@@ -4,7 +4,7 @@
 \echo '   1 – Node Information: master/replica, lag, DB size, tmp files, etc'
 \echo '   2 – Table Size'
 \echo '   3 – Load Profile'
-\echo '  a1 – [EXPERIMENTAL] Alignment Padding. How many bytes can be saved if columns are ordered better?'
+\echo '  a1 – Current Activity: count of current connections grouped by database, user name, state'
 \echo '  b1 – Tables Bloat, rough estimation'
 \echo '  b2 – B-tree Indexes Bloat, rough estimation'
 \echo '  b3 – Tables Bloat, more precise (requires pgstattuple extension; expensive)'
@@ -13,6 +13,7 @@
 \echo '  i1 – Unused/Rarely Used Indexes'
 \echo '  i2 – Unused/Redundant Indexes Do & Undo Migration DDL'
 \echo '  i3 – FKs with Missing/Bad Indexes'
+\echo '  p1 – [EXPERIMENTAL] Alignment Padding. How many bytes can be saved if columns are ordered better?'
 \echo '  s1 – Slowest Queries, by Total Time (requires pg_stat_statements extension)'
 \echo '  s2 – Slowest Queries Report (requires pg_stat_statements)'
 \if :postgres_dba_wide
@@ -38,6 +39,7 @@ select
 :d_stp::text = 'i1' as d_step_is_i1,
 :d_stp::text = 'i2' as d_step_is_i2,
 :d_stp::text = 'i3' as d_step_is_i3,
+:d_stp::text = 'p1' as d_step_is_p1,
 :d_stp::text = 's1' as d_step_is_s1,
 :d_stp::text = 's2' as d_step_is_s2,
 :d_stp::text = 'x' as d_step_is_x,
@@ -69,7 +71,7 @@ set postgres_dba.wide = 'on';
   \prompt 'Press <Enter> to continue…' d_dummy
   \ir ./start.psql
 \elif :d_step_is_a1
-  \ir ./sql/a1_alignment_padding.sql
+  \ir ./sql/a1_activity.sql
   \prompt 'Press <Enter> to continue…' d_dummy
   \ir ./start.psql
 \elif :d_step_is_b1
@@ -104,6 +106,10 @@ set postgres_dba.wide = 'on';
   \ir ./sql/i3_non_indexed_fks.sql
   \prompt 'Press <Enter> to continue…' d_dummy
   \ir ./start.psql
+\elif :d_step_is_p1
+  \ir ./sql/p1_alignment_padding.sql
+  \prompt 'Press <Enter> to continue…' d_dummy
+  \ir ./start.psql
 \elif :d_step_is_s1
   \ir ./sql/s1_pg_stat_statements_top_total.sql
   \prompt 'Press <Enter> to continue…' d_dummy

start.psql

@@ -0,0 +1 @@
+      User       |         DB          |  Current State   | Count | State changed >1m ago | State changed >1h ago