EF中的那些批量操作

在使用EF的过程中，我们经常会遇到需要批量操作数据的场景，批量操作有的时候不仅能提高性能，比如使用SqlBulkCopy进入批量插入的时候，而且比较方便操作，提高效率。那么这篇文章就来总结EF中的那些批量操作。

插入

1，单个插入

单个插入很简单，只需要构造好实体，然后调用DbSet的Add方法，最后SaveChanges就行，示例代码如下。

using (var db = new PackageFHContext())
{ // 单个插入 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，批量插入

很多时候我们需要向同一数据表插入大量的数据，如果插入一条就调一次SaveChanges这样性能很低，需要频繁地访问数据库。为了解决这个问题，可以使用SqlBulkCopy来批量插入数据，这样很大地提高性能。示例代码如下。

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(); }
}

当然SqlBulkCopy的操作封装在了DBHelper中了，后面会附上DBHelper.BulkInsert的实现。

更新

1，单个更新

单个更新很简单，只需要先查询出那条数据，然后修改字段的值，最后SaveChanges就行。示例代码如下。

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

2，批量更新

我们可以先查找要更新的那些记录，然后遍历修改字段的值，最后调用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();
}

通过SQL Profiler监控可以看到，最后生成的还是很多的UPDATE语句，也就是说每更新一条就是一个UPDATE语句。

删除

1，单个删除

示例代码如下。

using (var db = new PackageFHContext())
{// 单个删除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();
}

通过SQL Profiler监控，结果生成的也是多条DELETE语句。

附：DBHelper.BulkInsert的实现代码

 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

转载于:https://www.cnblogs.com/mcgrady/p/4355282.html

EF中的那些批量操作相关推荐

[转载]EF中的那些批量操作
阅读目录插入更新删除在使用EF的过程中,我们经常会遇到需要批量操作数据的场景,批量操作有的时候不仅能提高性能,比如使用SqlBulkCopy进入批量插入的时候,而且比较方便操作,提高效率.那么 ...
关于EF中ApplyCurrentValues和ApplyOriginalValues区别
关于EF中ApplyCurrentValues和ApplyOriginalValues区别:两者都是编辑数据时使用. // // 摘要: // 将 System ...
数据库在EF中创建模型
数据库在EF中创建模型,最简单的理解就是把数据库的字段以及关系映射到项目中,在项目中通过EF框架和LINQ语句直接对数据库数据进行增删改查.下边手把手教你建立模型. 1.建立一个项目,添加新项目,选择 ...
在EF中使用SQL执行简单高效的增删查操作
随着平台数据的积累,对于数据访问的速度要求愈来愈高.优化后台访问性能,将是之后的一个重点任务. 但是,后台在项目开发初期采用的是Abp(Lite DDD)框架,集成EnityFramework.因为之 ...
EF中加载实体的方式
EF中的查询执行时机: 1. foreach进行枚举 2. ToArray.ToList.ToDictionary 3. Linq的一些操作,如First.Any 4. DbSet上的Load操作.D ...
EF中三大开发模式之DB First,Model First,Code First以及在Production Environment中的抉择
一:ef中的三种开发方式 1. db first... db放在第一位,在我们开发之前必须要有完整的database,实际开发中用到最多的... <1> DBset集合的单复数... db ...
CodeFirst EF中导航属性的个人理解
>导航属性: 01.个人理解就是Ef中的属性在实体数据表中不存在(先这么认为); 02.就是除了根据表中列映射出的属性之外根据表与表之间的关系的关联属性.方便操作与之关联的表; 例如: 有表 ...
EF框架学习（5）---EF中的在线和离线场景
EF中的持久性场景使用EF实现实体持久化(保存)到数据库有两种情况:在线场景和离线场景. 1.在线场景在线场景中,context是同一个上下文实例(从DbContext派生),检索和保存实体都通过 ...
mvc+ef中比较数据
例如:根据Para表中的type和paraid 字段进行比较 public class TypeComparer : IEqualityComparer<Para> { bool IEqu ...

EF中的那些批量操作

插入

更新

删除

EF中的那些批量操作相关推荐

最新文章

热门文章