将新表添加到发布后，PostgreSQL 逻辑复制不起作用

Question

我是 PostgreSQL 逻辑复制的新手。 我做了测试，在向发布添加新表后，我发现复制不起作用，直到我重新创建订阅，我确信重新创建订阅不是最佳实践，您能否建议如何制作订阅者为新表申请交易？

测试如下：

1. 在主端和复制端创建第一个表：

    create table rep_test (a int primary key, b int);
   

2. 在主端创建发布：

    CREATE PUBLICATION rep_test_pub FOR table public.rep_test;
   

3. 在复制端创建订阅：

    CREATE SUBSCRIPTION rep_test_sub CONNECTION 'host=XXX port=5432 dbname=rocket user=XXX password=XXX' PUBLICATION rep_test_pub WITH (copy_data = false);
   

4. 测试复制，复制有效。 初级侧：

    insert into rep_test values (1, 1); insert into rep_test values (2, 1);
   

   复制：

    select * from rep_test;
   
    *---*---*
    | a | b |
    *---*---*
    | 1 | 1 |
    | 2 | 1 |
    *---*---*
   

5. 在主端和复制端创建一个新表

    create table rep_test (a int primary key, b text);
   

6. 将新表添加到主端的发布中

    alter publication rep_test_pub add table public.rep_test2;
   

7. 测试复制，复制不起作用。 主要：

    insert into rep_test values (3, 1); insert into rep_test2 values (1,'text');
   

复制：

    select * from rep_test;

    *---*---*
    | a | b |
    *---*---*
    | 1 | 1 |
    | 2 | 1 |
    | 3 | 1 |
    *---*---*

    select * from rep_test2;

注意：

rep_test2

中没有数据，复制未复制

rep_test2

。

8. 重新启动复制postgres，复制仍然无法工作。

9. 删除并重新创建订阅，复制工作正常。

小学：

truncate table rep_test; truncate table rep_test2;

复制：

drop subscription rep_test_sub;
CREATE SUBSCRIPTION rep_test_sub CONNECTION 'host=XXX port=5432 dbname=rocket user=XXX password=XXX' PUBLICATION rep_test_pub WITH (copy_data = false);

小学：

insert into rep_test values (1, 1); insert into rep_test2 values (1, 'text');

复制：

select * from rep_test;select * from rep_test2;
 
*---*---*
| a | b |
*---*---*
| 1 | 1 |
*---*---*
(1 row)

*---*-----*
| a | b   | 
*---*-----*
| 1 | text|
*---*-----*
(1 row)

重新创建订阅后复制即可工作。

您能否告知是否有其他方法可以让订阅者将交易应用到新表？

顺便说一句，我的版本：

x86_64-pc-linux-gnu 上的 PostgreSQL 12.2，由 gcc (GCC) 4.8.5 20150623 (Red Hat 4.8.5-39) 编译，64 位

谢谢

Answer 1

在您对订阅执行 REFRESH PUBLICATION 之前，不会复制新表。

https://www.postgresql.org/docs/current/sql-altersubscription.html

刷新发布 从发布者处获取缺失的表信息。 这将开始复制添加到的表 自上次调用 REFRESH 以来订阅的出版物 发布或创建订阅后。

Answer 2

jjanes 的答案有点精确，您只需在数据复制到订阅表后在订阅者数据库上运行以下命令即可。

更改订阅子名称刷新发布；

Answer 3

找出任何问题根源的最佳方法是日志。检查它们是否有错误。

但我想我知道你问题的根源是什么。 手动创建新表后检查其权限。 您的逻辑复制工作所在的用户应该能够从源表中读取数据。

GRANT SELECT ON your_scheme.your_new_table TO your_replication_user