VastbaseG100

基于openGauss内核开发的企业级关系型数据库。

Menu

PGReplicationConnection接口

功能描述

API只有在创建复制属性(PGProperty.REPLICATION和PGProperty.ASSUME_MIN_SERVER_VERSION)所需的连接时才可用。如果没有此属性,构建复制流将异常失败。

createReplicationSlot

功能描述

创建复制槽,可以在replicationStream()中使用。

语法格式

ChainedCreateReplicationSlotBuilder createReplicationSlot()

参数说明

无。

返回值

返回用于构建创建复制槽的非空流式api。

dropReplicationSlot

功能描述

删除复制槽。

语法格式

void dropReplicationSlot(String slotName)
                  throws SQLException

参数说明

参数名 参数说明
slotName 应删除的数据库中存在非空复制槽名称

返回值

无。

replicationStream

功能描述

启动复制流后,此连接不能用于其他查询,直到复制流关闭为止。

语法格式

ChainedStreamBuilder replicationStream()

参数说明

无。

返回值

返回用于构建复制流的非空流式api。

其他

已知的实现类:PGReplicationConnectionImpl。