暂无图片
暂无图片
暂无图片
暂无图片
暂无图片
首页 / 用Java获取PostgreSQL变更数据完整源码

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

山东Oracle用户组 2024-06-04
88

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

之前写过一篇简要介绍 用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

            近期文章：



            javapostgresql源码oracleoracle函数
            文章转载自山东Oracle用户组，如果涉嫌侵权，请发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。

            评论