2

我一直在研究使用 Entity Framework Core 编译的查询。我正在使用当前最新的稳定版本 2.2.2。我正在阅读这篇文章（https://docs.microsoft.com/en-us/dotnet/framework/data/adonet/ef/language-reference/compiled-queries-linq-to-entities）以了解编译查询，并试图了解这是 EF Core 中的错误还是他们尚未完成的事情。我认识到这篇文章是为 EF6 编写的，但期望编译的查询会以相同的方式工作，并且找不到任何相反的东西。

这是我的 DbContext 设置和一个简单的分页选项结构：

public class BuggyDbContext : DbContext
{
    public DbSet<User> Users { get; set; }
}

public struct PagingOptions
{
    public int Skip;
    public int Take;
}

[Table("User")]
public class User
{
    [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
    public int UserId { get; set; }

    public string FirstName { get; set; }
    public string LastName { get; set; }
}

这是我编译的查询。第一个选择基于结构参数的用户“页面”（非常类似于文章中的示例）。第二个做同样的事情，但接受“skip”和“take”作为基本 int32 类型的单独参数。

var badQuery = EF.CompileQuery<BuggyDbContext, PagingOptions, IEnumerable<User>>((context, paging) =>
     context.Users
         .OrderBy(u => u.LastName)
         .Skip(paging.Skip)
         .Take(paging.Take));

var goodQuery = EF.CompileQuery<BuggyDbContext, int,int, IEnumerable<User>>((context, skip, take) =>
     context.Users
         .OrderBy(u => u.LastName)
         .Skip(skip)
         .Take(take));

这是演示问题的用法：

 using (var db = new BuggyDbContext())
 {

     var pagingOptions = new PagingOptions {
         Skip = 0,
         Take = 25
     };
     var firstPage = badQuery.Invoke(db, pagingOptions).ToList();
     var alternateFirstPage = goodQuery.Invoke(db, pagingOptions.Skip, pagingOptions.Take).ToList();
 }

当goodQuery运行时，一切都按预期工作。以下内容在日志中显示为我期望的生成 SQL：

SELECT [u].[UserId], [u].[FirstName], [u].[LastName]
FROM [User] AS [u]
ORDER BY [u].[LastName]
OFFSET @__skip ROWS FETCH NEXT @__take ROWS ONLY

但是，当badQuery运行时，它会选择所有记录，然后评估内存中的 Skip 和 Take，这将导致糟糕的性能。

SELECT [u].[UserId], [u].[FirstName], [u].[LastName]
FROM [User] AS [u]
ORDER BY [u].[LastName]

warn: Microsoft.EntityFrameworkCore.Query[20500]
  => Microsoft.EntityFrameworkCore.Query.RelationalQueryModelVisitor
  The LINQ expression 'Skip(__paging.Skip)' could not be translated 
and will be evaluated locally.
warn: Microsoft.EntityFrameworkCore.Query[20500]
  => Microsoft.EntityFrameworkCore.Query.RelationalQueryModelVisitor
  The LINQ expression 'Take(__paging.Take)' could not be translated 
and will be evaluated locally.

由于几个非常重要的原因，我更喜欢使用复杂类型（引用或值结构，不关心）作为编译查询的参数：

  1. Lambda 函数具有最大数量的输入参数。如果我有一个需要多个输入的复杂过滤、排序和分组查询，我将被迫走其他路线。
  2. 对于调用查询的开发人员来说，输入参数更加清晰。即使在这个例子中，调用查询的开发人员也会开始输入 query.Invoke，然后在智能感知中盯着 2 个未命名的整数参数。他们知道他们的意思的唯一方法是查看查询。如果输入参数更改了顺序或含义，那么对查询的更改将非常危险。

EF Core 3.0 路线图（https://docs.microsoft.com/en-us/ef/core/what-is-new/roadmap）确实表示他们正在研究他们的 LINQ 查询策略（以避免这种可怕的运行查询，或者至少让您在运行前知道或碰巧在您的日志中捕获警告），但我希望 struct 参数能够工作。

如果我做错了什么或者这是正在进行中的事情，有人在这里有任何见解吗？你会认为这也是一个错误吗？

4

2 回答 2

1

我在https://github.com/aspnet/EntityFrameworkCore/issues/14857向 EF 团队提交了一份错误报告 它已关闭并标记为https://github.com/aspnet/EntityFrameworkCore/issues/13976的副本

被转移到积压。回复如下：“基于正常的分类，这是一个有合理解决方法的功能，我们还没有看到大量需求，所以我们现在将其移至积压工作。”

于 2019-02-27T21:46:46.717 回答
0

我相信这是由于表达式的存储和评估方式。这绝对是一个错误，但至于将来是否会修复，我不确定。

我在项目中设置分页的方式是使用一个泛型类，该类最终从值类型构建一个表达式。（注意有一些未使用的属性和字段，因为我在逻辑之外留下了一些特定于域的代码）

public class Pagination<T>
{
    public IQueryable<T> Items;

    public int CurrentPageNumber { get; }

    public int PageSize { get; }

    public int StartPage { get; }

    public int TotalPages { get; set; }

    public Pagination(IQueryable<T> items, int pageNumber, int pageSize)
    {
        if (pageNumber <= 0)
        {
            throw new ArgumentOutOfRangeException(nameof(pageNumber));
        }

        if (pageSize <= 0)
        {
            throw new ArgumentOutOfRangeException(nameof(pageSize));
        }

        if (((decimal)DisplayPages % 2) == 0)
        {
            throw new ArgumentOutOfRangeException(nameof(DisplayPages), "Number of pages to render must be odd.");
        }

        Items = items;
        CurrentPageNumber = pageNumber;
        PageSize = pageSize;
        StartPage = 1;

        if (items.Any())
        {
            var rowCount = items.Count();
            TotalPages = (int)Math.Ceiling((decimal)rowCount / PageSize);
        }
        else
        {
            TotalPages = 1;
        }

    }

    public IQueryable<T> GetPageData()
    {
        return Items.Skip((CurrentPageNumber - 1) * PageSize).Take(PageSize) ?? new List<T>().AsQueryable();
    }

}

然后你可以像这样使用它：

var paginatedObjects = new Pagination<Type>(query, 1, 10)
{
    //Options if nessasary
};
paginatedObjects.GetPageData();
于 2019-02-27T17:02:04.070 回答