efcore mysql使用datediff_DotNet 云原生架构师训练营（EF Core 介绍）

分手后的思念是犯贱 2023-01-10 11:53 33阅读 0赞

# **2.4.2 EF Core -- 介绍** #

*  ORM
 *  Repository 仓储
 *  UnitOfWork 工作单元
 *  DB Context 与 DB Set
 *  EF Core快速开始示例

# **ORM** #

ORM：object-rational mapping

*  对 SQL 语言进行封装，降低使用难度，多种 SQL 语言的抽象
 *  多出来的对事务、连接池、迁移、种子数据等一些功能
 *  多数情况下 ORM 生成的 SQL 脚本比你自己写的要好

# **Repository 仓储** #

在领域层和数据映射层之间，像一个内存级别的领域对象集合

*  为领域业务的单元测试提供替换点
 *  集中数据库访问逻辑

![694f887652a7246f31b9d20e94968fdc.png][]

# **UnitOfWork 工作单元** #

一个工作单元在一个事务范围内保留所有对数据库的变更，在这个工作单元结束的时候一次性提交所有改动到数据库

# **DB Context 与 DB Set** #

DB Context(UnitOfWork 工作单元)

DB Set(Repository 仓储)

EF Core 提供一个 DB Context 和多个 DB Set 组合完成数据查询和更新操作的 ORM 框架

# **EF Core快速开始示例** #

*  创建一个空的 web api 项目
 *  添加 Pomelo.EntityFrameworkCore.Mysql 的 nuget 包引用
 *  创建实体
 *  创建 DbContext
 *  配置连接字符串并且注入 DbContext
 *  使用 DbContext 完成数据查询与插入

# **创建实体** #

Entity

namespace LighterApi.Data{    public class Entity    {        ///         /// 主键Id        ///         public string Id { get; set; }        ///         /// 全局唯一的身份        ///         public string IdentityId { get; set; }        ///         /// 租户Id        ///         public string TenantId { get; set; }        ///         /// 用户Id        ///         public string UserId { get; set; }        ///         /// 创建时间        ///         public DateTime CreatedAt { get; set; }        ///         /// 创建的用户        ///         public string CreatedBy { get; set; }        ///         /// 最后修改时间        ///         public DateTime LastUpdateAt { get; set; }        ///         /// 最后修改人        ///         public string LastUpdateBy { get; set; }    }}

Assistant

namespace LighterApi.Data.Project{    public class Assistant : Entity    {        public string MemberId { get; set; }        public string ProjectGroupId { get; set; }    }}

Project

namespace LighterApi.Data.Project{    public class Project : Entity    {        public string Title { get; set; }        public DateTime StartDate { get; set; }        public DateTime EndDate { get; set; }        public string SupervisorId { get; set; }        public string PlanId { get; set; }    }}

Member

namespace LighterApi.Data.Project{    public class Member : Entity    {        public int Progress { get; set; }        public string ProjectId { get; set; }    }}

ProjectGroup

namespace LighterApi.Data.Project{    public class ProjectGroup : Entity    {        public string Name { get; set; }        public string ProjectId { get; set; }    }}

Task

namespace LighterApi.Data.Project{    public class Task : Entity    {        public string Title { get; set; }        public string SectionId { get; set; }        public string Description { get; set; }        public string ProjectId { get; set; }        public string MemberId { get; set; }        //public EnumTaskStauts Status { get; set; }    }}

EnumTaskStauts

namespace LighterApi.Share{    public class EnumTaskStauts    {    }}

# **创建 DbContext** #

LighterDbContext

namespace LighterApi.Data{    public class LighterDbContext : DbContext    {        public LighterDbContext(DbContextOptions options) : base(options)        {        }        public DbSet Projects { get; set; }        public DbSet Members { get; set; }        public DbSet Assistants { get; set; }        public DbSet ProjectGroups { get; set; }        public DbSet Tasks { get; set; }        protected override void OnModelCreating(ModelBuilder modelBuilder)        {            base.OnModelCreating(modelBuilder);        }    }}

# **配置连接字符串并且注入 DbContext** #

需要将 server 地址修改为数据库服务器地址

appsettings.json

{  "Logging": {    "LogLevel": {      "Default": "Information",      "Microsoft": "Warning",      "Microsoft.Hosting.Lifetime": "Information"    }  },  "ConnectionStrings": {    "LighterDbContext": "server=127.0.0.1;port=7306;user=root;password=root123456@;database=lighter"  },  "AllowedHosts": "*"}

Startup

public IConfiguration Configuration { get; }public Startup(IConfiguration configuration){    Configuration = configuration;}

services.AddDbContext(options =>{    options.UseMySql(Configuration.GetConnectionString("LighterDbContext"));});services.AddControllers();

app.UseEndpoints(endpoints =>{    endpoints.MapControllers();});

# **使用 DbContext 完成数据查询与插入** #

初始化数据库 ，注意在初始化以前确保正确配置了连接字符串，并且在startup.cs中添加了DbContext的注入

// 安装dotnet tool ef工具 dotnet tool install --global dotnet-ef// 以下命令需要在api项目的目录下执行 // 在项目内安装 dotnet add package Microsoft.EntityFrameworkCore.Design//添加迁移文件dotnet ef migrations add Init// 更新数据库 dotnet ef database update

创建控制器 ProjectController

namespace LighterApi.Controller{    [ApiController]    [Route("api/[controller]")]    public class ProjectController : ControllerBase    {        private readonly LighterDbContext _lighterDbContext;        public ProjectController(LighterDbContext lighterDbContext)        {            _lighterDbContext = lighterDbContext;        }    }}

列表

[HttpGet]public async Task> GetListAsync(CancellationToken cancellationToken){    return await _lighterDbContext.Projects.ToListAsync(cancellationToken);}

新增

public async Task> CreateAsync([FromBody] Project project,    CancellationToken cancellationToken){    project.Id = Guid.NewGuid().ToString();    _lighterDbContext.Projects.Add(project);    await _lighterDbContext.SaveChangesAsync(cancellationToken);    return StatusCode((int) HttpStatusCode.Created, project);}

修改启动端口，launchSettings.json

"applicationUrl": "https://localhost:6001;http://localhost:6000",

为了简化日期格式入参，添加 nuget 包 Microsoft.AspNetCore.Mvc.NewtonsoftJson

services.AddControllers()        .AddNewtonsoftJson();

在 Postman 中添加环境变量

![85aa572705454ad09fc692f2f8fb828c.png][]

启动项目，访问新增，列表接口

![2a87ac2ab92fcf572f95fd47c744be49.png][]

![e2033390c1530b31c7a1de1442e6eb7c.png][]

# **GitHub源码链接：** #

https://github.com/MINGSON666/Personal-Learning-Library/tree/main/ArchitectTrainingCamp/LighterApi

[694f887652a7246f31b9d20e94968fdc.png]: /images/20221119/acbbdcdb0bc4451aaf029176cc4cba35.png
[85aa572705454ad09fc692f2f8fb828c.png]: /images/20221119/72658c6e07cb4a4eb94fc66c12eeffe2.png
[2a87ac2ab92fcf572f95fd47c744be49.png]: /images/20221119/fda24c9a75824a44b1439e01c7da6cb6.png
[e2033390c1530b31c7a1de1442e6eb7c.png]: https://img-blog.csdnimg.cn/img_convert/e2033390c1530b31c7a1de1442e6eb7c.png