0

当我从 sqldatareader 读取数据时，我收到错误“读取器关闭时调用读取的尝试无效”。我的代码如下

显然，这已被 ExecSqlDataReader 中的 using 语句关闭

我希望能够调用此方法，然后在另一个类中使用阅读器，有没有办法绕过这个而不必循环通过 ExecSqlDataReader 方法中的 SqlDataReader ？

希望这是有道理的

谢谢

代码：

SqlDataReader reader = data.ExecSqlDataReader(1);
 while (reader.Read())
  {
   .....
  }


       public SqlDataReader ExecSqlDataReader(int queryType = 0)
       {
        using (var conn = new SqlConnection(this.ConnectionString))
        {
            try
            {
                PrepareCommandForExecution(conn, queryType);
                return _cmd.ExecuteReader();

            }
            finally
            {
                _cmd.Connection.Close();
            }
        }
    }

    private SqlCommand PrepareCommandForExecution(SqlConnection conn, int sqlType = 0)
    {

            _cmd.Connection = conn;
            switch (sqlType)
            {
                case 0:
                    _cmd.CommandType = CommandType.StoredProcedure;
                    break;
                case 1:
                    _cmd.CommandType = CommandType.Text;
                    _cmd.CommandText = _tSqltext;
                     break;
                case 2:
                    _cmd.CommandType = CommandType.TableDirect;
                    break;
            }

            _cmd.CommandTimeout = this.CommandTimeout;
            _cmd.Connection.Open();

            return _cmd;

    }
4

2 回答 2

5

问题是离开函数（通过 return 语句）会将您踢出using块，因此您正在使用的 SqlDataReader 和 SqlConnections 被释放。要解决此问题，请尝试更改函数签名，如下所示：

public static IEnumerable<IDataRecord> ExecSqlDataReader( int queryType )

然后像这样更新函数的中间：

using ( var reader = cmd.ExecuteReader() )
{
    while ( reader.Read() )
    {
        yield return reader;
    }
}

如何使用它：

var first10 = ExecSqlDataReader(0).Take(10);
foreach (var rec in first10)
{
    int ID = rec.GetInt32(0);
}

所以这应该有效，因为产量会导致连接保持活动状态：

于 2012-11-01T23:28:59.803 回答
0

您也许应该修改您的设计以传回（断开连接）DataTable而不是尝试保持连接打开（然后可能“泄漏”）。

于 2012-11-01T23:29:01.770 回答