EF Core 8中能否仅添加新实体、忽略数据库中已存在的实体？

方案1：数据库层面原子批量插入（推荐） #

直接利用SQL的INSERT ... SELECT ... WHERE NOT EXISTS语法，结合**表值参数（TVP）**传递批量数据，这是数据库级别的原子操作，能彻底避免并发场景下的重复插入问题，同时效率远高于客户端先查后插的逻辑。

实现步骤： #

1. 在SQL Server中定义与实体结构匹配的表值参数类型：

CREATE TYPE YourEntityType AS TABLE (
    Id UNIQUEIDENTIFIER, -- 替换成你的主键实际类型
    Column1 NVARCHAR(100),
    Column2 INT
)

2. 在EF Core中执行批量插入：

var entities = new List<YourEntity> { ... }; // 待插入的实体列表

// 将实体转换为匹配表值参数结构的DataTable
var dataTable = new DataTable();
dataTable.Columns.Add("Id", typeof(Guid));
dataTable.Columns.Add("Column1", typeof(string));
dataTable.Columns.Add("Column2", typeof(int));

foreach (var entity in entities)
{
    dataTable.Rows.Add(entity.Id, entity.Column1, entity.Column2);
}

// 执行原子插入SQL
await context.Database.ExecuteSqlAsync(@"
    INSERT INTO YourEntities (Id, Column1, Column2)
    SELECT t.Id, t.Column1, t.Column2
    FROM @Entities t
    WHERE NOT EXISTS (
        SELECT 1 FROM YourEntities e WHERE e.Id = t.Id
    )",
    new SqlParameter("@Entities", SqlDbType.Structured)
    {
        TypeName = "YourEntityType",
        Value = dataTable
    });

这种方式的核心优势是原子性，数据库会在插入时一次性完成存在性判断和插入操作，完全规避了客户端先查后插的时间窗口导致的并发问题。

方案2：EF Core上下文结合异常重试（适合简单场景） #

如果不想写原生SQL，可以尝试先批量添加所有实体，捕获DbUpdateException后筛选出重复键的实体，移除后重试保存。但注意，这种方式在高并发场景下仍可能出现重复异常，需要结合重试逻辑。

实现示例： #

var entitiesToAdd = new List<YourEntity> { ... };
context.AddRange(entitiesToAdd);

try
{
    await context.SaveChangesAsync();
}
catch (DbUpdateException ex)
{
    // 从异常中解析出重复的主键ID（需根据数据库类型自定义解析逻辑）
    var duplicateIds = ExtractDuplicateIdsFromException(ex);
    var entitiesToRetry = entitiesToAdd.Where(e => !duplicateIds.Contains(e.Id)).ToList();
    
    // 清空上下文状态，重新添加未重复的实体
    context.ChangeTracker.Clear();
    context.AddRange(entitiesToRetry);
    await context.SaveChangesAsync();
}

这种方式的缺点是依赖异常解析，不同数据库（如SQL Server、MySQL）的异常信息格式不同，且并发场景下可能需要多次重试，效率不如方案1。

方案3：EF Core预检查插入（仅适合低并发场景） #

利用EF Core查询现有实体ID，筛选出不存在的实体再插入，本质是客户端先判断后插入，仍存在并发时间窗口，仅适合低并发场景：

var existingIds = await context.YourEntities
    .Where(e => entitiesToAdd.Select(x => x.Id).Contains(e.Id))
    .Select(e => e.Id)
    .ToListAsync();

var newEntities = entitiesToAdd.Where(e => !existingIds.Contains(e.Id)).ToList();
context.AddRange(newEntities);
await context.SaveChangesAsync();

如你所说，这种方式无法应对其他进程在查询和插入之间新增实体的情况，仅适合并发极低的场景。

内容的提问来源于stack exchange，提问作者Álvaro García