每个发布可以(选择性地)指定每个表的哪些列复制到订阅者。订阅者一侧的表必须至少具有已发布的所有列。如果未指定列列表,则复制发布者上的所有列。有关语法的详细信息,请参见 CREATE PUBLICATION。
列的选择可以基于行为或性能原因。但是,不要依赖此功能来实现安全性:恶意订阅者能够获取未明确发布的列中的数据。如果安全性是考虑因素,则可以在发布者一侧应用保护措施。
如果未指定列列表,则稍后添加的任何列都将自动复制。这意味着具有列出所有列的列列表与根本没有列列表不同。
列列表只能包含简单的列引用。列表中列的顺序不会保留。
当发布也发布 FOR TABLES IN SCHEMA
时,不支持指定列列表。
对于分区表,发布参数 publish_via_partition_root
确定使用哪个列列表。如果 publish_via_partition_root
为 true
,则使用根分区表的列列表。否则,如果 publish_via_partition_root
为 false
(默认值),则使用每个分区的列列表。
如果某个发布发布 UPDATE
或 DELETE
操作,任何列列表都必须包括该表的副本标识列(请参见 REPLICA IDENTITY
)。如果某个发布仅发布 INSERT
操作,则列列表可以省略副本标识列。
列列表对 TRUNCATE
命令没有影响。
在初始数据同步期间,仅复制已发布的列。但是,如果订阅者来自 15 之前的版本,则在初始数据同步期间将复制表中的所有列,而忽略任何列列表。
目前不支持包含多个发布的订阅,其中同一张表已使用不同的列列表发布。CREATE SUBSCRIPTION 不允许创建此类订阅,但仍然可以在创建订阅后通过在发布端添加或更改列列表来进入该情况。
这意味着更改已订阅的发布上的表的列列表可能会导致在订阅者端引发错误。
如果订阅受到此问题的影响,恢复复制的唯一方法是调整发布端上的某个列列表,使其全部匹配;然后重新创建订阅,或使用 ALTER SUBSCRIPTION ... DROP PUBLICATION
删除其中一个有问题的发布并再次添加它。
创建表 t1
以用于以下示例。
test_pub=# CREATE TABLE t1(id int, a text, b text, c text, d text, e text, PRIMARY KEY(id)); CREATE TABLE
创建发布 p1
。为表 t1
定义列列表以减少将复制的列数。请注意,列列表中列名的顺序无关紧要。
test_pub=# CREATE PUBLICATION p1 FOR TABLE t1 (id, b, a, d); CREATE PUBLICATION
psql
可用于显示每个发布的列列表(如果已定义)。
test_pub=# \dRp+ Publication p1 Owner | All tables | Inserts | Updates | Deletes | Truncates | Via root ----------+------------+---------+---------+---------+-----------+---------- postgres | f | t | t | t | t | f Tables: "public.t1" (id, a, b, d)
psql
可用于显示每个表的列列表(如果已定义)。
test_pub=# \d t1 Table "public.t1" Column | Type | Collation | Nullable | Default --------+---------+-----------+----------+--------- id | integer | | not null | a | text | | | b | text | | | c | text | | | d | text | | | e | text | | | Indexes: "t1_pkey" PRIMARY KEY, btree (id) Publications: "p1" (id, a, b, d)
在订阅者节点上,创建表 t1
,该表现在仅需要发布者表 t1
上的部分列,还要创建订阅 s1
,该订阅订阅发布 p1
。
test_sub=# CREATE TABLE t1(id int, b text, a text, d text, PRIMARY KEY(id)); CREATE TABLE test_sub=# CREATE SUBSCRIPTION s1 test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=s1' test_sub-# PUBLICATION p1; CREATE SUBSCRIPTION
在发布者节点上,向表 t1
中插入一些行。
test_pub=# INSERT INTO t1 VALUES(1, 'a-1', 'b-1', 'c-1', 'd-1', 'e-1'); INSERT 0 1 test_pub=# INSERT INTO t1 VALUES(2, 'a-2', 'b-2', 'c-2', 'd-2', 'e-2'); INSERT 0 1 test_pub=# INSERT INTO t1 VALUES(3, 'a-3', 'b-3', 'c-3', 'd-3', 'e-3'); INSERT 0 1 test_pub=# SELECT * FROM t1 ORDER BY id; id | a | b | c | d | e ----+-----+-----+-----+-----+----- 1 | a-1 | b-1 | c-1 | d-1 | e-1 2 | a-2 | b-2 | c-2 | d-2 | e-2 3 | a-3 | b-3 | c-3 | d-3 | e-3 (3 rows)
只有来自发布 p1
的列列表中的数据被复制。
test_sub=# SELECT * FROM t1 ORDER BY id; id | b | a | d ----+-----+-----+----- 1 | b-1 | a-1 | d-1 2 | b-2 | a-2 | d-2 3 | b-3 | a-3 | d-3 (3 rows)