40 lines
1.7 KiB
RPMSpec
40 lines
1.7 KiB
RPMSpec
|
# Test decoding only the commit record of the transaction that have
|
||
|
|
# modified catalogs.
|
||
|
|
setup
|
||
|
|
{
|
||
|
|
DROP TABLE IF EXISTS tbl1;
|
||
|
|
CREATE TABLE tbl1 (val1 integer, val2 integer);
|
||
|
|
}
|
||
|
|
|
||
|
|
teardown
|
||
|
|
{
|
||
|
|
DROP TABLE tbl1;
|
||
|
|
SELECT 'stop' FROM pg_drop_replication_slot('isolation_slot');
|
||
|
|
}
|
||
|
|
|
||
|
|
session "s0"
|
||
|
|
setup { SET synchronous_commit=on; }
|
||
|
|
step "s0_init" { SELECT 'init' FROM pg_create_logical_replication_slot('isolation_slot', 'test_decoding'); }
|
||
|
|
step "s0_begin" { BEGIN; }
|
||
|
|
step "s0_savepoint" { SAVEPOINT sp1; }
|
||
|
|
step "s0_truncate" { TRUNCATE tbl1; }
|
||
|
|
step "s0_insert" { INSERT INTO tbl1 VALUES (1); }
|
||
|
|
step "s0_commit" { COMMIT; }
|
||
|
|
|
||
|
|
session "s1"
|
||
|
|
setup { SET synchronous_commit=on; }
|
||
|
|
step "s1_checkpoint" { CHECKPOINT; }
|
||
|
|
step "s1_get_changes" { SELECT data FROM pg_logical_slot_get_changes('isolation_slot', NULL, NULL, 'skip-empty-xacts', '1', 'include-xids', '0'); }
|
||
|
|
|
||
|
|
# For the transaction that TRUNCATEd the table tbl1, the last decoding decodes
|
||
|
|
# only its COMMIT record, because it starts from the RUNNING_XACTS record emitted
|
||
|
|
# during the first checkpoint execution. This transaction must be marked as
|
||
|
|
# containing catalog changes while decoding the COMMIT record and the decoding
|
||
|
|
# of the INSERT record must read the pg_class with the correct historic snapshot.
|
||
|
|
#
|
||
|
|
# Note that in a case where bgwriter wrote the RUNNING_XACTS record between "s0_commit"
|
||
|
|
# and "s0_begin", this doesn't happen as the decoding starts from the RUNNING_XACTS
|
||
|
|
# record written by bgwriter. One might think we can either stop the bgwriter or
|
||
|
|
# increase LOG_SNAPSHOT_INTERVAL_MS but it's not practical via tests.
|
||
|
|
permutation "s0_init" "s0_begin" "s0_savepoint" "s0_truncate" "s1_checkpoint" "s1_get_changes" "s0_commit" "s0_begin" "s0_insert" "s1_checkpoint" "s1_get_changes" "s0_commit" "s1_get_changes"
|