Entity Framework Core 2.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; }
}

Вот мои скомпилированные запросы. Первый выбирает "страницу" пользователей на основе параметра структуры (очень похоже на пример из статьи). Второй делает то же самое, но принимает "пропустить" и "взять" в качестве отдельных параметров базового типа 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, он выбирает ВСЕ записи и затем оценивает Пропуск и Взятие в память, что приведет к ужасной производительности.

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. Лямбда-функции имеют максимальное количество входных параметров. Если бы у меня был запрос с какой-то сложной фильтрацией, сортировкой и группировкой, который требовал многократных вводов, я был бы вынужден пойти другим путем.
  2. Входные параметры намного понятнее разработчику, который вызывает запрос. Даже в этом примере разработчик, вызывающий запрос, начнет вводить query.Invoke, а затем будет смотреть на 2 безымянных целочисленных аргумента в intellisense. Единственный способ узнать, что они имеют в виду, это посмотреть на запрос. Изменения в запросе были бы чрезвычайно опасны, если бы входные параметры изменили порядок или значение.

Дорожная карта EF Core 3.0 ( https://docs.microsoft.com/en-us/ef/core/what-is-new/roadmap) говорит, что они работают над своей стратегией LINQ Query в целом (чтобы избежать такой ужасной работы запросов, или, по крайней мере, чтобы вы знали перед выполнением или когда вы ловили предупреждение в ваших журналах), но я ожидал, что параметр struct будет работать.

У кого-нибудь есть понимание, если я делаю что-то не так или это то, что находится в разработке? Считаете ли вы это ошибкой?

2 ответа

Я отправил отчет об ошибке в команду EF по адресу https://github.com/aspnet/EntityFrameworkCore/issues/14857 Он был закрыт и помечен как дубликат https://github.com/aspnet/EntityFrameworkCore/issues/13976

Был перенесен в отставание. Вот ответ: "Основываясь на обычной сортировке, это функция, для которой есть разумный обходной путь, и для которой у нас пока нет значительного спроса, поэтому мы пока перенесем ее в отставание".

Я считаю, что это связано с тем, как выражение хранится и оценивается. Это определенно ошибка, но я не уверен, что это будет исправлено в будущем.

Я настроил разбиение на страницы в своем проекте с помощью универсального класса, который в итоге создает выражение из типов значений. (Обратите внимание, что есть неиспользуемые свойства и поля, так как я оставил некоторый специфичный для домена код из логики)

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();
Другие вопросы по тегам