Entity Framework 6重复数据处理：Insert on Duplicate Update实现咨询

嘿，我来帮你搞定这个Upsert（Insert on Duplicate Update）的需求！针对你用的EF6、C#和MySQL InnoDB组合，这里有几种实用的方案，适配不同场景：

方案1：完善现有查询-更新/插入逻辑（低并发场景首选） #

你的代码已经有了雏形，只需要补全异步提交的调用，同时优化成异步查询（毕竟你用了async Task）。这个方案简单直观，适合并发量不高的系统：

public async Task AddHostIdToGroup(HostsToGroup hostToGroup)
{
    using (var context = new MaintDbContext())
    {
        // 异步查询，避免阻塞线程
        HostsToGroup htg = await context.HostsToGroup.SingleOrDefaultAsync(hs => hs.HostId == hostToGroup.HostId);
        if (htg != null)
        {
            // 存在则更新指定字段
            htg.GroupId = hostToGroup.GroupId;
            // 如果有其他字段需要更新，在这里继续赋值
        }
        else
        {
            // 不存在则插入新记录
            context.HostsToGroup.Add(hostToGroup);
        }
        // 统一提交变更
        await context.SaveChangesAsync();
    }
}

⚠️ 注意：这个方案的查询和更新/插入不是原子操作，高并发下可能出现两个请求同时查询到记录不存在，导致重复插入的问题。如果你的系统并发量较高，建议用下面的方案。

方案2：使用MySQL原生INSERT ... ON DUPLICATE KEY UPDATE（高并发原子操作） #

MySQL本身支持这个原子性的Upsert语法，直接通过EF执行原生SQL就能实现，完美适配高并发场景：

public async Task AddHostIdToGroup(HostsToGroup hostToGroup)
{
    using (var context = new MaintDbContext())
    {
        // 编写MySQL原生Upsert语句
        var upsertSql = @"INSERT INTO HostsToGroup (HostId, GroupId) 
                          VALUES (@HostId, @GroupId) 
                          ON DUPLICATE KEY UPDATE GroupId = @GroupId";
        
        // 执行SQL，用参数化查询避免SQL注入
        await context.Database.ExecuteSqlCommandAsync(
            upsertSql,
            new MySqlParameter("@HostId", hostToGroup.HostId),
            new MySqlParameter("@GroupId", hostToGroup.GroupId)
        );
    }
}

✅ 关键前提：必须确保你的HostsToGroup表中，HostId字段是主键或者唯一约束（Unique Key），否则MySQL无法识别重复记录，ON DUPLICATE KEY UPDATE不会触发。

如果你的实体有更多字段需要更新，只需要扩展ON DUPLICATE KEY UPDATE部分即可，比如：

ON DUPLICATE KEY UPDATE 
    GroupId = @GroupId,
    LastUpdated = @LastUpdated,
    Creator = @Creator

方案3：使用EF扩展库（批量Upsert场景） #

如果需要处理批量的Upsert操作，可以考虑使用EntityFramework.Mysql.BulkExtensions（需确认版本兼容EF6），它封装了批量Upsert的逻辑，用法类似：

public async Task BulkAddHostIdsToGroup(List<HostsToGroup> hostToGroups)
{
    using (var context = new MaintDbContext())
    {
        await context.BulkInsertOrUpdateAsync(hostToGroups, options => 
        {
            options.UpdateWhereCondition = htg => htg.HostId;
        });
    }
}

不过单条记录的话，原生SQL方案更轻量，没必要引入额外库。

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