EFCore.BulkExtensions，EntityFramework-Plus??都是Microsoft推薦的EFcore擴展?。

可以通過nuget安裝

一、EFCore.BulkExtensions

使用方法如下：

實體批量操作：

context.BulkInsert(entitiesList); context.BulkInsertAsync(entitiesList);

context.BulkUpdate(entitiesList); context.BulkUpdateAsync(entitiesList);

context.BulkDelete(entitiesList); context.BulkDeleteAsync(entitiesList);

context.BulkInsertOrUpdate(entitiesList); context.BulkInsertOrUpdateAsync(entitiesList);//Upsert

context.BulkInsertOrUpdateOrDelete(entitiesList); context.BulkInsertOrUpdateOrDeleteAsync(entitiesList); //Sync

context.BulkRead(entitiesList); context.BulkReadAsync(entitiesList);

context.Truncate(); context.TruncateAsync();

按條件批量操作

//Delete

context.Items.Where(a => a.ItemId > 500).BatchDelete();

context.Items.Where(a=> a.ItemId > 500).BatchDeleteAsync();//Update (using Expression arg.) supports Increment/Decrement

context.Items.Where(a => a.ItemId <= 500).BatchUpdate(a => new Item { Quantity = a.Quantity + 100});//can be as value '+100' or as variable '+incrementStep' (int incrementStep = 100;)//Update (via simple object)

context.Items.Where(a => a.ItemId <= 500).BatchUpdate(new Item { Description = "Updated"});

context.Items.Where(a=> a.ItemId <= 500).BatchUpdateAsync(new Item { Description = "Updated"});//Update (via simple object) - requires additional Argument for setting to Property default value

var updateColumns = new List { nameof(Item.Quantity) }; //Update 'Quantity' to default value('0'-zero)

var q = context.Items.Where(a => a.ItemId <= 500);int affected = q.BatchUpdate(new Item { Description = "Updated" }, updateColumns);//result assigned to variable

當直接使用這些操作是獨立的事務和自動提交。不需要手動savechange

然后如果我們需要多個操作單一過程應該使用顯式事務。如下

using (var connection =(SqliteConnection)context.Database.GetDbConnection())

{

connection.Open();using (var transaction =connection.BeginTransaction())

{var bulkConfig = new BulkConfig() { SqliteConnection = connection, SqliteTransaction =transaction };

context.BulkInsert(entities, bulkConfig);

context.BulkInsert(subEntities, bulkConfig);

transaction.Commit();

}

}

二、EntityFramework-Plus

主要是mssql和mysql都支持

//using Z.EntityFramework.Plus;//Don't forget to include this.//DELETE all users which has been inactive for 2 years

ctx.Users.Where(x => x.LastLoginDate < DateTime.Now.AddYears(-2))

.Delete();//DELETE using a BatchSize

ctx.Users.Where(x => x.LastLoginDate < DateTime.Now.AddYears(-2))

.Delete(x=> x.BatchSize = 1000);//using Z.EntityFramework.Plus;//Don't forget to include this.//UPDATE all users which has been inactive for 2 years

ctx.Users.Where(x => x.LastLoginDate < DateTime.Now.AddYears(-2))

.Update(x=> new User() { IsSoftDeleted = 1 });

總結

以上是生活随笔為你收集整理的ef.extensions mysql_EFcore 使用 EFCore.BulkExtensions（不支持mysql）或 EntityFramework-Plus 批量增加、删除、修改...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。