diff options
Diffstat (limited to 'contrib')
| -rw-r--r-- | contrib/test_decoding/expected/messages.out | 5 | ||||
| -rw-r--r-- | contrib/test_decoding/sql/messages.sql | 5 |
2 files changed, 6 insertions, 4 deletions
diff --git a/contrib/test_decoding/expected/messages.out b/contrib/test_decoding/expected/messages.out index 0fd70036bd5..84baf8af3ee 100644 --- a/contrib/test_decoding/expected/messages.out +++ b/contrib/test_decoding/expected/messages.out @@ -6,13 +6,14 @@ SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot', 'test_d init (1 row) -SELECT 'msg1' FROM pg_logical_emit_message(true, 'test', 'msg1'); +-- These two cover the path for the flush variant. +SELECT 'msg1' FROM pg_logical_emit_message(true, 'test', 'msg1', true); ?column? ---------- msg1 (1 row) -SELECT 'msg2' FROM pg_logical_emit_message(false, 'test', 'msg2'); +SELECT 'msg2' FROM pg_logical_emit_message(false, 'test', 'msg2', true); ?column? ---------- msg2 diff --git a/contrib/test_decoding/sql/messages.sql b/contrib/test_decoding/sql/messages.sql index 3d8500f99cb..1f3dcb63ee7 100644 --- a/contrib/test_decoding/sql/messages.sql +++ b/contrib/test_decoding/sql/messages.sql @@ -3,8 +3,9 @@ SET synchronous_commit = on; SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot', 'test_decoding'); -SELECT 'msg1' FROM pg_logical_emit_message(true, 'test', 'msg1'); -SELECT 'msg2' FROM pg_logical_emit_message(false, 'test', 'msg2'); +-- These two cover the path for the flush variant. +SELECT 'msg1' FROM pg_logical_emit_message(true, 'test', 'msg1', true); +SELECT 'msg2' FROM pg_logical_emit_message(false, 'test', 'msg2', true); BEGIN; SELECT 'msg3' FROM pg_logical_emit_message(true, 'test', 'msg3'); |