database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-06-26 12:21:12 +03:00
Code Activity

Doc: Make logical replication examples executable in bulk.

Browse Source 
To improve the usability of logical replication examples, we need to
enable bulk copy-pasting of DML/DDL series.

Currently, output command tags and prompts disrupt this workflow. While
prompts are typically removed, converting them to comments is acceptable
here, given the multi-server context.

Additionally, ensure all examples containing operators like < and > are
wrapped in CDATA blocks to guarantee correct rendering and consistency
with other places.

Author: David G. Johnston <david.g.johnston@gmail.com>
Reviewed-by: Peter Smith <smithpb2250@gmail.com>
Discussion: https://postgr.es/m/CAKFQuwbhbL1uaDTuo9shmo1rA-fX6XGotR7qZQ7rd-ia5ZDoQA@mail.gmail.com
This commit is contained in:
Amit Kapila
2025-05-26 11:05:05 +05:30
parent 47d90b741d
commit 3bcb554fd2
1 changed files with 175 additions and 270 deletions
Download Patch File Download Diff File Expand all files Collapse all files

429
doc/src/sgml/logical-replication.sgml
View File

@ -363,34 +363,25 @@
<para> <para>
Create some test tables on the publisher. Create some test tables on the publisher.
<programlisting> <programlisting>
test_pub=# CREATE TABLE t1(a int, b text, PRIMARY KEY(a)); /* pub # */ CREATE TABLE t1(a int, b text, PRIMARY KEY(a));
CREATE TABLE /* pub # */ CREATE TABLE t2(c int, d text, PRIMARY KEY(c));
test_pub=# CREATE TABLE t2(c int, d text, PRIMARY KEY(c)); /* pub # */ CREATE TABLE t3(e int, f text, PRIMARY KEY(e));
CREATE TABLE
test_pub=# CREATE TABLE t3(e int, f text, PRIMARY KEY(e));
CREATE TABLE
</programlisting></para> </programlisting></para>
<para> <para>
Create the same tables on the subscriber. Create the same tables on the subscriber.
<programlisting> <programlisting>
test_sub=# CREATE TABLE t1(a int, b text, PRIMARY KEY(a)); /* sub # */ CREATE TABLE t1(a int, b text, PRIMARY KEY(a));
CREATE TABLE /* sub # */ CREATE TABLE t2(c int, d text, PRIMARY KEY(c));
test_sub=# CREATE TABLE t2(c int, d text, PRIMARY KEY(c)); /* sub # */ CREATE TABLE t3(e int, f text, PRIMARY KEY(e));
CREATE TABLE
test_sub=# CREATE TABLE t3(e int, f text, PRIMARY KEY(e));
CREATE TABLE
</programlisting></para> </programlisting></para>
<para> <para>
Insert data to the tables at the publisher side. Insert data to the tables at the publisher side.
<programlisting> <programlisting>
test_pub=# INSERT INTO t1 VALUES (1, 'one'), (2, 'two'), (3, 'three'); /* pub # */ INSERT INTO t1 VALUES (1, 'one'), (2, 'two'), (3, 'three');
INSERT 0 3 /* pub # */ INSERT INTO t2 VALUES (1, 'A'), (2, 'B'), (3, 'C');
test_pub=# INSERT INTO t2 VALUES (1, 'A'), (2, 'B'), (3, 'C'); /* pub # */ INSERT INTO t3 VALUES (1, 'i'), (2, 'ii'), (3, 'iii');
INSERT 0 3
test_pub=# INSERT INTO t3 VALUES (1, 'i'), (2, 'ii'), (3, 'iii');
INSERT 0 3
</programlisting></para> </programlisting></para>
<para> <para>
@ -399,41 +390,34 @@ INSERT 0 3
<link linkend="sql-createpublication-params-with-publish"><literal>publish</literal></link> <link linkend="sql-createpublication-params-with-publish"><literal>publish</literal></link>
operations. The publication <literal>pub3b</literal> has a row filter (see operations. The publication <literal>pub3b</literal> has a row filter (see
<xref linkend="logical-replication-row-filter"/>). <xref linkend="logical-replication-row-filter"/>).
<programlisting> <programlisting><![CDATA[
test_pub=# CREATE PUBLICATION pub1 FOR TABLE t1; /* pub # */ CREATE PUBLICATION pub1 FOR TABLE t1;
CREATE PUBLICATION /* pub # */ CREATE PUBLICATION pub2 FOR TABLE t2 WITH (publish = 'truncate');
test_pub=# CREATE PUBLICATION pub2 FOR TABLE t2 WITH (publish = 'truncate'); /* pub # */ CREATE PUBLICATION pub3a FOR TABLE t3 WITH (publish = 'truncate');
CREATE PUBLICATION /* pub # */ CREATE PUBLICATION pub3b FOR TABLE t3 WHERE (e > 5);
test_pub=# CREATE PUBLICATION pub3a FOR TABLE t3 WITH (publish = 'truncate'); ]]></programlisting></para>
CREATE PUBLICATION
test_pub=# CREATE PUBLICATION pub3b FOR TABLE t3 WHERE (e > 5);
CREATE PUBLICATION
</programlisting></para>
<para> <para>
Create subscriptions for the publications. The subscription Create subscriptions for the publications. The subscription
<literal>sub3</literal> subscribes to both <literal>pub3a</literal> and <literal>sub3</literal> subscribes to both <literal>pub3a</literal> and
<literal>pub3b</literal>. All subscriptions will copy initial data by default. <literal>pub3b</literal>. All subscriptions will copy initial data by default.
<programlisting> <programlisting>
test_sub=# CREATE SUBSCRIPTION sub1 /* sub # */ CREATE SUBSCRIPTION sub1
test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=sub1' /* sub - */ CONNECTION 'host=localhost dbname=test_pub application_name=sub1'
test_sub-# PUBLICATION pub1; /* sub - */ PUBLICATION pub1;
CREATE SUBSCRIPTION /* sub # */ CREATE SUBSCRIPTION sub2
test_sub=# CREATE SUBSCRIPTION sub2 /* sub - */ CONNECTION 'host=localhost dbname=test_pub application_name=sub2'
test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=sub2' /* sub - */ PUBLICATION pub2;
test_sub-# PUBLICATION pub2; /* sub # */ CREATE SUBSCRIPTION sub3
CREATE SUBSCRIPTION /* sub - */ CONNECTION 'host=localhost dbname=test_pub application_name=sub3'
test_sub=# CREATE SUBSCRIPTION sub3 /* sub - */ PUBLICATION pub3a, pub3b;
test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=sub3'
test_sub-# PUBLICATION pub3a, pub3b;
CREATE SUBSCRIPTION
</programlisting></para> </programlisting></para>
<para> <para>
Observe that initial table data is copied, regardless of the Observe that initial table data is copied, regardless of the
<literal>publish</literal> operation of the publication. <literal>publish</literal> operation of the publication.
<programlisting> <programlisting>
test_sub=# SELECT * FROM t1; /* sub # */ SELECT * FROM t1;
a | b a | b
---+------- ---+-------
1 | one 1 | one
@ -441,7 +425,7 @@ test_sub=# SELECT * FROM t1;
3 | three 3 | three
(3 rows) (3 rows)
test_sub=# SELECT * FROM t2; /* sub # */ SELECT * FROM t2;
c | d c | d
---+--- ---+---
1 | A 1 | A
@ -456,7 +440,7 @@ test_sub=# SELECT * FROM t2;
it means the copied table <literal>t3</literal> contains all rows even when it means the copied table <literal>t3</literal> contains all rows even when
they do not match the row filter of publication <literal>pub3b</literal>. they do not match the row filter of publication <literal>pub3b</literal>.
<programlisting> <programlisting>
test_sub=# SELECT * FROM t3; /* sub # */ SELECT * FROM t3;
e | f e | f
---+----- ---+-----
1 | i 1 | i
@ -468,18 +452,15 @@ test_sub=# SELECT * FROM t3;
<para> <para>
Insert more data to the tables at the publisher side. Insert more data to the tables at the publisher side.
<programlisting> <programlisting>
test_pub=# INSERT INTO t1 VALUES (4, 'four'), (5, 'five'), (6, 'six'); /* pub # */ INSERT INTO t1 VALUES (4, 'four'), (5, 'five'), (6, 'six');
INSERT 0 3 /* pub # */ INSERT INTO t2 VALUES (4, 'D'), (5, 'E'), (6, 'F');
test_pub=# INSERT INTO t2 VALUES (4, 'D'), (5, 'E'), (6, 'F'); /* pub # */ INSERT INTO t3 VALUES (4, 'iv'), (5, 'v'), (6, 'vi');
INSERT 0 3
test_pub=# INSERT INTO t3 VALUES (4, 'iv'), (5, 'v'), (6, 'vi');
INSERT 0 3
</programlisting></para> </programlisting></para>
<para> <para>
Now the publisher side data looks like: Now the publisher side data looks like:
<programlisting> <programlisting>
test_pub=# SELECT * FROM t1; /* pub # */ SELECT * FROM t1;
a | b a | b
---+------- ---+-------
1 | one 1 | one
@ -490,7 +471,7 @@ test_pub=# SELECT * FROM t1;
6 | six 6 | six
(6 rows) (6 rows)
test_pub=# SELECT * FROM t2; /* pub # */ SELECT * FROM t2;
c | d c | d
---+--- ---+---
1 | A 1 | A
@ -501,7 +482,7 @@ test_pub=# SELECT * FROM t2;
6 | F 6 | F
(6 rows) (6 rows)
test_pub=# SELECT * FROM t3; /* pub # */ SELECT * FROM t3;
e | f e | f
---+----- ---+-----
1 | i 1 | i
@ -521,7 +502,7 @@ test_pub=# SELECT * FROM t3;
only replicate data that matches the row filter of <literal>pub3b</literal>. only replicate data that matches the row filter of <literal>pub3b</literal>.
Now the subscriber side data looks like: Now the subscriber side data looks like:
<programlisting> <programlisting>
test_sub=# SELECT * FROM t1; /* sub # */ SELECT * FROM t1;
a | b a | b
---+------- ---+-------
1 | one 1 | one
@ -532,7 +513,7 @@ test_sub=# SELECT * FROM t1;
6 | six 6 | six
(6 rows) (6 rows)
test_sub=# SELECT * FROM t2; /* sub # */ SELECT * FROM t2;
c | d c | d
---+--- ---+---
1 | A 1 | A
@ -540,7 +521,7 @@ test_sub=# SELECT * FROM t2;
3 | C 3 | C
(3 rows) (3 rows)
test_sub=# SELECT * FROM t3; /* sub # */ SELECT * FROM t3;
e | f e | f
---+----- ---+-----
1 | i 1 | i
@ -567,8 +548,7 @@ test_sub=# SELECT * FROM t3;
<para> <para>
First, create a publication for the examples to use. First, create a publication for the examples to use.
<programlisting> <programlisting>
test_pub=# CREATE PUBLICATION pub1 FOR ALL TABLES; /* pub # */ CREATE PUBLICATION pub1 FOR ALL TABLES;
CREATE PUBLICATION
</programlisting></para> </programlisting></para>
<para> <para>
Example 1: Where the subscription says <literal>connect = false</literal> Example 1: Where the subscription says <literal>connect = false</literal>
@ -579,13 +559,12 @@ CREATE PUBLICATION
<para> <para>
Create the subscription. Create the subscription.
<programlisting> <programlisting>
test_sub=# CREATE SUBSCRIPTION sub1 /* sub # */ CREATE SUBSCRIPTION sub1
test_sub-# CONNECTION 'host=localhost dbname=test_pub' /* sub - */ CONNECTION 'host=localhost dbname=test_pub'
test_sub-# PUBLICATION pub1 /* sub - */ PUBLICATION pub1
test_sub-# WITH (connect=false); /* sub - */ WITH (connect=false);
WARNING: subscription was created, but is not connected WARNING: subscription was created, but is not connected
HINT: To initiate replication, you must manually create the replication slot, enable the subscription, and refresh the subscription. HINT: To initiate replication, you must manually create the replication slot, enable the subscription, and refresh the subscription.
CREATE SUBSCRIPTION
</programlisting></para> </programlisting></para>
</listitem> </listitem>
<listitem> <listitem>
@ -594,7 +573,7 @@ CREATE SUBSCRIPTION
specified during <literal>CREATE SUBSCRIPTION</literal>, the name of the specified during <literal>CREATE SUBSCRIPTION</literal>, the name of the
slot to create is same as the subscription name, e.g. "sub1". slot to create is same as the subscription name, e.g. "sub1".
<programlisting> <programlisting>
test_pub=# SELECT * FROM pg_create_logical_replication_slot('sub1', 'pgoutput'); /* pub # */ SELECT * FROM pg_create_logical_replication_slot('sub1', 'pgoutput');
slot_name | lsn slot_name | lsn
-----------+----------- -----------+-----------
sub1 | 0/19404D0 sub1 | 0/19404D0
@ -606,10 +585,8 @@ test_pub=# SELECT * FROM pg_create_logical_replication_slot('sub1', 'pgoutput');
On the subscriber, complete the activation of the subscription. After On the subscriber, complete the activation of the subscription. After
this the tables of <literal>pub1</literal> will start replicating. this the tables of <literal>pub1</literal> will start replicating.
<programlisting> <programlisting>
test_sub=# ALTER SUBSCRIPTION sub1 ENABLE; /* sub # */ ALTER SUBSCRIPTION sub1 ENABLE;
ALTER SUBSCRIPTION /* sub # */ ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION;
test_sub=# ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION;
ALTER SUBSCRIPTION
</programlisting></para> </programlisting></para>
</listitem> </listitem>
</itemizedlist> </itemizedlist>
@ -625,13 +602,12 @@ ALTER SUBSCRIPTION
<para> <para>
Create the subscription. Create the subscription.
<programlisting> <programlisting>
test_sub=# CREATE SUBSCRIPTION sub1 /* sub # */ CREATE SUBSCRIPTION sub1
test_sub-# CONNECTION 'host=localhost dbname=test_pub' /* sub - */ CONNECTION 'host=localhost dbname=test_pub'
test_sub-# PUBLICATION pub1 /* sub - */ PUBLICATION pub1
test_sub-# WITH (connect=false, slot_name='myslot'); /* sub - */ WITH (connect=false, slot_name='myslot');
WARNING: subscription was created, but is not connected WARNING: subscription was created, but is not connected
HINT: To initiate replication, you must manually create the replication slot, enable the subscription, and refresh the subscription. HINT: To initiate replication, you must manually create the replication slot, enable the subscription, and refresh the subscription.
CREATE SUBSCRIPTION
</programlisting></para> </programlisting></para>
</listitem> </listitem>
<listitem> <listitem>
@ -639,7 +615,7 @@ CREATE SUBSCRIPTION
On the publisher, manually create a slot using the same name that was On the publisher, manually create a slot using the same name that was
specified during <literal>CREATE SUBSCRIPTION</literal>, e.g. "myslot". specified during <literal>CREATE SUBSCRIPTION</literal>, e.g. "myslot".
<programlisting> <programlisting>
test_pub=# SELECT * FROM pg_create_logical_replication_slot('myslot', 'pgoutput'); /* pub # */ SELECT * FROM pg_create_logical_replication_slot('myslot', 'pgoutput');
slot_name | lsn slot_name | lsn
-----------+----------- -----------+-----------
myslot | 0/19059A0 myslot | 0/19059A0
@ -651,10 +627,8 @@ test_pub=# SELECT * FROM pg_create_logical_replication_slot('myslot', 'pgoutput'
On the subscriber, the remaining subscription activation steps are the On the subscriber, the remaining subscription activation steps are the
same as before. same as before.
<programlisting> <programlisting>
test_sub=# ALTER SUBSCRIPTION sub1 ENABLE; /* sub # */ ALTER SUBSCRIPTION sub1 ENABLE;
ALTER SUBSCRIPTION /* sub # */ ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION;
test_sub=# ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION;
ALTER SUBSCRIPTION
</programlisting></para> </programlisting></para>
</listitem> </listitem>
</itemizedlist> </itemizedlist>
@ -669,18 +643,17 @@ ALTER SUBSCRIPTION
<literal>enabled = false</literal>, and <literal>enabled = false</literal>, and
<literal>create_slot = false</literal> are also needed. <literal>create_slot = false</literal> are also needed.
<programlisting> <programlisting>
test_sub=# CREATE SUBSCRIPTION sub1 /* sub # */ CREATE SUBSCRIPTION sub1
test_sub-# CONNECTION 'host=localhost dbname=test_pub' /* sub - */ CONNECTION 'host=localhost dbname=test_pub'
test_sub-# PUBLICATION pub1 /* sub - */ PUBLICATION pub1
test_sub-# WITH (slot_name=NONE, enabled=false, create_slot=false); /* sub - */ WITH (slot_name=NONE, enabled=false, create_slot=false);
CREATE SUBSCRIPTION
</programlisting></para> </programlisting></para>
</listitem> </listitem>
<listitem> <listitem>
<para> <para>
On the publisher, manually create a slot using any name, e.g. "myslot". On the publisher, manually create a slot using any name, e.g. "myslot".
<programlisting> <programlisting>
test_pub=# SELECT * FROM pg_create_logical_replication_slot('myslot', 'pgoutput'); /* pub # */ SELECT * FROM pg_create_logical_replication_slot('myslot', 'pgoutput');
slot_name | lsn slot_name | lsn
-----------+----------- -----------+-----------
myslot | 0/1905930 myslot | 0/1905930
@ -692,18 +665,15 @@ test_pub=# SELECT * FROM pg_create_logical_replication_slot('myslot', 'pgoutput'
On the subscriber, associate the subscription with the slot name just On the subscriber, associate the subscription with the slot name just
created. created.
<programlisting> <programlisting>
test_sub=# ALTER SUBSCRIPTION sub1 SET (slot_name='myslot'); /* sub # */ ALTER SUBSCRIPTION sub1 SET (slot_name='myslot');
ALTER SUBSCRIPTION
</programlisting></para> </programlisting></para>
</listitem> </listitem>
<listitem> <listitem>
<para> <para>
The remaining subscription activation steps are same as before. The remaining subscription activation steps are same as before.
<programlisting> <programlisting>
test_sub=# ALTER SUBSCRIPTION sub1 ENABLE; /* sub # */ ALTER SUBSCRIPTION sub1 ENABLE;
ALTER SUBSCRIPTION /* sub # */ ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION;
test_sub=# ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION;
ALTER SUBSCRIPTION
</programlisting></para> </programlisting></para>
</listitem> </listitem>
</itemizedlist> </itemizedlist>
@ -752,7 +722,7 @@ ALTER SUBSCRIPTION
will return the relevant replication slots associated with the will return the relevant replication slots associated with the
failover-enabled subscriptions. failover-enabled subscriptions.
<programlisting> <programlisting>
test_sub=# SELECT /* sub # */ SELECT
array_agg(quote_literal(s.subslotname)) AS slots array_agg(quote_literal(s.subslotname)) AS slots
FROM pg_subscription s FROM pg_subscription s
WHERE s.subfailover AND WHERE s.subfailover AND
@ -775,7 +745,7 @@ test_sub=# SELECT
as they will either be dropped or re-created on the new primary server in those as they will either be dropped or re-created on the new primary server in those
cases. cases.
<programlisting> <programlisting>
test_sub=# SELECT /* sub # */ SELECT
array_agg(quote_literal(slot_name)) AS slots array_agg(quote_literal(slot_name)) AS slots
FROM FROM
( (
@ -794,7 +764,7 @@ test_sub=# SELECT
Check that the logical replication slots identified above exist on Check that the logical replication slots identified above exist on
the standby server and are ready for failover. the standby server and are ready for failover.
<programlisting> <programlisting>
test_standby=# SELECT slot_name, (synced AND NOT temporary AND NOT conflicting) AS failover_ready /* standby # */ SELECT slot_name, (synced AND NOT temporary AND NOT conflicting) AS failover_ready
FROM pg_replication_slots FROM pg_replication_slots
WHERE slot_name IN WHERE slot_name IN
('sub1','sub2','sub3', 'pg_16394_sync_16385_7394666715149055164'); ('sub1','sub2','sub3', 'pg_16394_sync_16385_7394666715149055164');
@ -1024,12 +994,9 @@ test_standby=# SELECT slot_name, (synced AND NOT temporary AND NOT conflicting)
<para> <para>
Create some tables to be used in the following examples. Create some tables to be used in the following examples.
<programlisting> <programlisting>
test_pub=# CREATE TABLE t1(a int, b int, c text, PRIMARY KEY(a,c)); /* pub # */ CREATE TABLE t1(a int, b int, c text, PRIMARY KEY(a,c));
CREATE TABLE /* pub # */ CREATE TABLE t2(d int, e int, f int, PRIMARY KEY(d));
test_pub=# CREATE TABLE t2(d int, e int, f int, PRIMARY KEY(d)); /* pub # */ CREATE TABLE t3(g int, h int, i int, PRIMARY KEY(g));
CREATE TABLE
test_pub=# CREATE TABLE t3(g int, h int, i int, PRIMARY KEY(g));
CREATE TABLE
</programlisting></para> </programlisting></para>
<para> <para>
@ -1038,20 +1005,17 @@ CREATE TABLE
<literal>p2</literal> has two tables. Table <literal>t1</literal> has no row <literal>p2</literal> has two tables. Table <literal>t1</literal> has no row
filter, and table <literal>t2</literal> has a row filter. Publication filter, and table <literal>t2</literal> has a row filter. Publication
<literal>p3</literal> has two tables, and both of them have a row filter. <literal>p3</literal> has two tables, and both of them have a row filter.
<programlisting> <programlisting><![CDATA[
test_pub=# CREATE PUBLICATION p1 FOR TABLE t1 WHERE (a > 5 AND c = 'NSW'); /* pub # */ CREATE PUBLICATION p1 FOR TABLE t1 WHERE (a > 5 AND c = 'NSW');
CREATE PUBLICATION /* pub # */ CREATE PUBLICATION p2 FOR TABLE t1, t2 WHERE (e = 99);
test_pub=# CREATE PUBLICATION p2 FOR TABLE t1, t2 WHERE (e = 99); /* pub # */ CREATE PUBLICATION p3 FOR TABLE t2 WHERE (d = 10), t3 WHERE (g = 10);
CREATE PUBLICATION ]]></programlisting></para>
test_pub=# CREATE PUBLICATION p3 FOR TABLE t2 WHERE (d = 10), t3 WHERE (g = 10);
CREATE PUBLICATION
</programlisting></para>
<para> <para>
<command>psql</command> can be used to show the row filter expressions (if <command>psql</command> can be used to show the row filter expressions (if
defined) for each publication. defined) for each publication.
<programlisting> <programlisting><![CDATA[
test_pub=# \dRp+ /* pub # */ \dRp+
Publication p1 Publication p1
Owner | All tables | Inserts | Updates | Deletes | Truncates | Via root Owner | All tables | Inserts | Updates | Deletes | Truncates | Via root
----------+------------+---------+---------+---------+-----------+---------- ----------+------------+---------+---------+---------+-----------+----------
@ -1074,7 +1038,7 @@ Tables:
Tables: Tables:
"public.t2" WHERE (d = 10) "public.t2" WHERE (d = 10)
"public.t3" WHERE (g = 10) "public.t3" WHERE (g = 10)
</programlisting></para> ]]></programlisting></para>
<para> <para>
<command>psql</command> can be used to show the row filter expressions (if <command>psql</command> can be used to show the row filter expressions (if
@ -1082,8 +1046,8 @@ Tables:
of two publications, but has a row filter only in <literal>p1</literal>. of two publications, but has a row filter only in <literal>p1</literal>.
See that table <literal>t2</literal> is a member of two publications, and See that table <literal>t2</literal> is a member of two publications, and
has a different row filter in each of them. has a different row filter in each of them.
<programlisting> <programlisting><![CDATA[
test_pub=# \d t1 /* pub # */ \d t1
Table "public.t1" Table "public.t1"
Column | Type | Collation | Nullable | Default Column | Type | Collation | Nullable | Default
--------+---------+-----------+----------+--------- --------+---------+-----------+----------+---------
@ -1096,7 +1060,7 @@ Publications:
"p1" WHERE ((a > 5) AND (c = 'NSW'::text)) "p1" WHERE ((a > 5) AND (c = 'NSW'::text))
"p2" "p2"
test_pub=# \d t2 /* pub # */ \d t2
Table "public.t2" Table "public.t2"
Column | Type | Collation | Nullable | Default Column | Type | Collation | Nullable | Default
--------+---------+-----------+----------+--------- --------+---------+-----------+----------+---------
@ -1109,7 +1073,7 @@ Publications:
"p2" WHERE (e = 99) "p2" WHERE (e = 99)
"p3" WHERE (d = 10) "p3" WHERE (d = 10)
test_pub=# \d t3 /* pub # */ \d t3
Table "public.t3" Table "public.t3"
Column | Type | Collation | Nullable | Default Column | Type | Collation | Nullable | Default
--------+---------+-----------+----------+--------- --------+---------+-----------+----------+---------
@ -1120,43 +1084,33 @@ Indexes:
"t3_pkey" PRIMARY KEY, btree (g) "t3_pkey" PRIMARY KEY, btree (g)
Publications: Publications:
"p3" WHERE (g = 10) "p3" WHERE (g = 10)
</programlisting></para> ]]></programlisting></para>
<para> <para>
On the subscriber node, create a table <literal>t1</literal> with the same On the subscriber node, create a table <literal>t1</literal> with the same
definition as the one on the publisher, and also create the subscription definition as the one on the publisher, and also create the subscription
<literal>s1</literal> that subscribes to the publication <literal>p1</literal>. <literal>s1</literal> that subscribes to the publication <literal>p1</literal>.
<programlisting> <programlisting>
test_sub=# CREATE TABLE t1(a int, b int, c text, PRIMARY KEY(a,c)); /* sub # */ CREATE TABLE t1(a int, b int, c text, PRIMARY KEY(a,c));
CREATE TABLE /* sub # */ CREATE SUBSCRIPTION s1
test_sub=# CREATE SUBSCRIPTION s1 /* sub - */ CONNECTION 'host=localhost dbname=test_pub application_name=s1'
test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=s1' /* sub - */ PUBLICATION p1;
test_sub-# PUBLICATION p1;
CREATE SUBSCRIPTION
</programlisting></para> </programlisting></para>
<para> <para>
Insert some rows. Only the rows satisfying the <literal>t1 WHERE</literal> Insert some rows. Only the rows satisfying the <literal>t1 WHERE</literal>
clause of publication <literal>p1</literal> are replicated. clause of publication <literal>p1</literal> are replicated.
<programlisting> <programlisting>
test_pub=# INSERT INTO t1 VALUES (2, 102, 'NSW'); /* pub # */ INSERT INTO t1 VALUES (2, 102, 'NSW');
INSERT 0 1 /* pub # */ INSERT INTO t1 VALUES (3, 103, 'QLD');
test_pub=# INSERT INTO t1 VALUES (3, 103, 'QLD'); /* pub # */ INSERT INTO t1 VALUES (4, 104, 'VIC');
INSERT 0 1 /* pub # */ INSERT INTO t1 VALUES (5, 105, 'ACT');
test_pub=# INSERT INTO t1 VALUES (4, 104, 'VIC'); /* pub # */ INSERT INTO t1 VALUES (6, 106, 'NSW');
INSERT 0 1 /* pub # */ INSERT INTO t1 VALUES (7, 107, 'NT');
test_pub=# INSERT INTO t1 VALUES (5, 105, 'ACT'); /* pub # */ INSERT INTO t1 VALUES (8, 108, 'QLD');
INSERT 0 1 /* pub # */ INSERT INTO t1 VALUES (9, 109, 'NSW');
test_pub=# INSERT INTO t1 VALUES (6, 106, 'NSW');
INSERT 0 1
test_pub=# INSERT INTO t1 VALUES (7, 107, 'NT');
INSERT 0 1
test_pub=# INSERT INTO t1 VALUES (8, 108, 'QLD');
INSERT 0 1
test_pub=# INSERT INTO t1 VALUES (9, 109, 'NSW');
INSERT 0 1
test_pub=# SELECT * FROM t1; /* pub # */ SELECT * FROM t1;
a | b | c a | b | c
---+-----+----- ---+-----+-----
2 | 102 | NSW 2 | 102 | NSW
@ -1170,7 +1124,7 @@ test_pub=# SELECT * FROM t1;
(8 rows) (8 rows)
</programlisting> </programlisting>
<programlisting> <programlisting>
test_sub=# SELECT * FROM t1; /* sub # */ SELECT * FROM t1;
a | b | c a | b | c
---+-----+----- ---+-----+-----
6 | 106 | NSW 6 | 106 | NSW
@ -1184,10 +1138,9 @@ test_sub=# SELECT * FROM t1;
<literal>p1</literal>. The <command>UPDATE</command> replicates <literal>p1</literal>. The <command>UPDATE</command> replicates
the change as normal. the change as normal.
<programlisting> <programlisting>
test_pub=# UPDATE t1 SET b = 999 WHERE a = 6; /* pub # */ UPDATE t1 SET b = 999 WHERE a = 6;
UPDATE 1
test_pub=# SELECT * FROM t1; /* pub # */ SELECT * FROM t1;
a | b | c a | b | c
---+-----+----- ---+-----+-----
2 | 102 | NSW 2 | 102 | NSW
@ -1201,7 +1154,7 @@ test_pub=# SELECT * FROM t1;
(8 rows) (8 rows)
</programlisting> </programlisting>
<programlisting> <programlisting>
test_sub=# SELECT * FROM t1; /* sub # */ SELECT * FROM t1;
a | b | c a | b | c
---+-----+----- ---+-----+-----
9 | 109 | NSW 9 | 109 | NSW
@ -1216,10 +1169,9 @@ test_sub=# SELECT * FROM t1;
transformed into an <command>INSERT</command> and the change is replicated. transformed into an <command>INSERT</command> and the change is replicated.
See the new row on the subscriber. See the new row on the subscriber.
<programlisting> <programlisting>
test_pub=# UPDATE t1 SET a = 555 WHERE a = 2; /* pub # */ UPDATE t1 SET a = 555 WHERE a = 2;
UPDATE 1
test_pub=# SELECT * FROM t1; /* pub # */ SELECT * FROM t1;
a | b | c a | b | c
-----+-----+----- -----+-----+-----
3 | 103 | QLD 3 | 103 | QLD
@ -1233,7 +1185,7 @@ test_pub=# SELECT * FROM t1;
(8 rows) (8 rows)
</programlisting> </programlisting>
<programlisting> <programlisting>
test_sub=# SELECT * FROM t1; /* sub # */ SELECT * FROM t1;
a | b | c a | b | c
-----+-----+----- -----+-----+-----
9 | 109 | NSW 9 | 109 | NSW
@ -1249,10 +1201,9 @@ test_sub=# SELECT * FROM t1;
transformed into a <command>DELETE</command> and the change is replicated. transformed into a <command>DELETE</command> and the change is replicated.
See that the row is removed from the subscriber. See that the row is removed from the subscriber.
<programlisting> <programlisting>
test_pub=# UPDATE t1 SET c = 'VIC' WHERE a = 9; /* pub # */ UPDATE t1 SET c = 'VIC' WHERE a = 9;
UPDATE 1
test_pub=# SELECT * FROM t1; /* pub # */ SELECT * FROM t1;
a | b | c a | b | c
-----+-----+----- -----+-----+-----
3 | 103 | QLD 3 | 103 | QLD
@ -1266,7 +1217,7 @@ test_pub=# SELECT * FROM t1;
(8 rows) (8 rows)
</programlisting> </programlisting>
<programlisting> <programlisting>
test_sub=# SELECT * FROM t1; /* sub # */ SELECT * FROM t1;
a | b | c a | b | c
-----+-----+----- -----+-----+-----
6 | 999 | NSW 6 | 999 | NSW
@ -1284,17 +1235,13 @@ test_sub=# SELECT * FROM t1;
<para> <para>
Create a partitioned table on the publisher. Create a partitioned table on the publisher.
<programlisting> <programlisting>
test_pub=# CREATE TABLE parent(a int PRIMARY KEY) PARTITION BY RANGE(a); /* pub # */ CREATE TABLE parent(a int PRIMARY KEY) PARTITION BY RANGE(a);
CREATE TABLE /* pub # */ CREATE TABLE child PARTITION OF parent DEFAULT;
test_pub=# CREATE TABLE child PARTITION OF parent DEFAULT;
CREATE TABLE
</programlisting> </programlisting>
Create the same tables on the subscriber. Create the same tables on the subscriber.
<programlisting> <programlisting>
test_sub=# CREATE TABLE parent(a int PRIMARY KEY) PARTITION BY RANGE(a); /* sub # */ CREATE TABLE parent(a int PRIMARY KEY) PARTITION BY RANGE(a);
CREATE TABLE /* sub # */ CREATE TABLE child PARTITION OF parent DEFAULT;
test_sub=# CREATE TABLE child PARTITION OF parent DEFAULT;
CREATE TABLE
</programlisting></para> </programlisting></para>
<para> <para>
@ -1302,16 +1249,14 @@ CREATE TABLE
publication parameter <literal>publish_via_partition_root</literal> is set publication parameter <literal>publish_via_partition_root</literal> is set
as true. There are row filters defined on both the partitioned table as true. There are row filters defined on both the partitioned table
(<literal>parent</literal>), and on the partition (<literal>child</literal>). (<literal>parent</literal>), and on the partition (<literal>child</literal>).
<programlisting><![CDATA[
/* pub # */ CREATE PUBLICATION p4 FOR TABLE parent WHERE (a < 5), child WHERE (a >= 5)
/* pub - */ WITH (publish_via_partition_root=true);
]]></programlisting>
<programlisting> <programlisting>
test_pub=# CREATE PUBLICATION p4 FOR TABLE parent WHERE (a &lt; 5), child WHERE (a >= 5) /* sub # */ CREATE SUBSCRIPTION s4
test_pub-# WITH (publish_via_partition_root=true); /* sub - */ CONNECTION 'host=localhost dbname=test_pub application_name=s4'
CREATE PUBLICATION /* sub - */ PUBLICATION p4;
</programlisting>
<programlisting>
test_sub=# CREATE SUBSCRIPTION s4
test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=s4'
test_sub-# PUBLICATION p4;
CREATE SUBSCRIPTION
</programlisting></para> </programlisting></para>
<para> <para>
@ -1320,12 +1265,10 @@ CREATE SUBSCRIPTION
<literal>parent</literal> (because <literal>publish_via_partition_root</literal> <literal>parent</literal> (because <literal>publish_via_partition_root</literal>
is true). is true).
<programlisting> <programlisting>
test_pub=# INSERT INTO parent VALUES (2), (4), (6); /* pub # */ INSERT INTO parent VALUES (2), (4), (6);
INSERT 0 3 /* pub # */ INSERT INTO child VALUES (3), (5), (7);
test_pub=# INSERT INTO child VALUES (3), (5), (7);
INSERT 0 3
test_pub=# SELECT * FROM parent ORDER BY a; /* pub # */ SELECT * FROM parent ORDER BY a;
a a
--- ---
2 2
@ -1337,7 +1280,7 @@ test_pub=# SELECT * FROM parent ORDER BY a;
(6 rows) (6 rows)
</programlisting> </programlisting>
<programlisting> <programlisting>
test_sub=# SELECT * FROM parent ORDER BY a; /* sub # */ SELECT * FROM parent ORDER BY a;
a a
--- ---
2 2
@ -1350,16 +1293,13 @@ test_sub=# SELECT * FROM parent ORDER BY a;
Repeat the same test, but with a different value for <literal>publish_via_partition_root</literal>. Repeat the same test, but with a different value for <literal>publish_via_partition_root</literal>.
The publication parameter <literal>publish_via_partition_root</literal> is The publication parameter <literal>publish_via_partition_root</literal> is
set as false. A row filter is defined on the partition (<literal>child</literal>). set as false. A row filter is defined on the partition (<literal>child</literal>).
<programlisting><![CDATA[
/* pub # */ DROP PUBLICATION p4;
/* pub # */ CREATE PUBLICATION p4 FOR TABLE parent, child WHERE (a >= 5)
/* pub - */ WITH (publish_via_partition_root=false);
]]></programlisting>
<programlisting> <programlisting>
test_pub=# DROP PUBLICATION p4; /* sub # */ ALTER SUBSCRIPTION s4 REFRESH PUBLICATION;
DROP PUBLICATION
test_pub=# CREATE PUBLICATION p4 FOR TABLE parent, child WHERE (a >= 5)
test_pub-# WITH (publish_via_partition_root=false);
CREATE PUBLICATION
</programlisting>
<programlisting>
test_sub=# ALTER SUBSCRIPTION s4 REFRESH PUBLICATION;
ALTER SUBSCRIPTION
</programlisting></para> </programlisting></para>
<para> <para>
@ -1367,14 +1307,11 @@ ALTER SUBSCRIPTION
row filter of <literal>child</literal> (because row filter of <literal>child</literal> (because
<literal>publish_via_partition_root</literal> is false). <literal>publish_via_partition_root</literal> is false).
<programlisting> <programlisting>
test_pub=# TRUNCATE parent; /* pub # */ TRUNCATE parent;
TRUNCATE TABLE /* pub # */ INSERT INTO parent VALUES (2), (4), (6);
test_pub=# INSERT INTO parent VALUES (2), (4), (6); /* pub # */ INSERT INTO child VALUES (3), (5), (7);
INSERT 0 3
test_pub=# INSERT INTO child VALUES (3), (5), (7);
INSERT 0 3
test_pub=# SELECT * FROM parent ORDER BY a; /* pub # */ SELECT * FROM parent ORDER BY a;
a a
--- ---
2 2
@ -1386,7 +1323,7 @@ test_pub=# SELECT * FROM parent ORDER BY a;
(6 rows) (6 rows)
</programlisting> </programlisting>
<programlisting> <programlisting>
test_sub=# SELECT * FROM child ORDER BY a; /* sub # */ SELECT * FROM child ORDER BY a;
a a
--- ---
5 5
@ -1505,8 +1442,7 @@ test_sub=# SELECT * FROM child ORDER BY a;
<para> <para>
Create a table <literal>t1</literal> to be used in the following example. Create a table <literal>t1</literal> to be used in the following example.
<programlisting> <programlisting>
test_pub=# CREATE TABLE t1(id int, a text, b text, c text, d text, e text, PRIMARY KEY(id)); /* pub # */ CREATE TABLE t1(id int, a text, b text, c text, d text, e text, PRIMARY KEY(id));
CREATE TABLE
</programlisting></para> </programlisting></para>
<para> <para>
@ -1515,15 +1451,14 @@ CREATE TABLE
replicated. Notice that the order of column names in the column list does replicated. Notice that the order of column names in the column list does
not matter. not matter.
<programlisting> <programlisting>
test_pub=# CREATE PUBLICATION p1 FOR TABLE t1 (id, b, a, d); /* pub # */ CREATE PUBLICATION p1 FOR TABLE t1 (id, b, a, d);
CREATE PUBLICATION
</programlisting></para> </programlisting></para>
<para> <para>
<literal>psql</literal> can be used to show the column lists (if defined) <literal>psql</literal> can be used to show the column lists (if defined)
for each publication. for each publication.
<programlisting> <programlisting>
test_pub=# \dRp+ /* pub # */ \dRp+
Publication p1 Publication p1
Owner | All tables | Inserts | Updates | Deletes | Truncates | Via root Owner | All tables | Inserts | Updates | Deletes | Truncates | Via root
----------+------------+---------+---------+---------+-----------+---------- ----------+------------+---------+---------+---------+-----------+----------
@ -1536,7 +1471,7 @@ Tables:
<literal>psql</literal> can be used to show the column lists (if defined) <literal>psql</literal> can be used to show the column lists (if defined)
for each table. for each table.
<programlisting> <programlisting>
test_pub=# \d t1 /* pub # */ \d t1
Table "public.t1" Table "public.t1"
Column | Type | Collation | Nullable | Default Column | Type | Collation | Nullable | Default
--------+---------+-----------+----------+--------- --------+---------+-----------+----------+---------
@ -1559,24 +1494,19 @@ Publications:
<literal>s1</literal> that subscribes to the publication <literal>s1</literal> that subscribes to the publication
<literal>p1</literal>. <literal>p1</literal>.
<programlisting> <programlisting>
test_sub=# CREATE TABLE t1(id int, b text, a text, d text, PRIMARY KEY(id)); /* sub # */ CREATE TABLE t1(id int, b text, a text, d text, PRIMARY KEY(id));
CREATE TABLE /* sub # */ CREATE SUBSCRIPTION s1
test_sub=# CREATE SUBSCRIPTION s1 /* sub - */ CONNECTION 'host=localhost dbname=test_pub application_name=s1'
test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=s1' /* sub - */ PUBLICATION p1;
test_sub-# PUBLICATION p1;
CREATE SUBSCRIPTION
</programlisting></para> </programlisting></para>
<para> <para>
On the publisher node, insert some rows to table <literal>t1</literal>. On the publisher node, insert some rows to table <literal>t1</literal>.
<programlisting> <programlisting>
test_pub=# INSERT INTO t1 VALUES(1, 'a-1', 'b-1', 'c-1', 'd-1', 'e-1'); /* pub # */ INSERT INTO t1 VALUES(1, 'a-1', 'b-1', 'c-1', 'd-1', 'e-1');
INSERT 0 1 /* pub # */ INSERT INTO t1 VALUES(2, 'a-2', 'b-2', 'c-2', 'd-2', 'e-2');
test_pub=# INSERT INTO t1 VALUES(2, 'a-2', 'b-2', 'c-2', 'd-2', 'e-2'); /* pub # */ INSERT INTO t1 VALUES(3, 'a-3', 'b-3', 'c-3', 'd-3', 'e-3');
INSERT 0 1 /* pub # */ SELECT * FROM t1 ORDER BY id;
test_pub=# INSERT INTO t1 VALUES(3, 'a-3', 'b-3', 'c-3', 'd-3', 'e-3');
INSERT 0 1
test_pub=# SELECT * FROM t1 ORDER BY id;
id | a | b | c | d | e id | a | b | c | d | e
----+-----+-----+-----+-----+----- ----+-----+-----+-----+-----+-----
1 | a-1 | b-1 | c-1 | d-1 | e-1 1 | a-1 | b-1 | c-1 | d-1 | e-1
@ -1589,7 +1519,7 @@ test_pub=# SELECT * FROM t1 ORDER BY id;
Only data from the column list of publication <literal>p1</literal> is Only data from the column list of publication <literal>p1</literal> is
replicated. replicated.
<programlisting> <programlisting>
test_sub=# SELECT * FROM t1 ORDER BY id; /* sub # */ SELECT * FROM t1 ORDER BY id;
id | b | a | d id | b | a | d
----+-----+-----+----- ----+-----+-----+-----
1 | b-1 | a-1 | d-1 1 | b-1 | a-1 | d-1
@ -1617,13 +1547,10 @@ test_sub=# SELECT * FROM t1 ORDER BY id;
For example, note below that subscriber table generated column value comes from the For example, note below that subscriber table generated column value comes from the
subscriber column's calculation. subscriber column's calculation.
<programlisting> <programlisting>
test_pub=# CREATE TABLE tab_gen_to_gen (a int, b int GENERATED ALWAYS AS (a + 1) STORED); /* pub # */ CREATE TABLE tab_gen_to_gen (a int, b int GENERATED ALWAYS AS (a + 1) STORED);
CREATE TABLE /* pub # */ INSERT INTO tab_gen_to_gen VALUES (1),(2),(3);
test_pub=# INSERT INTO tab_gen_to_gen VALUES (1),(2),(3); /* pub # */ CREATE PUBLICATION pub1 FOR TABLE tab_gen_to_gen;
INSERT 0 3 /* pub # */ SELECT * FROM tab_gen_to_gen;
test_pub=# CREATE PUBLICATION pub1 FOR TABLE tab_gen_to_gen;
CREATE PUBLICATION
test_pub=# SELECT * FROM tab_gen_to_gen;
a | b a | b
---+--- ---+---
1 | 2 1 | 2
@ -1631,11 +1558,9 @@ test_pub=# SELECT * FROM tab_gen_to_gen;
3 | 4 3 | 4
(3 rows) (3 rows)
test_sub=# CREATE TABLE tab_gen_to_gen (a int, b int GENERATED ALWAYS AS (a * 100) STORED); /* sub # */ CREATE TABLE tab_gen_to_gen (a int, b int GENERATED ALWAYS AS (a * 100) STORED);
CREATE TABLE /* sub # */ CREATE SUBSCRIPTION sub1 CONNECTION 'dbname=test_pub' PUBLICATION pub1;
test_sub=# CREATE SUBSCRIPTION sub1 CONNECTION 'dbname=test_pub' PUBLICATION pub1; /* sub # */ SELECT * from tab_gen_to_gen;
CREATE SUBSCRIPTION
test_sub=# SELECT * from tab_gen_to_gen;
a | b a | b
---+---- ---+----
1 | 100 1 | 100
@ -2690,8 +2615,7 @@ CONTEXT: processing remote data for replication origin "pg_16395" during "INSER
<link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>, <link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node2=# ALTER SUBSCRIPTION sub1_node1_node2 DISABLE; /* node2 # */ ALTER SUBSCRIPTION sub1_node1_node2 DISABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -2780,8 +2704,7 @@ pg_ctl -D /opt/PostgreSQL/data2_upgraded start -l logfile
<xref linkend="two-node-cluster-disable-subscriptions-node2"/> <xref linkend="two-node-cluster-disable-subscriptions-node2"/>
and now, e.g.: and now, e.g.:
<programlisting> <programlisting>
node2=# CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40)); /* node2 # */ CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40));
CREATE TABLE
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -2793,8 +2716,7 @@ CREATE TABLE
<link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>, <link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node2=# ALTER SUBSCRIPTION sub1_node1_node2 ENABLE; /* node2 # */ ALTER SUBSCRIPTION sub1_node1_node2 ENABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -2805,8 +2727,7 @@ ALTER SUBSCRIPTION
<link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>, <link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node2=# ALTER SUBSCRIPTION sub1_node1_node2 REFRESH PUBLICATION; /* node2 # */ ALTER SUBSCRIPTION sub1_node1_node2 REFRESH PUBLICATION;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -2844,8 +2765,7 @@ ALTER SUBSCRIPTION
<link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>, <link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node2=# ALTER SUBSCRIPTION sub1_node1_node2 DISABLE; /* node2 # */ ALTER SUBSCRIPTION sub1_node1_node2 DISABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -2896,8 +2816,7 @@ pg_ctl -D /opt/PostgreSQL/data1_upgraded start -l logfile
<link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>, <link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node3=# ALTER SUBSCRIPTION sub1_node2_node3 DISABLE; /* node3 # */ ALTER SUBSCRIPTION sub1_node2_node3 DISABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -2948,8 +2867,7 @@ pg_ctl -D /opt/PostgreSQL/data2_upgraded start -l logfile
<xref linkend="cascaded-cluster-disable-sub-node1-node2"/> <xref linkend="cascaded-cluster-disable-sub-node1-node2"/>
and now, e.g.: and now, e.g.:
<programlisting> <programlisting>
node2=# CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40)); /* node2 # */ CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40));
CREATE TABLE
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -2961,8 +2879,7 @@ CREATE TABLE
<link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>, <link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node2=# ALTER SUBSCRIPTION sub1_node1_node2 ENABLE; /* node2 # */ ALTER SUBSCRIPTION sub1_node1_node2 ENABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -2973,8 +2890,7 @@ ALTER SUBSCRIPTION
<link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>, <link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node2=# ALTER SUBSCRIPTION sub1_node1_node2 REFRESH PUBLICATION; /* node2 # */ ALTER SUBSCRIPTION sub1_node1_node2 REFRESH PUBLICATION;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3025,8 +2941,7 @@ pg_ctl -D /opt/PostgreSQL/data3_upgraded start -l logfile
<xref linkend="cascaded-cluster-disable-sub-node2-node3"/> and now, <xref linkend="cascaded-cluster-disable-sub-node2-node3"/> and now,
e.g.: e.g.:
<programlisting> <programlisting>
node3=# CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40)); /* node3 # */ CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40));
CREATE TABLE
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3038,8 +2953,7 @@ CREATE TABLE
<link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>, <link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node3=# ALTER SUBSCRIPTION sub1_node2_node3 ENABLE; /* node3 # */ ALTER SUBSCRIPTION sub1_node2_node3 ENABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3050,8 +2964,7 @@ ALTER SUBSCRIPTION
<link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>, <link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node3=# ALTER SUBSCRIPTION sub1_node2_node3 REFRESH PUBLICATION; /* node3 # */ ALTER SUBSCRIPTION sub1_node2_node3 REFRESH PUBLICATION;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3082,8 +2995,7 @@ ALTER SUBSCRIPTION
<link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>, <link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node2=# ALTER SUBSCRIPTION sub1_node1_node2 DISABLE; /* node2 # */ ALTER SUBSCRIPTION sub1_node1_node2 DISABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3134,8 +3046,7 @@ pg_ctl -D /opt/PostgreSQL/data1_upgraded start -l logfile
<link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>, <link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node2=# ALTER SUBSCRIPTION sub1_node1_node2 ENABLE; /* node2 # */ ALTER SUBSCRIPTION sub1_node1_node2 ENABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3146,8 +3057,7 @@ ALTER SUBSCRIPTION
<literal>node2</literal> between <xref linkend="circular-cluster-disable-sub-node2"/> <literal>node2</literal> between <xref linkend="circular-cluster-disable-sub-node2"/>
and now, e.g.: and now, e.g.:
<programlisting> <programlisting>
node1=# CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40)); /* node1 # */ CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40));
CREATE TABLE
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3160,8 +3070,7 @@ CREATE TABLE
<link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>, <link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node1=# ALTER SUBSCRIPTION sub1_node2_node1 REFRESH PUBLICATION; /* node1 # */ ALTER SUBSCRIPTION sub1_node2_node1 REFRESH PUBLICATION;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3173,8 +3082,7 @@ ALTER SUBSCRIPTION
<link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>, <link linkend="sql-altersubscription-params-disable"><command>ALTER SUBSCRIPTION ... DISABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node1=# ALTER SUBSCRIPTION sub1_node2_node1 DISABLE; /* node1 # */ ALTER SUBSCRIPTION sub1_node2_node1 DISABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3225,8 +3133,7 @@ pg_ctl -D /opt/PostgreSQL/data2_upgraded start -l logfile
<link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>, <link linkend="sql-altersubscription-params-enable"><command>ALTER SUBSCRIPTION ... ENABLE</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node1=# ALTER SUBSCRIPTION sub1_node2_node1 ENABLE; /* node1 # */ ALTER SUBSCRIPTION sub1_node2_node1 ENABLE;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3237,8 +3144,7 @@ ALTER SUBSCRIPTION
the upgraded <literal>node1</literal> between <xref linkend="circular-cluster-disable-sub-node1"/> the upgraded <literal>node1</literal> between <xref linkend="circular-cluster-disable-sub-node1"/>
and now, e.g.: and now, e.g.:
<programlisting> <programlisting>
node2=# CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40)); /* node2 # */ CREATE TABLE distributors (did integer PRIMARY KEY, name varchar(40));
CREATE TABLE
</programlisting> </programlisting>
</para> </para>
</step> </step>
@ -3250,8 +3156,7 @@ CREATE TABLE
<link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>, <link linkend="sql-altersubscription-params-refresh-publication"><command>ALTER SUBSCRIPTION ... REFRESH PUBLICATION</command></link>,
e.g.: e.g.:
<programlisting> <programlisting>
node2=# ALTER SUBSCRIPTION sub1_node1_node2 REFRESH PUBLICATION; /* node2 # */ ALTER SUBSCRIPTION sub1_node1_node2 REFRESH PUBLICATION;
ALTER SUBSCRIPTION
</programlisting> </programlisting>
</para> </para>
</step> </step>