PostgreSQL增量订阅方案：利用Logical Decoding订阅增量

Logical Decoding是PostgreSQL9.4中的一个重要功能,它的功能是从PG的WAL日志中，读取数据库更新信息，然后“翻译”（Decode）成逻辑的形式，可发送到远程从库做数据同步。
该方案实现思路如下：
1.要利用该功能，首先需要修改PostgreSQL的配置文件：

 wal_level = logical
 max_replication_slots = 1 # 该参数要大于等于1

2.创建Logical Replication Slot

SELECT * FROM pg_create_logical_replication_slot('regression_slot', 'test_decoding');
-- 使用'test_decoding'插件创建一个名为'regression_slot'的Logical Replication Slot

3.对PostgreSQL进行dml操作后，可以使用以下两个语句查看记录

SELECT * FROM pg_logical_slot_peek_changes('regression_slot', NULL, NULL);
SELECT * FROM pg_logical_slot_get_changes('regression_slot', NULL, NULL);

两者的区别在于pg_logical_slot_peek_changes可以多次查询记录；pg_logical_slot_get_changes在查询过记录后，便会删除记录。
显示结果如下：

由查询结果可知，test_decoding插件将DML的WAL日志解析成
table schema.table_name：操作类型: 列名[该列数据类型]：值...的形式，如果是对主键进行UPDATE操作，那么查询结果中还会包含旧的主键值。
对此，我们可以通过以下两种方式获取增量的SQL的格式:
(1) 通过修改test_decoding插件的转译格式，使得其查询结果显示为可用的SQL语句；
(2) 通过Java代码读取查询结果，拼凑成增量的SQL语句，然后在目标数据库执行。

1. 在完成增量订阅任务后，删除

SELECT pg_drop_replication_slot('regression_slot');