pgoutput

-- 为特定表创建发布
CREATE PUBLICATION my_pub FOR TABLE orders, customers;

-- 或发布所有表
CREATE PUBLICATION my_pub FOR ALL TABLES;

-- 带行过滤的发布（PG 15+）
CREATE PUBLICATION filtered_pub FOR TABLE orders WHERE (status = 'active');

-- 带列过滤的发布（PG 15+）
CREATE PUBLICATION col_pub FOR TABLE users (id, name, email);

-- 创建订阅
CREATE SUBSCRIPTION my_sub
    CONNECTION 'host=publisher dbname=mydb user=replicator'
    PUBLICATION my_pub;

-- 检查订阅状态
SELECT * FROM pg_stat_subscription;

-- 使用 pgoutput 创建逻辑复制槽
SELECT * FROM pg_create_logical_replication_slot('my_slot', 'pgoutput');

-- 消费变更（需要协议级参数）
-- pgoutput 设计用于流复制协议，
-- 而非 SQL 槽函数（SQL 测试请使用 test_decoding）

-- 向现有发布添加表
ALTER PUBLICATION my_pub ADD TABLE new_table;

-- 移除表
ALTER PUBLICATION my_pub DROP TABLE old_table;

-- 查看发布
SELECT * FROM pg_publication;
SELECT * FROM pg_publication_tables;

-- 禁用订阅
ALTER SUBSCRIPTION my_sub DISABLE;

-- 刷新订阅（获取新表）
ALTER SUBSCRIPTION my_sub REFRESH PUBLICATION;

-- 删除订阅
DROP SUBSCRIPTION my_sub;