EF Core在C#应用中基于多列实现Upsert操作的方案咨询

EF Core确实移除了EF6中的AddOrUpdate方法，你可以通过以下几种方案实现基于OrgId和PersonId的匹配更新/插入逻辑：

方案1：手动查询判断（最直观） #

先根据OrgId和PersonId查询数据库中是否存在匹配记录，存在则更新字段，不存在则新增实体。

using var context = new YourDbContext();

var existingEngagement = context.Engagements
    .FirstOrDefault(e => e.OrgId == targetOrgId && e.PersonId == targetPersonId);

if (existingEngagement != null)
{
    // 更新字段
    existingEngagement.OrgName = newOrgName;
    existingEngagement.ClubName = newClubName;
    // 其他字段更新...
}
else
{
    // 新增实体
    var newEngagement = new Engagement
    {
        OrgId = targetOrgId,
        PersonId = targetPersonId,
        OrgName = newOrgName,
        ClubName = newClubName,
        // 其他字段赋值...
    };
    context.Engagements.Add(newEngagement);
}

await context.SaveChangesAsync();

注意：这种方式会多一次查询操作，且在高并发场景下可能出现重复插入问题，建议给OrgId和PersonId组合添加唯一索引来避免。

方案2：先尝试更新，无匹配则插入（减少查询） #

利用EF Core的ExecuteUpdate方法先执行更新，通过返回的受影响行数判断是否存在匹配记录，若受影响行数为0则执行插入。

using var context = new YourDbContext();

// 尝试更新匹配的记录
var updatedCount = await context.Engagements
    .Where(e => e.OrgId == targetOrgId && e.PersonId == targetPersonId)
    .ExecuteUpdateAsync(setters => setters
        .SetProperty(e => e.OrgName, newOrgName)
        .SetProperty(e => e.ClubName, newClubName)
        // 其他字段更新...
    );

if (updatedCount == 0)
{
    // 无匹配记录，执行插入
    var newEngagement = new Engagement
    {
        OrgId = targetOrgId,
        PersonId = targetPersonId,
        OrgName = newOrgName,
        ClubName = newClubName,
        // 其他字段赋值...
    };
    context.Engagements.Add(newEngagement);
    await context.SaveChangesAsync();
}

这种方式只在需要插入时才会有额外的写入操作，比方案1少一次查询，性能更优。

方案3：使用数据库原生UPSERT语句（原子操作，高并发友好） #

直接通过数据库的原生语法执行UPSERT（比如SQL Server的MERGE，PostgreSQL的ON CONFLICT），这种方式是数据库层面的原子操作，完全避免并发问题。

以SQL Server为例，使用MERGE语句：

using var context = new YourDbContext();

var sql = @"
MERGE INTO Engagements AS Target
USING (VALUES (@OrgId, @PersonId, @OrgName, @ClubName)) AS Source (OrgId, PersonId, OrgName, ClubName)
ON Target.OrgId = Source.OrgId AND Target.PersonId = Source.PersonId
WHEN MATCHED THEN
    UPDATE SET 
        OrgName = Source.OrgName,
        ClubName = Source.ClubName
        -- 其他字段更新...
WHEN NOT MATCHED THEN
    INSERT (OrgId, PersonId, OrgName, ClubName)
    VALUES (Source.OrgId, Source.PersonId, Source.OrgName, Source.ClubName);
";

await context.Database.ExecuteSqlRawAsync(sql,
    new SqlParameter("@OrgId", targetOrgId),
    new SqlParameter("@PersonId", targetPersonId),
    new SqlParameter("@OrgName", newOrgName),
    new SqlParameter("@ClubName", newClubName)
    // 其他参数...
);

这种方式性能最好，且能保证原子性，适合高并发场景，但需要根据你使用的数据库调整语法。

额外建议 #

• 给OrgId和PersonId组合添加唯一约束，确保数据一致性：

  // 在DbContext的OnModelCreating中配置
  protected override void OnModelCreating(ModelBuilder modelBuilder)
  {
      modelBuilder.Entity<Engagement>()
          .HasIndex(e => new { e.OrgId, e.PersonId })
          .IsUnique();
  }
  

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