是否可以将 System.Transactions.TransactionScope 与 SqlBulkCopy 一起使用？

发布于 2024-12-03 05:34:17 字数 242 浏览 5 评论 0原文

非常简单的问题：是否可以将 System.Transactions.TransactionScope 与 SqlBulkCopy 一起使用？文档事务和批量复制操作没有提及任何内容（至少从 .NET 4.0 开始），并且我的测试表明它不会自动加入 TransactionScope。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

童话 2024-12-10 05:34:18

SqlBulkCopy 从不登记到事务中。 SqlCommand 也不会这样做。常见的误解。登记是在调用 SqlConnection.Open 时执行的。之后，在该连接上运行的任何内容都是隐式事务的一部分。事实上，不再允许传递显式交易。

如果您希望 SqlBulkCopy 使用 TransactionScope 参与 System.Transactions.Transaction，则必须在打开连接时设置事务。

这很容易做到：

using (var tran = new TransactionScope(...))
using (var conn = new SqlConnection(connStr))
{
  conn.Open(); //This enlists.

  using (var sqlBulkCopy = new SqlBulkCopy(conn)) {
    sqlBulkCopy.WriteToServer(...);
  }

  tran.Complete(); //Commit.
}

您只需要这段代码即可。可能的错误：

交易必须尽早开启。
请勿使用 SqlBulkCopy 的 SqlTransaction 参数。传递null。
不要使用SqlBulkCopyOptions.UseInternalTransaction。
除非您想实际做某事，否则不要添加异常处理。如果没有提交，回滚是自动的。
使用 using 语句进行干净的代码和确定性清理。除非必要，否则请勿手动关闭或处置任何这些物体。这将是多余的。

您可以使用任何您喜欢的批量大小，并且所有批量都将成为交易的一部分。因此，批处理的价值有限（特别是事务日志不能提前截断）。首先尝试完全不进行批处理。

SqlBulkCopy never enlists into a transaction. SqlCommand also does not do that. Common misconception. The enlistment is performed at the time SqlConnection.Open is called. After that, anything that runs on that connection is part of the transaction implicitly. In fact it is no longer allowed to pass an explicit transaction.

If you want SqlBulkCopy to take part in a System.Transactions.Transaction using TransactionScope the transaction must be set at the time you open the connection.

It is very easy to do:

using (var tran = new TransactionScope(...))
using (var conn = new SqlConnection(connStr))
{
  conn.Open(); //This enlists.

  using (var sqlBulkCopy = new SqlBulkCopy(conn)) {
    sqlBulkCopy.WriteToServer(...);
  }

  tran.Complete(); //Commit.
}

This code is all you need. Possible mistakes:

The transaction must be opened early enough.
Do not use the SqlTransaction parameter of SqlBulkCopy. Pass null.
Do not use SqlBulkCopyOptions.UseInternalTransaction.
Do not add exception handling unless you want to actually do something. Rollback is automatic if there is no commit.
Use the using statement for clean code and deterministic cleanup. Do not manually close or dispose any of these objects unless you have to. This would be redundant.

You can use any batch size you like and all batches will be part of the transaction. Therefore, batching has limited value (in particular the transaction log cannot be truncated early). Try no batching at all first.

回复收藏 0 原文

樱娆 2024-12-10 05:34:18

要执行跨所有批次（并且可选地跨其他数据库语句）的原子 SqlBulkCopy 导入，我们需要使用事务。以下步骤概述了通过 SqlBulkCopy 使用事务的过程：

创建到目标数据库服务器的 SqlConnection。
打开连接。
创建一个 SqlTransaction 对象。
创建传入SqlTransaction对象的SqlBulkCopy对象
进入构造函数。
执行导入 - 调用 WriteToServer - 在
尝试...抓住块。
如果操作完成，则提交事务；如果失败，则回滚。

通过 SqlBulkCopy 使用事务

回复收藏 0 原文

孤千羽 2024-12-10 05:34:18

（据我所知）在批量加载中定义事务的唯一方法是指定批量大小。

批量加载的优点是可以获得批量更新锁（多线程读取和多线程写入）。当使用 bcp、批量插入、带有 (tablock) 的 ssis 数据流任务、insert(columns)select columns from openrowset (bulk) 或 sqlbulkcopy 时，您会得到此信息。当尝试最小化加载时间和事务日志大小时，这非常方便（仅当您满足最小日志记录要求时，这将为您节省数百万行的时间）。

每当加载数据时，事务日志都将成为瓶颈。如果时间至关重要，那么尽量减少记录的数量就很重要。

一旦满足批量大小（您指定提交的行数），事务就会提交并重新开始。如果指定批量大小为 0，则事务将覆盖整个文件，并在出现任何数据问题时回滚。

回复收藏 0 原文

~没有更多了~