查缺补漏系统学习 EF Core 6 - 批量操作

这是 EF Core 系列的第六篇文章,上一篇文章讲述了 EF Core 中的实体数据修改。

这篇文章讲一讲 EF Core 如何进行批量操作。

在众多的 ORM 框架中,EF Core 的功能并不是最强大的那个,性能可能也不是最好的那个。但却一直是最稳定、最安全,扩展能力最强、使用人数最多的那个。.

虽然在性能方面,在 EF Core 6.0 中已经得到了非常大的提升。

但是在功能方面, EF Core 一直有一个不完善的地方,就是它不能很好的支持数据的批量操作,也就是批量删除和批量更新。

所以这篇文章就先从比较常用的批量删除和批量更新讲起。

批量操作

在 EF Core 中批量更新和删除数据,都需要先进行查询,把数据加载到内存中,然后再对数据操作,最后再SaveChanges 保存到数据库。

我们来看这个示例:

var accounts = _context.Accounts.Where(account => account.Age >= 1);

foreach (var a in accounts)
{
    a.Age = a.Age + 1;
}

_context.SaveChanges();

为了更新 Accounts 中实体的 Age 属性,我们必须查询出所有符合条件的实体集合,然后用遍历的方式,在内存中去逐个修改实体的 Age 属性。

最后,通过 SaveChanges 方法保存修改。

运行程序,结果如下图所示:

查缺补漏系统学习 EF Core 6 - 批量操作

通过控制台日志可以发现,前后总共执行了 3 条 SQL 语句,1 条 Selet 语句和 2 条 Uptete 语句。

第一条 Selet 语句,是为了查询出所有符合条件的数据,由于数据库中只有 2 条数据,所以后面 2 条 Uptete 语句,是针对这 2 条数据的更新操作。

如果我们把更新操作换成删除操作,EF Core 也会如此去做。

大家可以想象一下,如果批量更新或者删除的数据量比较大,那么这样的操作,性能无疑是非常底下的。

因此,我们需要一种在 EF Core 中,只使用一条 SQL 语句,就可以批量删除或更新数据的方法。

由于这个功能确实比较常用,很多其它第三方的 ORM 框架,几乎也都支持这个操作。

但为什么作为 ORM 框架大佬的 EF Core,却不提供这个功能呢?

简单来说,EF Core 的开发团队认为,这样做会导致 EF Core 的对象状态跟踪混乱。

比如对于同一个上下文类,如果用批量删除的方法删除了数据,那么在被删除之前,查询出来的数据状态就混乱了。

毕竟,EF Core 是一个成熟且安全性高的 ORM 框架,必然会考虑潜在风险的存在。

如果想要完美实现,可能需要重构 EF Core 的代码,工作量方面会比较大。

但是,我们作为开发者,完全可以根据场景需求,来规避这些问题的存在。

比如在一个 Web 应用中,删除操作通常都是在一个 HTTP 请求中完成的,不同的 HTTP 请求上下文是不同的,所以基本不会涉及到 EF Core 开发团队担心的问题。

即便在某些特殊场景下,涉及到在同一个上下文里,数据删除之前就把数据查询出来的场景,那也完全可以通过在删除之后,再重新查询一次的方式,来规避这个问题。

未来 EF Core 会不会添加这个功能,我们不得而知,但我们也有自己的解决方法。

第一个解决方法,就是执行原生 SQL 语句,不过它的缺点我们在前面的文章中已经提过,就不再多说。

第二个解决方法,是使用第三方的 ORM 框架,比如 FreeSQL、SugarSQL,它们都提供了批量更新和批量删除的功能,使用起来也非常简单。

不过,这种方法的缺点就是必须在项目替换掉 EF Core ,使用第三方的 ORM 框架。

目前 EF Core 是 .NET 中,使用率最高的 ORM 框架,主打安全性与稳定性,而且 6.0 版本性能也得到了大量的改善,所以不建议轻易更换。

第三个解决方法,就是使用 EF Core 的扩展插件,由于 EF Core 在全球范围有着最多的用户基数,所以也形成了一个强大的生态环境,拥有很多的第三方扩展。

这同样也是第三方 ORM 框架,所无法比拟的地方。

我们可以在 EF Core 的官方文档,查阅到被官方收集的第三方扩展插件和工具。

这里面支持批量操作的扩展插件有两个:「EFCore.BulkExtensions」 和 「Entity Framework Plus」

它们都支持最新的 EF Core,更新也比较稳定。

不同的是,E「FCore.BulkExtensions」 功能专一,仅扩展了批量操作方面的功能,同时也支持 「SqlBulkCopy」,也就是大数据量的批操作。

由于 「SqlBulkCopy」 只支持 SQLServer 和 SQLite ,所以 「EFCore.BulkExtensions」 只支持 SQLServer 和 SQLite。

「EF Plus」 功能更加强大,扩展了更多的查询功能,它分为免费版和收费版,基础的批量操作免费版就可以支持,高级批量操作以及 SqlBulkCopy 则只有收费版支持。

如果使用的是 MySQL,或者不需要 SqlBulkCopy,那么 「EF Plus 免费版」是首选,因为它支持更多的数据库,扩展了更丰富的查询功能。

安装好 EF Plus,这里我将刚才批量更新的操作,改为 EF Plus 来实现:

<PackageReference Include="Z.EntityFramework.Plus.EFCore" Version="6.13.19" />
_context.Accounts
    .Where(account => account.Age >= 1)
    .Update(account => new Account {Age = account.Age + 1},
            update => update.Executing = command => Console.WriteLine(command.CommandText));

Update 就是 EF Plus 扩展的方法,它的第一个参数是要更新的数据,第二个参数是一个执行拦截器委托,这里用来打印准备执行的 SQL 语句。

现在运行程序,可以在控制台中看到:

查缺补漏系统学习 EF Core 6 - 批量操作

执行的是 1 条 UPDATE 语句,这条 SQL 语句会更新所有 Accounts 中符合条件的 Age 字段。

除了批量更新,批量删除也同样简单。

更多的示例,大家可以看 EF Plus 的官网文档。