PostgreSQL逻辑复制表触发器失效求助：数据分发至子表无反应

核心问题定位 #

逻辑复制默认禁用目标端触发器，且触发器配置细节、静默错误会导致无效果甚至复制中断，以下是分步解决方案：

1. 开启订阅端触发器执行权限 #

这是最容易忽略的关键步骤：PostgreSQL订阅默认ENABLE_TRIGGERS = false，即便你把触发器设为REPLICA或ALWAYS也不会执行。执行以下命令开启：

-- 修改订阅参数启用触发器
ALTER SUBSCRIPTION your_subscription_name SET (ENABLE_TRIGGERS = true);
-- 重启订阅使参数生效
ALTER SUBSCRIPTION your_subscription_name DISABLE;
ALTER SUBSCRIPTION your_subscription_name ENABLE;

2. 修正触发器配置 #

确保触发器函数逻辑正确，且触发时机、范围符合要求：

第一步：创建正确的分发触发器函数 #

CREATE OR REPLACE FUNCTION distribute_a_to_t1_t2()
RETURNS TRIGGER AS $$
BEGIN
    CASE TG_OP
        WHEN 'INSERT' THEN
            -- 插入t1、t2，主键冲突则跳过
            INSERT INTO t1(a) VALUES(NEW.a) ON CONFLICT(a) DO NOTHING;
            INSERT INTO t2(b) VALUES(NEW.b) ON CONFLICT(b) DO NOTHING;
            RETURN NEW;
        WHEN 'UPDATE' THEN
            -- 仅当字段变化时更新对应表
            IF OLD.a != NEW.a THEN
                INSERT INTO t1(a) VALUES(NEW.a) ON CONFLICT(a) DO UPDATE SET a = NEW.a;
            END IF;
            IF OLD.b != NEW.b THEN
                INSERT INTO t2(b) VALUES(NEW.b) ON CONFLICT(b) DO UPDATE SET b = NEW.b;
            END IF;
            RETURN NEW;
        WHEN 'DELETE' THEN
            -- 删除对应表的关联记录
            DELETE FROM t1 WHERE a = OLD.a;
            DELETE FROM t2 WHERE b = OLD.b;
            RETURN OLD;
    END CASE;
END;
$$ LANGUAGE plpgsql;

第二步：创建触发器 #

注意指定FOR EACH ROW（行级触发器），且用ALWAYS确保复制操作和本地操作都触发：

CREATE TRIGGER trigger_distribute_table_a
AFTER INSERT OR UPDATE OR DELETE ON table_a
FOR EACH ROW
ALWAYS
EXECUTE FUNCTION distribute_a_to_t1_t2();

权限检查 #

确保创建触发器的用户拥有table_a、t1、t2的读写权限，以及触发器函数的执行权限。

3. 排查复制停止的静默错误 #

复制停止但无客户端报错，大概率是触发器执行时出现了未暴露的错误，需检查目标库的PostgreSQL日志（默认在pg_log目录），查找subscription、worker、trigger相关的错误信息：

• 常见错误：主键冲突（需在触发器中用ON CONFLICT处理）、权限不足、触发器函数逻辑错误
• 查看订阅状态：

SELECT subname, status FROM pg_stat_subscription;

如果status为down，执行前文的订阅重启命令恢复。

4. 初始数据同步处理 #

如果订阅创建时用了COPY_DATA = true，初始同步的COPY命令不会触发触发器，需手动同步t1、t2的初始数据：

INSERT INTO t1(a) SELECT a FROM table_a ON CONFLICT(a) DO NOTHING;
INSERT INTO t2(b) SELECT b FROM table_a ON CONFLICT(b) DO NOTHING;

内容的提问来源于stack exchange，提问作者Mateus Rauli