【轉】批量復制操作（SqlBulkCopy）的出錯處理：事務提交、回滾，sqlbulkcopy事務

【轉】批量復制操作（SqlBulkCopy）的出錯處理：事務提交、回滾，sqlbulkcopy事務

原文地址：http://blog.csdn.net/westsource/article/details/6658109

  默認情況下，批量復制操作作為獨立的操作執行。 批量復制操作以非事務性方式發生，不可能使其回滾。 如果需要在出錯時回滾全部批量復制或它的一部分，可以使用 SqlBulkCopy 托管的事務，在現有事務中執行批量復制操作，或者在 System.Transactions Transaction 中登記它。

     由於不同批次在不同事務中執行，因此，如果在批量復制操作期間發生錯誤，則當前批次中的所有行都將被回滾，但以前批次中的行將保留在數據庫中。 （在錯誤點之前復制的所有批次都被提交；回滾當前復制的批次，並且在處理任何其他批次前中止批量復制操作。）

比如：批量復制100條數據到數據庫匯總，batchsize設置為10.則沒10條數據復制作為一個事務，整個100條數據的復制操作被分割為10個獨立的事務。如果復制到第56條數據時（第6個事務），出錯了。則前50條數據提交到數據庫中，只回滾出錯的事務。

     如果由於發生錯誤而需要回滾整個批量復制操作，或者批量復制應作為更大的可回滾進程的一部分執行，則可以將 SQLTransaction 對象提供給 SqlBulkCopy 構造函數.

  示例：

using (SqlConnection destinationConnection = new SqlConnection(connectionString))
            {
                destinationConnection.Open();
 
                using (SqlTransaction transaction = destinationConnection.BeginTransaction())
                {
                    using (SqlBulkCopy bulkCopy = new SqlBulkCopy( destinationConnection, SqlBulkCopyOptions.Default,
                               transaction))
                    {
                        bulkCopy.BatchSize = 10;
                        bulkCopy.DestinationTableName = "dbo.BulkCopyDemoMatchingColumns";

                        try
                        {
                            bulkCopy.WriteToServer(reader);
                            transaction.Commit();
                        }
                        catch (Exception ex)
                        {
                            Console.WriteLine(ex.Message);
                            transaction.Rollback();
                        }
                        finally
                        {
                            reader.Close();
                        }
                    }
                }
            }

SqlBulkCopyOptions 屬性成員：

 

Default 對所有選項使用默認值。   KeepIdentity 保留源標識值。如果未指定，則由目標分配標識值。   CheckConstraints 請在插入數據的同時檢查約束。默認情況下，不檢查約束。   TableLock 在批量復制操作期間獲取批量更新鎖。如果未指定，則使用行鎖。   KeepNulls 保留目標表中的空值，而不管默認值的設置如何。如果未指定，則空值將由默認值替換（如果適用）。   FireTriggers 指定後，會導致服務器為插入到數據庫中的行激發插入觸發器。   UseInternalTransaction 如果已指定，則每一批批量復制操作將在事務中發生。如果指示了此選項，並且為構造函數提供了 SqlTransaction 對象，則發生 ArgumentException。

詳細請查閱：

http://msdn.microsoft.com/zh-cn/dynamics/tchktcdk.aspx

http://msdn.microsoft.com/zh-cn/partners/system.data.sqlclient.sqlbulkcopyoptions.aspx