由于 InitializedDatabases 列表，EntityFramework6 内存使用量很大

Question

在我们的应用程序中有大量表（大约 50k） - 所有这些表都实际使用，这导致实体框架中的内存消耗很高。

在进行一些内存分析后，我注意到 DbCompiledModel 类被保存在内存中，因此在进行了一些搜索后，将其追踪到保留“InitializedDatabases”列表的 LazyInternalContext 类。

https://github.com/dotnet/ef6/blob/master/src/EntityFramework/Internal/LazyInternalContext.cs#L670

有没有办法阻止实体框架这样做？如果这就是“InitializeDatabaseAction”所暗示的，这不是代码优先设置，数据库设置和迁移不会在这个应用程序中完成。

设置“return null”或将“InitializerDisabled”设置为 true 可使一切正常，但宁愿不运行自定义实体构建，而且不知道仅“更改”源会产生什么影响。

大多数表具有相同的定义，因此也尝试了我在这里找到的解决方案： Change table name at runtime

尝试此操作时出现错误“此命令存在开放数据读取器”，此处不支持使用 postgres 和 MARS（不知道为什么需要它，这只会更改正在运行的 sql）

Answer 1

解决方案在 Ivan Stoev 的评论中给出并且有效。

不使用反射无法关闭此功能，将“InternalContext.InitializerDisabled”属性设置为 true 会跳过字典。

所以：

• 使用提供 DbCachedModel 的 DbContext 构造函数
• 使用 Database.SetInitializer(null);
• 使用反射设置 InternalContext.InitializerDisabled = true

我用来测试此示例的代码，作为测试设置，我有 1 个具有 30k 分区的主表，分区本身被查询，因为 postgres（特别是 9.x）不能很好地扩展大量分区：

    public class PartContext : DbContext {
        private static readonly string _ConnectionString = new NpgsqlConnectionStringBuilder {
            Host = "localhost",
            Port = 5432,
            Database = "postgres",
            Username = "postgres",
            Password = "password"
        }.ConnectionString;

        public readonly string Table;
        public readonly string Partition;

        public PartContext(string pMainTable, string pPartition) : base(
            new NpgsqlConnection() { ConnectionString = _ConnectionString },
            PartDbModelBuilder.Get(_ConnectionString, pPartition),
            true
        ) {
            Table = pMainTable;
            Partition = pPartition;

            Database.SetInitializer<PartContext>(null);


            /**
             * Disable database initialization so that the DbCachedModels are not kept internally in Entity
             * This causes high memory usage when having a lot of tables 
             * In EF 6.4.2 there was no way to 'manage' that Dictionary externally
             */
            try {
                var InternalContext = typeof(PartContext).BaseType.GetProperty("InternalContext", BindingFlags.NonPublic | BindingFlags.Instance).GetValue(this, null);
                InternalContext.GetType().GetProperty("InitializerDisabled").SetValue(InternalContext, true);
            } catch(Exception) { }
        }

        public DbSet<MyPart> Parts { get; set; }

        protected override void OnModelCreating(DbModelBuilder modelBuilder) {
            modelBuilder.HasDefaultSchema("public");
            modelBuilder.Conventions.Remove<PluralizingTableNameConvention>();
        }
    }

这提供了 DbCachedModels：

我建议添加一些自定义缓存代码等，这只是一个示例

    class PartDbModelBuilder {
        public static DbCompiledModel Get(string pConnectionString, string pTable) {
            DbModelBuilder builder = new DbModelBuilder();
            builder.Entity<MyPart>().ToTable(pTable, "public");
            using (var connection = new NpgsqlConnection() { ConnectionString = pConnectionString }) {
                var obj = builder.Build(connection).Compile();
                return obj;
            }
        }
    }

这是我用作测试的实体：

    public class MyPart {
        public int id { get; set; }
        public string name { get; set; }
        public string value { get; set; }
    }

我用来运行测试的类：

    class EFTest {
        public void Run(int tableCount) {
            int done = 0;
            Parallel.For(0, tableCount, new ParallelOptions { MaxDegreeOfParallelism = 5 }, (i) => {
                string id = i.ToString().PadLeft(5, '0');
                using (var context = new PartContext("mypart", "mypart_" + id)) {
                    var objResult = context.Parts.First();
                    Console.WriteLine(objResult.name);
                }
                done++;
                Console.WriteLine(done + " DONE");
            });
        }
    }

表定义：

    CREATE TABLE IF NOT EXISTS mypart (
        id SERIAL,
        name text,
        value text
    ) partition by list (name);

    CREATE TABLE IF NOT EXISTS part partition of mypart_00000 for values in ('mypart00000');
    CREATE TABLE IF NOT EXISTS part partition of mypart_00001 for values in ('mypart00001');
    CREATE TABLE IF NOT EXISTS part partition of mypart_00002 for values in ('mypart00002');
    ...

Postgres 9：

    CREATE TABLE IF NOT EXISTS mypart (
        id SERIAL,
        name text,
        value text
    );

    CREATE TABLE IF NOT EXISTS ".$name."( CHECK ( name =  'mypart00000')) INHERITS (mypart);
    CREATE TABLE IF NOT EXISTS ".$name."( CHECK ( name =  'mypart00001')) INHERITS (mypart);
    CREATE TABLE IF NOT EXISTS ".$name."( CHECK ( name =  'mypart00002')) INHERITS (mypart);
    ...