diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-16 19:46:48 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-16 19:46:48 +0000 |
commit | 311bcfc6b3acdd6fd152798c7f287ddf74fa2a98 (patch) | |
tree | 0ec307299b1dada3701e42f4ca6eda57d708261e /src/test/modules/commit_ts/sql | |
parent | Initial commit. (diff) | |
download | postgresql-15-upstream.tar.xz postgresql-15-upstream.zip |
Adding upstream version 15.4.upstream/15.4upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/test/modules/commit_ts/sql')
-rw-r--r-- | src/test/modules/commit_ts/sql/commit_timestamp.sql | 64 |
1 files changed, 64 insertions, 0 deletions
diff --git a/src/test/modules/commit_ts/sql/commit_timestamp.sql b/src/test/modules/commit_ts/sql/commit_timestamp.sql new file mode 100644 index 0000000..3bb7bb2 --- /dev/null +++ b/src/test/modules/commit_ts/sql/commit_timestamp.sql @@ -0,0 +1,64 @@ +-- +-- Commit Timestamp +-- +SHOW track_commit_timestamp; +CREATE TABLE committs_test(id serial, ts timestamptz default now()); + +INSERT INTO committs_test DEFAULT VALUES; +INSERT INTO committs_test DEFAULT VALUES; +INSERT INTO committs_test DEFAULT VALUES; + +SELECT id, + pg_xact_commit_timestamp(xmin) >= ts, + pg_xact_commit_timestamp(xmin) <= now(), + pg_xact_commit_timestamp(xmin) - ts < '60s' -- 60s should give a lot of reserve +FROM committs_test +ORDER BY id; + +DROP TABLE committs_test; + +SELECT pg_xact_commit_timestamp('0'::xid); +SELECT pg_xact_commit_timestamp('1'::xid); +SELECT pg_xact_commit_timestamp('2'::xid); + +SELECT x.xid::text::bigint > 0 as xid_valid, + x.timestamp > '-infinity'::timestamptz AS ts_low, + x.timestamp <= now() AS ts_high, + roident != 0 AS valid_roident + FROM pg_last_committed_xact() x; + +-- Test non-normal transaction ids. +SELECT * FROM pg_xact_commit_timestamp_origin(NULL); -- ok, NULL +SELECT * FROM pg_xact_commit_timestamp_origin('0'::xid); -- error +SELECT * FROM pg_xact_commit_timestamp_origin('1'::xid); -- ok, NULL +SELECT * FROM pg_xact_commit_timestamp_origin('2'::xid); -- ok, NULL + +-- Test transaction without replication origin +SELECT txid_current() as txid_no_origin \gset +SELECT x.timestamp > '-infinity'::timestamptz AS ts_low, + x.timestamp <= now() AS ts_high, + roident != 0 AS valid_roident + FROM pg_last_committed_xact() x; +SELECT x.timestamp > '-infinity'::timestamptz AS ts_low, + x.timestamp <= now() AS ts_high, + roident != 0 AS valid_roident + FROM pg_xact_commit_timestamp_origin(:'txid_no_origin') x; + +-- Test transaction with replication origin +SELECT pg_replication_origin_create('regress_commit_ts: get_origin') != 0 + AS valid_roident; +SELECT pg_replication_origin_session_setup('regress_commit_ts: get_origin'); +SELECT txid_current() as txid_with_origin \gset +SELECT x.timestamp > '-infinity'::timestamptz AS ts_low, + x.timestamp <= now() AS ts_high, + r.roname + FROM pg_last_committed_xact() x, pg_replication_origin r + WHERE r.roident = x.roident; +SELECT x.timestamp > '-infinity'::timestamptz AS ts_low, + x.timestamp <= now() AS ts_high, + r.roname + FROM pg_xact_commit_timestamp_origin(:'txid_with_origin') x, pg_replication_origin r + WHERE r.roident = x.roident; + +SELECT pg_replication_origin_session_reset(); +SELECT pg_replication_origin_drop('regress_commit_ts: get_origin'); |