内容

pg_replication_origin_advance()

用于设置节点逻辑复制进度的函数

pg_replication_origin_advance() 是一个系统函数，用于将给定节点的复制进度设置为指定位置。

pg_replication_origin_advance() 添加于 PostgreSQL 9.5。

用法

pg_replication_origin_advance ( node_name text, lsn pg_lsn ) → void

node_name 对应于 pg_replication_origin 的 roname 列，或 pg_replication_origin_status 的 external_id 列。

变更历史

示例

为了演示 pg_replication_origin_advance() 的用法，假设有以下场景：有两个 PostgreSQL 节点（node1 和 node2），两个节点都包含一个创建如下表的表

CREATE TABLE foo (
  id   INT NOT NULL PRIMARY KEY,
  node TEXT,
  val  TEXT
)

node2 有一个订阅（"test_sub"），它从 node1 同步上述表到 node2。注意此订阅是在 "disable_on_error = true" 选项下创建的（PostgreSQL 15 及更高版本）。在初始表同步后，表具有以下内容

postgres=# SELECT * FROM foo;
 id |      node      |              val              
----+----------------+-------------------------------
  1 | logical[node1] | 2023-04-16 10:41:41.735911+00
(1 row)

在 node2 上，插入以下行

postgres=# INSERT INTO foo
                VALUES (2,
                        current_setting('cluster_name'),
                        clock_timestamp()
                       );
INSERT 0 1

postgres=# SELECT * FROM foo;
 id |      node      |              val              
----+----------------+-------------------------------
  1 | logical[node1] | 2023-04-16 10:41:41.735911+00
  2 | logical[node2] | 2023-04-16 10:46:40.83656+00
(2 rows)

在 node1 上，插入以下行

postgres=# INSERT INTO foo
                VALUES (2,
                        current_setting('cluster_name'),
                        clock_timestamp()
                       );
INSERT 0 1

postgres=# SELECT * FROM foo;
 id |      node      |              val              
----+----------------+-------------------------------
  1 | logical[node1] | 2023-04-16 10:41:41.735911+00
  2 | logical[node1] | 2023-04-16 10:47:38.830865+00
(2 rows)

id 为 2 的行将无法从 node1 复制到 node2，因为它会与 node2 上现有的行冲突。这将反映在 node2 上的 pg_stat_subscription_stats 中的一个条目中

postgres=# SELECT * FROM pg_stat_subscription_stats;
 subid | subname  | apply_error_count | sync_error_count | stats_reset 
-------+----------+-------------------+------------------+-------------
 16392 | test_sub |                 1 |                0 | 
(1 row)

以及 node2 日志中的相应条目

ERROR:  23505: duplicate key value violates unique constraint "foo_pkey"
DETAIL:  Key (id)=(2) already exists.
CONTEXT:  processing remote data for replication origin "pg_16392" during message type "INSERT" for replication target relation "public.foo" in transaction 740, finished at 0/2539AF8
LOG:  00000: subscription "test_sub" has been disabled because of an error

为了解决这种情况，可以对指定的复制来源执行 pg_replication_origin_advance()，并使用高于上面日志条目中报告的 LSN 值，然后可以重新启用订阅

postgres=# SELECT pg_replication_origin_advance('pg_16392', '0/2539AF9');
 pg_replication_origin_advance 
-------------------------------
 
(1 row)

postgres=# ALTER SUBSCRIPTION test_sub ENABLE;
ALTER SUBSCRIPTION

请注意，提供给 pg_replication_origin_advance() 的 LSN 应谨慎选择，否则可能会跳过有效的交易。在上述情况下，它被设置为报告的失败 LSN + 1，假设后续事务是有效的。

分类

逻辑复制，系统函数

参见

pg_replication_origin_progress()，pg_replication_slot_advance()，pg_stat_subscription_stats

反馈

提交任何关于 "pg_replication_origin_advance()" 的评论、建议或更正 此处。