国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

【轉】批量復制操作(SqlBulkCopy)的出錯處理:事務提交、回滾

2019-11-17 02:43:42
字體:
來源:轉載
供稿:網友

【轉】批量復制操作(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


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 阳高县| 拉萨市| 文昌市| 岳阳县| 镇坪县| 天长市| 上虞市| 南昌市| 新乐市| 肇东市| 广水市| 独山县| 望都县| 滦平县| 横峰县| 大足县| 虞城县| 临清市| 普安县| 新和县| 五家渠市| 海安县| 锡林郭勒盟| 喀什市| 泰州市| 南木林县| 交城县| 成都市| 长海县| 涪陵区| 犍为县| 泊头市| 安西县| 庆阳市| 体育| 新昌县| 杭锦旗| 邵阳市| 浙江省| 郁南县| 视频|