使用ExecuteUpdateAsync批量更新新值时遇LINQ翻译错误求助

问题描述 #

尝试将旧的foreach批量更新代码迁移为ExecuteUpdateAsync以提升性能，但遇到以下错误：

The LINQ expression could not be translated. Either rewrite the query in a form that can be translated, or switch to client evaluation explicitly by inserting a call to 'AsEnumerable', 'AsAsyncEnumerable', 'ToList', or 'ToListAsync

原代码如下：

public async Task Update(IEnumerable<StockDTO> dtos)
{
    var ids = dtos.Select(d => d.ProductStockIdentiferId);
    var StockTypes = dtos.Select(d => (int)d.StockType);
    
    await _dbcontext.Stocks
        .Where(s => 
                ids.Contains(s.ProductStockIdentiferId) &&
                StockTypes.Contains(s.StockTypeId))
        .ExecuteUpdateAsync(setters =>
            setters.SetProperty(
                stock => stock.Value,
                stock => dtos.First(x =>
                    x.ProductStockIdentiferId == stock.ProductStockIdentiferId).Value));
}

public record StockDTO
{
    public StockType StockType { get; set; }
    public long Value { get; set; }
    public int ProductStockIdentiferId { get; set; }
}

public partial class Stock
{
    public StockType StockType { get; set; }
    public int StockTypeId { get; set; }
    public long Value { get; set; }
    public int ProductStockIdentiferId { get; set; }
}

当把Value设为静态数字时代码可正常运行，核心问题是无法在ExecuteUpdateAsync中匹配对应DTO的Value值。

解决方案 #

核心原因 #

原代码中dtos.First(...)是客户端内存操作，EF Core无法将其翻译为SQL语句，因此报错。我们需要将DTO的映射关系转换为EF Core可翻译的结构——字典，利用EF Core 7.0+对字典的翻译支持来实现批量匹配更新。

修改后的代码 #

public async Task Update(IEnumerable<StockDTO> dtos)
{
    // 将DTO转换为(ProductStockIdentiferId, StockTypeId)为键、Value为值的字典
    var stockValueMap = dtos.ToDictionary(
        d => (d.ProductStockIdentiferId, StockTypeId: (int)d.StockType),
        d => d.Value);

    await _dbcontext.Stocks
        // 仅过滤出DTO中存在的(ID+类型)组合的记录，避免误更新
        .Where(s => stockValueMap.ContainsKey((s.ProductStockIdentiferId, s.StockTypeId)))
        .ExecuteUpdateAsync(setters =>
            setters.SetProperty(
                stock => stock.Value,
                // 字典索引访问会被EF Core翻译为SQL的CASE WHEN逻辑
                stock => stockValueMap[(stock.ProductStockIdentiferId, stock.StockTypeId)]));
}

说明 #

1. 字典映射：通过ToDictionary将DTO的唯一标识组合（ProductStockIdentiferId+StockTypeId）作为键，待更新的Value作为值，构建内存字典。
2. 精确过滤：使用stockValueMap.ContainsKey(...)替代原有的两个Contains条件，确保只更新DTO中存在的精确记录组合，避免误操作。
3. SQL翻译：EF Core 7.0及以上版本会自动将字典的索引访问翻译为SQL中的CASE WHEN语句，实现批量匹配更新，完全在数据库端执行，性能优于客户端循环更新。

内容的提问来源于stack exchange，提问作者João Cardoso