## 一、 确定发布端和订阅端 发布端，为业务数据库，会对数据库里的对象进行操作，发布端必须是主节点，不支持备节点；订阅端则是逻辑复制发布端的数据，订阅端不能够对发布端进行写入操作，一般用来查询数据。 更详细的说明请参考文档: http://www.light-pg.com/docs/lightdb/13.8-22.3/logical-replication.html ## 二、修改发布端配置 修改发布端数据库配置文件 `$LTDATA/lightdb.conf` 文件，修改配置项 `wal_level` ，重启数据库生效。 ```shell wal_level = logical ``` ## 三、发布配置 1. 登录到发布端数据库，创建用户，赋予访问权限 ```sql -- 创建专门用于订阅的用户 create role syncuser login replication with password 'abc123'; -- 把要同步的表查询权限赋给订阅用户 grant select on table tb1 to syncuser; grant select on table tb2 to syncuser; grant select on table tb3 to syncuser; ``` 2. 创建发布对象 注意，所有表必须要有主键或者唯一键 ```sql -- 创建发布对象(发布对象名称pubname可以修改), create publication pubname for table tb1,tb2,tb3; ``` 3. 查询已创建的发布对象 ```sql -- 查询已创建了哪些发布对象 zhj@lt_test=# select * from pg_publication where pubname = 'pubname'; -[ RECORD 1 ]+-------- oid | 24242 pubname | pubname pubowner | 10 puballtables | f pubinsert | t pubupdate | t pubdelete | t pubtruncate | t pubviaroot | f ``` ## 四、订阅配置 1. 在订阅数据库中创建要同步的表，表结构和发布库保持一致(逻辑订阅不同步DDL) 注意，表必须有主键或者唯一键 ```sql -- 例子: create table tb1(id int primary key, info text, crt_time timestamp); ``` 2. 创建订阅对象 ```sql -- 配置发布端数据库地址，账号，密码，库，发布名称等。 create subscription subname1 connection 'hostaddr= 10.20.30.110 port=5432 password=abc123 user=lt_test dbname=lt_test' publication pubname1; ``` 3. 查看有哪些订阅 ```sql -- 查询有哪些订阅 postgres=# select * from pg_subscription ; subdbid | subname | subowner | subenabled | subconninfo | subslotname | subsynccommit | subpublications ---------+----------+----------+------------+----------------------------------------------------------------+----------------+---------------+----------------- 16401 | subname1 | 10 | t | hostaddr= 10.20.30.110 port=5432 user=lt_test dbname=lt_test | sub1_from_pub1 | off | {pubname1} (1 row) ``` ## 五、 新增要同步的表 1. 在发布端的添加表 ```sql -- 把tb4表添加到发布中 ALTER PUBLICATION pubname ADD TABLE tb4; ``` 2. 在订阅端创建相同的表结构 **重要** 3. 在订阅端刷新订阅 ```sql alter subscription subname refresh publication; ``` ## 六、限制 1. 不复制数据库模式和DDL命令。 2. 不复制序列数据。序列字段(serial / GENERATED ... AS IDENTITY)的值会被复制，但序列的值不会更新 3. 不复制TRUNCATE命令。 4. 不复制大对象 5. 复制只能从基表到基表。也就是说，发布和订阅端的表必须是普通表，而不是视图， 物化视图，分区根表或外部表。订阅继承表的父表，只会复制父表的变更。 6. 只支持触发器的一部分功能 7. 不支持双向复制，会导致WAL循环。 8. 不支持在同一个实例上的两个数据库上创建订阅 9. 不支持在备机上创建订阅 10. CREATE SUBSCRIPTION命令执行时，要等待发布端正在执行的事务结束。 11. 订阅生效期间，发布端所有事务产生的WAL必须在该事务结束时才能被回收。 12. 订阅端UPDATE/DELETE找不到数据时，没有任何错误输出。