CREATE PUBLICATION

描述

CREATE PUBLICATION向当前数据库中添加一个新发布。该发布的名称必须不同于当前数据库中任何现有发布的名称。

发布本质上是一组表，其数据更改会通过逻辑复制进行复制。有关发布在逻辑复制配置中如何工作的详细信息，请参见第 29.1 节。

参数

当指定boolean类型的参数时，可以省略 = value 部分，这等价于指定TRUE。

注解

如果未指定FOR TABLE、FOR ALL TABLES或 FOR TABLES IN SCHEMA，则该发布开始时不包含任何表。这在稍后还要添加表或模式时很有用。

创建发布不会启动复制。它只为未来的订阅者定义分组和过滤逻辑。

要创建发布，调用用户必须具有当前数据库的CREATE权限。（当然，超级用户会绕过这一检查。）

要向发布中添加表，调用用户必须拥有该表。使用FOR ALL TABLES 和FOR TABLES IN SCHEMA子句要求调用用户是超级用户。

如果某个发布发布UPDATE和/或DELETE 操作，则加入该发布的表必须已经定义REPLICA IDENTITY。否则，在这些表上将不允许执行这些操作。

任何列列表都必须包含REPLICA IDENTITY列，这样 UPDATE或DELETE操作才能被发布。如果该发布只发布INSERT操作，则列列表没有限制。

行过滤表达式（即WHERE子句）必须只包含 REPLICA IDENTITY所覆盖的列，这样 UPDATE和DELETE操作才能被发布。对于发布INSERT操作，可以在WHERE 表达式中使用任何列。行过滤器只允许简单表达式。它不能包含用户定义的函数、操作符、类型和排序规则、系统列引用，或非不可变内置函数。

属于REPLICA IDENTITY的生成列必须被显式发布，即要么将其列入列列表，要么启用publish_generated_columns 选项，这样UPDATE和DELETE 操作才能被发布。

如果指定了FOR TABLES IN SCHEMA，并且该表属于所引用的模式，那么该表上的行过滤器就是多余的。

对于已发布的分区表，如果发布参数publish_via_partition_root 为true，则每个分区的行过滤器取自已发布的分区表；如果为false（默认值），则取自分区本身。有关行过滤器的详细信息，请参见第 29.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是PostgreSQL 的扩展。

另见