EF Core 中的异步方法

1.SaveChanges(), SaveChangesAsync()

2.异步方法大部分是定义在Microsoft.EntityFrameworkCore这个命名空间下的EntityFrameworkCoreQueryableExtensions等类中的扩展方法，记得using

3.一些异步方法

 TestDbContext ctx = new TestDbContext();
 ​
 await ctx.SaveChangesAsync();
 await ctx.AddAsync(new User { Name ="1" });
 ​
 await ctx.AddRangeAsync(new[] { new User { Name ="2" } });
 ​
 await ctx.Users.AnyAsync(u=>u.Id == 5);
 ​
 //之后看看
 await ctx.Users.AllAsync(u=>u.Id == 5);
 ​
 await ctx.Users.AverageAsync(u => u.Id);
 ​
 await ctx.Users.CountAsync(u=>u.Id == 5);
 ​
 await ctx.Users.CountAsync();
 ​
 await ctx.Users.FirstAsync();
 ​
 await ctx.Users.ForEachAsync(u => u.Name = u.Name + "1");
 ​
 await ctx.Users.LongCountAsync();
 ​
 await ctx.Users.SingleAsync();
 ​
 await ctx.Users.SingleOrDefaultAsync();
 ​
 await ctx.Users.SumAsync(u=>u.Id);
 ​
 ​
 //异步循环1 一般不这样做
 await foreach (var l in ctx.Leaves.AsAsyncEnumerable())
 {
     Console.WriteLine(l.Remarks);
 }
 ​
 //异步循环2 一般不这样做
 foreach (var l in await ctx.Leaves.ToListAsync())
 {
     Console.WriteLine(l.Remarks);
 }

EF Core 执行非查询原生sql语句

 --将查询出来的数据插入数据库
 insert into T_Articles(Title,Message,Price)
 select Title,'新闻正文xxx',Price
 from T_Articles
 where Price>=10

 using (TestDbContext ctx2 = new TestDbContext())
 {
     string tj1 = "10";
     //执行非查询原生sql语句
     await ctx2.Database.ExecuteSqlInterpolatedAsync(@$"insert into T_Articles(Title,Message,Price)
                                                     select Title,'新闻正文xxx',Price
                                                     from T_Articles
                                                     where Price>={tj1}");
 }

执行实体相关的查询原生SQL语句

    //执行实体相关的查询原生SQL语句
      var users = ctx2.Users.FromSqlInterpolated(@$"select * from T_Users where Name like '%杨%'");
     //可以只写必须要使用原生sql的部分 其他的对此的数据的操作可以用EF Core来完成
     //用Guid来无序排序
     foreach (var user in users.OrderBy(u => Guid.NewGuid()))
     {
         Console.WriteLine(user.Name);
     }

查询出来的要与实体列一一对应

只能单表查询，不能使用join查询，但是后续可以在查询结果后面Incluede()来，进行关联数据的获取。

执行原生sql语句 调用ADO.Net

  //执行原生sql语句 调用Ado.Net api
     //拿到Context对应的底层的 Connection
     DbConnection coon = ctx2.Database.GetDbConnection();
     if (coon.State != System.Data.ConnectionState.Open)
     { 
         await coon.OpenAsync(); 
     }
 ​
     using (var cmd = coon.CreateCommand())
     {
         cmd.CommandText = @$"select Name,count(*) from T_Users";
         using (var reader = await cmd.ExecuteReaderAsync())
         {
             while (await reader.ReadAsync()) 
             {
                 var name = reader.GetString(0);
                 var count = reader.GetInt32(1);
                 Console.WriteLine($"{name}:{count}");
             }
         }
     }

总结

一般的Linq操作即可，尽量不要写原生sql

1.非查询sql用await ctx2.Database.ExecuteSqlInterpolatedAsync();

2.针对实体的sql查询用ctx2.Users.FromSqlInterpolated();

3.复杂sql查询用ADO.Net的方式获取Dapper等。

EF Core 如何判断数据发生了变化

 //只要一个实体对象和DbContext发生任何的关系（查询，add,和与DbContext有关系的其他对象产生关系）
 //都默认会被DbContext跟踪   
 User user1 = await ctx.Users.FirstAsync();//EF Core存储了一个副本（快照）
     user1.Name = "2222";
  User user2 = new User();//这状态是Detached
     await ctx.SaveChangesAsync();//此时 对象与快照的值对比 发生改变则修改
 ​

总结：

1.已分离（Detached）和未改变（Unchanged)的实体,SaveChangesAsync()忽略。

2.已添加的实体，SaveChangesAsync（)插入数据库。

3.已修改的实体，SaveChangesAsync（)更新到数据库。

4.已删除的实体，SaveChangesAsync（)从数据库中删除。

 //对象的跟踪状态
 using TestDbContext ctx = new TestDbContext();
 Book[] books = ctx.Books.Take(3).ToArray();
 Book b1 = books[0];
 Book b2 = books[1];
 Book b3 = books[2];
 Book b4 = new Book { Title = "零基础趣学C语言", AuthorName = "老杨" };
 Book b5 = new Book { Title = "百年孤独", AuthorName = "马尔克斯" };
 b1.Title = "abc";
 ctx.Remove(b3);
 ctx.Add(b4);
 EntityEntry entry1 = ctx.Entry(b1);
 EntityEntry entry2 = ctx.Entry(b2);
 EntityEntry entry3 = ctx.Entry(b3);
 EntityEntry entry4 = ctx.Entry(b4);
 EntityEntry entry5 = ctx.Entry(b5);
 Console.WriteLine("b1.State:" + entry1.State);
 Console.WriteLine("b1.DebugView:" + entry1.DebugView.LongView);
 Console.WriteLine("b2.State:" + entry2.State);
 Console.WriteLine("b3.State:" + entry3.State);
 Console.WriteLine("b4.State:" + entry4.State);
 Console.WriteLine("b5.State:" + entry5.State);

总结

DbContext会根据跟踪的实体的状态，在调用SaveChangesAsync的时候，根据实体状态的不同，生成Update,Delete,Insert等SQL语句，来把内存中的实体的变化更新到数据库中。