无唯一约束时用Entity Framework 6实现Upsert操作

这个Upsert需求在EF6 Code First里确实挺常见的，尤其是当你需要用非主键字段（比如这里的Sku）作为判断依据的时候。我给你整理了几种可行的实现方案，你可以根据自己的场景选择：

方法一：先查询再判断（直观易调试） #

这是最直观的实现方式，先根据Sku查询数据库中是否存在对应记录，存在则更新属性，不存在则新增。

public void Save(Product p)
{
    using (var context = new YourDbContext())
    {
        var existingProduct = context.Products.FirstOrDefault(prod => prod.Sku == p.Sku);

        if (existingProduct != null)
        {
            // 更新现有实体的属性，根据你的实际需求调整字段
            existingProduct.Sku = p.Sku; // 若Sku不允许修改可省略
            // 示例：更新其他属性
            // existingProduct.ProductName = p.ProductName;
            // existingProduct.Price = p.Price;
        }
        else
        {
            // 新增实体到上下文
            context.Products.Add(p);
        }

        // 提交更改到数据库
        context.SaveChanges();
    }
}

注意点： #

• 这个方法会多一次数据库查询，在高并发场景下可能出现竞态条件（比如两个请求同时查询同一个Sku都未找到，导致重复插入）。
• 一定要在数据库给Sku字段添加唯一约束，这样即使出现竞态，数据库也会阻止重复数据，同时代码里可以捕获DbUpdateException来处理冲突。

方法二：使用EF的AddOrUpdate扩展（简洁但需注意坑点） #

EF6提供了AddOrUpdate扩展方法（位于System.Data.Entity.Migrations命名空间下），可以指定判断条件来自动处理新增或更新。不过要注意，这个方法原本是为数据库迁移设计的，并非为高并发场景优化。

// 需要引用命名空间：using System.Data.Entity.Migrations;

public void Save(Product p)
{
    using (var context = new YourDbContext())
    {
        // 第一个参数是判断条件（这里用Sku），第二个是要操作的实体
        context.Products.AddOrUpdate(prod => prod.Sku, p);
        context.SaveChanges();
    }
}

注意点： #

• 内部逻辑依然是先查询再操作，同样存在竞态条件，依赖数据库的唯一约束。
• 如果你的Id是自增主键，更新时不要传入新的Id值，否则会覆盖现有实体的主键，导致数据错误。
• 该方法会更新实体的所有属性，如果你有部分属性不想被覆盖（比如创建时间），这种方式就不太合适。

方法三：执行原生SQL（性能最优，适合高并发） #

如果追求性能和原子性，可以直接通过EF执行原生的Upsert SQL（比如SQL Server的MERGE语句），一次数据库操作完成，且能利用数据库的原子性避免竞态条件。

public void Save(Product p)
{
    using (var context = new YourDbContext())
    {
        // 以SQL Server的MERGE语句为例，其他数据库语法需调整（比如MySQL用INSERT ... ON DUPLICATE KEY UPDATE）
        var sql = @"
            MERGE INTO Products AS Target
            USING (VALUES (@Sku, @ProductName, @Price)) AS Source (Sku, ProductName, Price)
            ON Target.Sku = Source.Sku
            WHEN MATCHED THEN
                UPDATE SET ProductName = Source.ProductName, Price = Source.Price
            WHEN NOT MATCHED THEN
                INSERT (Sku, ProductName, Price) VALUES (Source.Sku, Source.ProductName, Source.Price);
        ";

        // 执行SQL并传入参数
        context.Database.ExecuteSqlCommand(sql,
            new System.Data.SqlClient.SqlParameter("@Sku", p.Sku),
            new System.Data.SqlClient.SqlParameter("@ProductName", p.ProductName),
            new System.Data.SqlClient.SqlParameter("@Price", p.Price)
        );
    }
}

优势： #

• 原子性操作，一次数据库往返完成，性能最优。
• 依赖数据库的唯一约束和锁机制，能有效避免高并发下的竞态问题。
• 缺点是需要编写原生SQL，不同数据库语法有差异，不够ORM化。

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