PostgreSQL中从Table A向Table B插入去重合并ta3、ta4值的方案咨询

一、一次性同步现有数据（避免重复插入） #

你之前用unnest出现重复插入，核心是没做好合并后的去重+存在性检查。可以通过合并列后先去重，再判断Table B中是否已存在该值，只插入新数据：

INSERT INTO Table B (tb1)
SELECT DISTINCT combined_value
FROM (
    -- 合并ta3和ta4的所有值
    SELECT ta3 AS combined_value FROM Table A
    UNION ALL
    SELECT ta4 AS combined_value FROM Table A
) AS merged_data
-- 排除空值（按需调整，如果你允许空值可以去掉这行）
WHERE combined_value IS NOT NULL
-- 只插入Table B中没有的新值
AND NOT EXISTS (
    SELECT 1 FROM Table B WHERE tb1 = merged_data.combined_value
);

如果想简化，也可以用UNION代替UNION ALL，它会自动去掉两列合并后的重复值，这样外层的DISTINCT可以省略：

INSERT INTO Table B (tb1)
SELECT combined_value
FROM (
    SELECT ta3 AS combined_value FROM Table A
    UNION
    SELECT ta4 AS combined_value FROM Table A
) AS merged_data
WHERE combined_value IS NOT NULL
AND NOT EXISTS (
    SELECT 1 FROM Table B WHERE tb1 = merged_data.combined_value
);

二、自动同步新增/更新的数据 #

要实现Table A的ta3或ta4新增数据时自动同步，需要用触发器来监听表的插入/更新事件，触发去重插入逻辑。

PostgreSQL 实现示例 #

1. 先创建触发器函数：

CREATE OR REPLACE FUNCTION sync_ta3_ta4_to_tableb()
RETURNS TRIGGER AS $$
BEGIN
    -- 处理新增/更新的ta3值
    IF NEW.ta3 IS NOT NULL THEN
        INSERT INTO Table B (tb1)
        SELECT NEW.ta3
        WHERE NOT EXISTS (SELECT 1 FROM Table B WHERE tb1 = NEW.ta3);
    END IF;

    -- 处理新增/更新的ta4值
    IF NEW.ta4 IS NOT NULL THEN
        INSERT INTO Table B (tb1)
        SELECT NEW.ta4
        WHERE NOT EXISTS (SELECT 1 FROM Table B WHERE tb1 = NEW.ta4);
    END IF;

    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

2. 给Table A绑定触发器，监听INSERT和UPDATE事件（如果只需要同步新增数据，只保留INSERT即可）：

CREATE TRIGGER trigger_sync_tablea_to_tableb
AFTER INSERT OR UPDATE OF ta3, ta4 ON Table A
FOR EACH ROW EXECUTE FUNCTION sync_ta3_ta4_to_tableb();

MySQL 实现示例 #

1. 创建存储过程（触发器调用的逻辑）：

DELIMITER //
CREATE PROCEDURE sync_ta3_ta4_to_tableb(IN new_ta3 VARCHAR(255), IN new_ta4 VARCHAR(255))
BEGIN
    IF new_ta3 IS NOT NULL THEN
        INSERT INTO Table B (tb1)
        SELECT new_ta3
        WHERE NOT EXISTS (SELECT 1 FROM Table B WHERE tb1 = new_ta3);
    END IF;
    IF new_ta4 IS NOT NULL THEN
        INSERT INTO Table B (tb1)
        SELECT new_ta4
        WHERE NOT EXISTS (SELECT 1 FROM Table B WHERE tb1 = new_ta4);
    END IF;
END //
DELIMITER ;

2. 创建触发器：

CREATE TRIGGER trigger_sync_tablea_to_tableb
AFTER INSERT ON Table A
FOR EACH ROW
CALL sync_ta3_ta4_to_tableb(NEW.ta3, NEW.ta4);

额外建议 #

给Table B的tb1列加唯一约束，就算触发器逻辑有疏漏，数据库层面也能拦截重复插入，避免脏数据：

-- PostgreSQL/MySQL通用语法
ALTER TABLE Table B ADD CONSTRAINT unique_tb1 UNIQUE (tb1);

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