WAIT FOR

等待直到根据指定的 mode 达到指定的 lsn， 该模式决定等待 WAL 被写入、刷盘还是重放。 如果没有指定 timeout，或者其值为零，则此命令会无限期等待 lsn。

超时时会发出错误，除非在 WITH 子句中指定了 NO_THROW。 对于备库模式（standby_replay、standby_write、 standby_flush），如果在达到 lsn 之前服务器被提升， 也会发出错误。如果指定了 NO_THROW，命令会返回一个状态字符串，而不是抛出错误。

可能的返回值是 success、timeout 和 not in recovery。

WAIT FOR 必须作为顶层命令执行。 它不能在函数、过程或 DO 块中执行。 它还要求不存在活动或已注册的快照，因此不能在必须保持此类快照处于活动状态的上下文中使用， 包括隔离级别高于 READ COMMITTED 的事务。

WAIT FOR 会根据指定的 mode 一直等待直到达到指定的 lsn。standby_replay 模式会等待该 LSN 被回放（应用到数据库）， 这有助于在使用异步副本读取和主库写入时实现读己之写一致性。 standby_flush 模式会等待 WAL 在副本上刷入持久存储，或者等待备库上已有的 WAL 已被回放。 standby_write 模式会等待 WAL 被写入操作系统，或者已经回放；对于新接收的 WAL， 这比刷盘更快，但持久性保证更弱。 primary_flush 模式会等待 WAL 在主库上刷盘。 在所有情况下，最后一次修改的 LSN 应当存储在客户端应用程序一侧或连接池一侧。

备库模式（standby_replay、standby_write、 standby_flush）只能在恢复期间使用，而 primary_flush 只能在主库上使用。对当前服务器状态使用错误的模式会导致错误。 如果在使用备库模式等待期间备库被提升，命令将返回 not in recovery（或者在未指定 NO_THROW 时抛出错误）。提升会创建新的时间线，而正在等待的 LSN 可能指向旧时间线中的 WAL。

WAIT FOR只比较LSN数值；它并不知道 WAL 记录属于哪条时间线。 当备库跨上游时间线切换继续恢复时，这一点很重要—例如，级联备库的上游被提升。 在这种情况下，只要所选等待模式使用的位置达到或超过该LSN数值， WAIT FOR就会返回success，而不考虑该 LSN属于哪条时间线。需要确认目标指向预期时间线的应用程序必须自行验证时间线。

在备库服务器上，WAIT FOR 会话可能会被恢复冲突中断。 某些恢复冲突是不可避免的：例如，回放一个表空间删除操作时，无论后端正在执行什么，都会通过终止所有后端来解决冲突。 在备库上使用 WAIT FOR 的应用程序应准备好处理此类中断，例如通过重试命令或回退到其他机制。

可以使用 WAIT FOR 命令等待 pg_lsn 值。 例如，应用程序可以更新 movie 表，并在刚刚完成更改后获取 lsn。 由于 synchronous_commit 可能设置为 off，此示例在主库上使用 pg_current_wal_insert_lsn 获取 lsn。

postgres=# UPDATE movie SET genre = 'Dramatic' WHERE genre = 'Drama';
UPDATE 100
postgres=# SELECT pg_current_wal_insert_lsn();
 pg_current_wal_insert_lsn
---------------------------
 0/0306EE20
(1 row)

然后，应用程序可以使用从主库获得的 lsn 运行 WAIT FOR。 之后，主库上所做的更改应当保证在副本上可见。

postgres=# WAIT FOR LSN '0/0306EE20';
 status
---------
 success
(1 row)
postgres=# SELECT * FROM movie WHERE genre = 'Drama';
 genre
-------
(0 rows)

等待刷盘（数据在副本上持久化）：

postgres=# WAIT FOR LSN '0/0306EE20' WITH (MODE 'standby_flush');
 status
---------
 success
(1 row)

带超时的等待写入：

postgres=# WAIT FOR LSN '0/0306EE20' WITH (MODE 'standby_write', TIMEOUT '100ms', NO_THROW);
 status
---------
 success
(1 row)

等待主库刷盘：

postgres=# WAIT FOR LSN '0/0306EE20' WITH (MODE 'primary_flush');
 status
---------
 success
(1 row)

如果在超时之前未达到目标 LSN，则会抛出错误：

postgres=# WAIT FOR LSN '0/0306EE20' WITH (TIMEOUT '0.1s');
ERROR:  timed out while waiting for target LSN 0/0306EE20 to be replayed; current standby_replay LSN 0/0306EA60

同一个示例使用带 NO_THROW 选项的 WAIT FOR：

postgres=# WAIT FOR LSN '0/0306EE20' WITH (TIMEOUT '100ms', NO_THROW);
 status
---------
 timeout
(1 row)