【问题讨论】：
标签： .net sql sql-server sql-server-2000 transactions
您没有指定是否使用 .NET 2.0，但我会做出这样的假设。 C# 3.0 示例代码如下：
using (var tx = new TransactionScope()) {
// Execute multiple DB statements inside here
ts.Complete();
}
如果任何 DB 语句失败，将永远无法到达 ts.complete，并且事务将在 using 语句结束时自动回滚。但是，对这种方法的一个警告是，如果您使用多个连接，您最终将利用 DTC，这意味着性能较慢。
修改为将 SqlTransaction 更改为 TransactionScope
强制单个 SQL 连接以避免使用 DTC 的示例：
using (var tx = new TransactionScope())
using (var db = new SqlConnection(connString)) {
// Command 1
using (var cmd = db.CreateCommand()) {
cmd.CommandText = "select...";
using (var reader = cmd.ExecuteReader()) {
// Process results or store them somewhere for later
}
}
// Command 2
using (var cmd = db.CreateCommand()) {
cmd.CommandText = "select...";
using (var reader = cmd.ExecuteReader()) {
// Process results or store them somewhere for later
}
}
// Command 3
using (var cmd = db.CreateCommand()) {
cmd.CommandText = "select...";
using (var reader = cmd.ExecuteReader()) {
// Process results or store them somewhere for later
}
}
tx.Complete();
}
【讨论】：
我认为一个事务不能跨越多个连接。
在不同的连接中进行多次插入的原因是什么？我认为您通常希望它们在一个连接中。
【讨论】：
IDbConnection 和多个 IDbCommands。事实上，如果您使用 SqlClient，ADO 的连接池将有效地使您重用与数据库的相同连接，即使您的代码似乎关闭并重新打开连接。
事务是在连接上创建的，并且没有超出创建它们的连接的范围，因此您无法按照您的要求进行操作。重构，以便您可以在连接上按顺序执行插入，而不是同时执行，或者实现不同的机制来实现回滚（例如，插入键的表可以用作查找以在稍后遇到错误时删除插入的记录过程）
【讨论】：
您不使用一个连接和多个命令（实际上是在循环中重新创建一个命令）的原因是什么？ 也许这个解决方案对你有用：
public static void CommandExecNonQuery(SqlCommand cmd,
string query, SqlParameter[] prms)
{
cmd.CommandText = query;
cmd.Parameters.AddRange(prms);
cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
}
static void Main(string[] args)
{
string insertQuery =
@"INSERT TESTTABLE (COLUMN1, COLUMN2) " +
"VALUES(@ParamCol1, @ParamCol2)";
using (SqlConnection connection =
new SqlConnection(connectionString))
{
using (SqlCommand command =
connection.CreateCommand())
{
SqlTransaction transaction = null;
try
{
// BeginTransaction() Requires Open Connection
connection.Open();
transaction = connection.BeginTransaction();
// Assign Transaction to Command
command.Transaction = transaction;
for (int i = 0; i < 100; i++)
CommandExecNonQuery(command, insertQuery,
new SqlParameter[] {
new SqlParameter("@ParamCol1", i),
new SqlParameter("@ParamCol2", i.ToString()) });
transaction.Commit();
}
catch
{
transaction.Rollback();
throw;
}
finally
{
connection.Close();
}
}
}
}
另见
Sql Server Transactions - ADO.NET 2.0 - Commit and Rollback - Using Statement - IDisposable
【讨论】：