使用UseInternalTransaction

在構造函數SqlBulkCopy(String, SqlBulkCopyOptions)里面有SqlBulkCopyOptions的選項，有如下可選項。

我們看到可選項分別有保持Identity鍵，檢查約束，是否鎖表，保持null值，觸發觸發器，使用事務。

所以如果只是想把SqlBulkCopy包含在事務中，只要打開此屬性即可。

使用System.Data.SqlClient.SqlTransaction

使用自定義的事務，將SqlBulkCopy和其他操作一起包含在一個事務中。

這種方法只要使用另一個構造函數即可：SqlBulkCopy(SqlConnection, SqlBulkCopyOptions, SqlTransaction)。

需要注意的是：當打開了UseInternalTransaction選項后，就不可以和自定義事務一起使用了，否則會拋出InvalidArgumentException。

事務影響性能？

下面是使用第一種開啟事務的測試代碼，沒有使用事務的代碼參見前一篇文章。

使用UseInternalTransaction的代碼。

1 using System; 2 using System.Data; 3 using System.Data.SqlClient; 4 5 namespace BulkInsert 6 { 7???? static class Program 8???? { 9???????? static void Main() 10???????? { 11???????????? DateTime dateTimeStart = DateTime.Now; 12???????????? Console.WriteLine("Start Insert:" + dateTimeStart.ToString("HH:mm:ss fff")); 13???????????? //導入導出的數據庫連接 14 //SqlConnection connectionDestination = new SqlConnection();15 ??????????? SqlConnection connectionSource = new SqlConnection("Server =.; User ID=sa; Password=password; Initial CataLog=ExportDataDemo_Source;"); 16 17???????????? //實例化一個SqlBulkCopy18 ??????????? var bulker = new SqlBulkCopy("Server =.; User ID=sa; Password=password; Initial CataLog=ExportDataDemo_Destination;", SqlBulkCopyOptions.UseInternalTransaction) { DestinationTableName = "DEMOTABLE", BulkCopyTimeout = 600 }; 19 20???????????? //獲取源數據庫的數據21 ??????????? SqlCommand sqlcmd = new SqlCommand("SELECT * FROM DEMOTABLE", connectionSource); 22???????????? SqlDataAdapter sqlDataAdapter = new SqlDataAdapter(sqlcmd); 23???????????? DataTable dataTableSource = new DataTable(); 24???????????? sqlDataAdapter.Fill(dataTableSource); 25 26???????????? //可以重新定義字段的Mapping關系 27 //SqlBulkCopyColumnMapping sqlBulkCopyColumnMapping = new SqlBulkCopyColumnMapping("COL1", "NEW_COL1"); 28 //bulker.ColumnMappings.Add(sqlBulkCopyColumnMapping); 29 //connectionDestination.Open();30 ??????????? bulker.WriteToServer(dataTableSource); 31???????????? bulker.Close(); 32???????????? DateTime dateTimeEnd = DateTime.Now; 33???????????? Console.WriteLine("Insert Ending:" + dateTimeEnd.ToString("HH:mm:ss fff")); 34???????? } 35???? } 36}

Source表同樣還是10萬的數據，每遷移一次后使用TRUNCATE TABLE清空數據，測試三次取平均值。

截圖如下。

A:不使用事務

B:使用事務

最終對比數據。單位為秒，忘記加在圖表上面了 :)

特定的測試環境與數據，測試結果僅供參考，歡迎交流、討論。

作者：Parry 出處：http://www.cnblogs.com/parry/

總結

以上是生活随笔為你收集整理的SqlBulkCopy加了事务真的会变快吗？的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。