更新时间:2024-05-07 GMT+08:00

PGReplicationConnection

PGReplicationConnection是GaussDB JDBC驱动中提供的一个API接口类,用于执行逻辑复制相关的功能。

PGReplicationConnection的继承关系

PGReplicationConnection是逻辑复制的接口,实现类是PGReplicationConnectionImpl,该类位于org.postgresql.replication Package中,该类的声明如下:

public class PGReplicationConnection implements PGReplicationConnection

构造方法

public PGReplicationConnection(BaseConnection connection)

常用方法

表1 PGReplicationConnection常用方法

返回值

方法

描述

throws

ChainedCreateReplicationSlotBuilder

createReplicationSlot()

用于创建逻辑复制槽。只能创建LSN序逻辑复制槽,若需要创建CSN序逻辑复制槽,请参考逻辑复制SQL函数pg_create_logical_replication_slot。

-

void

dropReplicationSlot(String slotName)

用于删除逻辑复制槽。

SQLException,IOException

ChainedStreamBuilder

replicationStream()

用户开启逻辑复制。

-