diff --git a/pg_stat_monitor.c b/pg_stat_monitor.c index ee63ba7..2f51c08 100644 --- a/pg_stat_monitor.c +++ b/pg_stat_monitor.c @@ -1712,6 +1712,11 @@ pg_stat_monitor_internal(FunctionCallInfo fcinfo, if (tmp.state == PGSS_FINISHED) continue; } + + /* Skip queries such as, $1, $2 := $3, etc. */ + if (tmp.state == PGSS_PARSE || tmp.state == PGSS_PLAN) + continue; + if (tmp.info.parentid != UINT64CONST(0)) { int len = 0; diff --git a/regression/expected/counters.out b/regression/expected/counters.out index c96775e..ebf26f7 100644 --- a/regression/expected/counters.out +++ b/regression/expected/counters.out @@ -68,7 +68,7 @@ end $$; SELECT query,calls FROM pg_stat_monitor ORDER BY query COLLATE "C"; query | calls ---------------------------------------------------------------------------------------------------+------- - SELECT a,b,c,d FROM t1, t2, t3, t4 WHERE t1.a = t2.b AND t3.c = t4.d ORDER BY a; | 1000 + SELECT a,b,c,d FROM t1, t2, t3, t4 WHERE t1.a = t2.b AND t3.c = t4.d ORDER BY a | 1000 SELECT pg_stat_monitor_reset(); | 1 SELECT query,calls FROM pg_stat_monitor ORDER BY query COLLATE "C"; | 1 do $$ +| 1 diff --git a/regression/expected/state.out b/regression/expected/state.out index 147054a..b051091 100644 --- a/regression/expected/state.out +++ b/regression/expected/state.out @@ -16,7 +16,7 @@ ERROR: division by zero SELECT query, state_code, state FROM pg_stat_monitor ORDER BY query COLLATE "C"; query | state_code | state ----------------------------------------------------------------------------------+------------+--------------------- - SELECT $1 AS num | 3 | FINISHED + SELECT $1 | 3 | FINISHED SELECT 1/0; | 4 | FINISHED WITH ERROR SELECT pg_stat_monitor_reset(); | 3 | FINISHED SELECT query, state_code, state FROM pg_stat_monitor ORDER BY query COLLATE "C"; | 2 | ACTIVE diff --git a/regression/expected/tags.out b/regression/expected/tags.out index 9da2b13..dffe468 100644 --- a/regression/expected/tags.out +++ b/regression/expected/tags.out @@ -12,11 +12,11 @@ SELECT 1 AS num /* { "application", psql_app, "real_ip", 192.168.1.3) */; (1 row) SELECT query, comments FROM pg_stat_monitor ORDER BY query COLLATE "C"; - query | comments --------------------------------------------------------------------------+------------------------------------------------------ - SELECT $1 AS num | { "application", psql_app, "real_ip", 192.168.1.3) - SELECT pg_stat_monitor_reset(); | - SELECT query, comments FROM pg_stat_monitor ORDER BY query COLLATE "C"; | + query | comments +---------------------------------------------------------------------------+------------------------------------------------------ + SELECT $1 AS num /* { "application", psql_app, "real_ip", 192.168.1.3) */ | { "application", psql_app, "real_ip", 192.168.1.3) + SELECT pg_stat_monitor_reset(); | + SELECT query, comments FROM pg_stat_monitor ORDER BY query COLLATE "C"; | (3 rows) SELECT pg_stat_monitor_reset();