Issue - (#1): Initial Commit for PostgreSQL's (pg_stat_statement).
The pg_stat_monitor is based on PostgreSQL-11's pg_stat_statement. To keep track of the changes, this is the base code of PostgreSQL's pg_stat_statement. (commit = d898edf4f233a3ffe6a0da64179fc268a1d46200).pull/9/head
parent
97c67356ca
commit
f70ad5ad48
|
@ -30,7 +30,6 @@
|
||||||
|
|
||||||
# Executables
|
# Executables
|
||||||
*.exe
|
*.exe
|
||||||
*.out
|
|
||||||
*.app
|
*.app
|
||||||
*.i*86
|
*.i*86
|
||||||
*.x86_64
|
*.x86_64
|
||||||
|
|
|
@ -0,0 +1,31 @@
|
||||||
|
# contrib/pg_stat_statements/Makefile
|
||||||
|
|
||||||
|
MODULE_big = pg_stat_statements
|
||||||
|
OBJS = pg_stat_statements.o $(WIN32RES)
|
||||||
|
|
||||||
|
EXTENSION = pg_stat_statements
|
||||||
|
DATA = pg_stat_statements--1.4.sql pg_stat_statements--1.5--1.6.sql \
|
||||||
|
pg_stat_statements--1.4--1.5.sql pg_stat_statements--1.3--1.4.sql \
|
||||||
|
pg_stat_statements--1.2--1.3.sql pg_stat_statements--1.1--1.2.sql \
|
||||||
|
pg_stat_statements--1.0--1.1.sql \
|
||||||
|
pg_stat_statements--unpackaged--1.0.sql
|
||||||
|
PGFILEDESC = "pg_stat_statements - execution statistics of SQL statements"
|
||||||
|
|
||||||
|
LDFLAGS_SL += $(filter -lm, $(LIBS))
|
||||||
|
|
||||||
|
REGRESS_OPTS = --temp-config $(top_srcdir)/contrib/pg_stat_statements/pg_stat_statements.conf
|
||||||
|
REGRESS = pg_stat_statements
|
||||||
|
# Disabled because these tests require "shared_preload_libraries=pg_stat_statements",
|
||||||
|
# which typical installcheck users do not have (e.g. buildfarm clients).
|
||||||
|
NO_INSTALLCHECK = 1
|
||||||
|
|
||||||
|
ifdef USE_PGXS
|
||||||
|
PG_CONFIG = pg_config
|
||||||
|
PGXS := $(shell $(PG_CONFIG) --pgxs)
|
||||||
|
include $(PGXS)
|
||||||
|
else
|
||||||
|
subdir = contrib/pg_stat_statements
|
||||||
|
top_builddir = ../..
|
||||||
|
include $(top_builddir)/src/Makefile.global
|
||||||
|
include $(top_srcdir)/contrib/contrib-global.mk
|
||||||
|
endif
|
|
@ -0,0 +1,398 @@
|
||||||
|
CREATE EXTENSION pg_stat_statements;
|
||||||
|
--
|
||||||
|
-- simple and compound statements
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track_utility = FALSE;
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
pg_stat_statements_reset
|
||||||
|
--------------------------
|
||||||
|
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT 1 AS "int";
|
||||||
|
int
|
||||||
|
-----
|
||||||
|
1
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT 'hello'
|
||||||
|
-- multiline
|
||||||
|
AS "text";
|
||||||
|
text
|
||||||
|
-------
|
||||||
|
hello
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT 'world' AS "text";
|
||||||
|
text
|
||||||
|
-------
|
||||||
|
world
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- transaction
|
||||||
|
BEGIN;
|
||||||
|
SELECT 1 AS "int";
|
||||||
|
int
|
||||||
|
-----
|
||||||
|
1
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT 'hello' AS "text";
|
||||||
|
text
|
||||||
|
-------
|
||||||
|
hello
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
COMMIT;
|
||||||
|
-- compound transaction
|
||||||
|
BEGIN \;
|
||||||
|
SELECT 2.0 AS "float" \;
|
||||||
|
SELECT 'world' AS "text" \;
|
||||||
|
COMMIT;
|
||||||
|
-- compound with empty statements and spurious leading spacing
|
||||||
|
\;\; SELECT 3 + 3 \;\;\; SELECT ' ' || ' !' \;\; SELECT 1 + 4 \;;
|
||||||
|
?column?
|
||||||
|
----------
|
||||||
|
5
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- non ;-terminated statements
|
||||||
|
SELECT 1 + 1 + 1 AS "add" \gset
|
||||||
|
SELECT :add + 1 + 1 AS "add" \;
|
||||||
|
SELECT :add + 1 + 1 AS "add" \gset
|
||||||
|
-- set operator
|
||||||
|
SELECT 1 AS i UNION SELECT 2 ORDER BY i;
|
||||||
|
i
|
||||||
|
---
|
||||||
|
1
|
||||||
|
2
|
||||||
|
(2 rows)
|
||||||
|
|
||||||
|
-- ? operator
|
||||||
|
select '{"a":1, "b":2}'::jsonb ? 'b';
|
||||||
|
?column?
|
||||||
|
----------
|
||||||
|
t
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- cte
|
||||||
|
WITH t(f) AS (
|
||||||
|
VALUES (1.0), (2.0)
|
||||||
|
)
|
||||||
|
SELECT f FROM t ORDER BY f;
|
||||||
|
f
|
||||||
|
-----
|
||||||
|
1.0
|
||||||
|
2.0
|
||||||
|
(2 rows)
|
||||||
|
|
||||||
|
-- prepared statement with parameter
|
||||||
|
PREPARE pgss_test (int) AS SELECT $1, 'test' LIMIT 1;
|
||||||
|
EXECUTE pgss_test(1);
|
||||||
|
?column? | ?column?
|
||||||
|
----------+----------
|
||||||
|
1 | test
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
DEALLOCATE pgss_test;
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
query | calls | rows
|
||||||
|
---------------------------------------------------+-------+------
|
||||||
|
PREPARE pgss_test (int) AS SELECT $1, $2 LIMIT $3 | 1 | 1
|
||||||
|
SELECT $1 +| 4 | 4
|
||||||
|
+| |
|
||||||
|
AS "text" | |
|
||||||
|
SELECT $1 + $2 | 2 | 2
|
||||||
|
SELECT $1 + $2 + $3 AS "add" | 3 | 3
|
||||||
|
SELECT $1 AS "float" | 1 | 1
|
||||||
|
SELECT $1 AS "int" | 2 | 2
|
||||||
|
SELECT $1 AS i UNION SELECT $2 ORDER BY i | 1 | 2
|
||||||
|
SELECT $1 || $2 | 1 | 1
|
||||||
|
SELECT pg_stat_statements_reset() | 1 | 1
|
||||||
|
WITH t(f) AS ( +| 1 | 2
|
||||||
|
VALUES ($1), ($2) +| |
|
||||||
|
) +| |
|
||||||
|
SELECT f FROM t ORDER BY f | |
|
||||||
|
select $1::jsonb ? $2 | 1 | 1
|
||||||
|
(11 rows)
|
||||||
|
|
||||||
|
--
|
||||||
|
-- CRUD: INSERT SELECT UPDATE DELETE on test table
|
||||||
|
--
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
pg_stat_statements_reset
|
||||||
|
--------------------------
|
||||||
|
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- utility "create table" should not be shown
|
||||||
|
CREATE TEMP TABLE test (a int, b char(20));
|
||||||
|
INSERT INTO test VALUES(generate_series(1, 10), 'aaa');
|
||||||
|
UPDATE test SET b = 'bbb' WHERE a > 7;
|
||||||
|
DELETE FROM test WHERE a > 9;
|
||||||
|
-- explicit transaction
|
||||||
|
BEGIN;
|
||||||
|
UPDATE test SET b = '111' WHERE a = 1 ;
|
||||||
|
COMMIT;
|
||||||
|
BEGIN \;
|
||||||
|
UPDATE test SET b = '222' WHERE a = 2 \;
|
||||||
|
COMMIT ;
|
||||||
|
UPDATE test SET b = '333' WHERE a = 3 \;
|
||||||
|
UPDATE test SET b = '444' WHERE a = 4 ;
|
||||||
|
BEGIN \;
|
||||||
|
UPDATE test SET b = '555' WHERE a = 5 \;
|
||||||
|
UPDATE test SET b = '666' WHERE a = 6 \;
|
||||||
|
COMMIT ;
|
||||||
|
-- many INSERT values
|
||||||
|
INSERT INTO test (a, b) VALUES (1, 'a'), (2, 'b'), (3, 'c');
|
||||||
|
-- SELECT with constants
|
||||||
|
SELECT * FROM test WHERE a > 5 ORDER BY a ;
|
||||||
|
a | b
|
||||||
|
---+----------------------
|
||||||
|
6 | 666
|
||||||
|
7 | aaa
|
||||||
|
8 | bbb
|
||||||
|
9 | bbb
|
||||||
|
(4 rows)
|
||||||
|
|
||||||
|
SELECT *
|
||||||
|
FROM test
|
||||||
|
WHERE a > 9
|
||||||
|
ORDER BY a ;
|
||||||
|
a | b
|
||||||
|
---+---
|
||||||
|
(0 rows)
|
||||||
|
|
||||||
|
-- SELECT without constants
|
||||||
|
SELECT * FROM test ORDER BY a;
|
||||||
|
a | b
|
||||||
|
---+----------------------
|
||||||
|
1 | a
|
||||||
|
1 | 111
|
||||||
|
2 | b
|
||||||
|
2 | 222
|
||||||
|
3 | c
|
||||||
|
3 | 333
|
||||||
|
4 | 444
|
||||||
|
5 | 555
|
||||||
|
6 | 666
|
||||||
|
7 | aaa
|
||||||
|
8 | bbb
|
||||||
|
9 | bbb
|
||||||
|
(12 rows)
|
||||||
|
|
||||||
|
-- SELECT with IN clause
|
||||||
|
SELECT * FROM test WHERE a IN (1, 2, 3, 4, 5);
|
||||||
|
a | b
|
||||||
|
---+----------------------
|
||||||
|
1 | 111
|
||||||
|
2 | 222
|
||||||
|
3 | 333
|
||||||
|
4 | 444
|
||||||
|
5 | 555
|
||||||
|
1 | a
|
||||||
|
2 | b
|
||||||
|
3 | c
|
||||||
|
(8 rows)
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
query | calls | rows
|
||||||
|
-------------------------------------------------------------+-------+------
|
||||||
|
DELETE FROM test WHERE a > $1 | 1 | 1
|
||||||
|
INSERT INTO test (a, b) VALUES ($1, $2), ($3, $4), ($5, $6) | 1 | 3
|
||||||
|
INSERT INTO test VALUES(generate_series($1, $2), $3) | 1 | 10
|
||||||
|
SELECT * FROM test ORDER BY a | 1 | 12
|
||||||
|
SELECT * FROM test WHERE a > $1 ORDER BY a | 2 | 4
|
||||||
|
SELECT * FROM test WHERE a IN ($1, $2, $3, $4, $5) | 1 | 8
|
||||||
|
SELECT pg_stat_statements_reset() | 1 | 1
|
||||||
|
UPDATE test SET b = $1 WHERE a = $2 | 6 | 6
|
||||||
|
UPDATE test SET b = $1 WHERE a > $2 | 1 | 3
|
||||||
|
(9 rows)
|
||||||
|
|
||||||
|
--
|
||||||
|
-- pg_stat_statements.track = none
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track = 'none';
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
pg_stat_statements_reset
|
||||||
|
--------------------------
|
||||||
|
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT 1 AS "one";
|
||||||
|
one
|
||||||
|
-----
|
||||||
|
1
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT 1 + 1 AS "two";
|
||||||
|
two
|
||||||
|
-----
|
||||||
|
2
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
query | calls | rows
|
||||||
|
-------+-------+------
|
||||||
|
(0 rows)
|
||||||
|
|
||||||
|
--
|
||||||
|
-- pg_stat_statements.track = top
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track = 'top';
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
pg_stat_statements_reset
|
||||||
|
--------------------------
|
||||||
|
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
DO LANGUAGE plpgsql $$
|
||||||
|
BEGIN
|
||||||
|
-- this is a SELECT
|
||||||
|
PERFORM 'hello world'::TEXT;
|
||||||
|
END;
|
||||||
|
$$;
|
||||||
|
-- PL/pgSQL function
|
||||||
|
CREATE FUNCTION PLUS_TWO(i INTEGER) RETURNS INTEGER AS $$
|
||||||
|
DECLARE
|
||||||
|
r INTEGER;
|
||||||
|
BEGIN
|
||||||
|
SELECT (i + 1 + 1.0)::INTEGER INTO r;
|
||||||
|
RETURN r;
|
||||||
|
END; $$ LANGUAGE plpgsql;
|
||||||
|
SELECT PLUS_TWO(3);
|
||||||
|
plus_two
|
||||||
|
----------
|
||||||
|
5
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT PLUS_TWO(7);
|
||||||
|
plus_two
|
||||||
|
----------
|
||||||
|
9
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- SQL function --- use LIMIT to keep it from being inlined
|
||||||
|
CREATE FUNCTION PLUS_ONE(i INTEGER) RETURNS INTEGER AS
|
||||||
|
$$ SELECT (i + 1.0)::INTEGER LIMIT 1 $$ LANGUAGE SQL;
|
||||||
|
SELECT PLUS_ONE(8);
|
||||||
|
plus_one
|
||||||
|
----------
|
||||||
|
9
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT PLUS_ONE(10);
|
||||||
|
plus_one
|
||||||
|
----------
|
||||||
|
11
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
query | calls | rows
|
||||||
|
-----------------------------------+-------+------
|
||||||
|
SELECT $1::TEXT | 1 | 1
|
||||||
|
SELECT PLUS_ONE($1) | 2 | 2
|
||||||
|
SELECT PLUS_TWO($1) | 2 | 2
|
||||||
|
SELECT pg_stat_statements_reset() | 1 | 1
|
||||||
|
(4 rows)
|
||||||
|
|
||||||
|
--
|
||||||
|
-- pg_stat_statements.track = all
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track = 'all';
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
pg_stat_statements_reset
|
||||||
|
--------------------------
|
||||||
|
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- we drop and recreate the functions to avoid any caching funnies
|
||||||
|
DROP FUNCTION PLUS_ONE(INTEGER);
|
||||||
|
DROP FUNCTION PLUS_TWO(INTEGER);
|
||||||
|
-- PL/pgSQL function
|
||||||
|
CREATE FUNCTION PLUS_TWO(i INTEGER) RETURNS INTEGER AS $$
|
||||||
|
DECLARE
|
||||||
|
r INTEGER;
|
||||||
|
BEGIN
|
||||||
|
SELECT (i + 1 + 1.0)::INTEGER INTO r;
|
||||||
|
RETURN r;
|
||||||
|
END; $$ LANGUAGE plpgsql;
|
||||||
|
SELECT PLUS_TWO(-1);
|
||||||
|
plus_two
|
||||||
|
----------
|
||||||
|
1
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT PLUS_TWO(2);
|
||||||
|
plus_two
|
||||||
|
----------
|
||||||
|
4
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
-- SQL function --- use LIMIT to keep it from being inlined
|
||||||
|
CREATE FUNCTION PLUS_ONE(i INTEGER) RETURNS INTEGER AS
|
||||||
|
$$ SELECT (i + 1.0)::INTEGER LIMIT 1 $$ LANGUAGE SQL;
|
||||||
|
SELECT PLUS_ONE(3);
|
||||||
|
plus_one
|
||||||
|
----------
|
||||||
|
4
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT PLUS_ONE(1);
|
||||||
|
plus_one
|
||||||
|
----------
|
||||||
|
2
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
query | calls | rows
|
||||||
|
-----------------------------------+-------+------
|
||||||
|
SELECT (i + $2 + $3)::INTEGER | 2 | 2
|
||||||
|
SELECT (i + $2)::INTEGER LIMIT $3 | 2 | 2
|
||||||
|
SELECT PLUS_ONE($1) | 2 | 2
|
||||||
|
SELECT PLUS_TWO($1) | 2 | 2
|
||||||
|
SELECT pg_stat_statements_reset() | 1 | 1
|
||||||
|
(5 rows)
|
||||||
|
|
||||||
|
--
|
||||||
|
-- utility commands
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track_utility = TRUE;
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
pg_stat_statements_reset
|
||||||
|
--------------------------
|
||||||
|
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
SELECT 1;
|
||||||
|
?column?
|
||||||
|
----------
|
||||||
|
1
|
||||||
|
(1 row)
|
||||||
|
|
||||||
|
CREATE INDEX test_b ON test(b);
|
||||||
|
DROP TABLE test \;
|
||||||
|
DROP TABLE IF EXISTS test \;
|
||||||
|
DROP FUNCTION PLUS_ONE(INTEGER);
|
||||||
|
NOTICE: table "test" does not exist, skipping
|
||||||
|
DROP TABLE IF EXISTS test \;
|
||||||
|
DROP TABLE IF EXISTS test \;
|
||||||
|
DROP FUNCTION IF EXISTS PLUS_ONE(INTEGER);
|
||||||
|
NOTICE: table "test" does not exist, skipping
|
||||||
|
NOTICE: table "test" does not exist, skipping
|
||||||
|
NOTICE: function plus_one(pg_catalog.int4) does not exist, skipping
|
||||||
|
DROP FUNCTION PLUS_TWO(INTEGER);
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
query | calls | rows
|
||||||
|
-------------------------------------------+-------+------
|
||||||
|
CREATE INDEX test_b ON test(b) | 1 | 0
|
||||||
|
DROP FUNCTION IF EXISTS PLUS_ONE(INTEGER) | 1 | 0
|
||||||
|
DROP FUNCTION PLUS_ONE(INTEGER) | 1 | 0
|
||||||
|
DROP FUNCTION PLUS_TWO(INTEGER) | 1 | 0
|
||||||
|
DROP TABLE IF EXISTS test | 3 | 0
|
||||||
|
DROP TABLE test | 1 | 0
|
||||||
|
SELECT $1 | 1 | 1
|
||||||
|
SELECT pg_stat_statements_reset() | 1 | 1
|
||||||
|
(8 rows)
|
||||||
|
|
||||||
|
DROP EXTENSION pg_stat_statements;
|
|
@ -0,0 +1,42 @@
|
||||||
|
/* contrib/pg_stat_statements/pg_stat_statements--1.0--1.1.sql */
|
||||||
|
|
||||||
|
-- complain if script is sourced in psql, rather than via ALTER EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION pg_stat_statements UPDATE TO '1.1'" to load this file. \quit
|
||||||
|
|
||||||
|
/* First we have to remove them from the extension */
|
||||||
|
ALTER EXTENSION pg_stat_statements DROP VIEW pg_stat_statements;
|
||||||
|
ALTER EXTENSION pg_stat_statements DROP FUNCTION pg_stat_statements();
|
||||||
|
|
||||||
|
/* Then we can drop them */
|
||||||
|
DROP VIEW pg_stat_statements;
|
||||||
|
DROP FUNCTION pg_stat_statements();
|
||||||
|
|
||||||
|
/* Now redefine */
|
||||||
|
CREATE FUNCTION pg_stat_statements(
|
||||||
|
OUT userid oid,
|
||||||
|
OUT dbid oid,
|
||||||
|
OUT query text,
|
||||||
|
OUT calls int8,
|
||||||
|
OUT total_time float8,
|
||||||
|
OUT rows int8,
|
||||||
|
OUT shared_blks_hit int8,
|
||||||
|
OUT shared_blks_read int8,
|
||||||
|
OUT shared_blks_dirtied int8,
|
||||||
|
OUT shared_blks_written int8,
|
||||||
|
OUT local_blks_hit int8,
|
||||||
|
OUT local_blks_read int8,
|
||||||
|
OUT local_blks_dirtied int8,
|
||||||
|
OUT local_blks_written int8,
|
||||||
|
OUT temp_blks_read int8,
|
||||||
|
OUT temp_blks_written int8,
|
||||||
|
OUT blk_read_time float8,
|
||||||
|
OUT blk_write_time float8
|
||||||
|
)
|
||||||
|
RETURNS SETOF record
|
||||||
|
AS 'MODULE_PATHNAME'
|
||||||
|
LANGUAGE C;
|
||||||
|
|
||||||
|
CREATE VIEW pg_stat_statements AS
|
||||||
|
SELECT * FROM pg_stat_statements();
|
||||||
|
|
||||||
|
GRANT SELECT ON pg_stat_statements TO PUBLIC;
|
|
@ -0,0 +1,43 @@
|
||||||
|
/* contrib/pg_stat_statements/pg_stat_statements--1.1--1.2.sql */
|
||||||
|
|
||||||
|
-- complain if script is sourced in psql, rather than via ALTER EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION pg_stat_statements UPDATE TO '1.2'" to load this file. \quit
|
||||||
|
|
||||||
|
/* First we have to remove them from the extension */
|
||||||
|
ALTER EXTENSION pg_stat_statements DROP VIEW pg_stat_statements;
|
||||||
|
ALTER EXTENSION pg_stat_statements DROP FUNCTION pg_stat_statements();
|
||||||
|
|
||||||
|
/* Then we can drop them */
|
||||||
|
DROP VIEW pg_stat_statements;
|
||||||
|
DROP FUNCTION pg_stat_statements();
|
||||||
|
|
||||||
|
/* Now redefine */
|
||||||
|
CREATE FUNCTION pg_stat_statements(IN showtext boolean,
|
||||||
|
OUT userid oid,
|
||||||
|
OUT dbid oid,
|
||||||
|
OUT queryid bigint,
|
||||||
|
OUT query text,
|
||||||
|
OUT calls int8,
|
||||||
|
OUT total_time float8,
|
||||||
|
OUT rows int8,
|
||||||
|
OUT shared_blks_hit int8,
|
||||||
|
OUT shared_blks_read int8,
|
||||||
|
OUT shared_blks_dirtied int8,
|
||||||
|
OUT shared_blks_written int8,
|
||||||
|
OUT local_blks_hit int8,
|
||||||
|
OUT local_blks_read int8,
|
||||||
|
OUT local_blks_dirtied int8,
|
||||||
|
OUT local_blks_written int8,
|
||||||
|
OUT temp_blks_read int8,
|
||||||
|
OUT temp_blks_written int8,
|
||||||
|
OUT blk_read_time float8,
|
||||||
|
OUT blk_write_time float8
|
||||||
|
)
|
||||||
|
RETURNS SETOF record
|
||||||
|
AS 'MODULE_PATHNAME', 'pg_stat_statements_1_2'
|
||||||
|
LANGUAGE C STRICT VOLATILE;
|
||||||
|
|
||||||
|
CREATE VIEW pg_stat_statements AS
|
||||||
|
SELECT * FROM pg_stat_statements(true);
|
||||||
|
|
||||||
|
GRANT SELECT ON pg_stat_statements TO PUBLIC;
|
|
@ -0,0 +1,47 @@
|
||||||
|
/* contrib/pg_stat_statements/pg_stat_statements--1.2--1.3.sql */
|
||||||
|
|
||||||
|
-- complain if script is sourced in psql, rather than via ALTER EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION pg_stat_statements UPDATE TO '1.3'" to load this file. \quit
|
||||||
|
|
||||||
|
/* First we have to remove them from the extension */
|
||||||
|
ALTER EXTENSION pg_stat_statements DROP VIEW pg_stat_statements;
|
||||||
|
ALTER EXTENSION pg_stat_statements DROP FUNCTION pg_stat_statements(boolean);
|
||||||
|
|
||||||
|
/* Then we can drop them */
|
||||||
|
DROP VIEW pg_stat_statements;
|
||||||
|
DROP FUNCTION pg_stat_statements(boolean);
|
||||||
|
|
||||||
|
/* Now redefine */
|
||||||
|
CREATE FUNCTION pg_stat_statements(IN showtext boolean,
|
||||||
|
OUT userid oid,
|
||||||
|
OUT dbid oid,
|
||||||
|
OUT queryid bigint,
|
||||||
|
OUT query text,
|
||||||
|
OUT calls int8,
|
||||||
|
OUT total_time float8,
|
||||||
|
OUT min_time float8,
|
||||||
|
OUT max_time float8,
|
||||||
|
OUT mean_time float8,
|
||||||
|
OUT stddev_time float8,
|
||||||
|
OUT rows int8,
|
||||||
|
OUT shared_blks_hit int8,
|
||||||
|
OUT shared_blks_read int8,
|
||||||
|
OUT shared_blks_dirtied int8,
|
||||||
|
OUT shared_blks_written int8,
|
||||||
|
OUT local_blks_hit int8,
|
||||||
|
OUT local_blks_read int8,
|
||||||
|
OUT local_blks_dirtied int8,
|
||||||
|
OUT local_blks_written int8,
|
||||||
|
OUT temp_blks_read int8,
|
||||||
|
OUT temp_blks_written int8,
|
||||||
|
OUT blk_read_time float8,
|
||||||
|
OUT blk_write_time float8
|
||||||
|
)
|
||||||
|
RETURNS SETOF record
|
||||||
|
AS 'MODULE_PATHNAME', 'pg_stat_statements_1_3'
|
||||||
|
LANGUAGE C STRICT VOLATILE;
|
||||||
|
|
||||||
|
CREATE VIEW pg_stat_statements AS
|
||||||
|
SELECT * FROM pg_stat_statements(true);
|
||||||
|
|
||||||
|
GRANT SELECT ON pg_stat_statements TO PUBLIC;
|
|
@ -0,0 +1,7 @@
|
||||||
|
/* contrib/pg_stat_statements/pg_stat_statements--1.3--1.4.sql */
|
||||||
|
|
||||||
|
-- complain if script is sourced in psql, rather than via ALTER EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION pg_stat_statements UPDATE TO '1.4'" to load this file. \quit
|
||||||
|
|
||||||
|
ALTER FUNCTION pg_stat_statements_reset() PARALLEL SAFE;
|
||||||
|
ALTER FUNCTION pg_stat_statements(boolean) PARALLEL SAFE;
|
|
@ -0,0 +1,6 @@
|
||||||
|
/* contrib/pg_stat_statements/pg_stat_statements--1.4--1.5.sql */
|
||||||
|
|
||||||
|
-- complain if script is sourced in psql, rather than via ALTER EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION pg_stat_statements UPDATE TO '1.5'" to load this file. \quit
|
||||||
|
|
||||||
|
GRANT EXECUTE ON FUNCTION pg_stat_statements_reset() TO pg_read_all_stats;
|
|
@ -0,0 +1,48 @@
|
||||||
|
/* contrib/pg_stat_statements/pg_stat_statements--1.4.sql */
|
||||||
|
|
||||||
|
-- complain if script is sourced in psql, rather than via CREATE EXTENSION
|
||||||
|
\echo Use "CREATE EXTENSION pg_stat_statements" to load this file. \quit
|
||||||
|
|
||||||
|
-- Register functions.
|
||||||
|
CREATE FUNCTION pg_stat_statements_reset()
|
||||||
|
RETURNS void
|
||||||
|
AS 'MODULE_PATHNAME'
|
||||||
|
LANGUAGE C PARALLEL SAFE;
|
||||||
|
|
||||||
|
CREATE FUNCTION pg_stat_statements(IN showtext boolean,
|
||||||
|
OUT userid oid,
|
||||||
|
OUT dbid oid,
|
||||||
|
OUT queryid bigint,
|
||||||
|
OUT query text,
|
||||||
|
OUT calls int8,
|
||||||
|
OUT total_time float8,
|
||||||
|
OUT min_time float8,
|
||||||
|
OUT max_time float8,
|
||||||
|
OUT mean_time float8,
|
||||||
|
OUT stddev_time float8,
|
||||||
|
OUT rows int8,
|
||||||
|
OUT shared_blks_hit int8,
|
||||||
|
OUT shared_blks_read int8,
|
||||||
|
OUT shared_blks_dirtied int8,
|
||||||
|
OUT shared_blks_written int8,
|
||||||
|
OUT local_blks_hit int8,
|
||||||
|
OUT local_blks_read int8,
|
||||||
|
OUT local_blks_dirtied int8,
|
||||||
|
OUT local_blks_written int8,
|
||||||
|
OUT temp_blks_read int8,
|
||||||
|
OUT temp_blks_written int8,
|
||||||
|
OUT blk_read_time float8,
|
||||||
|
OUT blk_write_time float8
|
||||||
|
)
|
||||||
|
RETURNS SETOF record
|
||||||
|
AS 'MODULE_PATHNAME', 'pg_stat_statements_1_3'
|
||||||
|
LANGUAGE C STRICT VOLATILE PARALLEL SAFE;
|
||||||
|
|
||||||
|
-- Register a view on the function for ease of use.
|
||||||
|
CREATE VIEW pg_stat_statements AS
|
||||||
|
SELECT * FROM pg_stat_statements(true);
|
||||||
|
|
||||||
|
GRANT SELECT ON pg_stat_statements TO PUBLIC;
|
||||||
|
|
||||||
|
-- Don't want this to be available to non-superusers.
|
||||||
|
REVOKE ALL ON FUNCTION pg_stat_statements_reset() FROM PUBLIC;
|
|
@ -0,0 +1,7 @@
|
||||||
|
/* contrib/pg_stat_statements/pg_stat_statements--1.5--1.6.sql */
|
||||||
|
|
||||||
|
-- complain if script is sourced in psql, rather than via ALTER EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION pg_stat_statements UPDATE TO '1.6'" to load this file. \quit
|
||||||
|
|
||||||
|
-- Execution is only allowed for superusers, fixing issue with 1.5.
|
||||||
|
REVOKE EXECUTE ON FUNCTION pg_stat_statements_reset() FROM pg_read_all_stats;
|
|
@ -0,0 +1,8 @@
|
||||||
|
/* contrib/pg_stat_statements/pg_stat_statements--unpackaged--1.0.sql */
|
||||||
|
|
||||||
|
-- complain if script is sourced in psql, rather than via CREATE EXTENSION
|
||||||
|
\echo Use "CREATE EXTENSION pg_stat_statements FROM unpackaged" to load this file. \quit
|
||||||
|
|
||||||
|
ALTER EXTENSION pg_stat_statements ADD function pg_stat_statements_reset();
|
||||||
|
ALTER EXTENSION pg_stat_statements ADD function pg_stat_statements();
|
||||||
|
ALTER EXTENSION pg_stat_statements ADD view pg_stat_statements;
|
File diff suppressed because it is too large
Load Diff
|
@ -0,0 +1 @@
|
||||||
|
shared_preload_libraries = 'pg_stat_statements'
|
|
@ -0,0 +1,5 @@
|
||||||
|
# pg_stat_statements extension
|
||||||
|
comment = 'track execution statistics of all SQL statements executed'
|
||||||
|
default_version = '1.6'
|
||||||
|
module_pathname = '$libdir/pg_stat_statements'
|
||||||
|
relocatable = true
|
|
@ -0,0 +1,198 @@
|
||||||
|
CREATE EXTENSION pg_stat_statements;
|
||||||
|
|
||||||
|
--
|
||||||
|
-- simple and compound statements
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track_utility = FALSE;
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
|
||||||
|
SELECT 1 AS "int";
|
||||||
|
|
||||||
|
SELECT 'hello'
|
||||||
|
-- multiline
|
||||||
|
AS "text";
|
||||||
|
|
||||||
|
SELECT 'world' AS "text";
|
||||||
|
|
||||||
|
-- transaction
|
||||||
|
BEGIN;
|
||||||
|
SELECT 1 AS "int";
|
||||||
|
SELECT 'hello' AS "text";
|
||||||
|
COMMIT;
|
||||||
|
|
||||||
|
-- compound transaction
|
||||||
|
BEGIN \;
|
||||||
|
SELECT 2.0 AS "float" \;
|
||||||
|
SELECT 'world' AS "text" \;
|
||||||
|
COMMIT;
|
||||||
|
|
||||||
|
-- compound with empty statements and spurious leading spacing
|
||||||
|
\;\; SELECT 3 + 3 \;\;\; SELECT ' ' || ' !' \;\; SELECT 1 + 4 \;;
|
||||||
|
|
||||||
|
-- non ;-terminated statements
|
||||||
|
SELECT 1 + 1 + 1 AS "add" \gset
|
||||||
|
SELECT :add + 1 + 1 AS "add" \;
|
||||||
|
SELECT :add + 1 + 1 AS "add" \gset
|
||||||
|
|
||||||
|
-- set operator
|
||||||
|
SELECT 1 AS i UNION SELECT 2 ORDER BY i;
|
||||||
|
|
||||||
|
-- ? operator
|
||||||
|
select '{"a":1, "b":2}'::jsonb ? 'b';
|
||||||
|
|
||||||
|
-- cte
|
||||||
|
WITH t(f) AS (
|
||||||
|
VALUES (1.0), (2.0)
|
||||||
|
)
|
||||||
|
SELECT f FROM t ORDER BY f;
|
||||||
|
|
||||||
|
-- prepared statement with parameter
|
||||||
|
PREPARE pgss_test (int) AS SELECT $1, 'test' LIMIT 1;
|
||||||
|
EXECUTE pgss_test(1);
|
||||||
|
DEALLOCATE pgss_test;
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
|
||||||
|
--
|
||||||
|
-- CRUD: INSERT SELECT UPDATE DELETE on test table
|
||||||
|
--
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
|
||||||
|
-- utility "create table" should not be shown
|
||||||
|
CREATE TEMP TABLE test (a int, b char(20));
|
||||||
|
|
||||||
|
INSERT INTO test VALUES(generate_series(1, 10), 'aaa');
|
||||||
|
UPDATE test SET b = 'bbb' WHERE a > 7;
|
||||||
|
DELETE FROM test WHERE a > 9;
|
||||||
|
|
||||||
|
-- explicit transaction
|
||||||
|
BEGIN;
|
||||||
|
UPDATE test SET b = '111' WHERE a = 1 ;
|
||||||
|
COMMIT;
|
||||||
|
|
||||||
|
BEGIN \;
|
||||||
|
UPDATE test SET b = '222' WHERE a = 2 \;
|
||||||
|
COMMIT ;
|
||||||
|
|
||||||
|
UPDATE test SET b = '333' WHERE a = 3 \;
|
||||||
|
UPDATE test SET b = '444' WHERE a = 4 ;
|
||||||
|
|
||||||
|
BEGIN \;
|
||||||
|
UPDATE test SET b = '555' WHERE a = 5 \;
|
||||||
|
UPDATE test SET b = '666' WHERE a = 6 \;
|
||||||
|
COMMIT ;
|
||||||
|
|
||||||
|
-- many INSERT values
|
||||||
|
INSERT INTO test (a, b) VALUES (1, 'a'), (2, 'b'), (3, 'c');
|
||||||
|
|
||||||
|
-- SELECT with constants
|
||||||
|
SELECT * FROM test WHERE a > 5 ORDER BY a ;
|
||||||
|
|
||||||
|
SELECT *
|
||||||
|
FROM test
|
||||||
|
WHERE a > 9
|
||||||
|
ORDER BY a ;
|
||||||
|
|
||||||
|
-- SELECT without constants
|
||||||
|
SELECT * FROM test ORDER BY a;
|
||||||
|
|
||||||
|
-- SELECT with IN clause
|
||||||
|
SELECT * FROM test WHERE a IN (1, 2, 3, 4, 5);
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
|
||||||
|
--
|
||||||
|
-- pg_stat_statements.track = none
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track = 'none';
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
|
||||||
|
SELECT 1 AS "one";
|
||||||
|
SELECT 1 + 1 AS "two";
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
|
||||||
|
--
|
||||||
|
-- pg_stat_statements.track = top
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track = 'top';
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
|
||||||
|
DO LANGUAGE plpgsql $$
|
||||||
|
BEGIN
|
||||||
|
-- this is a SELECT
|
||||||
|
PERFORM 'hello world'::TEXT;
|
||||||
|
END;
|
||||||
|
$$;
|
||||||
|
|
||||||
|
-- PL/pgSQL function
|
||||||
|
CREATE FUNCTION PLUS_TWO(i INTEGER) RETURNS INTEGER AS $$
|
||||||
|
DECLARE
|
||||||
|
r INTEGER;
|
||||||
|
BEGIN
|
||||||
|
SELECT (i + 1 + 1.0)::INTEGER INTO r;
|
||||||
|
RETURN r;
|
||||||
|
END; $$ LANGUAGE plpgsql;
|
||||||
|
|
||||||
|
SELECT PLUS_TWO(3);
|
||||||
|
SELECT PLUS_TWO(7);
|
||||||
|
|
||||||
|
-- SQL function --- use LIMIT to keep it from being inlined
|
||||||
|
CREATE FUNCTION PLUS_ONE(i INTEGER) RETURNS INTEGER AS
|
||||||
|
$$ SELECT (i + 1.0)::INTEGER LIMIT 1 $$ LANGUAGE SQL;
|
||||||
|
|
||||||
|
SELECT PLUS_ONE(8);
|
||||||
|
SELECT PLUS_ONE(10);
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
|
||||||
|
--
|
||||||
|
-- pg_stat_statements.track = all
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track = 'all';
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
|
||||||
|
-- we drop and recreate the functions to avoid any caching funnies
|
||||||
|
DROP FUNCTION PLUS_ONE(INTEGER);
|
||||||
|
DROP FUNCTION PLUS_TWO(INTEGER);
|
||||||
|
|
||||||
|
-- PL/pgSQL function
|
||||||
|
CREATE FUNCTION PLUS_TWO(i INTEGER) RETURNS INTEGER AS $$
|
||||||
|
DECLARE
|
||||||
|
r INTEGER;
|
||||||
|
BEGIN
|
||||||
|
SELECT (i + 1 + 1.0)::INTEGER INTO r;
|
||||||
|
RETURN r;
|
||||||
|
END; $$ LANGUAGE plpgsql;
|
||||||
|
|
||||||
|
SELECT PLUS_TWO(-1);
|
||||||
|
SELECT PLUS_TWO(2);
|
||||||
|
|
||||||
|
-- SQL function --- use LIMIT to keep it from being inlined
|
||||||
|
CREATE FUNCTION PLUS_ONE(i INTEGER) RETURNS INTEGER AS
|
||||||
|
$$ SELECT (i + 1.0)::INTEGER LIMIT 1 $$ LANGUAGE SQL;
|
||||||
|
|
||||||
|
SELECT PLUS_ONE(3);
|
||||||
|
SELECT PLUS_ONE(1);
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
|
||||||
|
--
|
||||||
|
-- utility commands
|
||||||
|
--
|
||||||
|
SET pg_stat_statements.track_utility = TRUE;
|
||||||
|
SELECT pg_stat_statements_reset();
|
||||||
|
|
||||||
|
SELECT 1;
|
||||||
|
CREATE INDEX test_b ON test(b);
|
||||||
|
DROP TABLE test \;
|
||||||
|
DROP TABLE IF EXISTS test \;
|
||||||
|
DROP FUNCTION PLUS_ONE(INTEGER);
|
||||||
|
DROP TABLE IF EXISTS test \;
|
||||||
|
DROP TABLE IF EXISTS test \;
|
||||||
|
DROP FUNCTION IF EXISTS PLUS_ONE(INTEGER);
|
||||||
|
DROP FUNCTION PLUS_TWO(INTEGER);
|
||||||
|
|
||||||
|
SELECT query, calls, rows FROM pg_stat_statements ORDER BY query COLLATE "C";
|
||||||
|
|
||||||
|
DROP EXTENSION pg_stat_statements;
|
Loading…
Reference in New Issue