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

时间：2024-11-13 14:46:36

云数据库 GAUSSDB

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