.NET EF Core（Entity Framework Core）

EF Core与其他ORM比较

1、Entity Framework Core(EF Core)是微软官方的ORM框架。优点：功能强大、官方支持、生产效率高、力求屏蔽底层数据库差异；缺点：复杂、上手门槛高、不熟悉EFCore的话可能会进坑。 2、Dapper。优点：简单，N分钟即可上手，行为可预期性强；缺点：生产效率低，需要处理底层数据库差异。 3、EF Core是模型驱动 (Model-Driven)的开发思想，Dapper是数据库驱动(DataBase-Driven)的开发思想的。没有优劣，只有比较。 4、性能： Dapper等≠性能高；EF Core≠性能差。 5、EF Core是官方推荐、推进的框架，尽量屏蔽底层数据库差异，.NET开发者必须熟悉，根据的项目情况再决定用哪个。

EF Core与EF比较

1、EF有DB First、Model First、Code First。EF Core不支持模型优先，推荐使用代码优先，遗留系统可以使用Scaffold-DbContext来生成代码实现类似DBFirst的效果，但是推荐用Code First 。 2、EF会对实体上的标注做校验，EF Core追求轻量化，不校验。 3、熟悉EF的话，掌握EFCore会很容易，很多用法都移植过来了。EF Core又增加了很多新东西。 4、EF中的一些类的命名空间以及一些方法的名字在EF Core中稍有不同。 5、EF不再做新特性增加。

Migration数据库迁移

面向对象的ORM开发中，数据库不是程序员手动创建的，而是由Migration工具生成的。关系数据库只是盛放模型数据的一个媒介而已，理想状态下，程序员不用关心数据库的操作。根据对象的定义变化，自动更新数据库中的表以及表结构的操作，叫做Migration（迁移）。迁移可以分为多步（项目进化），也可以回滚。

1、Nuget安装Install-Package Microsoft.EntityFrameworkCore.SqlServer,Microsoft.EntityFrameworkCore.Tools 2、搭建工程：创建实体类Book.cs

 
public class Book
{
    public long Id { get; set; }//主键
    public string Title { get; set; }//标题
    public DateTime PubTime { get; set; }//发布日期
    public double Price { get; set; }//单价
 
    public override string ToString()
    {
        return "Id:" + this.Id + ",Title:" + this.Title + ",PubTime" + this.PubTime +",Price" + this.Price + ",AuthorName" + AuthorName;
    }
}

实体配置类：创建实现了IEntityTypeConfiguration接口的实体配置类，配置实体类和数据库表的对应关系

 
class BookEntityConfig : IEntityTypeConfiguration<Book>
{
	public void Configure(EntityTypeBuilder<Book> builder)
	{
		builder.ToTable("T_Books");
	}
}

创建继承自DbContext的类

 
internal class MyDbContext: DbContext
{
    public DbSet<Book> Books { get; set; }
    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        string connStr = "Server=192.168.1.193;Database=demo1; User=sa;Password=@q123; Trusted_Connection=False;MultipleActiveResultSets=true;TrustServerCertificate=true";
        optionsBuilder.UseSqlServer(connStr);
    }
    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        base.OnModelCreating(modelBuilder);
        modelBuilder.ApplyConfigurationsFromAssembly(this.GetType().Assembly);
    }
 
}

2、在“程序包管理器控制台”中执行命令：Add-Migration InitialCreate，会自动在项目的Migrations文件夹中中生成操作数据库的C#代码。 3、代码需要执行后才会应用对数据库的操作。“程序包管理器控制台”中执行Update-database 4、查看一下数据库，表建好了

反向工程

1、根据数据库表来反向生成实体类 2、Scaffold-DbContext 'Server=.;Database=demo1;Trusted_Connection=True;MultipleActiveResultSets=true' Microsoft.EntityFrameworkCore.SqlServer

Tips：1、生成的实体类可能不能满足项目的要求，可能需要手工修改或者增加配置。 2、再次运行反向工程工具，对文件所做的任何更改都将丢失。 3、不建议把反向工具当成了日常开发工具使用，不建议DBFirst。

Migrations其他命令

1、Update-Database XXX ：把数据库回滚到XXX的状态，迁移脚本不动。 2、Remove-migration：删除最后一次的迁移脚本 3、Script-Migration：生成迁移SQL代码。可以生成版本D到版本F的SQL脚本：Script-Migration D F 生成版本D到最新版本的SQL脚本：Script-Migration D 4、通过给Add-Migration命令添加“-OutputDir”参数的形式来在同一个项目中为不同的数据库生成不同的迁移脚本

小结： 1、使用迁移脚本，可以对当前连接的数据库执行编号更高的迁移，这个操作叫做“向上迁移”（Up），也可以执行把数据库回退到旧的迁移，这个操作叫“向下迁移”（Down）。 2、除非有特殊需要，否则不要删除Migrations文件夹下的代码。 3、进一步分析Migrations下的代码。分析Up、Down等方法。查看Migration编号。 4、查看数据库的__EFMigrationsHistory表：记录当前数据库曾经应用过的迁移脚本，按顺序排列。

修改表结构

想要限制Title的最大长度为50，Title字段设置为“不可为空”，并且想增加一个不可为空且最大长度为20的AuthorName（作者名字）属性。 1、首先在Book实体类中增加一个AuthorName属性。

2、修改BookEntityConfig

 
builder.ToTable("T_Books");
builder.Property(e => e.Title).HasMaxLength(50).IsRequired();
builder.Property(e => e.AuthorName).HasMaxLength(20).IsRequired();

3、执行Add-Migration AddAuthorName_ModifyTitle。AddAuthorName_ModifyTitle为本次迁移操作的名称 4、执行：Update-Database

EF Core操作数据库

插入数据

只要操作Books属性，就可以向数据库中增加数据，但是通过C#代码修改Books中的数据只是修改了内存中的数据。对Books做修改后，需要调用DbContext的异步方法SaveChangesAsync()把修改保存到数据库。也有同步的保存方法SaveChanges()，但是用EF Core都推荐用异步方法。

 
 static async Task Main(string[] args)
 {
     using (MyDbContext dbContext = new MyDbContext())
     {
         Book book = new Book() { Title = "西游记", Price = 15.5, AuthorName = "吴承恩" };
         dbContext.Books.Add(book);
         await dbContext.SaveChangesAsync();
     }
 }

查询数据

DbSet实现了IEnumerable<T>接口，因此可以对DbSet实施Linq操作来进行数据查询。EF Core会把Linq操作转换为SQL语句。面向对象，而不是面向数据库(SQL)。

 
IQueryable<Book> books = dbContext.Books.Where(b => b.Price > 20);
foreach (Book book in books)
{
    Console.WriteLine(book);
}
Book b1 = dbContext.Books.Single(b => b.Title == "西游记");
Book b2 = dbContext.Books.FirstOrDefault(b => b.Id == 2);
Console.WriteLine(b1);
Console.WriteLine(b2);
IEnumerable<Book> books2 = dbContext.Books.OrderByDescending(b => b.Price);
 
var groups = dbContext.Books.GroupBy(b => b.AuthorName)
	.Select(g => new { AuthorName = g.Key, BooksCount = g.Count(), MaxPrice = g.Max(b => b.Price) });
foreach(var g in groups)
{
	Console.WriteLine($"作者名:{g.AuthorName},著作数量:{g.BooksCount},最贵的价格:{g.MaxPrice}");
}

修改、删除

1、要对数据进行修改，首先需要把要修改的数据查询出来，然后再对查询出来的对象进行修改，然后再执行SaveChangesAsync()保存修改。

修改：

 
 var b = dbContext.Books.Single(b => b.Title == "西游记");
 b.AuthorName = "WuChengEn";
 await dbContext.SaveChangesAsync();

2、删除也是先把要修改的数据查询出来，然后再调用DbSet或者DbContext的Remove方法把对象删除，然后再执行SaveChangesAsync()保存修改。

 
var b = dbContext.Books.Single(b => b.Id == 1);
dbContext.Remove(b);//也可以写成ctx.Books.Remove(b);
await dbContext.SaveChangesAsync();

开源批量修改删除插件

其他数据库

mysql： Install-Package Pomelo.EntityFrameworkCore.MySql

 
optionsBuilder.UseMySql("server=localhost;user=root;password=root;database=ef",
	new MySqlServerVersion(new Version(5, 6, 0)));

PostgreSQL： Install-Package Npgsql.EntityFrameworkCore.PostgreSQL


optionsBuilder.UseNpgsql("Host=127.0.0.1;Database=ef;Username=postgres;Password=123456");

EF Core实体的配置

主要规则： 1：表名采用DbContext中的对应的DbSet的属性名。 2：数据表列的名字采用实体类属性的名字，列的数据类型采用和实体类属性类型最兼容的类型。 3：数据表列的可空性取决于对应实体类属性的可空性。 4：名字为Id的属性为主键，如果主键为short, int 或者 long类型，则默认采用自增字段，如果主键为Guid类型，则默认采用默认的Guid生成机制生成主键值。

Data Annotation配置方式

把配置以特性（Annotation）的形式标注在实体类中

 
 [Table("t_books")]
 public class Book
 {
     public long Id { get; set; }//主键
     [Required]
     [MaxLength(50)]
     public string Title { get; set; }//标题
     public DateTime PubTime { get; set; }//发布日期
     public double Price { get; set; }//单价
 
     public string AuthorName { get; set; }
 
     public override string ToString()
     {
         return "Id:" + this.Id + ",Title:" + this.Title + ",PubTime" + this.PubTime +",Price" + this.Price + ",AuthorName" + AuthorName;
     }
 }

Fluent API配置方式

把配置写到单独的配置类中

 
 internal class BookEntityConfig : IEntityTypeConfiguration<Book>
 {
     public void Configure(EntityTypeBuilder<Book> builder)
     {
         builder.ToTable("t_books");
      
         builder.Property(e => e.Title).HasMaxLength(50).IsRequired();
         builder.Property(e => e.AuthorName).HasMaxLength(20).IsRequired();
     }
 }

Fluent API

1、视图与实体类映射：

modelBuilder.Entity<Blog>().ToView("blogsView");

2、排除属性映射：

modelBuilder.Entity<Blog>().Ignore(b => b. Name2);

3、配置列名：

modelBuilder.Entity<Blog>().Property(b =>b.BlogId).HasColumnName("blog_id");

4、配置列数据类型：


builder.Property(e => e.Title) .HasColumnType("varchar(200)");

5、配置主键默认把名字为Id或者“实体类型+Id“的属性作为主键，可以用HasKey()来配置其他属性作为主键。

modelBuilder.Entity<Student>().HasKey(c => c.Number);

6、可以用HasDefaultValue()为属性设定默认值


modelBuilder.Entity<Student>().Property(b => b.Age).HasDefaultValue(6);

7、索引

modelBuilder.Entity<Blog>().HasIndex(b => b.Url);

复合索引


modelBuilder.Entity<Person>().HasIndex(p => new { p.FirstName, p.LastName });

唯一索引：IsUnique()；聚集索引：IsClustered() 8、…

通过代码查看EF Core的sql语句

方法1：标准日志

nuget安装：Install-Package Microsoft.Extensions.Logging.Console

 
public static readonly ILoggerFactory MyLoggerFactory = LoggerFactory.Create(builder => { builder.AddConsole(); });
optionsBuilder.UseLoggerFactory(MyLoggerFactory);

完整代码：

 
 internal class MyDbContext: DbContext
 {
     public static readonly ILoggerFactory MyLoggerFactory = LoggerFactory.Create(builder => { builder.AddConsole(); });
 
     public DbSet<Book> Books { get; set; }
     protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
     {
         string connStr = "Server=192.168.1.193;Database=demo1; User=sa;Password=@q123; Trusted_Connection=False;MultipleActiveResultSets=true;TrustServerCertificate=true";
         optionsBuilder.UseSqlServer(connStr);
 
         optionsBuilder.UseLoggerFactory(MyLoggerFactory);
 
     }
     protected override void OnModelCreating(ModelBuilder modelBuilder)
     {
         base.OnModelCreating(modelBuilder);
         modelBuilder.ApplyConfigurationsFromAssembly(this.GetType().Assembly);
     }
 
 }

在这里插入图片描述

方法2：简单日志

此方式不需要额外的引入Logging框架

 
optionsBuilder.LogTo(Console.WriteLine);
//可以自己写代码过滤一些不需要的消息

方法3：ToQueryString

EF Core的Where方法返回的是IQueryable类型，DbSet也实现了IQueryable接口。 IQueryable有扩展方法ToQueryString()可以获得SQL

 
 IQueryable<Book> books = dbContext.Books.Where(b => b.Id == 2);
 string sql = books.ToQueryString();
 Console.WriteLine(sql);

悲观并发控制

悲观并发控制一般采用行锁、表锁等排他锁对资源进行锁定，确保同时只有一个使用者操作被锁定的资源。

MYSQL方案：select * from T_Houses where Id=1 for update 如果有其他的查询操作也使用for update来查询Id=1的这条数据的话，那些查询就会被挂起，一直到针对这条数据的更新操作完成从而释放这个行锁，代码才会继续执行。

锁是和事务相关的，因此通过BeginTransactionAsync()创建一个事务，并且在所有操作完成后调用CommitAsync()提交事务。

 
Console.WriteLine("请输入您的姓名");
string name = Console.ReadLine();
using MyDbContext ctx = new MyDbContext();
using var tx = await ctx.Database.BeginTransactionAsync();
Console.WriteLine("准备Select " + DateTime.Now.TimeOfDay);
var h1 = await ctx.Houses.FromSqlInterpolated($"select * from T_Houses where Id=1 for update")
	.SingleAsync();
Console.WriteLine("完成Select " + DateTime.Now.TimeOfDay);
if (string.IsNullOrEmpty(h1.Owner))
{
	await Task.Delay(5000);
	h1.Owner = name;
	await ctx.SaveChangesAsync();
	Console.WriteLine("抢到手了");
}
else
{
	if (h1.Owner == name)
	{
		Console.WriteLine("这个房子已经是你的了，不用抢");
	}
	else
	{
		Console.WriteLine($"这个房子已经被{h1.Owner}抢走了");
	}
}
await tx.CommitAsync();
Console.ReadKey();

Tips：悲观锁是独占、排他的，如果系统并发量很大的话，会严重影响性能，如果使用不当的话，甚至会导致死锁。

乐观并发控制：并发令牌

 
Update T_Houses set Owner=新值
where Id=1 and Owner=旧值

当Update的时候，如果数据库中的Owner值已经被其他操作者更新为其他值了，那么where语句的值就会为false，因此这个Update语句影响的行数就是0，EF Core就知道“发生并发冲突”了，因此SaveChanges()方法就会抛出DbUpdateConcurrencyException异常。

1、把被并发修改的属性使用IsConcurrencyToken()设置为并发令牌。

builder.Property(h => h.Owner).IsConcurrencyToken();

2、示例代码：

 
Console.WriteLine("请输入您的姓名");
string name = Console.ReadLine();
using MyDbContext ctx = new MyDbContext();
var h1 = await ctx.Houses.SingleAsync(h => h.Id == 1);
if (string.IsNullOrEmpty(h1.Owner))
{
	await Task.Delay(5000);
	h1.Owner = name;
	try
	{
		await ctx.SaveChangesAsync();
		Console.WriteLine("抢到手了");
	}
	catch (DbUpdateConcurrencyException ex)
	{
		var entry = ex.Entries.First();
		var dbValues = await entry.GetDatabaseValuesAsync();
		string newOwner = dbValues.GetValue<string>(nameof(House.Owner));
		Console.WriteLine($"并发冲突，被{newOwner}提前抢走了");
	}
}
else
{
	if (h1.Owner == name)
	{
		Console.WriteLine("这个房子已经是你的了，不用抢");
	}
	else
	{
		Console.WriteLine($"这个房子已经被{h1.Owner}抢走了");
	}
}
Console.ReadLine();

乐观并发控制：RowVersion

SQLServer数据库可以用一个byte[]类型的属性做并发令牌属性，然后使用IsRowVersion()把这个属性设置为RowVersion类型，这样这个属性对应的数据库列就会被设置为ROWVERSION类型。对于ROWVERSION类型的列，在每次插入或更新行时，数据库会自动为这一行的ROWVERSION类型的列其生成新值。

 
class House
{
	public long Id { get; set; }
	public string Name { get; set; }
	public string Owner { get; set; }
	public byte[] RowVer { get; set; }
}
builder.Property(h => h.RowVer).IsRowVersion();

Tips：乐观并发控制能够避免悲观锁带来的性能、死锁等问题，因此推荐使用乐观并发控制而不是悲观锁。

总结：如果有一个确定的字段要被进行并发控制，那么使用IsConcurrencyToken()把这个字段设置为并发令牌即可；如果无法确定一个唯一的并发令牌列，那么就可以引入一个额外的属性设置为并发令牌，并且在每次更新数据的时候，手动更新这一列的值。

	public class Book
	{
	public long Id { get; set; }//主键
	public string Title { get; set; }//标题
	public DateTime PubTime { get; set; }//发布日期
	public double Price { get; set; }//单价

	public override string ToString()
	{
	return "Id:" + this.Id + ",Title:" + this.Title + ",PubTime" + this.PubTime +",Price" + this.Price + ",AuthorName" + AuthorName;
	}
	}

	class BookEntityConfig : IEntityTypeConfiguration<Book>
	{
	public void Configure(EntityTypeBuilder<Book> builder)
	{
	builder.ToTable("T_Books");
	}
	}

	internal class MyDbContext: DbContext
	{
	public DbSet<Book> Books { get; set; }
	protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
	{
	string connStr = "Server=192.168.1.193;Database=demo1; User=sa;Password=@q123; Trusted_Connection=False;MultipleActiveResultSets=true;TrustServerCertificate=true";
	optionsBuilder.UseSqlServer(connStr);
	}
	protected override void OnModelCreating(ModelBuilder modelBuilder)
	{
	base.OnModelCreating(modelBuilder);
	modelBuilder.ApplyConfigurationsFromAssembly(this.GetType().Assembly);
	}

	}

	builder.ToTable("T_Books");
	builder.Property(e => e.Title).HasMaxLength(50).IsRequired();
	builder.Property(e => e.AuthorName).HasMaxLength(20).IsRequired();

	static async Task Main(string[] args)
	{
	using (MyDbContext dbContext = new MyDbContext())
	{
	Book book = new Book() { Title = "西游记", Price = 15.5, AuthorName = "吴承恩" };
	dbContext.Books.Add(book);
	await dbContext.SaveChangesAsync();
	}
	}

	IQueryable<Book> books = dbContext.Books.Where(b => b.Price > 20);
	foreach (Book book in books)
	{
	Console.WriteLine(book);
	}
	Book b1 = dbContext.Books.Single(b => b.Title == "西游记");
	Book b2 = dbContext.Books.FirstOrDefault(b => b.Id == 2);
	Console.WriteLine(b1);
	Console.WriteLine(b2);
	IEnumerable<Book> books2 = dbContext.Books.OrderByDescending(b => b.Price);

	var groups = dbContext.Books.GroupBy(b => b.AuthorName)
	.Select(g => new { AuthorName = g.Key, BooksCount = g.Count(), MaxPrice = g.Max(b => b.Price) });
	foreach(var g in groups)
	{
	Console.WriteLine($"作者名:{g.AuthorName},著作数量:{g.BooksCount},最贵的价格:{g.MaxPrice}");
	}

	var b = dbContext.Books.Single(b => b.Title == "西游记");
	b.AuthorName = "WuChengEn";
	await dbContext.SaveChangesAsync();

	var b = dbContext.Books.Single(b => b.Id == 1);
	dbContext.Remove(b);//也可以写成ctx.Books.Remove(b);
	await dbContext.SaveChangesAsync();

	optionsBuilder.UseMySql("server=localhost;user=root;password=root;database=ef",
	new MySqlServerVersion(new Version(5, 6, 0)));

	[Table("t_books")]
	public class Book
	{
	public long Id { get; set; }//主键
	[Required]
	[MaxLength(50)]
	public string Title { get; set; }//标题
	public DateTime PubTime { get; set; }//发布日期
	public double Price { get; set; }//单价

	public string AuthorName { get; set; }

	public override string ToString()
	{
	return "Id:" + this.Id + ",Title:" + this.Title + ",PubTime" + this.PubTime +",Price" + this.Price + ",AuthorName" + AuthorName;
	}
	}

	internal class BookEntityConfig : IEntityTypeConfiguration<Book>
	{
	public void Configure(EntityTypeBuilder<Book> builder)
	{
	builder.ToTable("t_books");

	builder.Property(e => e.Title).HasMaxLength(50).IsRequired();
	builder.Property(e => e.AuthorName).HasMaxLength(20).IsRequired();
	}
	}

	public static readonly ILoggerFactory MyLoggerFactory = LoggerFactory.Create(builder => { builder.AddConsole(); });
	optionsBuilder.UseLoggerFactory(MyLoggerFactory);

	optionsBuilder.LogTo(Console.WriteLine);
	//可以自己写代码过滤一些不需要的消息

	IQueryable<Book> books = dbContext.Books.Where(b => b.Id == 2);
	string sql = books.ToQueryString();
	Console.WriteLine(sql);

	Console.WriteLine("请输入您的姓名");
	string name = Console.ReadLine();
	using MyDbContext ctx = new MyDbContext();
	using var tx = await ctx.Database.BeginTransactionAsync();
	Console.WriteLine("准备Select " + DateTime.Now.TimeOfDay);
	var h1 = await ctx.Houses.FromSqlInterpolated($"select * from T_Houses where Id=1 for update")
	.SingleAsync();
	Console.WriteLine("完成Select " + DateTime.Now.TimeOfDay);
	if (string.IsNullOrEmpty(h1.Owner))
	{
	await Task.Delay(5000);
	h1.Owner = name;
	await ctx.SaveChangesAsync();
	Console.WriteLine("抢到手了");
	}
	else
	{
	if (h1.Owner == name)
	{
	Console.WriteLine("这个房子已经是你的了，不用抢");
	}
	else
	{
	Console.WriteLine($"这个房子已经被{h1.Owner}抢走了");
	}
	}
	await tx.CommitAsync();
	Console.ReadKey();

	class House
	{
	public long Id { get; set; }
	public string Name { get; set; }
	public string Owner { get; set; }
	public byte[] RowVer { get; set; }
	}
	builder.Property(h => h.RowVer).IsRowVersion();