华为云云数据库GaussDBPGReplicationConnection_云淘科技

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()

用于创建逻辑复制槽。连接CN只能创建集群级(CSN序)逻辑复制槽,并在其他CN和主DN上创建同名复制槽;连接DN只能创建本地(LSN序)逻辑复制槽;若需要创建CN上的LSN序逻辑复制槽,或是DN上的CSN序逻辑复制槽,请参考逻辑复制SQL函数pg_create_logical_replication_slot。

void

dropReplicationSlot(String slotName)

用于删除逻辑复制槽。连接CN删除逻辑复制槽时,若为LSN序逻辑复制槽,则仅删除当前节点复制槽,其他节点同名复制槽不受影响;否则只要其他节点有残留同名CSN序逻辑复制槽,执行删除时不会因为某些节点不存在复制槽而报错,同时所有节点的同名复制槽会被成功删除;如果任何节点均不存在该复制槽,则报错。如果当前CN节点残留LSN序逻辑复制槽,同时其他某些节点上残留同名CSN序逻辑复制槽,则连接当前CN节点上执行删除复制槽操作仅会删除本地LSN序逻辑复制槽,待删除完成再次执行删除操作方可删除其他节点的同名复制槽。

SQLException,IOException

ChainedStreamBuilder

replicationStream()

用户开启逻辑复制。

父主题: JDBC接口参考

同意关联代理商云淘科技,购买华为云产品更优惠(QQ 78315851)

内容没看懂? 不太想学习?想快速解决? 有偿解决: 联系专家