利用反射将Datatable、SqlDataReader转换成List模型

public class DataTableToList<T>whereT : new () 2 3 { 4 5 /// <summary> 6 7 /// 利用反射将Datatable转换成List模型 8 9 /// </summary> 10 11 /// <param name="dt"></param> 12 13 /// <returns></returns> 14 15 public static List<T> ConvertToList(DataTabledt) 16 17 { 18 19 List<T> list =newList<T> (); 20 21 Typetype = typeof (T); 22 23 stringtempName = string .Empty; 24 25 foreach (DataRowdrindt.Rows) 26 27 { 28 29 T t = newT(); 30 31 PropertyInfo[] propertys = 32 t.GetType().GetProperties(); 33 34 foreach (PropertyInfopiinpropertys) 35 36 { 37 38 tempName = pi.Name; 39 40 if (dt.Columns.Contains(tempName)) 41 42 { 43 44 if (! pi.CanWrite) 45 46 { 47 48 continue ; 49 50 } 51 52 var value = dr[tempName]; 53 54 if (value != DBNull.Value) 55 56 { 57 58 pi.SetValue(t, value, null ); 59 60 } 61 62 } 63 64 } 65 66 list.Add(t); 67 68 } 69 70 returnlist; 71 72 } 73 74 }

 

2. SqlDataReader转IList

  1           ///   <summary> 
  2           ///   判断SqlDataReader是否存在某列
   3           ///   </summary> 
  4           ///   <param name="dr">  SqlDataReader  </param> 
  5           ///   <param name="columnName">  列名  </param> 
  6           ///   <returns></returns> 
  7           private   bool  readerExists(SqlDataReader dr,  string   columnName)
   8           {
   9  
 10              dr.GetSchemaTable().DefaultView.RowFilter =  "  ColumnName= ‘  "  + columnName +  "  ‘  "  ;
  11  
 12               return  (dr.GetSchemaTable().DefaultView.Count >  0  );
  13  
 14           }
  15  
 16           ///  <summary> 
 17           ///  利用反射和泛型将SqlDataReader转换成List模型
  18           ///  </summary> 
 19           ///  <param name="sql">  查询sql语句  </param> 
 20           ///  <returns></returns> 
 21  
 22           public  IList<T> ExecuteToList<T>( string  sql)  where  T :  new  ()
  23  
 24           {
  25              IList<T>  list;
  26  
 27              Type type =  typeof   (T);
  28  
 29               string  tempName =  string  .Empty;
  30  
 31               using  (SqlDataReader reader =  ExecuteReader(sql))
  32               {
  33                   if   (reader.HasRows)
  34                   {
  35                      list =  new  List<T> ();
  36                       while   (reader.Read())
  37                       {
  38                          T t =  new   T();
  39  
 40                          PropertyInfo[] propertys =  t.GetType().GetProperties();
  41  
 42                           foreach  (PropertyInfo pi  in   propertys)
  43                           {
  44                              tempName =  pi.Name;
  45  
 46                               if   (readerExists(reader, tempName))
  47                               {
  48                                   if  (! pi.CanWrite)
  49                                   {
  50                                       continue  ;
  51                                   }
  52                                   var  value =  reader[tempName];
  53  
 54                                   if  (value !=  DBNull.Value)
  55                                   {
  56                                      pi.SetValue(t, value,  null  );
  57                                   }
  58  
 59                               }
  60  
 61                           }
  62  
 63                           list.Add(t);
  64  
 65                       }
  66                       return   list;
  67                   }
  68               }
  69               return   null  ;
  70          }

 

3、结果集从存储过程获取

  1     ///   <summary> 
  2           ///   处理存储过程
   3           ///   </summary> 
  4           ///   <param name="spName">  存储过程名  </param> 
  5           ///   <param name="parameters">  参数数组  </param> 
  6           ///   <returns>  sql数据流  </returns> 
  7           protected   virtual  SqlDataReader ExecuteReaderSP( string   spName, ArrayList parameters)
   8           {
   9              SqlDataReader result =  null  ;
  10              cmd.CommandText =  spName;
  11              cmd.CommandType =  CommandType.StoredProcedure;
  12               cmd.Parameters.Clear();
  13               if  (parameters !=  null  )
  14               {
  15                   foreach  (SqlParameter param  in   parameters)
  16                   {
  17                       cmd.Parameters.Add(param);
  18                   }
  19               }
  20               try 
 21               {
  22                   Open();
  23                  result =  cmd.ExecuteReader(CommandBehavior.CloseConnection);
  24               }
  25               catch   (Exception e)
  26               {
  27                   if  (result !=  null  && (! result.IsClosed))
  28                   {
  29                       result.Close();
  30                   }
  31                  LogHelper.WriteLog( "  \r\n方法异常【ExecuteReaderSP(string spName, ArrayList parameters)】  "  +  spName, e);
  32                   throw   new   Exception(e.Message);
  33               }
  34               return   result;
  35          }

 

  1  <strong>      </strong>  ///  <summary> 
  2           ///  利用反射将SqlDataReader转换成List模型
   3           ///  </summary> 
  4           ///  <param name="spName">  存储过程名称  </param> 
  5           ///  <returns></returns> 
  6  
  7           public  IList<T> ExecuteQueryListSP<T>( string  spName,  params  SqlParameter[] listParams)  where  T :  new  ()
   8           {
   9              IList<T>  list;
  10  
 11              Type type =  typeof  (T);
  12  
 13               string  tempName =  string  .Empty;
  14  
 15               using  (SqlDataReader reader = ExecuteReaderSP(spName,  new   ArrayList(listParams)))
  16               {
  17                   if   (reader.HasRows)
  18                   {
  19                      list =  new  List<T> ();
  20                       while   (reader.Read())
  21                       {
  22                          T t =  new   T();
  23  
 24                          PropertyInfo[] propertys =  t.GetType().GetProperties();
  25  
 26                           foreach  (PropertyInfo pi  in   propertys)
  27                           {
  28                              tempName =  pi.Name;
  29  
 30                               //  for (int intField = 0; intField < reader.FieldCount; intField++)
  31                               //  {  //  遍历该列名是否存在
  32                               //  } 
 33  
 34                               if   (readerExists(reader, tempName))
  35                               {
  36                                   if  (! pi.CanWrite)
  37                                   {
  38                                       continue  ;
  39                                   }
  40                                   var  value =  reader[tempName];
  41  
 42                                   if  (value !=  DBNull.Value)
  43                                   {
  44                                      pi.SetValue(t, value,  null  );
  45                                   }
  46  
 47                               }
  48  
 49                           }
  50  
 51                           list.Add(t);
  52  
 53                       }
  54                       return   list;
  55                   }
  56               }
  57               return   null  ;
  58          }

 

作者：dasihg

转载：http://blog.csdn.net/dasihg/article/details/8943811

 

利用反射将Datatable、SqlDataReader转换成List模型

标签：

查看更多关于利用反射将Datatable、SqlDataReader转换成List模型的详细内容...