如何在EF Core 6中实现类似SQL MERGE语句的数据增改删操作

EF Core 6没有直接提供对应SQL Server MERGE语句的原生API，但可以通过两种方式实现你需要的“新增/更新匹配行、删除不匹配行”的需求：

方法一：使用EF Core实体跟踪操作（适合小数据量） #

这种方式通过加载目标表实体、对比源数据来完成增删改，逻辑直观，适合数据量不大的场景：

1. 加载目标表中所有需要参与匹配的实体
2. 准备好源数据集合（比如从业务逻辑生成或外部导入的MemberSource数据）
3. 遍历源数据，对匹配到的实体执行更新，未匹配的执行新增
4. 找出目标表中不在源数据匹配范围内的实体，标记删除
5. 提交所有变更

代码示例：

using var context = new AppDbContext();

// 加载目标表所有实体
var targetEntities = await context.MemberTargets.ToListAsync();

// 模拟获取源数据（替换为你的实际源数据获取逻辑）
var sourceData = GetMemberSourceData();

// 用哈希集合存储源数据的匹配键，提升查找效率
var sourceMatchKeys = sourceData
    .Select(s => (s.CustomerID, s.WorkerID))
    .ToHashSet();

// 处理新增和更新
foreach (var sourceItem in sourceData)
{
    var existingEntity = targetEntities.FirstOrDefault(t => 
        t.CustomerID == sourceItem.CustomerID && t.WorkerID == sourceItem.WorkerID);
    
    if (existingEntity != null)
    {
        // 更新实体属性，根据你的业务需求修改字段
        existingEntity.Name = sourceItem.Name;
        existingEntity.Email = sourceItem.Email;
        // ...其他需要更新的属性
    }
    else
    {
        // 新增实体
        context.MemberTargets.Add(new MemberTarget
        {
            CustomerID = sourceItem.CustomerID,
            WorkerID = sourceItem.WorkerID,
            Name = sourceItem.Name,
            Email = sourceItem.Email
            // ...其他需要初始化的属性
        });
    }
}

// 处理删除：移除目标表中不在源数据里的实体
var entitiesToDelete = targetEntities
    .Where(t => !sourceMatchKeys.Contains((t.CustomerID, t.WorkerID)))
    .ToList();
context.MemberTargets.RemoveRange(entitiesToDelete);

// 提交所有变更
await context.SaveChangesAsync();

方法二：执行原生MERGE SQL（适合大数据量） #

如果数据量较大，直接执行原生SQL的MERGE语句性能更好，EF Core 6支持直接执行原生SQL：

代码示例：

using var context = new AppDbContext();

// 构造完整的MERGE语句，可根据需求补充更新、插入的字段逻辑
var mergeSql = @"
MERGE MemberTarget T
USING MemberSource S ON T.CustomerID = S.CustomerID AND T.WorkerID = S.WorkerID
WHEN MATCHED THEN 
    UPDATE SET T.Name = S.Name, T.Email = S.Email -- 按需修改更新字段
WHEN NOT MATCHED THEN
    INSERT (CustomerID, WorkerID, Name, Email)
    VALUES (S.CustomerID, S.WorkerID, S.Name, S.Email) -- 按需修改插入字段
WHEN NOT MATCHED BY SOURCE THEN
    DELETE;
";

// 执行原生SQL
await context.Database.ExecuteSqlRawAsync(mergeSql);

补充说明 #

如果你的MemberSource是内存集合而非数据库表，可以先通过SqlBulkCopy将内存数据写入临时表，再让MERGE语句关联临时表执行操作，这样同样能高效完成批量处理。

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