ChainedStreamBuilder接口

功能描述

构建复制流（逻辑或物理）的流式API的起点。Api不是线程安全的，只能用于创建单个流。

logical

功能描述

创建逻辑复制流，解码原始wal日志输出插件到逻辑形式。

语法格式

ChainedLogicalStreamBuilder logical()

参数说明

无。

返回值

非空流式api。

示例

创建逻辑复制流，解码原始wal日志输出插件到逻辑形式。

 PGReplicationStream stream =
        pgConnection
            .getReplicationAPI()
            .replicationStream()
            .logical()
            .withSlotName("test_decoding")
            .withSlotOption("include-xids", false)
            .withSlotOption("skip-empty-xacts", true)
            .start()；

    while (true) {
      ByteBuffer buffer = stream.read()；
      //process logical changes
    }

physical

功能描述

以二进制形式为流程wal日志创建物理复制流。

语法格式

ChainedPhysicalStreamBuilder physical()

参数说明

无。

返回值

非空流式api。

示例

获取逻辑插槽生成器。

     LogSequenceNumber lsn = getCurrentLSN()；

    PGReplicationStream stream =
        pgConnection
            .getReplicationAPI()
            .replicationStream()
            .physical()
            .withStartPosition(lsn)
            .start()；

    while (true) {
      ByteBuffer buffer = stream.read()；
      //process binary WAL logs
    }

其他

已知的实现类：ReplicationStreamBuilder。