Comme présenté plus tôt, chaque abonnement (actif) reçoit les changements depuis un slot de réplication du serveur distant (publication).

Des slots de synchronisation de tables supplémentaires sont normalement temporaires, créés en interne pour réaliser la synchronisation initiale des tables et supprimés automatiquement quand elles ne sont plus nécessaires. Ces slots de synchronisation de table ont des noms générés automatiquement : « pg_%u_sync_%u_%llu » (paramètres oid de la souscription, relid de la table, sysid pour l'identifiant du système).

Normalement, le slot de réplication distant est créé automatiquement en utilisant la commande CREATE SUBSCRIPTION et il est supprimé automatiquement en utilisant la commande DROP SUBSCRIPTION. Dans certaines situations, il peut être utile ou nécessaire de manipuler les abonnements ainsi que les slots de réplication sous-jacents de façon séparées. Voici quelques exemples :

Créer des tables tests sur le publieur.

test_pub=# CREATE TABLE t1(a int, b text, PRIMARY KEY(a));
CREATE TABLE
test_pub=# CREATE TABLE t2(c int, d text, PRIMARY KEY(c));
CREATE TABLE
test_pub=# CREATE TABLE t3(e int, f text, PRIMARY KEY(e));
CREATE TABLE

Créer les mêmes tables sur l'abonné.

test_sub=# CREATE TABLE t1(a int, b text, PRIMARY KEY(a));
CREATE TABLE
test_sub=# CREATE TABLE t2(c int, d text, PRIMARY KEY(c));
CREATE TABLE
test_sub=# CREATE TABLE t3(e int, f text, PRIMARY KEY(e));
CREATE TABLE

Insérer des données sur les tables du côté publieur.

test_pub=# INSERT INTO t1 VALUES (1, 'one'), (2, 'two'), (3, 'three');
INSERT 0 3
test_pub=# INSERT INTO t2 VALUES (1, 'A'), (2, 'B'), (3, 'C');
INSERT 0 3
test_pub=# INSERT INTO t3 VALUES (1, 'i'), (2, 'ii'), (3, 'iii');
INSERT 0 3

Créer les publications pour les tables. Les publications pub2 et pub3a interdisent certaines opérations publish. La publication pub3b a un filtre de lignes (voir Section 31.3).

test_pub=# CREATE PUBLICATION pub1 FOR TABLE t1;
CREATE PUBLICATION
test_pub=# CREATE PUBLICATION pub2 FOR TABLE t2 WITH (publish = 'truncate');
CREATE PUBLICATION
test_pub=# CREATE PUBLICATION pub3a FOR TABLE t3 WITH (publish = 'truncate');
CREATE PUBLICATION
test_pub=# CREATE PUBLICATION pub3b FOR TABLE t3 WHERE (e > 5);
CREATE PUBLICATION

Créer les abonnements (souscriptions) pour les publications. La souscription sub3 s'abonne à pub3a et pub3b. Toutes les souscriptions copieront les données initiales par défaut.

test_sub=# CREATE SUBSCRIPTION sub1
test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=sub1'
test_sub-# PUBLICATION pub1;
CREATE SUBSCRIPTION
test_sub=# CREATE SUBSCRIPTION sub2
test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=sub2'
test_sub-# PUBLICATION pub2;
CREATE SUBSCRIPTION
test_sub=# CREATE SUBSCRIPTION sub3
test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=sub3'
test_sub-# PUBLICATION pub3a, pub3b;
CREATE SUBSCRIPTION

Observez que les données initiales des tables sont copiées, quelque soit l'opération publish de la publication.

test_sub=# SELECT * FROM t1;
 a |   b
---+-------
 1 | one
 2 | two
 3 | three
(3 rows)

test_sub=# SELECT * FROM t2;
 c | d
---+---
 1 | A
 2 | B
 3 | C
(3 rows)

De plus, comme la copie initiale de données ignore l'opération publish et comme la publication pub3a n'a pas de filtre de lignes, cela signifie que la table t3 copiée contient toutes les lignes même quand elles ne correspondent pas au filtre de lignes de la publication pub3b.

test_sub=# SELECT * FROM t3;
 e |  f
---+-----
 1 | i
 2 | ii
 3 | iii
(3 rows)

Insérer plus de données dans les tables du côté publieur.

test_pub=# INSERT INTO t1 VALUES (4, 'four'), (5, 'five'), (6, 'six');
INSERT 0 3
test_pub=# INSERT INTO t2 VALUES (4, 'D'), (5, 'E'), (6, 'F');
INSERT 0 3
test_pub=# INSERT INTO t3 VALUES (4, 'iv'), (5, 'v'), (6, 'vi');
INSERT 0 3

Maintenant, les données du côté publieur ressemblent à ceci :

test_pub=# SELECT * FROM t1;
 a |   b
---+-------
 1 | one
 2 | two
 3 | three
 4 | four
 5 | five
 6 | six
(6 rows)

test_pub=# SELECT * FROM t2;
 c | d
---+---
 1 | A
 2 | B
 3 | C
 4 | D
 5 | E
 6 | F
(6 rows)

test_pub=# SELECT * FROM t3;
 e |  f
---+-----
 1 | i
 2 | ii
 3 | iii
 4 | iv
 5 | v
 6 | vi
(6 rows)

Observez que, durant la réplication normale, les opérations publish appropriées sont utilisées. Cela signifie que les publications pub2 et pub3a ne répliquent pas les opérations INSERT. De plus, la publication pub3b répliquera seulement les données correspondant au filtre de lignes de pub3b. Maintenant, les données du côté abonné ressemblent à ceci :

test_sub=# SELECT * FROM t1;
 a |   b
---+-------
 1 | one
 2 | two
 3 | three
 4 | four
 5 | five
 6 | six
(6 rows)

test_sub=# SELECT * FROM t2;
 c | d
---+---
 1 | A
 2 | B
 3 | C
(3 rows)

test_sub=# SELECT * FROM t3;
 e |  f
---+-----
 1 | i
 2 | ii
 3 | iii
 6 | vi
(4 rows)

Dans certains cas (i.e Section 31.2.1), si le slot de réplication n'a pas été créé automatiquement, l'utilisateur doit le créer manuellement avant que la souscription ne soit activée. Les étapes pour créer le slot et activer la souscription sont indiquées dans les exemples suivants. Ces exemples spécifient le plugin de décodage logique standard (pgoutput), qui est utilisé par la réplication logique interne.

D'abord, créer une publication pour les exemples.

test_pub=# CREATE PUBLICATION pub1 FOR ALL TABLES;
CREATE PUBLICATION

Exemple 1 : Quand l'abonnement indique connect = false

Exemple 2 : Quand l'abonnement indique connect = false, mais spécifie aussi l'option slot_name.

Exemple 3 : Quand l'abonnement indique slot_name = NONE