Как загрузить вложенные свойства через EF Core с помощью Expression?

Question

[NameOf Var]

Такая ситуация: есть метод ListAsync в методе репозитория, примерно реализован вот так:

public virtual async Task<IEnumerable<TEntity>> ListAsync(
            params Expression<Func<TEntity, object>>[] includeProperties)
        {
            IQueryable<TEntity> query = this.QueryableEntities;
 
            if (includeProperties != null)
            {
                foreach (Expression<Func<TEntity, object>> includeProperty in includeProperties)
                {
                    query = query.Include(includeProperty);
                }
            }
 
            return await query.AsNoTracking().ToListAsync();
        }

Параметр includeProperties говорит какие вложенные свойства нужно тоже загрузить. Есть у меня ещё три сущности:

class Image
{
        public Guid ImageGuid { get; set; }
 
        public List<ImageTag> ImageTags { get; set; }
}
 
class ImageTag
{
        public Guid ImageGuid { get; set; }
 
        public Image Image { get; set; }
 
        public int TagId { get; set; }
 
        public Tag Tag { get; set; }
}
 
class Tag
{
        public int TagId { get; set; }
 
        public string Name { get; set; }
 
        public List<ImageTag> ImageTags { get; set; }
}

Теперь я хочу загрузить список всех Image. Через ImageRepository пишу следующий код:

imageRepository.ListAsync(
   (img) => img.ImageTags.Select(t => t.Tags));

Но данная реализация выкидывает исключение: Lambda expression used inside Include is not valid. Подскажите, пожалуйста, как правильно реализовать загрузку вложенных свойств без ThenInclude в EF Core?

Comments

[Толстый Лорри]

Чем вам ThenInclude не угодил?

[NameOf Var]

Толстый Лорри, а как в данном случае запихнуть ещё и ThenInclude в Expression?

[Толстый Лорри]

NameOf Var, это будут разные экспрешны.
В обобщенном коде бывает проще задавать зависимости строками, например:

Экстеншн для удобства

public static IQueryable<TEntity> IncludeDependencies<TEntity>(
                                                this IQueryable<TEntity> query,
                                                     IList<string> deps)
            where TEntity : class
{
    foreach (string dependency in deps)
    {
        query = query.Include(dependency);
    }

    return query;
}

class BaseFilter {
    // public int Skip { get; set; }
    // public int Take { get; set; }
    // public string OrderBy { get; set; }
    // ...
    public IList<string> Dependencies { get; set; }
}

class ImageFilter: BaseFilter {
    //...
    public const string WITH_TAGS = $"{nameof(Image.ImageTags)}.{nameof(ImageTag.Tag}";
}

// somewhere in base repository
public virtual Task<IList<TEntity>> GetAsync<TFilter>(TFilter filter)
    where TFilter: BaseFilter
{
    IQueryable<TEntity> query = this.QueryableEntities;

    if (filter?.Dependencies != null)
    {
        query = query.IncludeDependencies(filter.Dependencies);
    }

    //...filtration, ordering, pagination

    return query.AsNoTracking().ToListAsync();
}


// Usage: 
var filter = new ImageFilter {
    Skip = (pageNo - 1) * ITEMS_PER_PAGE,
    Take = ITEMS_PER_PAGE,
    Dependencies = new [] { ImageFilter.WITH_TAGS },
};

var result = await imageRepository.GetAsync(filter);

[NameOf Var]

Толстый Лорри, не очень удобно, много функционала придётся переписать