Сначала установите параметры конфигурации в postgresql.conf:

wal_level = logical

Другие необходимые параметры по умолчанию имеют значения, подходящие для базовой настройки.

В файл pg_hba.conf необходимо внести изменения, чтобы разрешить репликацию (конкретные значения будут зависеть от фактической конфигурации сети и имени пользователя, с которым вы будете подключаться):

host     all     all     all     md5

Затем в базе данных публикации выполните:

CREATE PUBLICATION mypub FOR TABLE "category_trees", "brands", "card_products", "category_vendor", 
"characteristics", "comments", "countries", "filters", "filter_types", "grades", "images", "positions", "prices", 
"purposes", "sales", "search_requests", "shippings", "stocks_jsons", "suppliers"; 

И в базе данных подписчика:

CREATE SUBSCRIPTION mysub CONNECTION 'dbname=parser_wb host=10.5.0.5 user=parser_wb port=5432 password=parser_wb' PUBLICATION mypub;

Показанная выше команда запустит процесс репликации, который вначале синхронизирует исходное содержимого таблиц users и departments, а затем начнёт перенос инкрементальных изменений в этих таблицах.

SELECT pr.* ,pc.relname, pp.pubname  FROM pg_publication_rel pr
INNER JOIN pg_class pc ON pc.oid = pr.prrelid
INNER JOIN pg_publication pp ON pp.oid = pr.prpubid

SELECT psr.*, pc.relname, ps.subname, ps.subenabled,ps.subconninfo FROM pg_subscription_rel psr
INNER JOIN pg_class pc ON pc.oid = psr.srrelid
INNER JOIN pg_subscription ps ON ps.oid = psr.srsubid

ALTER PUBLICATION mypub SET (publish = 'update, delete');

ALTER PUBLICATION mypub ADD TABLE users, departments;

На мастере заполняем таблицу и создаем публикацию:

INSERT INTO test VALUES ('k1', 'v1'), ('k2', 'v2');
CREATE PUBLICATION mypub FOR ALL TABLES;

Здесь в публикацию были добавлены все сущесвтующие таблицы, но также можно указать и список конкретных таблиц:

CREATE PUBLICATION mypub FOR TABLE table1, table2;

Кроме того, можно указать, какие именно изменения следует публиковать:

CREATE PUBLICATION mypub
FOR ALL TABLES WITH (publish = 'insert,update');

Изменение списка таблиц в публикации происходит так:

ALTER PUBLICATION mypub ADD  TABLE t1, t2;

ALTER PUBLICATION mypub SET  TABLE t3, t4;

 ALTER PUBLICATION mypub DROP TABLE t5, t6;

На реплике создаем подписку и проверяем содержимое таблицы:

– можно указывать и несколько публикаций через запятую

CREATE SUBSCRIPTION allsub
CONNECTION 'host=10.128.0.16 user=eax dbname=eax'
PUBLICATION mypub;
 
SELECT * FROM test;

Если все было сделано правильно, на реплике вы увидите все те же данные, что и на мастере. Кроме того, любые изменения таблицы на мастере будут приводить к соответствующим изменениям на реплике. При желании можно проверить работу логической репликации под нагрузкой, например, так:

INSERT INTO test SELECT 'kk' %%|%%| i, 'vv' %%|%%| i
FROM generate_series(1, 10000) AS i;

При создании новых таблиц реплика не будет автоматически их тянуть, даже если публикация была создана как FOR ALL TABLES. Как уже было отмечено, DDL не реплицируется. Для решения проблемы нужно создать на реплике таблицы с такой же схемой, что и на мастере (с поправкой на порядок полей и прочее, см выше), а затем сказать:

ALTER SUBSCRIPTION mysub REFRESH PUBLICATION;

Подписку можно временно включать и выключать:

ALTER SUBSCRIPTION mysub ENABLE;
ALTER SUBSCRIPTION mysub DISABLE;

… а также менять мастера:

ALTER SUBSCRIPTION mysub CONNECTION 'host=...';

Наконец, рассмотрим удаление публикации и подписки:

– на реплике

DROP SUBSCRIPTION mysub;

– на мастере

DROP PUBLICATION mypub;

Казалось бы, что это все. Однако на практике репликацию нужно еще и как-то мониторить. Давайте выясним, как это делается.

SELECT * FROM pg_publication;

Каталог pg_publication содержит все публикации, созданные в базе данных. Подробнее о публикациях можно узнать в Разделе 30.1.

Столбцы pg_publication

Каталог pg_publication_rel содержит сопоставления отношений и публикаций в базе данных (это сопоставления вида многие-ко-многим). Более понятное пользователю представление этой информации можно также получить в Разделе 49.78.

Столбцы pg_publication_rel

Каталог pg_subscription_rel содержит состояние каждого реплицируемого отношения в каждой подписке (это связь вида многие-ко-многим).

Этот каталог содержит только таблицы, известные в подписке после выполнения CREATE SUBSCRIPTION или ALTER SUBSCRIPTION … REFRESH PUBLICATION.

Столбцы pg_subscription_rel