Synapse中如何基于主键匹配通过T-SQL EXISTS实现表数据更新插入

是否需要IF...THEN...ELSE逻辑？ #

不需要。用EXISTS条件分别配合更新、插入语句即可完成需求，额外加分支判断反而存在明显弊端：

• 逐行判断逻辑已经内置在UPDATE/INSERT的WHERE条件中：语句执行时会自动逐行判断每条记录是否满足主键匹配规则，不需要提前全局判断「是否存在匹配记录」再走分支。
• 性能更优：Synapse是分布式计算架构，IF分支判断需要先做全表扫描统计匹配情况，会带来额外的计算开销，直接带EXISTS条件的写入语句可以下推到计算节点执行，效率更高。
• 避免并发不一致：IF判断和后续写入操作之间如果有其他并发任务修改数据，会出现判断结果和实际执行时数据状态不一致的问题，直接用EXISTS条件的写入语句在执行时实时判断，不会有这个问题。

现有测试代码的问题 #

你编写的带EXISTS的SELECT语句，仅能查询出tbl1中与tbl2存在FName匹配的记录，没有任何写入逻辑，无法完成数据同步。你可以在正式执行写入前跑这类校验语句，确认匹配规则命中的记录范围符合预期，避免误操作。

具体实现代码 #

注意：以下代码默认主键匹配规则为「id字段相同 或 name（FName）字段相同即判定为同一条记录」，如果业务要求两个字段同时匹配才算命中，把所有匹配条件里的OR替换为AND即可。代码里的BizColumn1、BizColumn2为示例业务字段，执行前请替换成你表中实际需要同步的字段。

首先执行匹配更新逻辑，用EXISTS锁定需要更新的记录范围：

-- 主键匹配时，更新tbl1中对应记录
UPDATE a
SET
    a.FName = b.FName,
    a.BizColumn1 = b.BizColumn1,
    a.BizColumn2 = b.BizColumn2
    -- 按实际同步需求补充需要更新的字段，注意不要更新主键字段
FROM dbo.tbl1 a
INNER JOIN dbo.tbl2 b
    ON a.id = b.id OR a.FName = b.FName
WHERE EXISTS (
    SELECT 1
    FROM dbo.tbl2 b_check
    WHERE a.id = b_check.id OR a.FName = b_check.FName
);

再执行无匹配记录的插入逻辑，用NOT EXISTS过滤掉tbl1中已经存在的记录：

-- 主键无匹配时，向tbl1插入tbl2中的新记录
INSERT INTO dbo.tbl1 (id, FName, BizColumn1, BizColumn2 /* 补充其余需要插入的字段*/)
SELECT
    b.id,
    b.FName,
    b.BizColumn1,
    b.BizColumn2
    -- 按字段顺序补充对应取值
FROM dbo.tbl2 b
WHERE NOT EXISTS (
    SELECT 1
    FROM dbo.tbl1 a
    WHERE a.id = b.id OR a.FName = b.FName
    -- 注意：这里的匹配规则必须和上面UPDATE语句的规则完全一致
);

可选优化 #

如果同步数据量较大，或者需要保证操作原子性（避免更新执行成功、插入执行失败导致的数据不一致），可以把两步操作包裹在显式事务中执行：

BEGIN TRANSACTION;
-- 粘贴上述UPDATE语句
-- 粘贴上述INSERT语句
COMMIT TRANSACTION;

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