主页 / coding / 问题 / 77993370
Accepted
Adem Aygun
Asked: 2024-02-14 17:50:53 +0800 CST

EF Core 6：查询过滤器中的 .Any() 产生“无法翻译。要么以可以翻译的形式重写查询”

  • 772

我有 Product 实体并在存储库类中编写一个方法（使用 npgsql）。但我收到错误：

无法翻译。以可翻译的形式重写查询，或者通过插入对“AsEnumerable”、“AsAsyncEnumerable”、“ToList”或“ToListAsync”的调用来显式切换到客户端计算。有关详细信息，请参阅https://go.microsoft.com/fwlink/?linkid=2101038 。System.InvalidOperationException：LINQ 表达式的 => s.ProductId == EntityShaperExpression：

public class Product:IEntity
{
  public string Id { get; set; }
  public string SerialNo { get; set; }
  public string Imei { get; set; }
  public string Name { get; set; }
}   

public class ProductInput
{
  public string ProductId { get; set; }
  public string SerialNo { get; set; }
  public string Imei { get; set; }
}

public async Task<List<Product>> GetProducts(List<ProductInput> input) //EfCoreProductRepository.cs
{
      var result = (from product in (await GetDbContextAsync()).Products
                    where input.Any(s => s.ProductId == product.Id && s.SerialNo == product.SerialNo && s.Imei == product.Imei)
                    select product).ToList();
    return result;
}

我应该如何编辑查询以避免出现此错误？

.net-core

1 个回答

  1. Best Answer

    看起来您正在尝试检索input按多个条件与您的行匹配的数据库行。有多种方法可以做到这一点，例如：

    • 将input数据推入表值 (SQL Server) 或类型数组(Postgres) 参数，甚至 JSON 字符串 blob (可怕) 并INNER JOIN使用该参数执行操作。
      • 我可能是错的，但我不相信 Entity Framework Core 支持除单列过滤之外的功能。
    • 或者（更可靠），您可以动态构建一个新的 Linq 查询来定义WHERE零件中所需的匹配项。
      • 唯一真正的缺点是动态查询无法利用缓存查询计划或查询存储之类的东西。
    • 故障安全方法是通过在 C# 中循环并执行单个查询来 执行RBAR查询input
      • 呃。不。

    在作者看来，选项 2（动态构建的 Linq 查询）是这里总体上“最好的”，所以这样做：

    首先，getPredicateBuilder - 它是一个非常重要的依赖项，使得使用 Linq 构建Or谓词变得更加容易。它实际上是class从 Albahari 网站上复制粘贴的。

    其次，像这样使用它：

    public async Task<List<Product>> GetProductsAsync( List<ProductInput> input, CancellationToken cancellationToken )
{
    DbSet<Product> dbSet = await this.GetDbSetAsync();

    var predicate = PredicateBuilder.False<Product>();
    foreach( ProductInput pi in input )
    {
        predicate = predicate.Or( p => (
            p.ProductId == pi.Id
            &&
            p.SerialNo == pi.SerialNo
            &&
            p.Imei == pi.Imei
        ) );
    }

    IQueryable<Product> query = dbSet.Where( predicate );

    List<Product> results = await query.ToListAsync(cancellationToken);
    return results;
}

    谓词生成器

    为了后代，我class PredicateBuilder在这里转载：

    using System;
using System.Linq;
using System.Linq.Expressions;
using System.Collections.Generic;
 
public static class PredicateBuilder
{
  public static Expression<Func<T,Boolean>> True<T> ()  => ( f => true );
  public static Expression<Func<T,Boolean>> False<T> () => ( f => false );
 
  public static Expression<Func<T,Boolean>> Or<T>(this Expression<Func<T,Boolean>> expr1, Expression<Func<T,Boolean>> expr2)
  {
    var invokedExpr = Expression.Invoke(
      expr2,
      expr1.Parameters.Cast<Expression>()
    );

    return Expression.Lambda<Func<T,Boolean>>(
      Expression.OrElse(expr1.Body, invokedExpr),
      expr1.Parameters
    );
  }
 
  public static Expression<Func<T,Boolean>> And<T>(this Expression<Func<T,Boolean>> expr1, Expression<Func<T,Boolean>> expr2)
  {
    var invokedExpr = Expression.Invoke(
      expr2,
      expr1.Parameters.Cast<Expression>()
    );
    
    return Expression.Lambda<Func<T,Boolean>>(
      Expression.AndAlso(expr1.Body, invokedExpr),
      expr1.Parameters
    );
  }
}
    • 1

相关问题