Entity Framework先查库再添加元素触发唯一主键约束错误排查

问题根源：竞态条件（并发冲突） #

你的代码执行的是**「检查-插入」两步非原子操作**，在多线程/多请求并发场景下会出现以下流程：

1. 线程A执行FirstOrDefault检查，发现目标物种不存在
2. 线程B在A还未执行SaveChanges前，也完成了同样的检查，同样判定物种不存在
3. 两个线程先后执行Add和SaveChanges，导致数据库尝试插入重复的PK_Species，触发唯一约束报错

特定物种频繁触发问题，大概率是该物种的并发请求量更高，或者其业务流程更容易遭遇并发场景。

至于AsNoTracking()无效，是因为它的作用是关闭EF的实体状态跟踪，和数据库层面的并发冲突完全无关，自然解决不了问题。

可行解决方案 #

1. 数据库层面原子操作（推荐） #

将「检查+插入」合并为数据库端的原子SQL操作，从根源避免竞态条件。以SQL Server为例：

foreach (var species in list.Species.ToList())
{
    // 替换为你的实际表字段
    var insertSql = @"
        INSERT INTO Species (PK_Species, SpeciesName, [其他字段])
        SELECT @Pk, @Name, @OtherField
        WHERE NOT EXISTS (SELECT 1 FROM Species WHERE PK_Species = @Pk)";

    context.Database.ExecuteSqlRaw(insertSql,
        new SqlParameter("@Pk", species.PK_Species),
        new SqlParameter("@Name", species.SpeciesName),
        new SqlParameter("@OtherField", species.OtherField));
}

这种方式让数据库在同一事务内完成检查和插入，完全避免并发冲突。

2. 捕获唯一约束异常并重试 #

如果无法修改SQL，可以通过捕获异常后重试的方式处理冲突：

foreach (var species in list.Species.ToList())
{
    bool isSaved = false;
    int retryTimes = 3; // 设置重试次数

    while (!isSaved && retryTimes > 0)
    {
        try
        {
            if (context.Species.FirstOrDefault(x => x.PK_Species == species.PK_Species) == null)
            {
                context.Species.Add(species);
                context.SaveChanges();
            }
            isSaved = true;
        }
        catch (DbUpdateException ex) 
        when (ex.InnerException is SqlException sqlEx && sqlEx.Number == 2627) // SQL Server唯一约束错误码
        {
            retryTimes--;
            // 重置实体状态，避免上下文跟踪混乱
            context.Entry(species).State = EntityState.Detached;
        }
    }
}

冲突发生后，重试时的检查会发现数据已存在，就不会再次插入。

3. 代码层面加锁 #

针对单个物种ID加锁，确保同一时间只有一个线程处理该物种：

// 用字典存储每个物种的锁对象，避免全局锁影响性能
private static readonly Dictionary<string, object> _speciesLocks = new Dictionary<string, object>();

// 在处理方法内
foreach (var species in list.Species.ToList())
{
    lock (GetLockObject(species.PK_Species))
    {
        if (context.Species.FirstOrDefault(x => x.PK_Species == species.PK_Species) == null)
        {
            context.Species.Add(species);
            context.SaveChanges();
        }
    }
}

// 辅助方法获取锁对象
private static object GetLockObject(string speciesId)
{
    lock (_speciesLocks)
    {
        if (!_speciesLocks.TryGetValue(speciesId, out var lockObj))
        {
            lockObj = new object();
            _speciesLocks[speciesId] = lockObj;
        }
        return lockObj;
    }
}

注意：这种方式仅适用于单进程场景，如果是多进程部署（比如多个Web服务器），需要用分布式锁（如Redis锁）。

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