“阅读器关闭时调用 Read 的尝试无效”使用 SqlDataReader 时

Question

1) 我有以下代码：

private static sqlDataReader gCandidateList = null;

public SqlDataReader myCandidateList
{
    set
    {
        gCandidateList = value;
    }
    get
    {
        return gCandidateList;
    }
}

2) 在 FormA 中，我有：

sqlConn.ConnectionString = mySettings.myConnString;
sqlConn.Open();
SqlCommand cmdAvailableCandidate = new SqlCommand(tempString, sqlConn);
SqlDataReader drAvailableCandidate = cmdAvailableCandidate.ExecuteReader();
mySettings.myCandidateList = drAvailableCandidate;
sqlConn.Close();

3) 在 FormB 中，我想重用 myCandidatList 中保存的数据，因此我使用：

SqlDataReader drCandidate = mySettings.myCandidateList;
drCandidate.Read();

4) 然后，我收到错误“阅读器关闭时调用 Read 的尝试无效。 ”

5）我尝试了上面（3）中的mySettings.myCandidateList.Read（），并再次收到相同的错误消息。

6）如何重新打开SqlDataReader drCandidate来读取数据？

7) 非常感谢您的建议和帮助。

Answer 1

连接关闭或处置后，您将无法读取阅读器。如果您想稍后在代码中使用这些行（获取结果），您需要创建一个 List 或 DataTable。

例如，

System.Data.DataTable dt = new System.Data.DataTable();
dt.Load(drAvailableCandidate);

Answer 2

如果您想在稍后阶段使用数据读取器，则必须将相同的参数指定为 ExecuteReader 方法。您在 FormA 中的代码应更改如下。

sqlConn.ConnectionString = mySettings.myConnString;  
sqlConn.Open();  
SqlCommand cmdAvailableCandidate = new SqlCommand(tempString, sqlConn);  
SqlDataReader drAvailableCandidate = cmdAvailableCandidate.ExecuteReader(CommandBehavior.CloseConnection);  
mySettings.myCandidateList = drAvailableCandidate;  
sqlConn.Close(); 

确保在使用数据读取器后将其丢弃，因为与数据库的连接将保持打开状态，直到数据读取器关闭。最好更改 FormB 中的代码，如下所示。

using (mySettings.myCandidateList)
{
mySettings.myCandidateList.Read();  
}

Answer 3

在尝试从阅读器读取数据之前，您将关闭连接。那是行不通的。

Answer 4

当您对 SqlConnection 对象调用 Close (sqlConn.Close();) 时，它会关闭连接和数据读取器。这就是当您尝试从 FormB 中读取 SqlDataReader 时收到错误的原因。

您需要做的是更改 myCandidateList 属性的定义，以返回从 drAvailableCandidate 阅读器中提取的数据的表示形式。

本质上，您需要做的是迭代 drAvailableCandidate 对象中的行，提取值并将它们缓存在您的属性中以供以后检索。

Answer 5

只是为了添加已经给出的答案，如果您使用 async/await 那么很容易因为不等待 SqlConnection 的 using 块内的操作而陷入困境。例如，执行以下操作可能会给出报告的错误。

public Task GetData()
{
    using(new SqlConnection(connString))
    {
        return SomeAsyncOperation();
    }
}

这里的问题是我们没有等待 using 中的操作，因此在我们实际执行底层异步操作之前它已被处理掉。相当明显，但之前已经让我发现了。

正确的做法是在使用中等待。

public async Task GetData()
{
    using(new SqlConnection(connString))
    {
        await SomeAsyncOperation();
    }
}