PostgreSQL多表联动触发器咨询：表A关联向表F插入含JSON字段数据

实现方案说明 #

根据你的需求，这里提供两种适配不同业务场景的PostgreSQL触发器实现方案，核心都是绑定在父表A上，确保A、B、C、D、E都插入对应数据后，自动向F表插入符合要求的数据（包括指定JSON列）。

前提假设

先明确各表的关联逻辑：

• 表A的主键为a_id（示例用自增序列）
• B、C、D、E表均通过a_id外键关联A表
• F表包含A的字段，以及一个a_json JSON类型列，用于存储A的3个varchar字段的键值对JSON

方案一：直接检查关联表数据存在性 #

适合数据插入顺序不固定，只要B/C/D/E都有对应A的记录就触发插入的场景。

1. 创建触发器函数

CREATE OR REPLACE FUNCTION insert_f_when_all_ready()
RETURNS TRIGGER AS $$
BEGIN
    -- 检查B/C/D/E是否都存在当前A记录的关联数据，且F中无重复记录
    IF EXISTS (SELECT 1 FROM B WHERE a_id = NEW.a_id)
       AND EXISTS (SELECT 1 FROM C WHERE a_id = NEW.a_id)
       AND EXISTS (SELECT 1 FROM D WHERE a_id = NEW.a_id)
       AND EXISTS (SELECT 1 FROM E WHERE a_id = NEW.a_id)
       AND NOT EXISTS (SELECT 1 FROM F WHERE a_id = NEW.a_id) THEN
        
        -- 向F插入数据，拼接指定JSON列
        INSERT INTO F (a_id, col1, col2, col3, other_col, a_json)
        VALUES (
            NEW.a_id,
            NEW.col1,
            NEW.col2,
            NEW.col3,
            NEW.other_col,
            -- 将A的3个varchar字段转为键值对JSON
            json_build_object(
                'col1', NEW.col1,
                'col2', NEW.col2,
                'col3', NEW.col3
            )
        );
    END IF;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

2. 创建绑定A表的触发器

CREATE TRIGGER trigger_a_after_insert_update
AFTER INSERT OR UPDATE ON A
FOR EACH ROW
EXECUTE FUNCTION insert_f_when_all_ready();

方案逻辑

• 触发器在A表插入或更新时触发
• 函数内检查B/C/D/E是否都有对应a_id的记录，同时避免F表重复插入
• 满足条件时自动插入F表，a_json列通过json_build_object生成合法的键值对JSON

使用方式

当B/C/D/E都插入完对应A的记录后，只需执行一次A表的更新操作（比如更新任意字段），就能触发触发器完成F表的插入：

UPDATE A SET other_col = other_col WHERE a_id = 1; -- 无实际修改，仅触发触发器

方案二：通过计数自动触发 #

适合B/C/D/E每个表只会插入一条对应A的记录，希望自动检测全部就绪的场景。

1. 给A表添加就绪计数字段

ALTER TABLE A ADD COLUMN ready_count INT DEFAULT 0;

2. 创建更新计数的触发器函数

CREATE OR REPLACE FUNCTION update_a_ready_count()
RETURNS TRIGGER AS $$
BEGIN
    -- 每插入一个关联表的记录，A的就绪计数+1
    UPDATE A SET ready_count = ready_count + 1 WHERE a_id = NEW.a_id;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

3. 给B/C/D/E表绑定计数触发器

-- B表触发器
CREATE TRIGGER trigger_b_after_insert
AFTER INSERT ON B
FOR EACH ROW
EXECUTE FUNCTION update_a_ready_count();

-- C表触发器
CREATE TRIGGER trigger_c_after_insert
AFTER INSERT ON C
FOR EACH ROW
EXECUTE FUNCTION update_a_ready_count();

-- D表触发器
CREATE TRIGGER trigger_d_after_insert
AFTER INSERT ON D
FOR EACH ROW
EXECUTE FUNCTION update_a_ready_count();

-- E表触发器
CREATE TRIGGER trigger_e_after_insert
AFTER INSERT ON E
FOR EACH ROW
EXECUTE FUNCTION update_a_ready_count();

4. 修改A表的触发器函数

CREATE OR REPLACE FUNCTION insert_f_when_count_full()
RETURNS TRIGGER AS $$
BEGIN
    -- 当就绪计数等于4（B/C/D/E各一条）且F无重复记录时插入
    IF NEW.ready_count = 4
       AND NOT EXISTS (SELECT 1 FROM F WHERE a_id = NEW.a_id) THEN
        
        INSERT INTO F (a_id, col1, col2, col3, other_col, a_json)
        VALUES (
            NEW.a_id,
            NEW.col1,
            NEW.col2,
            NEW.col3,
            NEW.other_col,
            json_build_object('col1', NEW.col1, 'col2', NEW.col2, 'col3', NEW.col3)
        );
    END IF;
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

5. 绑定A表的最终触发器

CREATE TRIGGER trigger_a_after_count_update
AFTER UPDATE ON A
FOR EACH ROW
EXECUTE FUNCTION insert_f_when_count_full();

方案逻辑

• 每插入B/C/D/E的一条关联记录，A表的ready_count自动+1
• 当计数达到4时，A表的更新触发器自动触发，完成F表的插入
• 全程无需手动干预，完全自动触发

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