逻辑复制函数

    • 描述：创建逻辑复制槽。

      参数说明：

      • slot_name

        流复制槽名称。

        取值范围：字符串，不支持除字母，数字,以及（_?-.）以外的字符。

      • plugin_name

        插件名称。

        取值范围：字符串，当前支持test_decoding和mppdb_decoding。

      返回值类型：name, text

      备注：第一个返回值表示slot_name，第二个返回值表示该逻辑复制槽解码的起始LSN位置。

    • pg_create_physical_replication_slot(‘slot_name’, ‘isDummyStandby’)

      描述：创建新的物理复制槽。

      参数说明：

      • slot_name

        流复制槽名称。

        取值范围：字符串，不支持除字母，数字,以及（_?-.）以外的字符。

      • isDummyStandby

        是否是从从备连接主机创建的复制槽。

        类型：bool。

        返回值类型：name, text

    • pg_drop_replication_slot(‘slot_name’)

      参数说明：

      • slot_name

        流复制槽名称。

        取值范围：字符串，不支持除字母，数字,以及（_?-.）以外的字符。

      返回值类型：void

    • pg_logical_slot_get_changes(‘slot_name’, ‘LSN’, upto_nchanges, ‘options_name’, ‘options_value’)

    描述：解码并推进流复制槽。

    参数说明： 与pg_logical_slot_peek_changes一致，详细内容请参见 pg_logical_slot_peek_ch…。

    • pg_replication_slot_advance (‘slot_name’, ‘LSN’)

    描述：直接推进流复制槽到指定LSN，不输出解码结果。

    参数说明：

    • slot_name

      流复制槽名称。

      取值范围：字符串，不支持除字母，数字,以及（_?-.）以外的字符。

    • LSN

      推进到的日志LSN位置，下次解码时只会输出提交位置比该LSN大的事务结果。如果输入的LSN比当前流复制槽记录的推进位置还要小，则直接返回；如果输入的LSN比当前最新物理日志LSN还要大，则推进到当前最新物理日志LSN。

      取值范围：字符串（LSN，格式为xlogid/xrecoff）。

    返回值类型：name, text

    备注：返回值分别对应slot_name和实际推进至的LSN。

    描述：获取复制槽列表。

    示例：