Описание

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

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

Параметры

Примечания

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

Создание публикации не влечёт немедленный запуск репликации. Эта операция только определяет логику группирования и фильтрации для будущих подписчиков.

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

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

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

Для публикации операций UPDATE или DELETE необходимо, чтобы список столбцов включал столбцы идентификатора реплики (REPLICA IDENTITY). Если публикация создаётся только для операций INSERT, ограничений на список столбцов нет.

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

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

Для опубликованных секционированных таблиц фильтр строк для каждой секции берётся из опубликованной секционированной таблицы, если параметр публикации publish_via_partition_root равен true, или из самой секции, если он равен false (по умолчанию). Подробнее фильтры строк описаны в Разделе 31.3. Аналогично, для опубликованных секционированных таблиц список столбцов для каждой секции берётся из опубликованной секционированной таблицы, если параметр публикации 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 является расширением PostgreSQL.

См. также