Entity Framework Core 根据类的类型显式加载相关数据

Question

我有包含的 Repository 类。下面的代码适用于一对一的关系。但是对于收藏我需要将DbContext.Entry(model.Result).Reference(include).Load(); 更改为DbContext.Entry(model.Result).Collection(include).Load();

    public virtual async Task<TEntity> GetByIdAsync(object[] keyValues,
        List<Expression<Func<TEntity, object>>> includes,
        CancellationToken cancellationToken = default(CancellationToken))
    {
        var model = DbSet.FindAsync(keyValues, cancellationToken);
        if (includes == null) return await model;
        foreach (var include in includes)
            //if (include.Body.Type.IsAssignableFrom(typeof(ICollection<>)))
            DbContext.Entry(model.Result).Reference(include).Load();

        return await model;

        //return await DbSet.FindAsync(keyValues, cancellationToken);
    }

我可以在这里使用什么样的条件来将引用和集合彼此分开？

谢谢。

编辑： 示例对象是

System.Collections.Generic.IList`1[[WestCore.Domain.Entities.WestLife.MhpProduct]]

一般来说，集合可以是ICollection 或IList。

Answer 1

您可以使用更通用的Navigation 方法，而不是单独的Reference / Collection 方法。不幸的是，它没有 lambda 表达式的重载，因此您需要手动提取属性名称。由于您的方法设计不支持嵌套属性，您可以从 lambda 表达式主体中获取该信息，转换为 MemberExpression：

foreach (var include in includes)
{
    var propertyName = ((MemberExpression)include.Body).Member.Name;
    DbContext.Entry(model.Result).Navigation(propertyName).Load();
}

Answer 2

我会改变它，而不是明确模仿 FindByIdAsync 我会有一个更灵活的方法：

public async Task<T> GetItemAsync<T>(Expression<Func<T, bool>> filter, 
          List<Expression<Func<T,object>>> includes) where T: class
{
    var model = Set<T>();
    foreach (var include in includes)
    {
        model.Include(include);
    }
    return await model.FirstOrDefaultAsync(filter);
}

然后你会打电话给：

var result = GetItemAsync<MyEntity>(x => x.Id == 3, 
             new List<Expression<Func<MyEntity, object>>> 
             { 
                 x => s.SomeProperty, 
                 x => s.SomeOtherProperty
             });

这与您的非常相似，但更灵活一些，并且只会访问数据库一次，而不是像我相信您现有的代码那样懒惰地单独加载所有内容。这可能是您的意图，但我们没有这样的背景。

另外 - 调用 model.Result 并使用非 asyc Load() 方法意味着您的代码对异步的友好程度低于预期...

Answer 3

编辑：

我发现我仍然有问题。是

public virtual async Task<TEntity> GetByIdAsync(object[] keyValues,
        List<Expression<Func<TEntity, object>>> includes,
        CancellationToken cancellationToken = default(CancellationToken))
    {
        Task<TEntity> model = null;

        foreach (var include in includes)
        {
            if (include.Body.Type.GetInterface(nameof(IEnumerable<TEntity>)) != null)
            { //this part generates SQL Below
                await DbSet.Include(include).LoadAsync(cancellationToken);
                model = DbSet.FindAsync(keyValues, cancellationToken);
            }
            else //this part is working
            {
                var propertyName = ((MemberExpression)include.Body).Member.Name;
                model = DbSet.FindAsync(keyValues, cancellationToken);
                await DbContext.Entry(model.Result).Navigation(propertyName).LoadAsync(cancellationToken);
            }
        }

        if (model == null)
            model = DbSet.FindAsync(keyValues, cancellationToken);

        return await model;
    }

IEnumerable 部分生成下面的SQL：

选择“product.MhpProducts”.MP_MHP_ID、“product.MhpProducts”.MP_PRODUCT_ID、“product.MhpProducts”.MP_G_ORDER、“product.MhpProducts”.G_END_DATE、“product.MhpProducts”.G_INSERT_BY、“product.MhpProducts”。 G_INSERT_DATE, "product.MhpProducts".G_IS_DELETED, "product.MhpProducts".G_START_DATE, "product.MhpProducts"."MP_WEST_CORE._DOMAIN._ENTITIES._WEST_LIFE._MHP_PRODUCT" FROM MHP_PRODUCT "product.MhpProducts" 内部联接 （ 选择“product0”.TP_ID FROM TREE_PRODUCT "product0" ) "t" ON "product.MhpProducts".MP_PRODUCT_ID = "t".TP_ID ORDER BY "t".TP_ID