目录

pg_logical_slot_get_changes()

返回逻辑复制槽中变更的函数

pg_logical_slot_get_changes() 是一个系统函数，用于返回指定逻辑复制槽中的指定变更集。

pg_logical_slot_get_changes() 函数于 PostgreSQL 9.4 中添加。

用法

pg_logical_slot_get_changes ( slot_name name, upto_lsn pg_lsn, upto_nchanges integer, VARIADIC options text[] ) →
        setof record ( lsn pg_lsn, xid xid, data text )

返回的变更集将从之前消耗变更的那个点开始。

如果 upto_lsn 和 upto_nchanges 都为 NULL，则将返回直到可用 WAL 结束的所有更改。

options 参数允许提供由逻辑复制槽关联的输出插件定义的选项。

要检索变更而不消耗它们，请使用 pg_logical_slot_peek_changes()。

变更历史

示例

使用 test_decoding 作为插件创建一个逻辑复制槽

postgres=# SELECT * FROM pg_create_logical_replication_slot('test_slot_1', 'test_decoding');
  slot_name  |    lsn
-------------+-----------
 test_slot_1 | 0/3000758
(1 row)

执行一些 WAL 活动，这里是通过向现有表插入一行来实现的

postgres=# INSERT INTO foo VALUES (1, clock_timestamp());
INSERT 0 1

此 WAL 活动随后可以通过先前创建的逻辑复制槽使用 pg_logical_slot_get_changes() 进行查询。

postgres=# SELECT * FROM pg_logical_slot_get_changes('test_slot_1', NULL, NULL, 'include-xids', '0');
    lsn    | xid |                                       data
-----------+-----+-----------------------------------------------------------------------------------
 0/3023580 | 726 | BEGIN
 0/3023580 | 726 | table public.foo: INSERT: id[integer]:1 val[text]:'2021-08-09 10:00:38.622597+01'
 0/3023610 | 726 | COMMIT
(3 rows)

由于输出插件现在已经消耗了这些变更，后续的 pg_logical_slot_get_changes() 调用（假设没有写入新的 WAL）将返回一个空结果集。

postgres=# SELECT * FROM pg_logical_slot_get_changes('test_slot_1', NULL, NULL, 'include-xids', '0');
 lsn | xid | data
-----+-----+------
(0 rows)

尝试从物理复制槽检索变更。

postgres=# SELECT * FROM pg_logical_slot_get_changes('physical_slot_1', NULL, NULL, 'include-xids', '0');
ERROR:  cannot use physical replication slot for logical decoding

分类

逻辑复制, 复制, 复制槽, 系统函数

另请参阅

pg_logical_slot_peek_changes(), pg_logical_slot_get_binary_changes(), pg_logical_slot_peek_binary_changes()

反馈

提交有关“pg_logical_slot_get_changes()”的任何评论、建议或更正，请点击此处。