summaryrefslogtreecommitdiff
path: root/src/test/regress/sql/object_address.sql
diff options
context:
space:
mode:
authorPeter Eisentraut2017-03-23 12:36:36 +0000
committerPeter Eisentraut2017-03-23 12:55:37 +0000
commit7c4f52409a8c7d85ed169bbbc1f6092274d03920 (patch)
treefa3dc592bb2855e5cc0a200f4c408b4c8d299be5 /src/test/regress/sql/object_address.sql
parent707576b571f05ec5b89adb65964d55f3ccccbd1b (diff)
Logical replication support for initial data copy
Add functionality for a new subscription to copy the initial data in the tables and then sync with the ongoing apply process. For the copying, add a new internal COPY option to have the COPY source data provided by a callback function. The initial data copy works on the subscriber by receiving COPY data from the publisher and then providing it locally into a COPY that writes to the destination table. A WAL receiver can now execute full SQL commands. This is used here to obtain information about tables and publications. Several new options were added to CREATE and ALTER SUBSCRIPTION to control whether and when initial table syncing happens. Change pg_dump option --no-create-subscription-slots to --no-subscription-connect and use the new CREATE SUBSCRIPTION ... NOCONNECT option for that. Author: Petr Jelinek <[email protected]> Tested-by: Erik Rijkers <[email protected]>
Diffstat (limited to 'src/test/regress/sql/object_address.sql')
-rw-r--r--src/test/regress/sql/object_address.sql2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/test/regress/sql/object_address.sql b/src/test/regress/sql/object_address.sql
index 6b85fe29497..28476daff18 100644
--- a/src/test/regress/sql/object_address.sql
+++ b/src/test/regress/sql/object_address.sql
@@ -40,7 +40,7 @@ CREATE TRANSFORM FOR int LANGUAGE SQL (
FROM SQL WITH FUNCTION varchar_transform(internal),
TO SQL WITH FUNCTION int4recv(internal));
CREATE PUBLICATION addr_pub FOR TABLE addr_nsp.gentable;
-CREATE SUBSCRIPTION addr_sub CONNECTION '' PUBLICATION bar WITH (DISABLED, NOCREATE SLOT);
+CREATE SUBSCRIPTION addr_sub CONNECTION '' PUBLICATION bar WITH (DISABLED, NOCONNECT);
-- test some error cases
SELECT pg_get_object_address('stone', '{}', '{}');