spock

概览

Bundled with pgEdge 15.19/16.15/17.11/18.6.

版本

构建

您可以使用 pig build 命令构建 spock 扩展的 RPM / DEB 包：

pig build pkg spock         # 构建 RPM / DEB 包

安装

您可以直接安装 spock 扩展包的预置二进制包，首先确保 PGDG 和 PIGSTY 仓库已经添加并启用：

pig repo add pgsql -u          # 添加仓库并更新缓存

使用 pig 或者是 apt/yum/dnf 安装扩展：

pig install spock;          # 当前活跃 PG 版本安装

pig ext install -y spock -v 18  # PG 18
pig ext install -y spock -v 17  # PG 17
pig ext install -y spock -v 16  # PG 16
pig ext install -y spock -v 15  # PG 15

dnf install -y pgedge-18       # PG 18
dnf install -y pgedge-17       # PG 17
dnf install -y pgedge-16       # PG 16
dnf install -y pgedge-15       # PG 15

apt install -y pgedge-18   # PG 18
apt install -y pgedge-17   # PG 17
apt install -y pgedge-16   # PG 16
apt install -y pgedge-15   # PG 15

预加载配置：

shared_preload_libraries = 'spock';

创建扩展：

CREATE EXTENSION spock;

用法

来源：

• Spock v5.0.12 README
• Getting started
• Configuration reference
• Limitations
• Release notes

spock 为 PostgreSQL 15 至 18 提供了主动-主动逻辑复制。每个参与的数据库都是一个 Spock 节点；通过在节点之间创建有向订阅，形成一个多主拓扑结构。

配置

在 postgresql.conf 中：

wal_level = 'logical'
max_worker_processes = 10
max_replication_slots = 10
max_wal_senders = 10
shared_preload_libraries = 'spock'
track_commit_timestamp = on
spock.enable_ddl_replication = on
spock.include_ddl_repset = on

启用

CREATE EXTENSION spock;

创建节点

在每个节点上创建节点身份：

-- Node 1
SELECT spock.node_create(
    node_name := 'n1',
    dsn := 'host=10.0.0.5 port=5432 dbname=mydb'
);

-- Node 2
SELECT spock.node_create(
    node_name := 'n2',
    dsn := 'host=10.0.0.7 port=5432 dbname=mydb'
);

创建订阅

对于多主模式，每个节点订阅其他所有节点：

-- On n1: subscribe to n2
SELECT spock.sub_create(
    subscription_name := 'sub_n1n2',
    provider_dsn := 'host=10.0.0.7 port=5432 dbname=mydb'
);

-- On n2: subscribe to n1
SELECT spock.sub_create(
    subscription_name := 'sub_n2n1',
    provider_dsn := 'host=10.0.0.5 port=5432 dbname=mydb'
);

复制集管理

-- Add table to replication
SELECT spock.repset_add_table('default', 'my_table');

-- Remove table from replication
SELECT spock.repset_remove_table('default', 'my_table');

-- Add all tables in a schema
SELECT spock.repset_add_all_tables('default', '{public}');

关键功能

• 多主（主动-主动）复制
• 自动 DDL 复制
• 使用提交时间戳进行冲突检测和解决
• 行和列过滤
• 支持 PostgreSQL 15、16、17 和 18
• 表必须在所有节点上具有主键且模式匹配

操作与注意事项

• 在创建节点或订阅之前，在每个参与的服务器上安装 spock 并将其添加到 shared_preload_libraries 中。
• 确保各节点上的表定义、数据类型、主键和相关唯一索引一致。即使启用了 DDL 复制，也要协调 DDL 操作。
• 被复制的表需要具有主键或其他可用的副本标识符。临时表和未记录表不是复制目标。
• Spock 是按数据库操作的。对于每个参与的数据库，重复扩展名和拓扑结构设置。
• 主动-主动冲突处理依赖于提交时间戳和策略。在生产使用前，请测试同时插入和更新操作，特别是空值唯一键。
• 上游文档中在 README 中列出了平台/构建要求；请验证每个节点上使用的 PostgreSQL 构建和 Spock 包是兼容的。

5.0.12 版本与升级

Spock 要求应用上游 README 中对应版本的 PostgreSQL 内核补丁，仅匹配大版本并不充分。所有节点都应使用兼容内核，例如匹配的 pgEdge 构建。修改共享预加载需要重启。5.0.12 初步支持 PostgreSQL 19，但上游明确不支持将该测试版用于生产；当前 Pigsty pgEdge 构建覆盖 15–18。

带有输出插件安全修复的 PostgreSQL 要求将 spock_output 纳入 output_plugin_libraries，包括将来可能成为发布端的物理备库。先确认参数是否存在：

SELECT current_setting('output_plugin_libraries', true);

仅当查询返回非空值时才加入插件，并保留其他必需条目：

output_plugin_libraries = 'pgoutput, test_decoding, spock_output'

旧服务器遇到未知参数会无法启动；允许列表检查也作用于已有复制槽恢复解码的过程，因此应在 PostgreSQL 小版本升级前安排这个设置。

5.0.12 补丁没有模式变化。它在不推进复制源位置的情况下重试临时应用错误，修复重放、异常处理和生成列复制，并校验接收到的元组元数据。永久性的模式差异仍须修复；应用进程反复重启不代表复制健康。每个节点升级后，应检查复制延迟、异常状态和订阅。

5.0.11 引入 spock.use_native_failover_slots，修改后需要重启；原生复制槽行为依赖 PostgreSQL 17 或更新版本，故障切换配置还须遵循专门的上游操作指南。不能仅因为集群有备库就启用它。