C#一次性向数据库插入上万条数据的方法

一次性插入上万条数据的写法

1.

[csharp] view plaincopy

1. /// <summary>   
2.   
3. /// DataTable批量添加(有事务)   
4.   
5. /// </summary> /  
6.   
7. // <param name="Table">数据源</param>  
8.   
9.  /// <param name="Mapping">定义数据源和目标源列的关系集合</param>   
10.   
11. /// <param name="DestinationTableName">目标表</param>   
12.   
13. public static bool MySqlBulkCopy(DataTable Table, SqlBulkCopyColumnMapping[] Mapping, string DestinationTableName) {   
14.   
15. bool Bool = true;   
16.   
17. using (SqlConnection con = new SqlConnection(ConnectionString)) {   
18.   
19. con.Open();   
20.   
21. using (SqlTransaction Tran = con.BeginTransaction()) {  
22.   
23.  using (SqlBulkCopy Copy = new SqlBulkCopy(con,SqlBulkCopyOptions.KeepIdentity,Tran)) {   
24.   
25. Copy.DestinationTableName = DestinationTableName;//指定目标表   
26.   
27. if (Mapping != null) { //如果有数据   
28.   
29. foreach (SqlBulkCopyColumnMapping Map in Mapping) {   
30.   
31. Copy.ColumnMappings.Add(Map); } }   
32.   
33. try { Copy.WriteToServer(Table);//批量添加   
34.   
35. Tran.Commit();//提交事务 }   
36.   
37. catch { Tran.Rollback();  
38.   
39. //回滚事务 Bool = false; } } } }  
40.   
41.  return Bool; }  

2.MSSQL使用SqlBulkCopy,传数据源，表名，列影射，我导入150万几秒完成

[csharp] view plaincopy

1. /// <summary>  
2.   /// 使用SqlBulkCopy批量插入，只限SQLServer  
3.   /// 缺点，没有返回行数  
4.   /// </summary>  
5.   /// <param name="table">填充的DataTable,支持其它数据源，请看重载</param>  
6.   /// <param name="tableName">数据库对应表名</param>  
7.   /// <param name="columns">插入表对应的列名集合</param>  
8.   public void SqlBulkCopyInsert(DataTable table, string tableName, string[] columns)  
9.   {  
10.   SqlBulkCopy sbc = new SqlBulkCopy("接连字符串");  
11.   sbc.DestinationTableName = tableName;  
12.   foreach (string col in columns)  
13.   {  
14.   sbc.ColumnMappings.Add(col, col);  
15.   }  
16.   sbc.WriteToServer(table);  
17.   }  

3.其它数据库，将数据查到一个datatable,往table填充数据,再在adpt.Update(table)

[csharp] view plaincopy

1. /// <summary>  
2.   /// 多行插入,Connection/Command/DataAdapter看你连接的数据库类型  
3.   /// 进行相应的替换即可  
4.   /// </summary>  
5.   /// <param name="ds">填充数据后的数据集</param>  
6.   /// <returns>受影响行数</returns>  
7.   public int MultyInsert(DataSet ds)  
8.   {  
9.   int result = 0;  
10.   IDbConnection con = new OracleConnection("连接字符串");  
11.   con.Open();  
12.   IDbCommand cmd = new OracleCommand();  
13.   cmd.CommandText = "Insert into Member(UserName,Password) values(@name,@password)";  
14.   IDbDataParameter namePar = cmd.CreateParameter();  
15.   namePar.ParameterName = "@name";  
16.   namePar.SourceColumn = "UserName";  
17.   namePar.SourceVersion = DataRowVersion.Original;  
18.   namePar.DbType = DbType.String;  
19.   cmd.Parameters.Add(namePar);  
20.   IDbDataParameter passPar = cmd.CreateParameter();  
21.   passPar.ParameterName = "@pass";  
22.   passPar.DbType = DbType.String;  
23.   passPar.SourceColumn = "Password";  
24.   passPar.SourceVersion = DataRowVersion.Original;  
25.   cmd.Parameters.Add(passPar);  
26.   IDbDataAdapter adpt = new OracleDataAdapter();  
27.   adpt.InsertCommand = cmd;  
28.   try  
29.   {  
30.   result = adpt.Update(ds);  
31.   }  
32.   catch (Exception)  
33.   {  
34.   
35.   throw;  
36.   }  
37.   finally  
38.   {  
39.   con.Close();  
40.   }  
41.   return result;  
42.   }