每个发布可以可选地指定将每个表的哪些列复制到订阅者。订阅者端的表必须至少包含所有已发布的列。如果未指定列列表,则会复制发布者上的所有列。有关语法的详细信息,请参见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)
如果您在文档中发现任何不正确、与您使用特定功能的经验不符或需要进一步澄清的内容,请使用此表格报告文档问题。