如何在Entity Framework C#中实现Azure SQL表批量更新？

我现有一段用Azure.Data.Tables在Azure表存储中执行批量更新的代码：

public async Task BatchUpdateUsersAsync(IEnumerable<User> users)
{            
    var batchOperation = new List<TableTransactionAction>();

    if (users.Count() <= 100)
    {
        foreach (var user in users)
        {
            batchOperation.Add(new TableTransactionAction(TableTransactionActionType.UpdateMerge, user));
        }

        if (batchOperation.Any())
        {
            await _tableClient.SubmitTransactionAsync(batchOperation);
        }
    }
}

想知道怎么用Entity Framework在Azure SQL表中实现类似的批量更新？以下是DatabaseRepo的框架代码：

public class DatabaseRepo
{
    private readonly UserContext _context;
    
    public DatabaseRepo(UserContext userContext)
    {
        _context = userContext;
    }        

    public async Task BatchUpdateUsersAsync(IEnumerable<User> users)
    {            
        
    }
}

几种实现方案 #

1. 用EF Core 7+的ExecuteUpdate（推荐，性能最优） #

EF Core 7及以上版本支持直接生成批量更新SQL的ExecuteUpdate，不用把实体加载到内存，性能拉满。假设你要更新Name、Email这类字段，代码可以这么写：

public async Task BatchUpdateUsersAsync(IEnumerable<User> users)
{
    // 把用户转成字典，方便匹配主键
    var userDict = users.ToDictionary(u => u.Id); // 这里假设User的主键是Id

    // 生成单条UPDATE语句批量更新
    await _context.Users
        .Where(u => userDict.ContainsKey(u.Id))
        .ExecuteUpdateAsync(s => s
            .SetProperty(u => u.Name, u => userDict[u.Id].Name)
            .SetProperty(u => u.Email, u => userDict[u.Id].Email)
            // 有其他要更新的字段，继续在这里添加
        );
}

这种方式只会发一条SQL到数据库，比逐条更新快得多。

2. 传统跟踪式批量更新（兼容所有EF版本，但性能一般） #

如果你的EF版本较低，或者需要更新整个实体，可以把实体附加到上下文标记为修改，再批量保存：

public async Task BatchUpdateUsersAsync(IEnumerable<User> users)
{
    foreach (var user in users)
    {
        // 附加实体到上下文，标记为已修改
        _context.Users.Attach(user);
        _context.Entry(user).State = EntityState.Modified;
        // 如果只需要更新部分字段，不用全标记，比如：
        // _context.Entry(user).Property(u => u.Name).IsModified = true;
    }

    // 一次性保存所有更改
    await _context.SaveChangesAsync();
}

注意：这种方式会给每个用户生成一条UPDATE语句，数据量大的时候（比如超过100条）性能会差很多。如果要处理大量数据，可以分批次提交：

public async Task BatchUpdateUsersAsync(IEnumerable<User> users)
{
    var userList = users.ToList();
    const int batchSize = 100; // 和你之前表存储的批量大小保持一致

    for (int i = 0; i < userList.Count; i += batchSize)
    {
        var batch = userList.Skip(i).Take(batchSize);

        foreach (var user in batch)
        {
            _context.Users.Attach(user);
            _context.Entry(user).State = EntityState.Modified;
        }

        await _context.SaveChangesAsync();
        // 清空上下文跟踪，避免内存占用过高
        _context.ChangeTracker.Clear();
    }
}

3. 用第三方批量扩展库（可选，性能接近原生SQL） #

如果需要更复杂的批量操作，可以用EFCore.BulkExtensions这个第三方库，它能生成高效的批量SQL。

先安装NuGet包：Install-Package EFCore.BulkExtensions

然后实现代码：

public async Task BatchUpdateUsersAsync(IEnumerable<User> users)
{
    await _context.BulkUpdateAsync(users);
}

这个库支持批量增删改查，性能和原生SQL差不多，适合复杂场景。

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