Zack.EFCore.Batch是一個(gè)支持在Entity Framework Core中高效刪除和更新數(shù)據(jù)的開源庫。我們知道，EF Core中不支持高效的刪除和更新數(shù)據(jù)，所有的更新和操作都是逐條數(shù)據(jù)處理。比如，如果使用如下的語句刪除實(shí)現(xiàn)“刪除所有價(jià)格大于10元的書“：

ctx.RemoveRange(ctx.Books.Where(b=> b.Price > 33))

那么，EntityFramework Core會先執(zhí)行Select * from books where price>33，然后再對于每一條數(shù)據(jù)執(zhí)行delete from books where id=@id進(jìn)行刪除。EF Core中批量數(shù)據(jù)的更新原理也是類似。因此在EF Core中進(jìn)行大量數(shù)據(jù)的批量刪除、更新效率是比較低的。

為了能夠?qū)崿F(xiàn) “一句SQL實(shí)現(xiàn)數(shù)據(jù)的刪除、更新“，我開發(fā)了開源項(xiàng)目Zack.EFCore.Batch，這個(gè)開源項(xiàng)目實(shí)現(xiàn)了如下批量刪除的寫法：

await ctx.DeleteRangeAsync<Book>(b => b.Price > n || b.AuthorName =="zack yang");

?上面的C#代碼就會執(zhí)行如下的SQL語句，從而實(shí)現(xiàn)“一句SQL刪除數(shù)據(jù)“的效果：

Delete FROM[T_Books] WHERE ([Price] > @__p_0) OR ([AuthorName] = @__s_1)

? 這個(gè)開源項(xiàng)目使用EF Core實(shí)現(xiàn)SQL語句的翻譯，因此只要EF Core支持的數(shù)據(jù)庫，對應(yīng)的Linq操作都可以實(shí)現(xiàn)翻譯成對應(yīng)的方言SQL，比如下面的批量更新操作的Linq代碼：

await ctx.BatchUpdate<Book>().Set(b => b.Price, b => b.Price + 3).Set(b => b.Title, b => s).Set(b =>b.AuthorName,b=>b.Title.Substring(3,2)+b.AuthorName.ToUpper()).Set(b => b.PubTime, b => DateTime.Now).Where(b => b.Id > n || b.AuthorName.StartsWith("Zack")) .ExecuteAsync();

?在SQL Server數(shù)據(jù)庫下就會翻譯成一條Update語句，如下：

Update [T_Books]SET [Price] = [Price] + 3.0E0, [Title] = @__s_1, [AuthorName] =COALESCE(SUBSTRING([Title], 3 + 1, 2), N'') + COALESCE(UPPER([AuthorName]),N''), [PubTime] = GETDATE() WHERE ([Id] >@__p_0) OR ([AuthorName] IS NOT NULL AND ([AuthorName] LIKE N'Zack%'))

?經(jīng)歷用戶幾個(gè)月的使用和反饋issue，目前項(xiàng)目已經(jīng)升級到1.4.3版，支持SQLServer、MySQL、PostgreSQL、Oracle、SQLite數(shù)據(jù)庫。理論上來講，只要EF Core支持的數(shù)據(jù)庫，Zack.EFCore.Batch都可以支持。如果您有其他數(shù)據(jù)庫需要支持，請和我聯(lián)系。

除了已有的特性之外，Zack.EFCore.Batch新版增加了如下特性。

?

特性一、基于實(shí)體關(guān)系的數(shù)據(jù)過濾

? ? 在過濾條件中支持實(shí)體之間的關(guān)系。例如：

ctx. DeleteRangeAsync<Article>(a=>a.Comments.Any(c=>c.Message.Contains(“History”)) ||a.Author.BirthDay.Year<2000);

?特性二、支持?jǐn)?shù)據(jù)的批量插入

可以用如下的方式進(jìn)行高效的批量插入：

List<Book> books = new List<Book>(); for (int i = 0; i < 100; i++) {books.Add(newBook { AuthorName = "abc" + i, Price = new Random().NextDouble(),PubTime = DateTime.Now, Title = Guid.NewGuid().ToString() }); } using (TestDbContext ctx = newTestDbContext()) {ctx.BulkInsert(books); }

?????? BulkInsert()底層使用各個(gè)數(shù)據(jù)庫的BulkCopy機(jī)制實(shí)現(xiàn)數(shù)據(jù)插入，因此插入效率非常高。目前有如下兩個(gè)缺點(diǎn)：不支持關(guān)聯(lián)數(shù)據(jù)的自動(dòng)插入，對于關(guān)聯(lián)的對象，請同樣調(diào)用BulkInsert()進(jìn)行插入；由于PostgreSQL的.NET Core Provider還沒有支持BulkCopy，所以目前Zack.EFCore.Batch暫不支持PostgreSQL，我后面再去想辦法解決。

?

特征三、支持Take()、Skip()來限制刪除和更新數(shù)據(jù)的范圍

?????? 批量刪除和批量更新都支持通過Take()、Skip()來實(shí)現(xiàn)部分刪除和部分更新，例子代碼如下：

await ctx.Comments.Where(c =>c.Article.Id == id).Skip(3) .DeleteRangeAsync<Comment>(ctx); await ctx.Comments.Where(c =>c.Article.Id == id).Skip(3).Take(10) .DeleteRangeAsync<Comment>(ctx); await ctx.Comments.Where(c =>c.Article.Id == id).Take(10) .DeleteRangeAsync<Comment>(ctx);awaitctx.BatchUpdate<Comment>().Set(c => c.Message, c => c.Message +"abc").Where(c=> c.Article.Id == id).Skip(3).ExecuteAsync();await ctx.BatchUpdate<Comment>().Set(c=> c.Message, c => c.Message + "abc").Where(c=> c.Article.Id == id).Skip(3).Take(10).ExecuteAsync(); awaitctx.BatchUpdate<Comment>().Set(c => c.Message, c => c.Message +"abc").Where(c => c.Article.Id == id).Take(10).ExecuteAsync();

?

具體用法請?jiān)L問開源項(xiàng)目地址：

https://github.com/yangzhongke/Zack.EFCore.Batch

NuGet地址：https://www.nuget.org/packages/Zack.EFCore.Batch/

總結(jié)

以上是生活随笔為你收集整理的EF Core中高效批量删除、更新数据的Zack.EFCore.Batch发布三个新特性的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。