我没有太多有关Entity Framework的经验,所以我将尽力提供尽可能多的信息,并尽量不要使它太长。

这是我的DbContext:

using MySql.Data.Entity;
using MySql.Data.MySqlClient;
using System;
using System.Data.Entity;
using System.Data.Entity.Infrastructure;
using System.Data.Entity.Migrations;

namespace src.Database.Models
{
    [DbConfigurationType(typeof(MySqlEFConfiguration))]
    public class DefaultDbContext : DbContext
    {
        public DefaultDbContext(string connectionString) : base(connectionString)
        {
            System.Data.Entity.Database.SetInitializer(new MigrateDatabaseToLatestVersion<DefaultDbContext, MigrationConfiguration>());
        }

        public DbSet<User> Users { get; set; }
        public DbSet<Character> Characters { get; set; }
        public DbSet<CharacterClothes> CharacterClothes { get; set; }
        public DbSet<CharacterVehicles> CharacterVehicles { get; set; }
        public DbSet<Dealership> Dealership { get; set; }
        public DbSet<DealershipVehicle> DealershipVehicles { get; set; }
    }

    public class ContextFactory : IDbContextFactory<DefaultDbContext>
    {
        private static string ConnectionString;

        public static void SetConnectionParameters(string serverAddress, string username, string password, string database, uint port = 3306)
        {
            var connectionStringBuilder = new MySqlConnectionStringBuilder()
            {
                Server = serverAddress,
                UserID = username,
                Password = password,
                Database = database,
                Port = port
            };

            ConnectionString = connectionStringBuilder.ToString();
        }

        private static DefaultDbContext _instance;

        public static DefaultDbContext Instance
        {
            get
            {
                if (_instance != null) return _instance;
                return _instance = new ContextFactory().Create();
            }
            private set { }
        }

        public DefaultDbContext Create()
        {
            if (string.IsNullOrEmpty(ConnectionString)) throw new InvalidOperationException("Please set the connection parameters before trying to instantiate a database connection.");

            return new DefaultDbContext(ConnectionString);
        }
    }

    internal sealed class MigrationConfiguration : DbMigrationsConfiguration<DefaultDbContext>
    {
        public MigrationConfiguration()
        {
            AutomaticMigrationsEnabled = true;
            AutomaticMigrationDataLossAllowed = true;
            SetSqlGenerator("MySql.Data.MySqlClient", new MySqlMigrationSqlGenerator());
        }
    }
}


因此,它正在为我访问的所有连接使用一个实例,如下所示:

var user = ContextFactory.Instance.Users.FirstOrDefault(x => x.id == id);
var dealerships = ContextFactory.Instance.Dealership.ToList();


而且工作正常!

虽然,偶尔我会收到此错误:

已经有一个与此连接相关联的打开的DataReader,必须先关闭它。

我想这是因为它正在尝试使用实例,而该实例已经在使用中。

我一直在寻找如何解决它的日子,但仍然无法使它起作用。我读过有关MultipleActiveResultSets的信息,但我正在使用MySQL,似乎不支持它。

最佳答案

你应该改变它

private static DefaultDbContext _instance;




[ThreadStatic]
private static DefaultDbContext _instance;


为每个线程/请求创建一个新的DBContext实例可能更好。通过线程共享相同的DbContext是危险且令人反感的。这将导致不同的线程尝试使用已经使用过的同一DBContext实例。

另外,还有一篇很好的文章here关于UnitOfWork,事务管理以及为每个线程/请求创建DbContext的好处。

关于c# - Entity Framework DbContext实例DataReader已打开,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/47841467/

10-11 01:40
查看更多