速度超快：使用SqlBulkCopy导入DataTable数据到MSSQL数据库
速度超快：使用SqlBulkCopy导入DataTable数据到MSSQL数据库
[URL=http://www.cuiwenyuan.com/shanghai/post/Import-Excel-Into-Database-via-NPOI2-In-CSharp-Web-Development.html]上篇文章[/URL]提到使用NPOI导入Excel到数据库，其实只完成了一半的工作，那就是Excel上传到服务器，然后读取到了内存的DataTable，最后面的插入数据库的操作是另一半工作。
相关的参考代码，原理就是创建一个临时表，把读取到内存的Excel数据（DataTable）使用SqlBulkCopy快速导入到数据库，然后再导入真正的业务表。在我导入13800条记录的时候，基本上10秒之内搞定，当然了最初用那个循环DataTable，然后再循环中使用Entity的方式添加，速度不知快了多少倍。
越多的业务开发，越来越感觉到吉日嘎拉的GPM平台的便利，现在基本上有一个数据维护管理类的应用，数据表根据模型建立好之后，基本上当天就能弄好。后期的工作重点要放在报表分析、复杂查询上了，因为这是用户喜欢用OA的理由之一。
<br/>#region public void SqlBulkCopyData(DataTable dt) 利用Net SqlBulkCopy 批量导入数据库,速度超快<br/> /// <summary><br/> /// 利用Net SqlBulkCopy 批量导入数据库,速度超快<br/> /// </summary><br/> /// <param name="dt">源内存数据表</param><br/> public void SqlBulkCopyData(DataTable dt)<br/> {<br/> // SQL 数据连接<br/> SqlConnection sqlConnection = null;<br/> // 打开数据库<br/> this.Open();<br/> // 获取连接<br/> sqlConnection = (SqlConnection)GetDbConnection();<br/> using (SqlTransaction tran = sqlConnection.BeginTransaction())<br/> {<br/> // 批量保存数据，只能用于Sql<br/> SqlBulkCopy sqlbulkCopy = new SqlBulkCopy(sqlConnection, SqlBulkCopyOptions.Default, tran);<br/> // 设置源表名称<br/> sqlbulkCopy.DestinationTableName = dt.TableName;<br/> // 设置超时限制<br/> sqlbulkCopy.BulkCopyTimeout = 1000;<br/><br/> foreach (DataColumn dtColumn in dt.Columns)<br/> {<br/> sqlbulkCopy.ColumnMappings.Add(dtColumn.ColumnName, dtColumn.ColumnName);<br/> }<br/> try<br/> {<br/> // 写入<br/> sqlbulkCopy.WriteToServer(dt);<br/> // 提交事务<br/> tran.Commit();<br/> }<br/> catch<br/> {<br/> tran.Rollback();<br/> sqlbulkCopy.Close();<br/> }<br/> finally<br/> {<br/> sqlbulkCopy.Close();<br/> this.Close();<br/> }<br/> }<br/> }<br/> #endregion<br/>
<br/>if (dt != null)<br/> {<br/> // 用循环把数据一行行输出到缓冲流中<br/> if (dt.Rows.Count <= 100)<br/> {<br/> for (int i = 0; i < dt.Rows.Count; i++)<br/> {<br/> PurchasePriceComparisonEntity entity = new PurchasePriceComparisonEntity();<br/> entity.BPS = dt.Rows[i]["BPS"].ToString();<br/> entity.Family = dt.Rows[i]["Family"].ToString();<br/>
entity.PartNumber = dt.Rows[i]["PartNumber"].ToString();<br/> entity.POPriceCurrentMonth = dt.Rows[i]["POPriceCurrentMonth"].ToString();<br/> entity.POPriceCurrentYear = dt.Rows[i]["POPriceCurrentYear"].ToString();<br/> entity.POPriceLastMonth = dt.Rows[i]["POPriceLastMonth"].ToString();<br/> entity.POPriceLastYear = dt.Rows[i]["POPriceLastYear"].ToString();<br/> entity.ProductGroup = dt.Rows[i]["ProductGroup"].ToString();<br/> entity.SPG = dt.Rows[i]["SPG"].ToString();<br/> entity.Supplier = dt.Rows[i]["Supplier"].ToString();<br/> entity.TotalPurchaseYTDSpendCurrentMonthPOPrice = dt.Rows[i]["TotalPurchaseYTDSpendCurrentMonthPOPrice"].ToString();<br/> entity.TotalPurchaseYTDSpendCurrentYearPOPrice = dt.Rows[i]["TotalPurchaseYTDSpendCurrentYearPOPrice"].ToString();<br/> entity.TotalPurchaseYTDSpendLastMonthPOPrice = dt.Rows[i]["TotalPurchaseYTDSpendLastMonthPOPrice"].ToString();<br/> entity.TotalPurchaseYTDSpendLastYearPOPrice = dt.Rows[i]["TotalPurchaseYTDSpendLastYearPOPrice"].ToString();<br/> entity.YTDPurchaseQTY = float.Parse(dt.Rows[i]["YTDPurchaseQTY"].ToString());<br/> // 追加到数据库<br/> manager.Add(entity);<br/> // 置空<br/> //entity = null;<br/> }<br/> }<br/> // 快速导入<br/> else<br/> {<br/> // 指定表名<br/> dt.TableName = "PurchasePriceComparisonTemp";<br/> manager.SqlBulkImport(dt);<br/> }<br/> }<br/> // 清空掉dt里的内容<br/> dt = null;<br/>