如何在 EF 生成的查询中避免 N+1

Question

我曾经为 POCO 中的多对多关系或关系 ID 生成所有帮助表，如 UsergroupUsers，但现在我希望 EF 处理它们。现在我认为这毕竟不是一个好主意。

问题

当我尝试获取特定用户的所有 UsergroupDynamicField 时，它会为每个用户组用户所在的每个用户组生成 N+1 查询。

Here 我通过简单地声明Usergroups 将是IQUeriable 而不是IEnumerable 克服了这个问题。现在我不能这样做，因为 EF 不会映射它，它必须是 ICollection。

代码

public class User
{
    ...
    public virtual ICollection<Usergroup> Usergroups { get; set; }
    public IEnumerable<UserField> Fields
    {
        get
        {
            var fields = this.Usergroups.SelectMany(x => x.UsergroupDynamicFields); // N + 1 for every Usergroup

            foreach (var field in fields)
            {
                yield return new UserField
                {
                    Name = field.Name
                };
            }
        }
    }
}

数据库

Answer 1

在这里，我通过简单地说明用户组将是 IQUeriable 而不是 IEnumerable 来克服这个问题。现在我不能这样做，因为 EF 不会映射它，它必须是 ICollection。

但最终实现ICollection 的类是EntityCollection<T>。这个集合有一个CreateSourceQuery() function，你可以使用：

var usergroupsQuery = ((EntityCollection<UserGroup>)this.Usergroups).CreateSourceQuery();
var fields = usergroupsQuery.SelectMany(x => x.UsergroupDynamicFields);

更新：正如 cmets 中所指出的，ICollection<T> 将仅在可以并启用更改跟踪时使用 EntityCollection<T> 实现（非密封类和所有相关属性 virtual )。您可以通过其他方式创建查询：

var usergroupsQuery = db.Entry(this).Collection(u => u.Usergroups).Query();
var fields = usergroupsQuery.SelectMany(x => x.UsergroupDynamicFields);

请注意，这要求您以某种方式访问​​db。

Answer 2

我尝试使用类似的东西

var res = c.Users.Include("Groups.DynFields").First().Groups.SelectMany(x => x.DynFields).ToList();

而且似乎没问题。我使用EF5。

当然...这不是 User 类中的方法。它需要能够在 DbSet 对象上调用 Include 方法。

我希望这会有所帮助。

完整解决方案

 public class User {
        public Int32 Id { get; set; }
        public String Name { get; set; }

        public virtual ICollection<UserGroup> Groups { get; set; }
    }

    public class UserGroup {
        public Int32 Id { get; set; }
        public String Name { get; set; }

        public virtual ICollection<User> Users { get; set; }

        public virtual ICollection<UserGroupDynamicField> DynFields { get; set; }
    }

    public class UserGroupDynamicField {
        public Int32 Id { get; set; }
        public String Name { get; set; }
        public virtual UserGroup Group { get; set; }
    }


    public class UserGroupDynFEFCFConfiguration : EntityTypeConfiguration<UserGroupDynamicField > {
        public UserGroupDynFEFCFConfiguration()
            : base() {
                HasRequired(x => x.Group);
        }
    }

    public class UserGroupEFCFConfiguration : EntityTypeConfiguration<UserGroup> {
        public UserGroupEFCFConfiguration()
            : base() {
                HasMany(x => x.Users).WithMany(y => y.Groups);
        }
    }       

    public class TestEFContext : DbContext {
        public IDbSet<User> Users { get; set; }
        public IDbSet<UserGroup> Groups { get; set; }

        public TestEFContext(String cs)
            : base(cs) {
            Database.SetInitializer<TestEFContext>(new DropCreateDatabaseAlways<TestEFContext>());
        }

        protected override void OnModelCreating(DbModelBuilder modelBuilder) {
            base.OnModelCreating(modelBuilder);

            modelBuilder.Configurations.Add(new UserGroupDynFEFCFConfiguration());
            modelBuilder.Configurations.Add(new UserGroupEFCFConfiguration());
        }
    }

    class Program {
        static void Main(String[] args) {
            String cs = @"Data Source=ALIASTVALK;Initial Catalog=TestEF;Integrated Security=True; MultipleActiveResultSets=True";

            using (TestEFContext c = new TestEFContext(cs)) {
                UserGroup g1 = new UserGroup {
                    Name = "G1",
                    DynFields = new List<UserGroupDynamicField> { 
                        new UserGroupDynamicField { Name = "DF11"},
                        new UserGroupDynamicField { Name = "DF12"}
                    }
                };
                c.Groups.Add(g1);

                UserGroup g2 = new UserGroup {
                    Name = "G2",
                    DynFields = new List<UserGroupDynamicField> { 
                        new UserGroupDynamicField { Name = "DF21"},
                        new UserGroupDynamicField { Name = "DF22"}
                    }
                };
                c.Groups.Add(g2);

                c.Users.Add(new User {
                    Name = "U1",
                    Groups = new List<UserGroup> { g1, g2 }
                });

                c.SaveChanges();
            }      

            using (TestEFContext c = new TestEFContext(cs)) {
                var res = c.Users.Include("Groups.DynFields").First().Groups.SelectMany(x => x.DynFields).ToList();
                foreach (var v in res) {
                    Console.WriteLine(v.Name);
                } 
            }
        }
    }