本节介绍每条逻辑复制消息的详细格式。这些消息由复制槽 SQL 接口返回,或由 walsender 发送。对于 walsender,它们封装在复制协议 WAL 消息中,如 第 55.4 节 所述,并且通常遵循与物理复制相同的消息流。
将消息标识为开始消息。
事务的最终 LSN。
事务的提交时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。
事务的 Xid。
将消息标识为逻辑解码消息。
事务的 Xid(仅在流事务中出现)。此字段自协议版本 2 起可用。
标志;无标志时为 0,逻辑解码消息为事务性时为 1。
逻辑解码消息的 LSN。
逻辑解码消息的前缀。
内容长度。
n
逻辑解码消息的内容。
将消息标识为提交消息。
标志;当前未使用。
提交的 LSN。
事务的结束 LSN。
事务的提交时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。
将消息标识为来源消息。
来源服务器上提交的 LSN。
来源名称。
请注意,单个事务中可以有多个来源消息。
将消息标识为关系消息。
事务的 Xid(仅在流事务中出现)。此字段自协议版本 2 起可用。
关系的 Oid。
命名空间(对于 pg_catalog
为空字符串)。
关系名称。
关系的副本标识设置(与 pg_class
中的 relreplident
相同)。
列数。
接下来,对于发布中包含的每一列(生成的列除外),将出现以下消息部分
列的标志。当前可以是 0(表示没有标志)或 1(将列标记为键的一部分)。
列名称。
列数据类型的 Oid。
列的类型修饰符(atttypmod
)。
将消息标识为类型消息。
事务的 Xid(仅在流事务中出现)。此字段自协议版本 2 起可用。
数据类型的 Oid。
命名空间(对于 pg_catalog
为空字符串)。
数据类型名称。
将消息标识为插入消息。
事务的 Xid(仅在流事务中出现)。此字段自协议版本 2 起可用。
与关系消息中 ID 对应的关系的 Oid。
将以下 TupleData 消息标识为新元组。
TupleData 消息部分表示新元组的内容。
将消息标识为更新消息。
事务的 Xid(仅在流事务中出现)。此字段自协议版本 2 起可用。
与关系消息中 ID 对应的关系的 Oid。
将以下 TupleData 子消息标识为键。此字段是可选的,仅当更新更改了 REPLICA IDENTITY 索引中任何列中的数据时才存在。
将以下 TupleData 子消息标识为旧元组。此字段是可选的,仅当发生更新的表将 REPLICA IDENTITY 设置为 FULL 时才存在。
TupleData 消息部分表示旧元组或主键的内容。仅当存在前面的“O”或“K”部分时才存在。
将以下 TupleData 消息标识为新元组。
TupleData 消息部分表示新元组的内容。
更新消息可能包含“K”消息部分或“O”消息部分,或两者都不包含,但绝不会同时包含两者。
将消息标识为删除消息。
事务的 Xid(仅在流事务中出现)。此字段自协议版本 2 起可用。
与关系消息中 ID 对应的关系的 Oid。
将以下 TupleData 子消息标识为键。如果发生删除的表使用索引作为 REPLICA IDENTITY,则此字段存在。
将以下 TupleData 消息标识为旧元组。如果发生删除的表将 REPLICA IDENTITY 设置为 FULL,则此字段存在。
TupleData 消息部分表示旧元组或主键的内容,具体取决于前面的字段。
删除消息可能包含“K”消息部分或“O”消息部分,但绝不会同时包含两者。
将消息标识为截断消息。
事务的 Xid(仅在流事务中出现)。此字段自协议版本 2 起可用。
关系数
用于 TRUNCATE
的选项位:CASCADE
为 1,RESTART IDENTITY
为 2
关系消息中 ID 对应的关系的 OID。此字段针对每个关系重复。
以下消息(流开始、流停止、流提交和流中止)自协议版本 2 起可用。
将消息标识为流开始消息。
事务的 Xid。
值 1 表示这是此 XID 的第一个流段,对于任何其他流段,值为 0。
将消息标识为流停止消息。
将消息标识为流提交消息。
事务的 Xid。
标志;当前未使用。
提交的 LSN。
事务的结束 LSN。
事务的提交时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。
将消息标识为流中止消息。
事务的 Xid。
子事务的 Xid(对于顶级事务,将与事务的 xid 相同)。
中止的 LSN。此字段自协议版本 4 起可用。
事务的中止时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。此字段自协议版本 4 起可用。
以下消息(开始准备、准备、提交已准备、回滚已准备、流准备)自协议版本 3 起可用。
将消息标识为已准备事务消息的开头。
准备的 LSN。
已准备事务的结束 LSN。
事务的准备时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。
事务的 Xid。
已准备事务的用户定义 GID。
将消息标识为已准备事务消息。
标志;当前未使用。
准备的 LSN。
已准备事务的结束 LSN。
事务的准备时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。
事务的 Xid。
已准备事务的用户定义 GID。
将消息标识为已准备事务消息的提交。
标志;当前未使用。
已准备事务提交的 LSN。
已准备事务提交的结束 LSN。
事务的提交时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。
事务的 Xid。
已准备事务的用户定义 GID。
将消息标识为已准备事务消息的回滚。
标志;当前未使用。
已准备事务的结束 LSN。
已准备事务回滚的结束 LSN。
事务的准备时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。
事务的回滚时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。
事务的 Xid。
已准备事务的用户定义 GID。
将消息标识为流准备事务消息。
标志;当前未使用。
准备的 LSN。
已准备事务的结束 LSN。
事务的准备时间戳。该值以自 PostgreSQL 纪元(2000-01-01)以来的微秒数表示。
事务的 Xid。
已准备事务的用户定义 GID。
上述消息的以下部分是共享的。
列数。
接下来,对于每一列(生成的列除外),将显示以下子消息之一
将数据标识为 NULL 值。
或
标识未更改的 TOAST 值(不会发送实际值)。
或
将数据标识为文本格式值。
或
将数据标识为二进制格式值。
列值长度。
n
列值,采用二进制或文本格式。(如前一个格式字节中指定)。n
为上述长度。