在使用EF的過(guò)程中，我們經(jīng)常會(huì)遇到需要批量操作數(shù)據(jù)的場(chǎng)景，批量操作有的時(shí)候不僅能提高性能，比如使用SqlBulkCopy進(jìn)入批量插入的時(shí)候，而且比較方便操作，提高效率。那么這篇文章就來(lái)總結(jié)EF中的那些批量操作。

插入

1，單個(gè)插入

單個(gè)插入很簡(jiǎn)單，只需要構(gòu)造好實(shí)體，然后調(diào)用DbSet的Add方法，最后SaveChanges就行，示例代碼如下。

using (var db = new PackageFHContext()) { // 單個(gè)插入 var entity = new ProdImage { ProductID = 1807, Type = 7, Priority = 0, Url = " http://www.baidu.com/abc.png", Alt = "test", Creator = "system", CreateOn = DateTime.Now }; db.ProdImageSet.Add(entity); db.SaveChanges(); }

2，批量插入

很多時(shí)候我們需要向同一數(shù)據(jù)表插入大量的數(shù)據(jù)，如果插入一條就調(diào)一次SaveChanges這樣性能很低，需要頻繁地訪問(wèn)數(shù)據(jù)庫(kù)。為了解決這個(gè)問(wèn)題，可以使用SqlBulkCopy來(lái)批量插入數(shù)據(jù)，這樣很大地提高性能。示例代碼如下。

using (var db = new PackageFHContext()) { // 批量插入(使用到SqlBulkCopy) var prodImages = new List<ProdImage>(); for (int i = 0; i < 50; i++) { prodImages.Add(new ProdImage { ProductID = 1807, Type = 7, Priority = 0, Url = " http://www.baidu.com/abc.png", Alt = "test" + i, Creator = "system", CreateOn = DateTime.Now }); } if (db.Database.Connection.State != ConnectionState.Open) { db.Database.Connection.Open(); } PackageFH.Common.DBHelper.BulkInsert((SqlConnection)db.Database.Connection, "dbo.Pkg_ProdImage", prodImages); if (db.Database.Connection.State != ConnectionState.Closed) { db.Database.Connection.Close(); } }

當(dāng)然SqlBulkCopy的操作封裝在了DBHelper中了，后面會(huì)附上DBHelper.BulkInsert的實(shí)現(xiàn)。

更新

1，單個(gè)更新

單個(gè)更新很簡(jiǎn)單，只需要先查詢出那條數(shù)據(jù)，然后修改字段的值，最后SaveChanges就行。示例代碼如下。

using (var db = new PackageFHContext()) {// 單個(gè)更新var entity = db.ProdImageSet.FirstOrDefault(p => p.ImageID == 275695);entity.Alt = "ooooooooooo";db.SaveChanges(); }

2，批量更新

我們可以先查找要更新的那些記錄，然后遍歷修改字段的值，最后調(diào)用SaveChanges提交更新。示例代碼如下。

using (var db = new PackageFHContext()) {// 批量更新var entitys = db.ProdImageSet.Where(p => p.ProductID == 1807 && p.Type == 7);var j = 1;entitys.ToList().ForEach(item =>{item.Alt = "update test" + j;db.Entry(item).State = System.Data.Entity.EntityState.Modified; //不加這句也可以，為什么？j++;});db.SaveChanges(); }

通過(guò)SQL Profiler監(jiān)控可以看到，最后生成的還是很多的UPDATE語(yǔ)句，也就是說(shuō)每更新一條就是一個(gè)UPDATE語(yǔ)句。

刪除

1，單個(gè)刪除

示例代碼如下。

using (var db = new PackageFHContext()) {// 單個(gè)刪除var entity = db.ProdImageSet.FirstOrDefault(p => p.ImageID == 275695);db.ProdImageSet.Remove(entity);db.SaveChanges(); }

2，批量刪除

示例代碼如下。

using (var db = new PackageFHContext()) {// 批量刪除var entitys = db.ProdImageSet.Where(p => p.ProductID == 1783 && p.Type == 0);entitys.ToList().ForEach(entity => db.Entry(entity).State = System.Data.Entity.EntityState.Deleted); //不加這句也可以，為什么？ db.ProdImageSet.RemoveRange(entitys);db.SaveChanges(); }

通過(guò)SQL Profiler監(jiān)控，結(jié)果生成的也是多條DELETE語(yǔ)句。

附：DBHelper.BulkInsert的實(shí)現(xiàn)代碼

1 public static void BulkInsert<T>(SqlConnection conn, string tableName, IList<T> list) 2 { 3 using (var bulkCopy = new SqlBulkCopy(conn)) 4 { 5 bulkCopy.BatchSize = list.Count; 6 bulkCopy.DestinationTableName = tableName; 7 8 var table = new DataTable(); 9 var props = TypeDescriptor.GetProperties(typeof(T), new Attribute[] { new DatabaseTableColumnAttribute() }) 10 //Dirty hack to make sure we only have system data types 11 //i.e. filter out the relationships/collections 12 .Cast<PropertyDescriptor>() 13 .Where(propertyInfo => propertyInfo.PropertyType.Namespace.Equals("System")) 14 .ToArray(); 15 16 foreach (var propertyInfo in props) 17 { 18 bulkCopy.ColumnMappings.Add(propertyInfo.Name, propertyInfo.Name); 19 table.Columns.Add(propertyInfo.Name, Nullable.GetUnderlyingType(propertyInfo.PropertyType) ?? propertyInfo.PropertyType); 20 } 21 22 var values = new object[props.Length]; 23 foreach (var item in list) 24 { 25 for (var i = 0; i < values.Length; i++) 26 { 27 values[i] = props[i].GetValue(item); 28 } 29 30 table.Rows.Add(values); 31 } 32 33 bulkCopy.WriteToServer(table); 34 } 35 } View Code

轉(zhuǎn)載于:https://www.cnblogs.com/mcgrady/p/4355282.html

總結(jié)

以上是生活随笔為你收集整理的EF中的那些批量操作的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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