如何修改基于表达式的过滤器以避免在 Entity Framework Core 3.0 中进行客户端评估

Question

我有以下代码用于将基于 Func 的过滤器转换为 Expression 并过滤 Entity Framework Core 2.2 中的数据：

public async Task<TType> GetDataAsync<TType>(Func<TType, bool> filtering = null) where TType : class
{
  Expression<Func<TType, bool>> filteringExpression = (type) => filtering(type);
  if (filtering != null)
    //return await myContext.Set<TType>().FirstOrDefaultAsync(filteringExpression);
    return await myContext.Set<TType>().Where(filteringExpression ).FirstOrDefaultAsync();
  return await myContext.Set<TType>().FirstOrDefaultAsync();
}

我就是这样使用它的：

public async Task<DataLog> GetDataLogByID(Guid dataLogID) => await GetDataAsync<DataLog>(dataLog => dataLog.ID == dataLogID);

(Un)幸运的是，当我升级到 Entity Framework Core 3.0 时，代码抛出了 InvalidOperationException，因为表达式无法转换为 SQL 查询（尽管它只过滤了一个属性匹配数据库列）：

System.InvalidOperationException: 'LINQ 表达式 '在哪里（ 来源：数据库集， 谓词：(f) => Invoke(__filtering_0, f[DataLog]) )' 无法翻译。要么重写查询形式， 翻译，或通过插入显式切换到客户端评估 调用 AsEnumerable()、AsAsyncEnumerable()、ToList() 或 ToListAsync()。见https://go.microsoft.com/fwlink/?linkid=2101038 更多信息。

那么你能告诉我，我应该如何修改代码以确保所有（大部分）处理都留在服务器端？保持通用代码符合标准的最佳做法是什么？

Answer 1

恭喜，您发现了 EF Core 3.0 中的一项重大更改 - LINQ queries are no longer evaluated on the client

旧行为

在 3.0 之前，当 EF Core 无法将作为查询的一部分的表达式转换为 SQL 或参数时，它会自动评估客户端上的表达式。默认情况下，客户端对可能昂贵的表达式的评估只会触发警告。

新行为

从 3.0 开始，EF Core 仅允许在客户端评估顶级投影（查询中的最后一个 Select() 调用）中的表达式。当查询的任何其他部分中的表达式无法转换为 SQL 或参数时，将引发异常。

有关详细信息，请参阅文档（上面的链接），但是您在升级之前遇到的警告现在会生成 InvalidOperationExceptions 并且与 SQLite 无关，您会遇到与 SQL Server 相同的问题。

解决此问题的唯一方法是确保您的过滤表达式/函数可以转换为适当的 SQL...或恢复为 EF Core

更新

您可以尝试不包装传递的 Func 并将参数类型更改为 Expression<Func<TType, bool>>（它应该不需要对调用该方法的代码进行任何更改）

public async Task<TType> GetDataAsync<TType>(Expression<Func<TType, bool>> filter = null)
    where TType : class
{
    var query = myContext.Set<TType>();

    if (filter != null)
        query = query.Where(filter);

    return await query.FirstOrDefaultAsync();
}

刚刚注意到对GetDataAsync 的调用似乎不正确，并且有一个额外的类型参数Guid 应该从本示例中删除。

public async Task<DataLog> GetDataLogByID(Guid dataLogID) =>
    await GetDataAsync<DataLog>(dataLog => dataLog.ID == dataLogID);