spock

pig build pkg spock         # 构建 RPM / DEB 包

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

shared_preload_libraries = 'spock';

CREATE EXTENSION spock;

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;

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

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

-- 在 n1 上：订阅 n2
SELECT spock.sub_create(
    subscription_name := 'sub_n1n2',
    provider_dsn := 'host=10.0.0.7 port=5432 dbname=mydb'
);

-- 在 n2 上：订阅 n1
SELECT spock.sub_create(
    subscription_name := 'sub_n2n1',
    provider_dsn := 'host=10.0.0.5 port=5432 dbname=mydb'
);

-- 将表添加到复制
SELECT spock.repset_add_table('default', 'my_table');

-- 从复制中移除表
SELECT spock.repset_remove_table('default', 'my_table');

-- 添加模式中的所有表
SELECT spock.repset_add_all_tables('default', '{public}');