无论是Linq To SQL还是Linq To Object(Entity frameworks)它们都为开发人员提供了Insert操作,及Insert集合操作,即InsertOnSubmit和InsertAllOnSubmit,前者是将一个实体标记为一个插入状态,而后都是将一个集合标记为插入状态,...

无论是Linq To SQL还是Linq To Object(Entity frameworks)它们都为开发人员提供了Insert操作,及Insert集合操作,即InsertOnSubmit和InsertAllOnSubmit,前者是将一个实体标记为一个插入状态,而后都是将一个集合标记为插入状态,而当前进行这两种操作时,你并没有与数据库进行连接,这就是LINQ提倡的延时加载,那它们什么时候与数据库进行真正的交互呢,实现上,实验表明,是在触发SubmitChanges方法时,才会真实与数据库进行操作,这是正常的,也没有什么可以说的。

而今天我主要说的就是,当我们进行批量插入时,用linq给我们提供的InsertAllOnSubmit方法是否可以实现我们的操作,如果实现了,那是否是我们能够接受的方式,我们在做一个实验吧

一个列表:

1
2
3
4
5
6
7
8
9
List userList=new List();
                    
 for(int i=0;i<100000;i++)
 {
   userList.Add(new User{Name="zzl"+i});
 }
 _db.InsertAllOnSubmit(userList);
                    
_db.SubmitChanges();

结果怎么样呢?经过我的观察,结果是正确的,10万条数据可以插入到数据库中,LINQ确实是帮助我们完成了列表的插入工作,但过程我们是否可以接受?

可以肯定的说,不可以,而且是非常不可以,对于这个插入操作,它对数据服务器的压力是惊人的,它建立“链接”次为10万次,即每个Insert语句就建立一个链接,这是我们不能接受的,所以,LINQ的批量操作确实靠不住。 
OK,既然LINQ的方式是不可取的,那我们只好自己去动手写了,呵呵,我们的思想去将10条Insert合并在一起,一次性发给服务器,一次性执行,对于目前的网络带宽这10条数据不成问题,呵呵。

一 单个实体的Insert,我们采用LINQ的延时插入方式:

1
2
3
4
5
public virtual void Insert(TEntity entity) where TEntity : class
       {
          DB.GetTable().InsertOnSubmit(entity);
           this.SubmitChanges();
      }

二 批量插入实体,我们采用拼接字符串,并向数据服务器发命令的方式,这个也是我比较满足的作品,它是一个通用的方式,并且不需要修改原来插入代码,它的

方法签名是一个列表,这样做是正确的,对于程序员来说是非常友好的。

先看之前的LINQ批量插入:

public virtual void Insert(IEnumerable list) where TEntity : class 
       { 
           DB.GetTable().InsertAllOnSubmit(list); 
           this.SubmitChanges(); 
       } 
而在我们修改后,方法签名是不变的,所以原来调用它的方法,不需要进行修改:

1         ///

2         /// ADO优化的批量添加 
3         ///

4         ///

5         ///

6         public virtual void Insert

(IEnumerable list) where TEntity : class 
7         { 
8             this.InsertForADO(list); 
9         } 
所需要的辅助方法:

1 #region LINQ调用T-SQL实现批量添加 
2         ///
3         /// 得到数据库表或视图的抽象 
4         ///
5         /// 
6         /// 
7         MetaTable GetMetaTable(Type rowType) 
8         { 
9             return DB.Mapping.GetTable(rowType); 
10         } 
11 
12         ///
13         /// 建立SQL语句 
14         ///
15         /// 
16         /// 
17         Tuple<string,> CreateInsertArguments(TEntity entity) 
18         { 
19             if (entity == null) 
20                 throw new ArgumentException("The database entity can not be null."); 
21 
22             Type entityType = entity.GetType(); 
23             MetaTable table = GetMetaTable(entityType); 
24             MetaDataMember identityDatamember = table.RowType.DBGeneratedIdentityMember; 
25 
26             List arguments = new List(); 
27             StringBuilder fieldbuilder = new StringBuilder(); 
28             StringBuilder valuebuilder = new StringBuilder(); 
29 
30             fieldbuilder.Append("INSERT INTO " + table.TableName + " ("); 
31 
32             foreach (var member in table.RowType.PersistentDataMembers) 
33             { 
34 
35                 if (!member.IsAssociation && !member.IsDbGenerated) 
36                 { 
37                     object value = entityType.GetProperty(member.Name).GetValue(entity, null); 
38                     if (value != null) 
39                     { 
40                         if (arguments.Count != 0) 
41                         { 
42                             fieldbuilder.Append(", "); 
43                             valuebuilder.Append(", "); 
44                         } 
45 
46                         fieldbuilder.Append(member.MappedName); 
47                         if (member.Type == typeof(string) || member.Type == typeof(DateTime)) 
48                             valuebuilder.Append("'{" + arguments.Count + "}'"); 
49                         else 
50                             valuebuilder.Append("{" + arguments.Count + "}"); 
51                         if (value.GetType() == typeof(string)) 
52                             value = value.ToString().Replace("'", "char(39)"); 
53                         arguments.Add(value); 
54 
55                     } 
56                 } 
57             } 
58 
59 
60             fieldbuilder.Append(") Values ("); 
61 
62             fieldbuilder.Append(valuebuilder.ToString()); 
63             fieldbuilder.Append(");"); 
64             return new Tuple<string,>(fieldbuilder.ToString(), arguments.ToArray()); 
65         } 
66 
67         void InsertForADO(IEnumerable list) 
68         { 
69             StringBuilder sqlstr = new StringBuilder(); 
70             list.ToList().ForEach(i =>
71             { 
72                 Tuple<string,> insert = CreateInsertArguments(i); 
73                 sqlstr.AppendFormat(insert.Item1, insert.Item2); 
74             }); 
75             DB.ExecuteCommand(sqlstr.ToString()); 
76         } 
77 
78         #endregion

最新文章

  1. 去掉IE11的叉叉
  2. .NET 多个程序配置文件合并到主app.config
  3. R语言入门系列1--数学狗还是做数据好了
  4. mysql主从切换
  5. 利用windbg查找dictionary导致IIS占CPU100%案例分析(一)
  6. 【POJ】2406 Power Strings
  7. [ios][swift]swift GPS传感器的调用
  8. C#实现union以及lock的使用
  9. Some thoughts on a progress
  10. 软件工程 speedsnail 冲刺3
  11. web sevice 生成代理类及使用
  12. exercise.tour.go google的go官方教程答案
  13. 用hdfs存储海量的视频数据的设计思路
  14. C语言中的结构体和C++中的结构体以及C++中类的区别
  15. mysql 练习题
  16. [cb]SceneView 获取鼠标位置
  17. django 高级
  18. Redis常用指令
  19. hihocoder1711 评论框排版[并查集+set]
  20. insert-delete-getrandom-o1-duplicates-allowed

热门文章

  1. A*算法——第K短路
  2. String类型_static成员_动态内存分配_拷贝构造函数_const关键字_友元函数与友元类
  3. win10系统,vbox下安装centos6/7,挂载实现目录共享
  4. escape encodeURI和encodeURIComponent的区别
  5. webstorm中使用git管理服务器上的代码——入门级
  6. Linux 静态IP配置
  7. linux下安装rabbitmq 集群
  8. java后台对上传的图片进行压缩
  9. 转载 ASP.NET SignalR 与LayIM配合,轻松实现网站客服聊天室(一) 整理基础数据
  10. LRU Cache数据结构简介