aboutsummaryrefslogtreecommitdiff
path: root/contrib/test_decoding/sql/replorigin.sql
diff options
context:
space:
mode:
authorAndres Freund <andres@anarazel.de>2016-04-13 17:38:54 -0700
committerAndres Freund <andres@anarazel.de>2016-04-13 17:38:54 -0700
commitbe65eddd80093a923b091dc60776aa6f966d1f07 (patch)
treee8e58ef17ea0fddbf173b032039c99dd6ac92f09 /contrib/test_decoding/sql/replorigin.sql
parent80abbeba23d466b6541cf95082a9e1f36704424e (diff)
downloadpostgresql-be65eddd80093a923b091dc60776aa6f966d1f07.tar.gz
postgresql-be65eddd80093a923b091dc60776aa6f966d1f07.zip
Add required database and origin filtering for logical messages.
Logical messages, added in 3fe3511d05, during decoding failed to filter messages emitted in other databases and messages emitted "under" a replication origin the output plugin isn't interested in. Add tests to verify that both types of filtering actually work. While touching message.sql remove hunk obsoleted by d25379e. Bump XLOG_PAGE_MAGIC because xl_logical_message changed and because 3fe3511d05 had omitted doing so. 3fe3511d05 additionally didn't bump catversion, but 7a542700d has done so since. Author: Petr Jelinek Reported-By: Andres Freund Discussion: 20160406142513.wotqy3ba3kanr423@alap3.anarazel.de
Diffstat (limited to 'contrib/test_decoding/sql/replorigin.sql')
-rw-r--r--contrib/test_decoding/sql/replorigin.sql2
1 files changed, 2 insertions, 0 deletions
diff --git a/contrib/test_decoding/sql/replorigin.sql b/contrib/test_decoding/sql/replorigin.sql
index e12404e106e..7870f0ea321 100644
--- a/contrib/test_decoding/sql/replorigin.sql
+++ b/contrib/test_decoding/sql/replorigin.sql
@@ -31,6 +31,8 @@ SELECT pg_replication_origin_session_setup('test_decoding: regression_slot');
-- ensure we prevent duplicate setup
SELECT pg_replication_origin_session_setup('test_decoding: regression_slot');
+SELECT '' FROM pg_logical_emit_message(false, 'test', 'this message will not be decoded');
+
BEGIN;
-- setup transaction origin
SELECT pg_replication_origin_xact_setup('0/aabbccdd', '2013-01-01 00:00');