【无私分享:ASP.NET CORE 项目实战(第十二章)】添加对SqlServer、MySql、Oracle的支持

目录索引 

【无私分享:ASP.NET CORE 项目实战】目录索引

简介

  

  增加对多数据库的支持,并不是意味着同时对多种数据库操作,当然,后面,我们会尝试同时对多种数据库操作,这可能需要多个上下文,暂且不论。分布式数据库,我们采用的是阿里云的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");

  

  读取数据库类型:

  public bool _isSqlServer
  {
    get
      {
        return dataBaserProvider.DataBase.ToLower() == "mssql";
      }

  }

  public bool _isMySql
  {
    get
      {
        return dataBaserProvider.DataBase.ToLower() == "mysql";
      }
  }

  public bool _isOracle
  {
    get
      {
        return dataBaserProvider.DataBase.ToLower() == "oracle";
      }
  }

  好了,我们回到我们的 Startup.cs:

  首先,我们实例化一下我们这个类:

  

  修改 ConfigureServices(IServiceCollection services) 方法的 上下文注册服务:

  

  OK,这样我们就很简陋的实现了切换,我们来测试一下:

  首先使用SqlServer:siteconfig.json : "DataBase": "MSSQL"

  dotnet ef database update

  

  使用MySql:siteconfig.json : "DataBase": "MYSQL"

  dotnet ef database update

  

  好了,到这里就结束了,虽然简陋,给大家提供一下思路。

希望跟大家一起学习Asp.net Core

刚开始接触,水平有限,很多东西都是自己的理解和翻阅网上大神的资料,如果有不对的地方和不理解的地方,希望大家指正!

虽然Asp.net Core 现在很火热,但是网上的很多资料都是前篇一律的复制,所以有很多问题我也暂时没有解决,希望大家能共同帮助一下!

原创文章 转载请尊重劳动成果 http://yuangang.cnblogs.com

时间: 2025-01-16 09:39:18

【无私分享:ASP.NET CORE 项目实战(第十二章)】添加对SqlServer、MySql、Oracle的支持的相关文章

【无私分享:ASP.NET CORE 项目实战(第四章)】Code First 创建数据库和数据表

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 本章我们来介绍下Asp.net Core 使用 CodeFirst 创建数据库和表,通过 控制台 和 dotnet ef 两种方式 修改EF上下文对象,添加测试类 我修改了一下名字,Domains 改为了 wkmvc.Data 我们新建一个文件夹 Models 用于存放 模型类 我们在Models下面再新建一个文件夹SysModelsMange 用于区域模型类 我们新建一个测试类SYS_USER namespace wkm

【无私分享:ASP.NET CORE 项目实战(第五章)】Repository仓储 UnitofWork

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 本章我们来创建仓储类Repository 并且引入 UnitOfWork 我对UnitOfWork的一些理解  UnitOfWork 工作单元,对于这个的解释和实例,网上很多很多大神之作,我在这就不班门弄斧了,只是浅谈 一下个人理解,不一定对,希望大家指正: UnitOfWork 看了很多,个人理解就是 统一事务,在很多操作中我们可能是进行多项操作的,比如 同时保存两个表的数据,如果我们先保存一个表(SaveChanges

【无私分享:ASP.NET CORE 项目实战(第三章)】EntityFramework下领域驱动设计的应用

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 在我们 [无私分享:从入门到精通ASP.NET MVC] 系列中,我们其实也是有DDD思想的,但是没有完全的去实现,因为并不是所有的好的东西都必须要用到的,还是根据实际情况,DDD在大型的系统中是非常好的一种设计思想,这点不否认.但是根据具体情况而言,在我们小型的项目中,我们设计框架的更多考虑的是让使用者快速.便捷的开发,能快速的了解框架进行项目开发. 重构我们的思路 最近研究了一下几位大神的博客,特别是:@腾飞(Jess

【无私分享:ASP.NET CORE 项目实战(第十一章)】Asp.net Core 缓存 MemoryCache 和 Redis

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 经过 N 久反复的尝试,翻阅了网上无数的资料,GitHub上下载了十几个源码参考, Memory 和 Redis 终于写出一个 简陋 的 封装,为了统一和易用,我们两种缓存都统一实现了一个接口 ICacheService,微软也有很多是通过IDistributedCache,大家可以参考 https://docs.asp.net/en/latest/performance/caching/distributed.html 

【无私分享:ASP.NET CORE 项目实战(第七章)】文件操作 FileHelper

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 在程序设计中,我们很多情况下,会用到对文件的操作,在 上一个系列 中,我们有很多文件基本操作的示例,在Core中有一些改变,主要是我们常用的Server.MapPath()不存在了,不知道后续的版本会不会有,在这里,我们只能自己封装方法去实现.今天,我们就对一些基本的操作写了一个 FileHelper 类,供大家探讨.在此要感谢以为不愿意透漏姓名的大神的帮助:@YINYEJUN 获取文件的绝对路径  在以前的操作中,这个应

【无私分享:ASP.NET CORE 项目实战(第六章)】读取配置文件(一) appsettings.json

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 在我们之前的Asp.net mvc 开发中,一提到配置文件,我们不由的想到 web.config 和 app.config,在 core 中,我们看到了很多的变化,新的配置系统显得更加轻量级,具有更好的扩展性,并且支持多样化的数据源. 博客园对于这个的讲解很多,比如:Artche ,但是,没有点基础看老A的博客还是有些吃力的,对于老A介绍的配置,我也是看的一头雾水,在后面的文章中,我会用像我们这些菜鸟容易接受的方式,重新解

【无私分享:ASP.NET CORE 项目实战(第五章)】Code First 创建数据库和数据表

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 本章我们来介绍下Asp.net Core 使用 CodeFirst 创建数据库和表 修改EF上下文对象,添加测试类 我修改了一下名字,Domains 改为了 wkmvc.Data 我们新建一个文件夹 Models 用于存放 模型类 我们在Models下面再新建一个文件夹SysModelsMange 用于区域模型类 我们新建一个测试类SYS_USER namespace wkmvc.Data.Models  { public

【无私分享:ASP.NET CORE 项目实战(第七章)】读取配置文件(二) 读取自定义配置文件

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 我们在 读取配置文件(一) appsettings.json 中介绍了,如何读取appsettings.json. 但随之产生了问题:我们使用的是在 Startup.cs 中(如下图)来实现配置读取,有两个问题 ① 我们如果定义N种配置,是否要再这里添加N条这样的配置 : ② 如果我们的配置不想写在appsettings.json中呢 解决问题 带着上面的两个问题,我们首先来添加一个配置文件 siteconfig.json

【无私分享:ASP.NET CORE 项目实战(第九章)】创建区域Areas,添加TagHelper

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 在Asp.net Core VS2015中,我们发现还有很多不太简便的地方,比如右击添加视图,转到试图页等功能图不见了,虽然我们可以通过工具栏的自定义命令,把这两个右击菜单添加上,但是貌似是灰色的不能用. 其实,这样也好,通过手动创建,更让我们深刻的理解MVC以及路由之间的关系,很多人认为底层的东西是高大上的,比如一提到汇编,很多人感觉牛的不行不行的,其实术业有专攻,做程序的感觉搞核电的很牛,搞核电的同样也感觉做程序的很牛

【无私分享:ASP.NET CORE 项目实战(第二章)】添加EF上下文对象,添加接口、实现类以及无处不在的依赖注入(DI)

目录索引 [无私分享:ASP.NET CORE 项目实战]目录索引 简介 上一章,我们介绍了安装和新建控制器.视图,这一章我们来创建个数据模型,并且添加接口和实现类. 添加EF上下文对象 按照我们以前的习惯,我们还是新建几个文件夹 Commons:存放帮助类 Domians:数据模型 Services:接口和实现类 我们在Domains文件夹下添加一个类库 Domain 我们新建一个类 ApplicationDbContext 继承 DbContext 1 using Microsoft.Ent