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。