diff options
Diffstat (limited to 'contrib/test_decoding/sql')
| -rw-r--r-- | contrib/test_decoding/sql/messages.sql | 5 |
1 files changed, 3 insertions, 2 deletions
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'); |