前言

根据appsettings.json的中配置的数据库类型，使用工厂模式创建DbContext

代码实现

appsettings.json中的配置项

  //使用的数据库类型

  "ServerType": "oracle",

  "OracleSettings": {

    "PROTOCOL": "tcp",

    "HOST": "XX.XX.XX.XX",

    "PORT": "XX",

    "SERVICE_NAME": "XX",

    "UserId": "XX",

    "Password": "XX"

  },

  "MySQLSettings": {

    "HOST": "XX",

    "PORT": "XX",

    "DataBase": "XX",

    "UserId": "XX",

    "Password": "XX"

  }

DbContext工厂

DbContextFactory

    public class DbContextFactory

    {

        public static DbContext CreateContext()

        {

            DbContext dbContext = null;

            string dbType = AppConfigurtaionServices.Configuration["ServerType"];

            switch (dbType)

            {

                case "mysql":

                    dbContext = CreateMySQLContext();

                    break;

                case "oracle":

                    dbContext = CreateOracleContext();

                    break;

            }

            return dbContext;

        }

        #region 创建dbContext

        /// <summary>

        /// 创建ORACLE Dbcontext

        /// </summary>

        /// <returns></returns>

        static DbContext CreateOracleContext()

        {

            DbContextOptions<OracleContext> options = new DbContextOptions<OracleContext>();

            OracleContext oracleContext = new OracleContext(options);

            return oracleContext;

        }

        /// <summary>

        /// 创建MySQL Dbcontext

        /// </summary>

        /// <returns></returns>

        static DbContext CreateMySQLContext()

        {

            DbContextOptions<MySQLContext> options = new DbContextOptions<MySQLContext>();

            MySQLContext mySQLContext = new MySQLContext(options);

            return mySQLContext;

        }

        #endregion

    }

AppConfigurtaionServices

    public class AppConfigurtaionServices

    {

        public static IConfiguration Configuration { get; set; }

        static AppConfigurtaionServices()

        {

            //ReloadOnChange = true 当appsettings.json被修改时重新加载       

            Configuration = new ConfigurationBuilder()

            .Add(new JsonConfigurationSource { Path = "appsettings.json", ReloadOnChange = true })

            .Build();

        }

    }

OracleContext示例

    public class OracleContext : DbContext

    {

        public OracleContext(DbContextOptions<OracleContext> options) : base(options)

        { }

        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)

        {

            string PROTOCOL = AppConfigurtaionServices.Configuration["OracleSettings:PROTOCOL"];

            string HOST = AppConfigurtaionServices.Configuration["OracleSettings:HOST"];

            string PORT = AppConfigurtaionServices.Configuration["OracleSettings:PORT"];

            string SERVICE_NAME = AppConfigurtaionServices.Configuration["OracleSettings:SERVICE_NAME"];

            string UserId = AppConfigurtaionServices.Configuration["OracleSettings:UserId"];

            string Password = AppConfigurtaionServices.Configuration["OracleSettings:Password"];

            optionsBuilder.UseOracle(

                "Data Source = (DESCRIPTION = (ADDRESS = (PROTOCOL = " + PROTOCOL + ")(HOST = " + HOST + ")(PORT = " + PORT + "))(CONNECT_DATA = (SERVICE_NAME = " + SERVICE_NAME + "))); User Id = " + UserId + "; Password = " + Password + "; ");

            base.OnConfiguring(optionsBuilder);

        }

    }

巴特西

简单的DbContext工厂类（EFCore）

前言

代码实现

appsettings.json中的配置项

DbContext工厂

DbContextFactory

AppConfigurtaionServices

OracleContext示例

最新文章

热门文章