PGReplicationConnection
PGReplicationConnection是GaussDB JDBC驱动中提供的一个API接口类,用于执行逻辑复制相关的功能。
PGReplicationConnection的继承关系
PGReplicationConnection是逻辑复制的接口,实现类是PGReplicationConnectionImpl,该类位于org.postgresql.replication Package中,该类的声明如下:
public class PGReplicationConnection implements PGReplicationConnection
构造方法
public PGReplicationConnection(BaseConnection connection)
常用方法
| 返回值 | 方法 | 描述 | throws |
|---|---|---|---|
| ChainedCreateReplicationSlotBuilder | createReplicationSlot() | 用于创建逻辑复制槽。只能创建LSN序逻辑复制槽,若需要创建CSN序逻辑复制槽,请参考逻辑复制SQL函数pg_create_logical_replication_slot。 | - |
| void | dropReplicationSlot(String slotName) | 用于删除逻辑复制槽。 | SQLException,IOException |
| ChainedStreamBuilder | replicationStream() | 用户开启逻辑复制。 | - |