3

我想执行一个 SELECT 查询，然后执行一系列 UPDATE 查询（都在同一张表上）；UPDATE 是在一个单独的方法中实现的，该方法被重复调用。如果其中一个 UPDATE 查询失败，我希望它们全部失败/回滚 - 所以我想将它们加入事务。但是，我不确定SqlConnection应该在哪里打开以避免任何问题。我当前的实现如下所示：

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    // execute a single SELECT here

    using (TransactionScope scope = new TransactionScope())
    {
        for (int i=0; i<...; i++)
        {
            Update(); // UPDATE query
        }

        scope.Complete();
    }
}


Update()
{
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        connection.Open();

        // execute a single UPDATE here
    }
}

这应该在所有情况下都按预期工作吗？

可以在SELECT之前打开一个连接，然后在Update()方法中打开一个新连接吗？由于连接池，相同的连接将用于 SELECT 和 UPDATE 查询（connectionString相同），但只有 UPDATE 查询将被纳入事务，对吗？但是如果使用不同的连接会发生什么Update()？所有 UPDATE 查询是否仍会按预期加入事务并自动执行？

如果我理解正确，在关闭第一个连接后（在执行 SELECT 的块之后）创建事务范围using仍然有效，但会降低性能，因为连接将被关闭并需要重新打开，对吗？或者实际上是为事务范围创建了一个新连接，并且每次Update()调用都会打开和关闭？

4

1 回答 1

8

由于连接池，相同的连接将用于 SELECT 和 UPDATE 查询

不，它不会；只有先将连接释放回池中，它才能做到这一点 - 目前您同时有两个连接，所以它不可能是同一件事。您需要进行一些重组：

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    // execute a single SELECT here
} // <==== end the first connection

using (TransactionScope scope = new TransactionScope())
{
    for (int i=0; i<...; i++)
    {
        Update(); // UPDATE query
    }

    scope.Complete();
}

在关闭第一个连接（...）后创建事务范围，但会降低性能，因为连接将被关闭并需要重新打开，正确

不; 当你“关闭”它时，你实际上只是将它释放回池中；它不会关闭底层连接（除非您禁用了池）。关闭（或至少，处置）是正常的和预期的。

但只有 UPDATE 查询将被纳入事务，对吗？

正确，因为那只是在事务范围内打开连接的地方

但是如果在 Update() 中使用不同的连接会发生什么？所有 UPDATE 查询是否仍会按预期加入事务并自动执行？

任何支持登记的连接（假设它没有在连接字符串中被禁用）都将被登记。但是，根据服务器的不同，这可能使用 LTM 或可能使用 DTC。如果您想确定您的连接：控制它们：

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    // execute a single SELECT here
} // <==== end the first connection

using (TransactionScope scope = new TransactionScope())
using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();
    for (int i=0; i<...; i++)
    {
        Update(connection); // UPDATE query
    }

    scope.Complete();
}

注意我在上面传递了connectioninto Update；这里很明显将使用单个连接（假设Update工作正常）。

于 2013-05-31T10:28:36.067 回答