共计 2824 个字符,预计需要花费 8 分钟才能阅读完成。
0. 前言
《EF Core》实际上已经可以告一段落了,但是感觉还有一点点意犹未尽。所以决定分享一下,个人在实际开发中使用 EF Core 的一些经验和使用的扩展包。
1. EF Core 的异步操作
正如这小节题目所言,EF Core 是支持异步操作的,但实际可用集中在 SaveChanges 和异步查询这两个方法上。
具体方法声明如下:
public virtual System.Threading.Tasks.Task<int> SaveChangesAsync (System.Threading.CancellationToken cancellationToken = null);
public virtual System.Threading.Tasks.Task<TEntity> FindAsync<TEntity> (params object[] keyValues) where TEntity : class;
public virtual System.Threading.Tasks.Task<TEntity> FindAsync<TEntity> (object[] keyValues, System.Threading.CancellationToken cancellationToken) where TEntity : class;
public virtual System.Threading.Tasks.Task<object> FindAsync (Type entityType, params object[] keyValues);
public virtual System.Threading.Tasks.Task<object> FindAsync (Type entityType, object[] keyValues, System.Threading.CancellationToken cancellationToken);
这五个方法分别是 SaveChanges 的异步版,和 Find 的异步版。两种方法都支持传入一个取消令牌(这部分内容需要等后期的《C# 异步编程系列》里介绍)。
返回一个 Task,然后按照 Task 进行执行就行。
DbContext 也提供了 Add/AddRange 的异步方法,但是这组方法的异步版需要数据库的支持,并不是一个通用的方法,所以就没有提。
var context = new DefaultContext("Data Source=./blogging1.db");
var task1 = context.FindAsync<SingleModel>(1);
var result = task1.Result;
var task2 = context.SaveChangesAsync();
这两个任务是创建一个热启动任务,也就是不用手动调用 Run 方法。
回到数据查询来,查询的异步支持方法组是来自于 Linq,但是底层来源于数据访问接口。
简单的实例:
var task3 = context.Set<SingleModel>().Where(t => true).ToListAsync();
当获取 task3 结果的时候,会强制等待任务完成执行。
2. using 的另一种用法
我们知道 using 关键字通常用来引入命名空间,当然微软引入了另外一种用法。对于 EF Core 的 DbContext,框架推荐在用完之后将上下文销毁。而我们每次使用必须都进行手动销毁。
如果我们在使用 try/catch/finally 进行捕获异常的时候,需要在 finally 里放资源释放的代码。如果资源得不到正确及时的释放会出现更多的问题。
为了改善这种现状,微软便添加了 using 关键字的另外一种用法。
using (var context = new DefaultContext("Data Source=./blogging1.db"))
{// 使用 context}
以上实例代码中 using 的含义是声明一个 context 作用于两个大括号之间,当两个大括号之间的代码执行完成后,会自动调用 context.Dispose() 方法。
using 关键字的机制不会因为中途返回而不执行 context.Dispose(),也不会因为中间被抛出异常不执行。using 的使用并不局限于实现 IDisposable 接口的对象,其他的对象也可以使用。
3. EF Core 的数据库访问插件
微软为 SQLite 和 SQL Server 提供了默认的数据库连接程序,其中 SQLite 的是:
Microsoft.EntityFrameworkCore.Sqlite
SQL Server 是:
Microsoft.EntityFrameworkCore.SqlServer
其他的常用数据库都是由三方提供,以下是一些常见的连接程序包和数据库名称:
NuGet 程序包 | 支持的数据库引擎 | 维护商 / 供应商 |
---|---|---|
Npgsql.EntityFrameworkCore.PostgreSQL | postgresql | Npgsql 开发团队 |
Pomelo.EntityFrameworkCore.MySql | MySQL、MariaDB | Pomelo Foundation 项目 |
Devart.Data.MySql.EFCore | MySQL 5 及以上版本 | DevArt |
Devart.Data.Oracle.EFCore | Oracle DB 9.2.0.4 及更高版本 | DevArt |
Devart.Data.PostgreSql.EFCore | PostgreSQL 8.0 及以上版本 | DevArt |
Oracle.EntityFrameworkCore | Oracle DB 11.2 及更高版本 | Oracle |
4. EF Core 的配件
在 EF 4 的年代,EF 本身不支持对批量数据的支持。后续慢慢增加了对数组的处理,包括增删。
但是随着时代的发展,数据量越来越大。所以仅仅是数组不能满足实际需求了。
现在给大家推荐一个插件:
Z.EntityFramework.Plus.EFCore
这个插件可以扩展 DbContext 的功能,使其支持对查询结果的操作:
var ctx = new DbContext();
var date = DateTime.Now.AddYears(-2);
ctx.Users.Where(x => x.LastLoginDate < date)
.Delete();
// DELETE using a BatchSize
var date = DateTime.Now.AddYears(-2);
ctx.Users.Where(x => x.LastLoginDate < date)
.Delete(x => x.BatchSize = 1000);
当然,还有更多的特点,以后在 ASP.NET Core 篇再为大家介绍。
5. 后续
EF Core 到目前为止已经结束了,下一篇将开始探索一下 Nhibernate 或者 Dapper 吧。OK,C# 的数据访问篇里的大头基本完成了。
下一个系列,小伙伴们打算看什么?预计是开始 ASP.NET Core 系列了。
更多内容烦请关注我的博客《高先生小屋》