批量处理数据 SqlBulkCopy

  string connectionString = new PublicDBHelper().GetCon(System.Configuration.ConfigurationManager.AppSettings["constring"].ToString());

using (SqlConnection destinationConnection = new SqlConnection(connectionString))
{
destinationConnection.Open();

using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connectionString, SqlBulkCopyOptions.CheckConstraints | SqlBulkCopyOptions.FireTriggers))
{
try
{
bulkCopy.DestinationTableName = "TB_CusorderDetail";//要插入的表的表明
bulkCopy.ColumnMappings.Add("billno", "billno");//映射字段名 DataTable列名 ,数据库 对应的列名
bulkCopy.ColumnMappings.Add("billid", "billid");
bulkCopy.ColumnMappings.Add("spbm", "spbm");
bulkCopy.ColumnMappings.Add("spmc", "spmc");
bulkCopy.ColumnMappings.Add("spPrice", "spPrice");
bulkCopy.ColumnMappings.Add("spid", "spid");
bulkCopy.ColumnMappings.Add("splb", "splb");
bulkCopy.ColumnMappings.Add("splbid", "splbid");
bulkCopy.ColumnMappings.Add("sppp", "sppp");
bulkCopy.ColumnMappings.Add("spppid", "spppid");
bulkCopy.ColumnMappings.Add("ordernum", "ordernum");
bulkCopy.ColumnMappings.Add("orderPrice", "orderPrice");
bulkCopy.ColumnMappings.Add("issptz", "issptz");
bulkCopy.ColumnMappings.Add("remark", "remark");
bulkCopy.WriteToServer(tblDataDetails);
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
finally
{
// Close the SqlDataReader. The SqlBulkCopy
// object is automatically closed at the end
// of the using block.
}
}
}

实际使用过了,效果不太太好太明显

转自http://www.cnblogs.com/shikyoh/archive/2011/07/01/2095633.html