Как отмечалось ранее, каждая (активная) подписка получает изменения через слот репликации на удаленной стороне (стороне публикации).

Дополнительные слоты синхронизации таблиц обычно являются временными; они создаются внутренними механизмами для выполнения начальной синхронизации таблиц и автоматически удаляются, когда в них отпадает необходимость. Эти слоты синхронизации таблиц имеют генерируемые имена: «pg_%u_sync_%u_%llu» (параметры: подписка oid, таблица relid, системный идентификатор sysid)

Обычно удаленный слот репликации создается автоматически при создании подписки с помощью CREATE SUBSCRIPTION , и он автоматически удаляется при удалении подписки с помощью DROP SUBSCRIPTION. Однако в некоторых ситуациях может быть полезно или необходимо управлять подпиской и базовым слотом репликации по отдельности. Ниже приведены некоторые сценарии:

Создание тестовых таблиц на стороне Издателя.

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

Создание таких же таблиц на стороне Подписчика.

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

Вставка данных в таблицы на стороне Издателя.

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

Создайте публикации для таблиц. Публикации pub2 и pub3a запрещают некоторые «публикация» операции. Публикация pub3b имеет фильтр строк (см. Раздел 3.14.4).

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

Создайте подписки для данных публикаций. Подписка sub3 оформляется на обе публикации pub3a и pub3b. Все подписки по умолчанию копируют исходные данные.

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

Следует отметить, что начальные данные таблицы копируются независимо от «публикация» операции публикации.

test_sub=# SELECT * FROM t1;
 a |   b
---+-------
 1 | one
 2 | two
 3 | three
(3 строки)

test_sub=# SELECT * FROM t2;
 c | d
---+---
 1 | A
 2 | B
 3 | C
(3 строки)

Более того, так как при начальном копировании данных игнорируется «публикация» операция, и поскольку публикация pub3a не имеет фильтра строк, это означает, что скопированная таблица t3 содержит все строки, даже если они не соответствуют фильтру строк публикации pub3b.

test_sub=# SELECT * FROM t3;
 e |  f
---+-----
 1 | i
 2 | ii
 3 | iii
(3 строки)

Добавление дополнительных данных в таблицы на стороне издателя.

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

Теперь данные на стороне издателя выглядят следующим образом:

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)

Следует отметить, что в процессе обычной репликации используются соответствующие «публикация» операции. Это означает, что публикации pub2 и pub3a не будут реплицировать INSERT. Кроме того, публикация pub3b будет реплицировать только те данные, которые соответствуют фильтру строк pub3b. Теперь данные на стороне подписчика выглядят следующим образом:

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)

Существуют определенные случаи (например, Раздел 3.14.2.1) когда, если удаленный слот репликации не был создан автоматически, требуется создать его вручную до активации подписки. Процедура создания слота и активации подписки приведена в следующих примерах. В этих примерах указывается стандартный плагин вывода логического декодирования (pgoutput), который используется встроенным механизмом логической репликации.

Сначала создается публикация для использования в примерах.

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

Пример 1: Когда в параметрах подписки указано параметра

Пример 2: В случае, когда в подписке указано параметра, но также определен slot_name параметр.

Пример 3: Случай, когда в подписке указан параметр slot_name = NONE