SqlDataReader 在 Dispose() 上挂起

Question

我使用以下方法对数据库执行查询并读取数据：

using(SqlConnection connection = new SqlConnection("Connection string"))
{
    connection.Open();

    using(SqlCommand command = new SqlCommand("SELECT * FROM TableName", connection))
    {
        using (SqlDataReader reader = command.ExecuteReader())
        {
              // read and process data somehow (possible source of exceptions)
        } // <- reader hangs here if exception occurs
    } 
}

在读取和处理数据时，可能会发生一些异常。问题是当DataReader 抛出异常时，Close() 调用挂起。你有什么想法为什么？？？以及如何以适当的方式解决这个问题？当我写try..catch..finally 块而不是using 并调用command.Cancel() 之后，问题就消失了，然后将阅读器置于finally 中。

工作版本：

    using(SqlConnection connection = new SqlConnection("Connection string"))
    {
        connection.Open();

        using(SqlCommand command = new SqlCommand("SELECT * FROM TableName", connection))
        {
            SqlDataReader reader = command.ExecuteReader();
            try
            {
                // read and process data somehow (possible source of exceptions)
            }
            catch(Exception ex)
            {
                // handle exception somehow
            }
            finally
            {
               command.Cancel(); // !!!
               reader.Dispose();
            }
        } 
    }

Answer 1

发生异常时，您会在收到所有数据之前停止处理数据。如果您在几行后中止处理，即使没有异常，您也可以重现此问题。

当命令或读取器被释放时，查询仍在服务器上运行。 ADO.NET 只是疯狂地读取所有剩余的行和结果集并将它们丢弃。这样做是因为服务器正在发送它们并且协议需要接收它们。

调用SqlCommand.Cancel 会向SQL Server 发送“注意”，从而导致查询真正中止。这和在 SSMS 中按下取消按钮是一样的。

总而言之，只要您停止处理行，尽管有更多行入站，就会出现此问题。您的解决方法（调用SqlCommand.Cancel）是正确的解决方案。

Answer 2

关于SqlDataReader的Dispose方法，MSDN（link）有这样的说法：

释放 DbDataReader 使用的资源并调用 Close。

我添加的重点。如果你再去看看Close 方法（link），它会说明：

Close方法填写输出参数的值，返回 值和 RecordsAffected，增加关闭所需的时间 用于处理大型或复杂查询的 SqlDataReader。 当返回值和受查询影响的记录数 不重要，关闭 SqlDataReader 所需的时间 可以通过调用关联的Cancel方法来减少 调用 Close 方法之前的 SqlCommand 对象。

因此，如果您需要停止遍历阅读器，最好先取消该命令，就像您的工作版本一样。

Answer 3

我不会那样格式化它。
打开（）;不在 try 块中，它可以抛出异常
执行阅读器（）；不在 try 块中，它可以抛出异常
我喜欢 reader.Close - 因为这就是我在 MSDN 示例中看到的内容
我捕捉到 SQLexception，因为它们有数字（比如超时）

SqlConnection connection = new SqlConnection();
SqlDataReader reader = null;
try
{
    connection.Open();  // you are missing this as a possible source of exceptions
    SqlCommand command = new SqlCommand("SELECT * FROM TableName", connection);
    reader = command.ExecuteReader();  // you are missing this as a possible source of exceptions
    // read and process data somehow (possible source of exceptions)
}
catch (SqlException ex)
{
}
catch (Exception ex)
{
    // handle exception somehow
}
finally
{
    if (reader != null) reader.Close();
    connection.Close();
}