zoukankan      html  css  js  c++  java
  • SqlBulkCopy加了事务真的会变快吗?

    使用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:使用事务

    最终对比数据。单位为秒,忘记加在图表上面了 :)

    特定的测试环境与数据,测试结果仅供参考,欢迎交流、讨论。

  • 相关阅读:
    for循环里面不要进行remove操作,for循环里remove元素后,list的下标会减小,导致遍历不完全
    elasticsearch,java api, transport Client, 查询时索引库可以用通配符*和删除接口不能用
    (一)WebPack4.0 从零开始
    合并代码 dev 到 master
    vscode 终端无法输入问题 看这个就行了
    node 学习笔记:一、 nvm 安装管理Node版本
    常见的对象创建模式
    深入理解闭包
    sort对数组排序
    图片压缩
  • 原文地址:https://www.cnblogs.com/soundcode/p/2690093.html
Copyright © 2011-2022 走看看