# 模块二 基础巩固 EF Core 介绍
## 2.4.2 EF Core -- 介绍
* ORM
* Repository 仓储
* UnitOfWork 工作单元
* DB Context 与 DB Set
* EF Core快速开始示例
### ORM
ORM：object-rational mapping
* 对 SQL 语言进行封装，降低使用难度，多种 SQL 语言的抽象
* 多出来的对事务、连接池、迁移、种子数据等一些功能
* 多数情况下 ORM 生成的 SQL 脚本比你自己写的要好
### Repository 仓储
在领域层和数据映射层之间，像一个内存级别的领域对象集合
* 为领域业务的单元测试提供替换点
* 集中数据库访问逻辑
### 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 中添加环境变量
启动项目，访问新增，列表接口
### GitHub源码链接：