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

Biegral 2016/1/7 15:37:34 4959

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

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.   }  
本文转载:CSDN博客

阅读排行

分类

归档