Got it，既然你的源表和目标表都没有主键，那些依赖主键/唯一约束的常规UPSERT方案（比如MySQL的ON DUPLICATE KEY UPDATE、PostgreSQL的ON CONFLICT）确实没法直接用。不过我们可以通过匹配你定义的「存在」判断条件，结合事务和条件执行来实现需求。

首先明确核心：你需要先定义什么算是「记录存在」——从你的SQL片段来看，判断逻辑应该是基于ColumnB和ColumnC的匹配（毕竟你从源表取了DISTINCT ColumnB, ColumnC），下面的方案都基于这个匹配逻辑展开。

SQL Server / PostgreSQL 15+（使用MERGE语句） #

MERGE是最简洁的方式，它能在一个事务里完成匹配判断、更新、插入操作，避免并发问题：

BEGIN TRANSACTION;

MERGE INTO TargetTable AS t
-- 取源表中需要匹配/插入的记录
USING (
    SELECT DISTINCT ColumnB, ColumnC FROM SourceTable WHERE ColumnB = 'a'
) AS s
-- 这里是「记录存在」的判断条件，可根据你的实际需求调整
ON (t.ColumnB = s.ColumnB AND t.ColumnC = s.ColumnC)
WHEN MATCHED THEN
    -- 存在时执行更新
    UPDATE SET ColumnD = '...', ColumnE = '...'
WHEN NOT MATCHED THEN
    -- 不存在时执行插入（注意：原INSERT语句中derived_table只有B、C列，你需要补充A、F、G的取值来源，示例用占位符代替）
    INSERT (ColumnA, ColumnB, ColumnC, ColumnD, ColumnE, ColumnF, ColumnG)
    VALUES (
        'your_columnA_value', -- 替换为ColumnA的实际取值（比如默认值/其他表字段）
        s.ColumnB,
        s.ColumnC,
        '...',
        '...',
        'your_columnF_value', -- 替换为ColumnF的实际取值
        'your_columnG_value'  -- 替换为ColumnG的实际取值
    );

COMMIT TRANSACTION;

MySQL（使用事务+条件执行） #

MySQL没有原生MERGE，但可以通过事务包裹「先更新，再判断行数插入」的逻辑：

START TRANSACTION;

-- 先尝试更新匹配的记录
UPDATE TargetTable 
SET ColumnD = '...', ColumnE = '...'
WHERE ColumnB = 'a' 
  AND EXISTS (
      SELECT 1 FROM SourceTable s 
      WHERE s.ColumnB = TargetTable.ColumnB AND s.ColumnC = TargetTable.ColumnC
  );

-- 如果UPDATE没有影响任何行，说明没有匹配记录，执行插入
IF ROW_COUNT() = 0 THEN
    INSERT INTO TargetTable (ColumnA, ColumnB, ColumnC, ColumnD, ColumnE, ColumnF, ColumnG)
    SELECT 
        'your_columnA_value',
        s.ColumnB,
        s.ColumnC,
        '...',
        '...',
        'your_columnF_value',
        'your_columnG_value'
    FROM (SELECT DISTINCT ColumnB, ColumnC FROM SourceTable WHERE ColumnB = 'a') s;
END IF;

COMMIT;

PostgreSQL 14及以下（使用事务+条件执行） #

如果你的PostgreSQL版本不支持MERGE，可以用类似MySQL的逻辑，通过NOT FOUND判断是否需要插入：

BEGIN;

-- 先更新匹配的记录
UPDATE TargetTable t
SET ColumnD = '...', ColumnE = '...'
FROM (SELECT DISTINCT ColumnB, ColumnC FROM SourceTable WHERE ColumnB = 'a') s
WHERE t.ColumnB = s.ColumnB AND t.ColumnC = s.ColumnC;

-- 如果没有更新到任何行，执行插入
IF NOT FOUND THEN
    INSERT INTO TargetTable (ColumnA, ColumnB, ColumnC, ColumnD, ColumnE, ColumnF, ColumnG)
    SELECT 
        'your_columnA_value',
        s.ColumnB,
        s.ColumnC,
        '...',
        '...',
        'your_columnF_value',
        'your_columnG_value'
    FROM (SELECT DISTINCT ColumnB, ColumnC FROM SourceTable WHERE ColumnB = 'a') s;
END IF;

COMMIT;

关键注意事项 #

• 明确匹配条件：一定要确保ON子句或UPDATE的WHERE条件能准确识别「重复记录」，否则会出现误更新或重复插入的问题。
• 补充缺失字段：你的原INSERT语句中，derived_table只有ColumnB和ColumnC，但要插入的列包含A、F、G，必须为这些字段指定合法的取值来源（比如默认值、固定值、关联其他表）。
• 并发安全：所有操作必须包裹在事务中，高并发场景下可以考虑提升事务隔离级别，避免出现更新丢失或重复插入的问题。

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