云数据库 GAUSSDB-PGReplicationStream:常用方法

时间：2024-11-02 18:52:03

云数据库 GAUSSDB

表1 PGReplicationConnection常用方法
方法名	返回值类型	描述	throws
close()	void	结束逻辑复制，并释放资源。	SQLException
forceUpdateStatus()	void	强制将上次接收、刷新和应用的 LSN 状态发送到后端。	SQLException
getLastAppliedLSN()	LogSequenceNumber	获取上次主机日志回放的LSN。	-
getLastFlushedLSN()	LogSequenceNumber	获取上次主机刷新的LSN，即当前逻辑解码推进的LSN。	-
getLastReceiveLSN()	LogSequenceNumber	获取上次接收的LSN。	-
isClosed()	boolean	复制流是否关闭。	-
read()	ByteBuffer	从后端读取下一条WAL记录。如果读取不到，该方法阻塞I/O读。	SQLException
readPending()	ByteBuffer	从后端读取下一条WAL记录。如果读取不到，该方法不阻塞I/O读。	SQLException
setAppliedLSN(LogSequenceNumber applied)	void	设置应用的LSN。	-
setFlushedLSN(LogSequenceNumber flushed)	void	设置刷新的LSN，在下次更新时发送至后端，用于推进服务端LSN。	-