如果没有更多要读取的行，则关闭 SqlDataReader - C#

Question

这让我很头疼。我知道这个问题（或至少它的变体）已被问过很多次，但在将其标记为重复之前，请考虑以下代码：

    string myConnectionString =  myConnectionString = ConfigurationManager.ConnectionStrings["DBCS"].ToString();
     SqlConnection mySQLConnection;
     SqlCommand mySQLCommand;
     SqlDataReader mySQLDataReader;

    using (mySQLConnection = new SqlConnection(myConnectionString))
    {
       mySQLCommand = new SqlCommand("SELECT TOP 1 * FROM Table ORDER BY Id DESC", mySQLConnection);
       mySQLCommand.Connection = mySQLConnection;
       mySQLCommand.Connection.Open();
       using(mySQLDataReader = mySQLCommand.ExecuteReader())
       {
         if (mySQLDataReader.HasRows)
         {
             if (mySQLConnection.State == ConnectionState.Open)
             {
                while (mySQLDataReader.Read())
                {
                  //Perform Logic : If the last record being returned meets some condition then call the below method
                   MethodCalled();
                }            
            }
         }
      }
         MessageBox.Show("Connection state: " + mySQLConnection.State);
   }

我想找到一种方法：

1. 读完后关闭读卡器
2. 当 while-loop 读完并且没有剩余行时，退出它

但我只是不断收到SqlException 说明以下内容：

阅读器关闭时调用 read 的尝试无效

仅从广泛的观察来看，我可以追踪到该错误是由于我返回的数据仅包含一行。问题在于，在读取该行之后，编译器会返回到While(mySQLDataReader.Read()){} 并尝试读取一个不包含任何行的表。

我尝试了以下方法：

1. 将命令对象中的ExecuteReader() 包装在using 块中，以便在完成读取后分别自动关闭读取器和连接：

   using(mySQLDataReader = mySQLCommand.ExecuteReader())
   {
       //Logic performed
   }
   

2. 就在while-loop 的右大括号之前，我尝试检查是否有更多行从 sql 命令留下/返回，并在满足该条件后中断循环：

   if(mySQLDataReader.HasRows == false) //No more rows left to read
   {
        break; //break out of loop
   }
   

两次尝试均未成功。我该如何解决这个问题？

Answer 1

它必须是以下三件事之一：

1. 您在using 块之外使用Read()。请记住，using 块将隐式调用您的阅读器上的 Close 和 Dispose。因此，任何Read() 调用都必须放在using 块内。
2. using 块的主体明确关闭了阅读器。这似乎不太可能。
3. 显然您已在更高级别声明了您的mySQLDataReader。可能是其他一些（异步）代码正在关闭阅读器。这也是不太可能的。在大多数情况下，您不应该在全局级别定义 DataReader。

编辑

阅读您现在发布的完整代码块，我建议进行一些更改。您能否运行以下命令并告诉我们它是否运行：

using (var mySQLConnection = new SqlConnection(myConnectionString))
{
   mySQLCommand = new SqlCommand("SELECT TOP 1 * FROM Table ORDER BY Id DESC", mySQLConnection, mySQLConnection);
   mySQLCommand.Connection.Open();
   using(mySQLDataReader = mySQLCommand.ExecuteReader())
   {
      while (mySQLDataReader.Read())
      {
        //Perform Logic : If the last record being returned meets some condition then call the below method
         MethodCalled();
      }            
   }
}

如果这个版本运行良好，我们可以更好地挖掘问题。

Answer 2

如果没有要迭代的数据，while 循环将根本不会执行。您是否需要检查 HasRows 本身？此外，您应该在创建数据读取器时使用 CommandBehavior.CloseConnection。这将确保在您通读后关闭底层连接。

Should if call SqlDataReader.HasRows if I am calling SqlReader.Read

SQLDataReader Source Code

using (SqlConnection mySQLConnection = new SqlConnection(myConnectionString))
{
using (SqlCommand mySQLCommand = new SqlCommand("SELECT TOP 1 * FROM Table ORDER BY Id DESC", mySQLConnection))
  {
    mySQLConnection.Open();

    SqlDataReader mySQLDataReader = mySQLCommand.ExecuteReader(CommandBehavior.CloseConnection);
     while (mySQLDataReader.Read())
       {
          //Code logic here
        }
        // this call to mySQLDataReader.Close(); will close the underlying connection
         mySQLDataReader.Close();
    }
     MessageBox.Show("Connection state: " + mySQLConnection.State);
}