Описание

CREATE PUBLICATION Добавляет новую публикацию в текущую базу данных. Имя публикации должно отличаться от имени любой существующей публикации в текущей базе данных.

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

Параметры

При указании параметра типа boolean, часть = значение часть может быть опущена, что эквивалентно указанию TRUE.

Примечания

Если FOR TABLE, FOR ALL TABLES или FOR TABLES IN SCHEMA не указаны, публикация создается с пустым набором таблиц. Это удобно, если таблицы или схемы будут добавлены позже.

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

Для создания публикации вызывающий пользователь должен иметь привилегию CREATE для текущей базы данных. (Разумеется, суперпользователи обходят эту проверку.)

Чтобы добавить таблицу в публикацию, вызывающий пользователь должен обладать правами владельца этой таблицы. Предложения FOR ALL TABLES и FOR TABLES IN SCHEMA требуют, чтобы вызывающий пользователь был суперпользователем.

Таблицы, добавленные в публикацию, в которой публикуются UPDATE и/или DELETE операции, должны иметь определенный REPLICA IDENTITY defined. В противном случае выполнение этих операций для таких таблиц будет запрещено.

Любой список столбцов должен включать REPLICA IDENTITY столбцы для того чтобы UPDATE или DELETE операции, подлежащие публикации. Ограничения на список столбцов отсутствуют, если публикация публикует только INSERT операции.

Выражение фильтра строк (т. е. предложение WHERE предложение) должно содержать только те столбцы, которые охвачены REPLICA IDENTITY, для того чтобы UPDATE и DELETE операции могли быть опубликованы. Для публикации INSERT операций в предложении может быть использован любой столбец WHERE выражение. Фильтр строк допускает простые выражения, не содержащие пользовательских функций, операторов, типов, правил сортировки, изменчивых (non-immutable) встроенных функций или ссылок на системные столбцы.

Фильтр строк для таблицы становится избыточным, если указано FOR TABLES IN SCHEMA, и таблица принадлежит к соответствующей схеме.

Для публикуемых секционированных таблиц фильтр строк каждой секции берется из опубликованной секционированной таблицы, если параметр публикации publish_via_partition_root имеет значение true, либо из самой секции, если оно равно false (по умолчанию). См. Раздел 3.14.4 для получения подробной информации о фильтрах строк. Аналогично, для опубликованных секционированных таблиц список столбцов для каждой секции берется из опубликованной секционированной таблицы, если параметр публикации publish_via_partition_root имеет значение true, или из самой секции, если он имеет значение false.

Для команды INSERT ... ON CONFLICT публикация опубликует операцию, которая является результатом выполнения команды. В зависимости от результата, она может быть опубликована как INSERT или UPDATE, либо не опубликована вовсе.

Для команды MERGE публикация опубликует INSERT, UPDATE, или DELETE для каждой вставленной, обновленной или удаленной строки.

ATTACHтаблицы к дереву секций, корень которого опубликован с использованием публикации с параметром publish_via_partition_root в значении true не приводит к репликации существующего содержимого таблицы.

COPY ... FROM команды публикуются как INSERT операции.

DDL операции не публикуются.

Выражение WHERE предложения выполняется с ролью, используемой для соединения репликации.

Примеры

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

CREATE PUBLICATION mypublication FOR TABLE users, departments;

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

CREATE PUBLICATION active_departments FOR TABLE departments WHERE (active IS TRUE);

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

CREATE PUBLICATION alltables FOR ALL TABLES;

Создание публикации, которая передает только INSERT операции в одной таблице:

CREATE PUBLICATION insert_only FOR TABLE mydata
    WITH (publish = 'insert');

Создание публикации, которая передает все изменения для таблиц users, departments и все изменения для всех таблиц, входящих в схему production:

CREATE PUBLICATION production_publication FOR TABLE users, departments, TABLES IN SCHEMA production;

Создает публикацию, которая публикует все изменения для всех таблиц, входящих в схемы marketing и sales:

CREATE PUBLICATION sales_publication FOR TABLES IN SCHEMA marketing, sales;

Создает публикацию, которая публикует все изменения для таблицы users, но реплицирует только столбцы user_id и firstname:

CREATE PUBLICATION users_filtered FOR TABLE users (user_id, firstname);

Совместимость

CREATE PUBLICATION является Digital Q.DataBase расширением.

См. также