在线程中用 OracleBulkCopy 导至 CPU 百分百

 1         private void BulkCopy(string connStr, DataTable dt, string tblName) { 
 2             if (dt.Rows.Count > 0) { 
 3                 using (var bc = new OracleBulkCopy(connStr)) { 
 4                     bc.DestinationTableName = tblName; 
 5                     foreach (DataColumn col in dt.Columns) { 
 6                         bc.ColumnMappings.Add(col.ColumnName, col.ColumnName); 
 7                     } 
 8                     bc.WriteToServer(dt); 
 9                 } 
10             } 
11         }

 1        /// <summary> 
 2         /// 将 List 转换为 DataTable, 只针对 T 中 的 public Property 
 3         /// </summary> 
 4         /// <typeparam name="T"></typeparam> 
 5         /// <param name="list"></param> 
 6         public static DataTable ToDataTable<T>(this List<T> list) where T : class { 
 7             if (list == null) 
 8                 return null; 
 9 
10 
11             Type type = typeof(T); 
12             var ps = type.GetProperties().Where(p => p.CanWrite && (p.PropertyType.IsValueType || p.PropertyType.IsPrimitive || p.PropertyType == typeof(String))); 
13             Type targetType; 
14             NullableConverter nullableConvert; 
15             List<DataColumn> cols = new List<DataColumn>(); 
16             foreach (var p in ps) { 
17                 if (p.PropertyType.IsGenericType && p.PropertyType.GetGenericTypeDefinition().Equals(typeof(Nullable<>))) { 
18                     nullableConvert = new NullableConverter(p.PropertyType); 
19                     targetType = nullableConvert.UnderlyingType; 
20                     cols.Add(new DataColumn(p.Name, targetType)); 
21                 } else { 
22                     cols.Add(new DataColumn(p.Name, p.PropertyType)); 
23                 } 
24             } 
25 
26 
27             DataTable dt = new DataTable(); 
28             dt.Columns.AddRange(cols.ToArray()); 
29 
30 
31             list.ForEach((l) => { 
32                 List<object> objs = new List<object>(); 
33                 objs.AddRange(ps.Select(p => p.GetValue(l, null))); 
34                 dt.Rows.Add(objs.ToArray()); 
35             }); 
36 
37 
38             return dt; 
39         }