山东建设工程招标网官方网站,seo网站推广优化公司,上海陆海建设集团网站,安徽关键词seoZack.EFCore.Batch是一个支持在Entity Framework Core中高效删除和更新数据的开源库。我们知道#xff0c;EF Core中不支持高效的删除和更新数据#xff0c;所有的更新和操作都是逐条数据处理。比如#xff0c;如果使用如下的语句删除实现“删除所有价格大于10元的书“… Zack.EFCore.Batch是一个支持在Entity Framework Core中高效删除和更新数据的开源库。我们知道EF Core中不支持高效的删除和更新数据所有的更新和操作都是逐条数据处理。比如如果使用如下的语句删除实现“删除所有价格大于10元的书“ctx.RemoveRange(ctx.Books.Where(b b.Price 33))
那么EntityFramework Core会先执行Select * from books where price33然后再对于每一条数据执行delete from books where idid进行删除。EF Core中批量数据的更新原理也是类似。因此在EF Core中进行大量数据的批量删除、更新效率是比较低的。为了能够实现 “一句SQL实现数据的删除、更新“我开发了开源项目Zack.EFCore.Batch这个开源项目实现了如下批量删除的写法await ctx.DeleteRangeAsyncBook(b b.Price n || b.AuthorName zack yang);上面的C#代码就会执行如下的SQL语句从而实现“一句SQL删除数据“的效果Delete FROM[T_Books] WHERE ([Price] __p_0) OR ([AuthorName] __s_1)这个开源项目使用EF Core实现SQL语句的翻译因此只要EF Core支持的数据库对应的Linq操作都可以实现翻译成对应的方言SQL比如下面的批量更新操作的Linq代码await ctx.BatchUpdateBook().Set(b b.Price, b b.Price 3).Set(b b.Title, b s).Set(b b.AuthorName,bb.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数据库下就会翻译成一条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 NZack%))经历用户几个月的使用和反馈issue目前项目已经升级到1.4.3版支持SQLServer、MySQL、PostgreSQL、Oracle、SQLite数据库。理论上来讲只要EF Core支持的数据库Zack.EFCore.Batch都可以支持。如果您有其他数据库需要支持请和我联系。除了已有的特性之外Zack.EFCore.Batch新版增加了如下特性。 特性一、基于实体关系的数据过滤 在过滤条件中支持实体之间的关系。例如ctx. DeleteRangeAsyncArticle(aa.Comments.Any(cc.Message.Contains(“History”))
||a.Author.BirthDay.Year2000);特性二、支持数据的批量插入可以用如下的方式进行高效的批量插入ListBook books new ListBook();
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()底层使用各个数据库的BulkCopy机制实现数据插入因此插入效率非常高。目前有如下两个缺点不支持关联数据的自动插入对于关联的对象请同样调用BulkInsert()进行插入由于PostgreSQL的.NET Core Provider还没有支持BulkCopy所以目前Zack.EFCore.Batch暂不支持PostgreSQL我后面再去想办法解决。 特征三、支持Take()、Skip()来限制删除和更新数据的范围 批量删除和批量更新都支持通过Take()、Skip()来实现部分删除和部分更新例子代码如下await ctx.Comments.Where(c c.Article.Id id).Skip(3)
.DeleteRangeAsyncComment(ctx);
await ctx.Comments.Where(c c.Article.Id id).Skip(3).Take(10)
.DeleteRangeAsyncComment(ctx);
await ctx.Comments.Where(c c.Article.Id id).Take(10)
.DeleteRangeAsyncComment(ctx);awaitctx.BatchUpdateComment().Set(c c.Message, c c.Message abc).Where(c c.Article.Id id).Skip(3).ExecuteAsync();await ctx.BatchUpdateComment().Set(c c.Message, c c.Message abc).Where(c c.Article.Id id).Skip(3).Take(10).ExecuteAsync();
awaitctx.BatchUpdateComment().Set(c c.Message, c c.Message abc).Where(c c.Article.Id id).Take(10).ExecuteAsync();具体用法请访问开源项目地址https://github.com/yangzhongke/Zack.EFCore.BatchNuGet地址https://www.nuget.org/packages/Zack.EFCore.Batch/
