Redrock Postgres 搜索 英文
版本: 14 / 15 / 16

49.10.  逻辑解码的两阶段提交支持 #

对于基本输出插件回调(例如,begin_cbchange_cbcommit_cbmessage_cb),两阶段提交命令(如 PREPARE TRANSACTIONCOMMIT PREPAREDROLLBACK PREPARED)不会被解码。虽然 PREPARE TRANSACTION 被忽略,但 COMMIT PREPARED 被解码为 COMMIT,而 ROLLBACK PREPARED 被解码为 ROLLBACK

为了支持两阶段命令的流式传输,输出插件需要提供额外的回调。有多个必需的两阶段提交回调(begin_prepare_cbprepare_cbcommit_prepared_cbrollback_prepared_cbstream_prepare_cb),以及一个可选回调(filter_prepare_cb)。

如果提供了用于解码两阶段提交命令的输出插件回调,那么在 PREPARE TRANSACTION 中,将解码该事务的更改,将其传递给输出插件,并调用 prepare_cb 回调。这与仅在提交事务时将更改传递给输出插件的基本解码设置不同。准备好的事务的开始由 begin_prepare_cb 回调指示。

当使用 ROLLBACK PREPARED 回滚已准备好的事务时,将调用 rollback_prepared_cb 回调,当使用 COMMIT PREPARED 提交已准备好的事务时,将调用 commit_prepared_cb 回调。

输出插件可以选择通过 filter_prepare_cb 定义过滤规则,以仅解码两阶段中的特定事务。这可以通过对 gid 进行模式匹配或通过使用 xid 进行查找来实现。

想要解码已准备好的事务的用户需要小心以下提到的要点