ChainedCreateReplicationSlotBuilder接口

功能描述

为逻辑复制和物理复制指定通用参数的流畅接口。

logical

功能描述

获取逻辑插槽生成器。

语法格式

ChainedLogicalCreateSlotBuilder logical()

参数说明

无。

返回值

非空流式api。

示例

获取逻辑插槽生成器。

pgConnection
        .getReplicationAPI()
        .createReplicationSlot()
        .logical()
        .withSlotName("mySlot")
        .withOutputPlugin("test_decoding")
        .make()；

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

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

physical

功能描述

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

语法格式

ChainedPhysicalCreateSlotBuilder physical()

参数说明

无。

返回值

非空流式api。

示例

获取逻辑插槽生成器。

    pgConnection
        .getReplicationAPI()
        .createReplicationSlot()
        .physical()
        .withSlotName("mySlot")
        .make()；

    PGReplicationStream stream =
        pgConnection
            .getReplicationAPI()
            .replicationStream()
            .physical()
            .withSlotName("mySlot")
            .start()；

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

其他

已知的实现类：ReplicationCreateSlotBuilder。