25
25
INSERT INTO test_prepared1 VALUES (5);
26
26
ALTER TABLE test_prepared1 ADD COLUMN data text;
27
27
INSERT INTO test_prepared1 VALUES (6, 'frakbar');
28
+ LOCK test_prepared1;
28
29
PREPARE TRANSACTION 'test_prepared#3';
29
30
-- test that we decode correctly while an uncommitted prepared xact
30
31
-- with ddl exists.
@@ -44,27 +45,33 @@ SELECT data FROM pg_logical_slot_get_changes('regression_slot', NULL, NULL, 'inc
44
45
-------------------------------------------------------------------------
45
46
BEGIN
46
47
table public.test_prepared1: INSERT: id[integer]:1
47
- COMMIT
48
+ PREPARE
49
+ COMMIT PREPARED
48
50
BEGIN
49
51
table public.test_prepared1: INSERT: id[integer]:2
50
52
COMMIT
51
53
BEGIN
52
- table public.test_prepared1: INSERT: id[integer]:4
53
- COMMIT
54
+ table public.test_prepared1: INSERT: id[integer]:3
55
+ PREPARE
56
+ ABORT PREPARED
54
57
BEGIN
55
- table public.test_prepared2 : INSERT: id[integer]:7
58
+ table public.test_prepared1 : INSERT: id[integer]:4
56
59
COMMIT
57
60
BEGIN
58
61
table public.test_prepared1: INSERT: id[integer]:5
59
62
table public.test_prepared1: INSERT: id[integer]:6 data[text]:'frakbar'
63
+ PREPARE
64
+ BEGIN
65
+ table public.test_prepared2: INSERT: id[integer]:7
60
66
COMMIT
67
+ COMMIT PREPARED
61
68
BEGIN
62
69
table public.test_prepared1: INSERT: id[integer]:8 data[text]:null
63
70
COMMIT
64
71
BEGIN
65
72
table public.test_prepared2: INSERT: id[integer]:9
66
73
COMMIT
67
- (22 rows)
74
+ (28 rows)
68
75
69
76
SELECT pg_drop_replication_slot('regression_slot');
70
77
pg_drop_replication_slot