如何用Entity Framework Core高效更新API同步的无主键关联现有记录？

以API返回的唯一标识ID（比如命名为ExternalId）作为匹配依据，通过"批量查询匹配-更新已有记录-插入新增记录"的逻辑实现同步，避免冗余操作提升效率。

假设你的实体类定义如下：

public class BusinessEntity
{
    // 数据库自增主键
    public int Id { get; set; }
    // API返回的唯一标识，需在数据库中配置唯一约束
    public string ExternalId { get; set; } = string.Empty;
    // 其他业务字段示例
    public string Title { get; set; } = string.Empty;
    public DateTime UpdateTime { get; set; }
    // 更多业务字段...
}

同步逻辑代码：

public async Task SyncApiDataAsync(YourDbContext dbContext, List<BusinessEntity> apiDataList)
{
    // 将API数据按ExternalId构建字典，快速匹配
    var apiDataMap = apiDataList.ToDictionary(item => item.ExternalId);
    
    // 批量查询数据库中已存在的对应记录
    var existingEntities = await dbContext.Set<BusinessEntity>()
        .Where(e => apiDataMap.Keys.Contains(e.ExternalId))
        .ToListAsync();

    // 更新已有记录的业务字段
    foreach (var entity in existingEntities)
    {
        var latestData = apiDataMap[entity.ExternalId];
        entity.Title = latestData.Title;
        entity.UpdateTime = latestData.UpdateTime;
        // 同步其他需要更新的字段
        dbContext.Entry(entity).State = EntityState.Modified;
    }

    // 筛选出API中存在但数据库没有的记录，执行插入
    var existingExternalIds = existingEntities.Select(e => e.ExternalId).ToHashSet();
    var newEntities = apiDataList.Where(item => !existingExternalIds.Contains(item.ExternalId)).ToList();
    
    if (newEntities.Any())
    {
        await dbContext.Set<BusinessEntity>().AddRangeAsync(newEntities);
    }

    // 提交所有变更
    await dbContext.SaveChangesAsync();
}

如果数据量较大，可使用ExecuteUpdate实现批量更新，无需加载实体到内存，效率更高：

public async Task BatchSyncApiDataAsync(YourDbContext dbContext, List<BusinessEntity> apiDataList)
{
    // 批量更新已有记录
    foreach (var apiItem in apiDataList)
    {
        await dbContext.Set<BusinessEntity>()
            .Where(e => e.ExternalId == apiItem.ExternalId)
            .ExecuteUpdateAsync(s => s
                .SetProperty(e => e.Title, apiItem.Title)
                .SetProperty(e => e.UpdateTime, apiItem.UpdateTime));
    }

    // 查询已存在的ExternalId集合
    var existingIds = await dbContext.Set<BusinessEntity>()
        .Where(e => apiDataList.Select(a => a.ExternalId).Contains(e.ExternalId))
        .Select(e => e.ExternalId)
        .ToListAsync();

    // 插入新增记录
    var newItems = apiDataList.Where(item => !existingIds.Contains(item.ExternalId)).ToList();
    if (newItems.Any())
    {
        await dbContext.AddRangeAsync(newItems);
        await dbContext.SaveChangesAsync();
    }
}

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