如何用Entity Framework实现存在则更新、不存在则插入的逻辑？

针对你的员工数据同步需求（变更现有员工字段、新增新员工），以下是不同EF Core版本下的最优实现方案，结合你的现有代码给出具体示例：

EF Core 7.0+ 推荐：原生Upsert（原子操作，性能最优） #

EF Core 7.0及以上版本提供了原生的Upsert支持，通过Upsert API直接在数据库层面执行原子操作，避免先查询再修改的并发冲突，性能表现最佳。

实现代码 #

假设你有一批待同步的员工数据集合IEnumerable<DisplayAPIDataEmployee> newEmployees，代码示例如下：

using (var context = new DataContext())
{
    foreach (var employee in newEmployees)
    {
        var upsertOperation = context.Employee
            .Upsert(employee)
            .On(e => e.employee_id) // 以主键employee_id判断记录是否存在
            .WhenMatchedUpdate(setters => setters
                .SetProperty(e => e.displayName, employee.displayName)
                .SetProperty(e => e.shortBirthDate, employee.shortBirthDate))
            .WhenNotMatchedInsert(setters => setters
                .SetProperty(e => e.createdOn, DateTime.Now)
                .SetProperty(e => e.displayName, employee.displayName)
                .SetProperty(e => e.shortBirthDate, employee.shortBirthDate)
                .SetProperty(e => e.employee_id, employee.employee_id));

        upsertOperation.Execute();
    }
}

关键说明 #

• 原子性：底层通过SQL Server的MERGE语句实现，确保单次数据库操作完成判断与更新/插入，避免并发场景下的数据冲突
• 字段精准控制：更新仅修改指定字段，插入时显式设置createdOn，避免更新时覆盖原有创建时间

EF Core 3.1~6.x：查询判断式实现（兼容方案） #

若项目使用较低版本的EF Core，可采用先查询再判断的方式实现需求，需注意并发场景的冲突处理。

实现代码 #

using (var context = new DataContext())
{
    foreach (var newEmp in newEmployees)
    {
        var existingEmp = context.Employee.Find(newEmp.employee_id);
        
        if (existingEmp != null)
        {
            // 仅更新实际变更的字段，减少数据库写入开销
            if (!string.Equals(existingEmp.displayName, newEmp.displayName, StringComparison.Ordinal))
                existingEmp.displayName = newEmp.displayName;
            if (!string.Equals(existingEmp.shortBirthDate, newEmp.shortBirthDate, StringComparison.Ordinal))
                existingEmp.shortBirthDate = newEmp.shortBirthDate;
        }
        else
        {
            // 新增员工，createdOn由模型构造函数自动赋值
            context.Employee.Add(newEmp);
        }
    }
    
    context.SaveChanges();
}

优化建议 #

• 使用Find方法：通过主键直接查询，比FirstOrDefault更高效
• 按需更新：仅修改实际变更的字段，避免不必要的数据库操作
• 批量处理：若数据量较大，建议分批次调用SaveChanges，降低内存占用

针对现有代码的优化点 #

1. 连接字符串配置：将硬编码的连接字符串迁移至配置文件（如appsettings.json），提升安全性与可维护性
2. 模型属性调整：createdOn建议设置为非可空DateTime类型，因为新增时必然会赋值，可空类型会增加数据库存储开销
3. 临时表适配：你的代码已启用系统版本表（IsTemporal()），Upsert操作会自动记录版本历史，无需额外处理

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