用Java获取PostgreSQL变更数据完整源码

你是否在做数据同步项目，是否想自己实现数据变更的捕获？

之前写过一篇简要介绍 用Java获取PostgreSQL变更数据 的文章，由于有小伙伴自己进行测试的时候有问题，这里给出完整的程序代码，源代码已上传到 github，具体连接见文末。

一、基础知识

PostgreSQL数据库提供了两种复制方式：物理复制和逻辑复制。

1、物理复制

物理复制是指将主库 WAL 日志的日志页直接发到备机，备机完全应用的一种复制方式。

2、逻辑复制

PostgreSQL 逻辑复制是事务级别的复制，使用订阅复制槽技术，通过在订阅端回放 WAL 日志中的逻辑条目。物理复制和逻辑复制有各自的适用场景以及优缺点，这部分不是本篇讨论范围。

本篇我们主要介绍如何通过 Java 程序，实现 PostgreSQL 的逻辑复制。

二、PostgreSQL 配置

要使用 PostgreSQL 的逻辑复制功能，首先需要对数据库进行相应的配置以支持逻辑复制功能。

1、修改 postgres.conf

在 postgres.conf 中加入以下配置项。

修改完毕后 重启 PostgreSQL 数据库，使参数生效。

wal_level = logical
max_wal_senders = 10
max_worker_processes = 10
max_replication_slots = 10

2、在 PostgreSQL 数据库中创建复制账号

假设 账号和密码均为：repuser

CREATE USER repuser REPLICATION LOGIN
CONNECTION LIMIT 8 ENCRYPTED PASSWORD 'repuser';

三、修改 Java 程序中的数据库连接

1、编辑 PostgresConnection.java 文件中的数据库连接信息

private static String URL = "jdbc:postgresql://localhost:5432/postgres";
private static String USERNAME = "repuser";
private static String PASSWORD = "repuser";

2、启动测试

运行 PgReplicationDBTest 项目中的 PgReplicationTest.java 类中的，在启动完成后，在数据库表中插入数据即可。

例如在数据库中插入一条数据执行如下SQL：

insert into test (id, name) values ('4','d');

程序会输出如下内容：

BEGIN 1051
table public.test: INSERT: id[character varying]:'4' name[character varying]:'d'
COMMIT 1051 (at 2024-06-03 19:07:34.927343+08)

完整源码已上传到 github，有需要的小伙伴可以移步下面的连接或点击原文链接：

源码链接：https://github.com/fiyo/PgReplication-DBTest