Net Core中使用EF Core连接Mysql数据库

  • Net Core中使用EF Core连接Mysql数据库已关闭评论
  • 76 次浏览
  • A+
所属分类：.NET技术
摘要

Entity Framework Core的前身是微软提供并主推的ORM框架，简称EF，其底层是对ADO.NET的封装。EF支持SQLServer、MYSQL、Oracle、Sqlite等所有主流数据库。
首先是使用时的几个模式的整理及其理解：
便宜好用的国外VPS推荐

Entity Framework Core的前身是微软提供并主推的ORM框架，简称EF，其底层是对ADO.NET的封装。EF支持SQLServer、MYSQL、Oracle、Sqlite等所有主流数据库。
首先是使用时的几个模式的整理及其理解：

  1. Code First：根据代码自动创建数据库表结构甚至是数据库，可以支持多库开发，代码较少冗余，由于会自动更改数据库，如果有在实体类中自定义了字段，不希望在数据库中创建此字段（有时偷懒，不想定义ViewModel会这样做），还需要自己实现单独的生成代码。这就复杂了。
  2. DB First：根据现有的数据库结构生成模型类或实体类，这种适合数据库结构比较稳定的产品，数据库结构较大，表较多，甚至多人开发时频繁变动各自都要去生成太容易出错。同样偷懒模式下会删除字段。
  3. Model First：这种有可视化的模型设计，也就是Edm文件，可以利用VS等工具快速生成数据库脚本，类似Code Fist，只不过能可视化编写模式，需要完全了解数据库结构，貌似现在的NET Core时代没有这玩意了。
  4. 灵活的模式：这个算是我自加的，我称之为灵活的模式，就是DB和Code分开来实现，可以由不同的人来协作完成，更适合团队协作，DB由A来完成，Code由B来完成，甚至更多的人来参与，当然这个也会有一个大问题就是可能实体Code和DB不能很好的同步更新。
    我这里基于第四种灵活的模式来实现，DB和Code分开编写。分三步走。

第一步：引入EF
VS中NuGet需要添加两个引用包，当然你也可以用NuGet的包管理——程序包管理器控制台安装
Microsoft.EntityFrameworkCore 和 Pomelo.EntityFrameworkCore.MySql
当然在.NetCore中配置文件已Json的方式配置，你还得引入读取配置相关的包
Microsoft.Extensions.Configuration.Json

第二步：创建数据上下文DbContext
首先，什么是EF Core的数据上下文，建议参考下文章：https://www.cnblogs.com/Alex80/p/13413791.html。说得非常明白。
然后，我们来创建一个数据上下文MyDbContext类，继承自Microsoft.EntityFrameworkCore.DbContext。我们需要配置上数据库连接：在构造函数中指定需要读取的配置文件，并且重写OnConfiguring方法，在其中读取配置文件中我们配置的连接字符串,我这里读取的是appsettings.json配置文件中的名为Default的配置。
配置文件的Mysql连接字符串类似如下：

appsettings.json中的Mysql连接字符串 
{   "ConnectionStrings": {     "Default": "Server=localhost;Database=ct_threeview;charset=utf8;uid=root;pwd=0b85232f9ebda56fc8a1f54f74383aF8a4055e570bb36cbb5;port=3506;"   } }

MyDbContext类中的主要代码如下，其中Test1，Study，Series就是我们的实体类，是和数据库中的表一一对应的。

Net Core中使用EF Core连接Mysql数据库

实体类是我们自己项目中手动添加的类，Study表实体类参考如下，
可以通过特性Table特性标识实体对应的是数据库中的哪个表
可以通过Key特性来标识哪个字段是主键
可以通过Column特性来标识对应数据库表中的字段是哪个
Net Core中使用EF Core连接Mysql数据库

到这里，真个的EF Core的引入就算完了，后面我们就可以开始使用了，这里我贴几个常规操作的代码，更多的大家可以参考微软官网或自行百度。

添加操作 
        /// <summary>         /// 这里是添加操作         /// </summary>         /// <param name="entity"></param>         /// <returns></returns>         public Study Insert(Study entity)         {             using (MyDbContext db = new MyDbContext())             {                 db.Study.Add(entity);                 db.SaveChanges();                 //entity.Id= db.Entry(entity).Entity.Id;//返回插入的记录并注入到userEntity,关键是这句                 return entity;             }         }
单个表部分字段更新操作 
        public void UpdateNote(int studyId,string Note)         {             using (MyDbContext db = new MyDbContext())             {                 var study = new Study() { Id = studyId, Notes = Note,modify_time=DateTime.Now };                 db.Study.Attach(study);                 db.Entry<Study>(study).Property("Notes").IsModified = true;                 db.Entry<Study>(study).Property("modify_time").IsModified = true;                 db.SaveChanges();             }         }
多表联查操作 
        public List<PatientDataListModel> QueryAllData()         {             using (MyDbContext db = new MyDbContext())             {                 var query = from a in db.Study                             join b in db.Series on a.Id equals b.Study_Id                             select new PatientDataListModel                             {                                 StudyId = a.Id,                                 StudyInstanceUID = a.StudyInstanceUID,                                 StudyDate = a.StudyDate,                                 Modality = a.Modality,                                 StudyFilePath = a.StudyFilePath,                                 Notes=a.Notes,                                 PatientName = a.PatientName,                                 PatientID = a.PatientID,                                 PatientSex = a.PatientSex,                                 Frames = b.Frames,                                 SeriesId = b.Id,
使用事务的操作 
            List<Sop> List = new List<Sop>(); ;              using (MyDbContext db = new MyDbContext())             {                 //查询数据                 IQueryable<Sop>  query = db.Sop.FromSqlRaw($"select * from sop where Series_Id in (select Id from series where Study_Id = {studyId})");                 List = query.ToList();                 using (var transaction =db.Database.BeginTransaction())                 {                     int effectRow = 0;                     try                     {                          effectRow =db.Database.ExecuteSqlRaw(@"delete from sop where Series_Id in (                                 select Id from series where Study_Id = " + studyId + @")");                         //transaction.CreateSavepoint("BeforeDelete"); //可以创建回滚点;出错后可以指定DB操作回滚到此前                         db.Database.ExecuteSqlRaw(@"delete from series where Id=" + studyId);                         //transaction.CreateSavepoint("BeforeDelete2"); //可以打开此代码，这里是创建的还原点2

当然，针对MyDbContext，我们也可以使用在Startup.cs注册，使用IOC的方式去使用。这种资料网上也非常多。
最后，在项目调试时，如果想实时查看EF 生成的SQL语句确实不方便，不像SqlSugar那样有一个tosql方法能直接看到。我目前没有找到很好的方法，参考网上其他人给出方案，就是在VS的控制台来输出SQL语句，当然，我们首先需要引入微软的官方日志组件Microsoft.Extensions.Logging.Debug。
然后再数据上下文（这里是MyDBContext）类中New一个日志工厂，在OnConfiguring方法中添加日志组件，这样我们在调试时就能在VS的调试输出中看到生成的SQL语句。
Net Core中使用EF Core连接Mysql数据库

EFCore逆向工程——生成实体类
如果想逆向根据DB的表结构来生成实体类，这里需要借助与微软提供的包：Microsoft.EntityFrameworkCore.Tools
首先在NuGet中引入Microsoft.EntityFrameworkCore.Tools，然后VS中菜单选择工具——》NuGet包管理器——》程序包管理器控制台。在包管理器控制台输入如下命令：
Scaffold-DbContext 'Server=localhost;Database=您的数据库名;charset=utf8;uid=账号;pwd=密码;port=端口;' Pomelo.EntityFrameworkCore.MySql -OutputDir "输出的目录文件夹"
OutputDir 如果不提供的话会将实体类生成在项目根目录下，看个人需求。

便宜好用的国外VPS推荐