EF架构~性能高效的批量操作(Update篇）

回到目录

很多时间之长，我写了EF架构~性能高效的批量操作(Insert篇），而今天我把Update篇也写一下，这对于批量处理数据很有帮助，它解决了EF与linq to sql批量更新数据上的效率问题。

对于EF架构中的批量更新操作，需要我们为实体的导航属性进行手动的标示，因为EF生成的实体中没有一个特殊的说明，所以，我们必须要告诉系统，哪个属性是导航属性，而导航属性是我们不去进行update的。

1    /// 
2     /// 属性的导航属性
3     /// 
4     public class NavigationAttribute : Attribute
5     {
6 
7     }

而对于要进行批量更新的实体，我们需要为导航属性添加这个特性

1    public class User
2     {
3         public int UserID { get; set; }
4         [Navigation]
5         public User_Extension User_Extension { get; set; }
6     }

而对于我们构建批量Update语句，请看代码，它需要对导航属性进行过滤

 1         /// 
 2         /// 构建Update语句串
 3         /// 
 4         /// 
 5         /// 
 6         /// 
 7         private Tuple CreateUpdateSQL(TEntity entity) where TEntity : class
 8         {
 9             if (entity == null)
10                 throw new ArgumentException("The database entity can not be null.");
11             List pkList = GetPrimaryKey().Select(i => i.Name).ToList();
12 
13             Type entityType = entity.GetType();
14             var table = entityType.GetProperties().Where(i =>
15                 !pkList.Contains(i.Name)
16                 && i.GetValue(entity, null) != null
17                 && i.PropertyType != typeof(EntityState)
18                 && !(i.GetCustomAttributes(false).Length > 0
19                 && i.GetCustomAttributes(false).Where(j => j.GetType() == typeof(NavigationAttribute)) != null)
20                 && (i.PropertyType.IsValueType || i.PropertyType == typeof(string)) //过滤导航属性
21                  ).ToArray();
22 
23             //过滤主键，航行属性，状态属性等
24             if (pkList == null || pkList.Count == 0)
25                 throw new ArgumentException("The Table entity have not a primary key.");
26             List arguments = new List();
27             StringBuilder builder = new StringBuilder();
28 
29             foreach (var change in table)
30             {
31                 if (pkList.Contains(change.Name))
32                     continue;
33                 if (arguments.Count != 0)
34                     builder.Append(", ");
35                 builder.Append(change.Name + " = {" + arguments.Count + "}");
36                 if (change.PropertyType == typeof(string) || change.PropertyType == typeof(DateTime))
37                     arguments.Add("'" + change.GetValue(entity, null).ToString().Replace("'", "char(39)") + "'");
38                 else
39                     arguments.Add(change.GetValue(entity, null));
40             }
41 
42             if (builder.Length == 0)
43                 throw new Exception("没有任何属性进行更新");
44 
45             builder.Insert(0, " UPDATE " + string.Format("[{0}]", entityType.Name) + " SET ");
46 
47             builder.Append(" WHERE ");
48             bool firstPrimaryKey = true;
49 
50             foreach (var primaryField in pkList)
51             {
52                 if (firstPrimaryKey)
53                     firstPrimaryKey = false;
54                 else
55                     builder.Append(" AND ");
56 
57                 object val = entityType.GetProperty(primaryField).GetValue(entity, null);
58                 builder.Append(GetEqualStatment(primaryField, arguments.Count));
59                 arguments.Add(val);
60             }
61             return new Tuple(builder.ToString(), arguments.ToArray());
62 
63         }


而对子类公开的Update方法，我们进行了一个封装，它通过操作枚举来确实你是要insert,update还是delete，看代码



 1         /// 
 2         /// 执行ＳＱＬ，根据ＳＱＬ操作的类型
 3         /// 
 4         /// 
 5         /// 
 6         /// 
 7         /// 
 8         protected string DoSQL(IEnumerable list, SQLType sqlType) where TEntity : class
 9         {
10             StringBuilder sqlstr = new StringBuilder();
11             switch (sqlType)
12             {
13                 case SQLType.Insert:
14                     list.ToList().ForEach(i =>
15                     {
16                         Tuple sql = CreateInsertSQL(i);
17                         sqlstr.AppendFormat(sql.Item1, sql.Item2);
18                     });
19                     break;
20                 case SQLType.Update:
21                     list.ToList().ForEach(i =>
22                     {
23                         Tuple sql = CreateUpdateSQL(i);
24                         sqlstr.AppendFormat(sql.Item1, sql.Item2);
25                     });
26                     break;
27                 case SQLType.Delete:
28                     list.ToList().ForEach(i =>
29                     {
30                         Tuple sql = CreateDeleteSQL(i);
31                         sqlstr.AppendFormat(sql.Item1, sql.Item2);
32                     });
33                     break;
34                 default:
35                     throw new ArgumentException("请输入正确的参数");
36             }
37             return sqlstr.ToString();
38         }



回到目录



 

 




Mathilda91
0

  • lee576的专栏
 3万+



在网上找了很久,得到的答案是”Entity Framework 中不能同时更新多条记录”,历经这么多版本,居然还没有这种基本功能,我真的很无语了.还
 
转 https://blog.csdn.net/weixin_33767813/article/details/85534978
						  
					  
						
							
    

						
    
							
							
			ef							
						



						
    
						
						
    

						

						
					
					
    
					
					
    
						
    相关
    
						

    				
						
			
    
																
								
    
										
    cefSharp通过js操控页面，含跨域操控
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    swoole 报错  SWOOLE_LIBRARY already defined
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    MySQL left join、right join和join的区别
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    EF通过导航属性取出从表的集合后，无法删除子表
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    FireflySoft.LeaderElection增加基于ZooKeeper的Leader选举
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    python的WeakKeyDictionary类和weakref模块的其他函数
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    WEBAPI ScopeFilter执行顺序以及OverrideActionFilters
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    CefSharp基于.Net Framework 4.0 框架编译
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    makefile基本语法
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    PHP高级特性-反射Reflection以及Factory工厂设计模式的结合使用[代码实例]
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    大爽Python入门教程 4-3 函数传参 形参、实参 default、*args、**kwargs
    
									
									
    
								 

        
    
								
    
							
							
    
																
								
    
										
    EfficientNetV2: Smaller Models and Faster Training
    
									
									
    
								 

        
    
								
    
							
							
                
            
            
                                    
           
  			
						

					
    
					
				

				
    
														
					
					

					
									
    
					
									   
    标签
    
										
    
										
      
										
    
									

										
										
    
									
    
					

					
				
    

			
		
		
		
			


						
    

    

    
	
    
	
    一品网 冀ICP备14022925号-6