无私分享：ASP.NET CORE 项目实战（第十二章）添加对SqlServerMySqlOracle的支持

Posted 2020-08-05 我来自江湖，江湖却没有关于我的传说...

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了无私分享：ASP.NET CORE 项目实战（第十二章）添加对SqlServerMySqlOracle的支持相关的知识，希望对你有一定的参考价值。

目录索引　

简介

　　增加对多数据库的支持，并不是意味着同时对多种数据库操作，当然，后面，我们会尝试同时对多种数据库操作，这可能需要多个上下文，暂且不论。分布式数据库，我们采用的是阿里云的Mycat，这个后面会更新出来。我们今天的场景是：我们的项目可能是在windows上开发的使用的是SqlServer，我们要发布到linux上，SqlServer 2017 据说是支持liunx的，但是还没出... 当然不是说 SqlServer 就不能装在liunx上，但是我们的Liunx服务器可能已经安装了mysql或 Oracle，我们希望使用现有的，又或者是，我们需要切换数据库。那么，我们需要可以随时切换数据库的支持。

添加NuGet包，注册服务

　　使用SqlServer数据库，这个官方有详细的步骤和解释，可以参考：https://docs.efproject.net/en/latest/providers/sql-server/index.html ，我们简单介绍一下

　　在【（第四章）】Code First 创建数据库和数据表中，我们使用的就是SqlServer，我们新建了一个数据上下文 ApplicationDbContext ，

　　然后在 Startup.cs 的 ConfigureServices(IServiceCollection services) 中，我们作为一个服务注册了上下文对象：

　　 services.AddDbContext<ApplicationDbContext>(options => options.UseSqlServer(Configuration.GetConnectionString("SqlServerConnection")));

　　在使用 UseSqlServer() 的时候，我们在 project.json 中添加了依赖包：Microsoft.EntityFrameworkCore.SqlServer

　　那么，如何添加对Mysql的支持呢，在2016年8月24日，Mysql 官方出了第一版对 EntityFrameworkCore 支持的依赖包（MySql.Data.EntityFrameworkCore 7.0.4-IR-191），这个我第一时间就尝试过，有少许问题，因为刚出，资料非常少，也几乎没多少用过的，也可能是有Bug，也可能是我自身的原因，不管什么原因，我还是一直用官方没出之前的第三方的依赖，今天，我们就是用这个依赖包作为演示，当然，大家可以使用官方的，对于使用，因为我们使用的是EF，所以在操作上没什么太大的区别，也可以随时切换。

　　首先，我们引入这个包 Pomelo.EntityFrameworkCore.MySql，NuGet：Install-Package Pomelo.EntityFrameworkCore.MySql

　　使用非常简单，跟上面的 SqlServer 一样，我们注册上下文（Startup.cs）：

　　services.AddDbContext<ApplicationDbContext>(options => options.UseMySql(Configuration.GetConnectionString("MySqlConnection")));

　　对了，就是把 UseSqlServer（）改成 UseMySql（）

　　Oracle的官方也没出，也没发现很好的第三方，我们这里就先不介绍了，等养肥了。

修改配置文件，实现切换

　　我们上面实现了 EntityFrameworkCore 对两种数据库的支持，那么，我们总不能每次切换数据库都要修改 Startup.cs 再编译生成吧，我们应该做一个类似开关之类的，可以实现发布完成的项目的数据库的切换。

　　这里，我用的是配置文件。

　　我们在【（第八章）】读取配置文件（二）读取自定义配置文件中介绍了，如何使用自定义配置文件 siteconfig.json

　　并且我们写了一个读取自定义配置文件的方法 GetAppSettings<T>（string key），这个方法，我稍微做了修改，增加了一个参数，可以读取任意的自定义配置文件，同时增加了对集合的读取（MyCat分布式数据库的时候读取节点会用到），这里把修改后的给大家贴一下：

　　public class AppConfigurtaionServices
　　{
　　　　/// <summary>
　　　　/// 获取自定义配置文件配置
　　　　/// </summary>
　　　　/// <typeparam name="T">配置模型</typeparam>
　　　　/// <param name="key">根节点</param>
　　　　/// <param name="configPath">配置文件名称</param>
　　　　/// <returns></returns>
　　　　public T GetAppSettings<T>(string key,string configPath= "siteconfig.json") where T:class,new()
　　　　{
　　　　　　IConfiguration config = new ConfigurationBuilder()
　　　　　　　　　　　　　　　　　　.Add(new JsonConfigurationSource { Path= configPath, ReloadOnChange=true })
　　　　　　　　　　　　　　　　　　.Build();

　　　　　　var appconfig= new ServiceCollection()
　　　　　　　　　　　　　　　　.AddOptions()
　　　　　　　　　　　　　　　　.Configure<T>(config.GetSection(key))
　　　　　　　　　　　　　　　　.BuildServiceProvider()
　　　　　　　　　　　　　　　　.GetService<IOptions<T>>()
　　　　　　　　　　　　　　　　.Value;

　　　　　　return appconfig;
　　　　}
　　　　/// <summary>
　　　　/// 获取自定义配置文件配置（异步方式）
　　　　/// </summary>
　　　　/// <typeparam name="T">配置模型</typeparam>
　　　　/// <param name="key">根节点</param>
　　　　/// <param name="configPath">配置文件名称</param>
　　　　/// <returns></returns>
　　　　public async Task<T> GetAppSettingsAsync<T>(string key, string configPath = "siteconfig.json") where T : class, new()
　　　　{
　　　　　　IConfiguration config = new ConfigurationBuilder()
　　　　　　　　　　　　　　　　　　　　.Add(new JsonConfigurationSource { Path = configPath, ReloadOnChange = true })
　　　　　　　　　　　　　　　　　　　　.Build();

　　　　　　var appconfig = new ServiceCollection()
　　　　　　　　　　　　　　　　.AddOptions()
　　　　　　　　　　　　　　　　.Configure<T>(config.GetSection(key))
　　　　　　　　　　　　　　　　.BuildServiceProvider()
　　　　　　　　　　　　　　　　.GetService<IOptions<T>>()
　　　　　　　　　　　　　　　　.Value;

　　　　　　return await Task.Run(() => appconfig);
　　　　}

　　　　/// <summary>
　　　　/// 获取自定义配置文件配置
　　　　/// </summary>
　　　　/// <typeparam name="T">配置模型</typeparam>
　　　　/// <param name="key">根节点</param>
　　　　/// <param name="configPath">配置文件名称</param>
　　　　/// <returns></returns>
　　　　public List<T> GetListAppSettings<T>(string key, string configPath = "siteconfig.json") where T : class, new()
　　　　{
　　　　　　IConfiguration config = new ConfigurationBuilder()
　　　　　　　　　　　　　　　　　　　　.Add(new JsonConfigurationSource { Path = configPath, ReloadOnChange = true })
　　　　　　　　　　　　　　　　　　　　.Build();

　　　　　　var appconfig = new ServiceCollection()
　　　　　　　　　　　　　　　　　.AddOptions()
　　　　　　　　　　　　　　　　　.Configure<List<T>>(config.GetSection(key))
　　　　　　　　　　　　　　　　　.BuildServiceProvider()
　　　　　　　　　　　　　　　　　.GetService<IOptions<List<T>>>()
　　　　　　　　　　　　　　　　　.Value;

　　　　　　return appconfig;
　　　　}
　　　　/// <summary>
　　　　/// 获取自定义配置文件配置（异步方式）
　　　　/// </summary>
　　　　/// <typeparam name="T">配置模型</typeparam>
　　　　/// <param name="key">根节点</param>
　　　　/// <param name="configPath">配置文件名称</param>
　　　　/// <returns></returns>
　　　　public async Task<List<T>> GetListAppSettingsAsync<T>(string key, string configPath = "siteconfig.json") where T : class, new()
　　　　{
　　　　　　IConfiguration config = new ConfigurationBuilder()
　　　　　　　　　　　　　　　　　　　　.Add(new JsonConfigurationSource { Path = configPath, ReloadOnChange = true })
　　　　　　　　　　　　　　　　　　　　.Build();

　　　　　　var appconfig = new ServiceCollection()
　　　　　　　　　　　　　　　　　　.AddOptions()
　　　　　　　　　　　　　　　　　　.Configure<List<T>>(config.GetSection(key))
　　　　　　　　　　　　　　　　　　.BuildServiceProvider()
　　　　　　　　　　　　　　　　　　.GetService<IOptions<List<T>>>()
　　　　　　　　　　　　　　　　　　.Value;

　　　　　　return await Task.Run(() => appconfig);
　　　　}
　　}

　　我们修改一下我们的配置文件siteconfig.json ：添加一个数据库选择的配置

　　我们在平台检测类（没有的也可以自己新建一个）中，增加一个类用于检测数据库配置：internal class DataBaseProvider { }

　　我们通过我们上面的读取配置文件的方法读取我们的配置：

　　private ApplicationConfiguration dataBaserProvider = new Services.ConfigServices.AppConfigurtaionServices().GetAppSettings<ApplicationConfiguration>("siteconfig");