多次读取IDataReader时出错



我正在尝试将SQL数据库中的数据(1个表中的4列)加载到列表中,并且到目前为止已经完成了

List<string> FNameList = (from IDataRecord r in myReader
                          select (string)r["FirstName"]).ToList();
List<string> LNameList = (from IDataRecord r in myReader
                          select (string)r["LastName"]).ToList();
List<string> EmailList = (from IDataRecord r in myReader
                          select (string)r["Email"]).ToList();
List<string> PhoneList = (from IDataRecord r in myReader
                          select (string)r["PhoneNumber"]).ToList();

现在我使用的数据库有三行数据,所以每行数据的长度应该是3。然而,只有第一个返回的长度为三;其他的长度为0。更奇怪的是,如果我评论掉第一个,第二个会起作用,但其他的就不行了。第三个和第四个也是如此。

这很难解释,因为我无法提供用于测试的数据库,所以我想知道上面是否有任何明显的内容,或者这是否是将列数据加载到数组/列表格式的错误方法。

我假设您有一个类似于以下的Select扩展方法:

public static IEnumerable<T> Select<T>(this IDataReader reader, Func<IDataRecord, T> selector)
{
    while(reader.Read())
        yield return selector(reader);
}

因此,当读取器被枚举时,它位于可用数据的末尾,再次读取数据的唯一方法是重新发出查询。因此,您需要一次获取所有字段:

var records = (from IDataRecord r in myReader
               select new
               {
                   FirstName = (string)r["FirstName"],
                   LastName = (string)r["LastName"],
                   Email = (string)r["Email"],
                   PhoneNumber = (string)r["PhoneNumber"]
               }).ToList();

您的读取器在第一次查询后前进到最后一条记录。您需要提取所有行,然后构建列表:

var records = (from IDataRecord r in myReader select r).ToArray();
List<string> LNameList = (from IDataRecord r in records
                       select (string)r["LastName"]).ToList();
// Keep the last row for all fields
myReader是一个SqlDataReader。SqlDataReader provides a way of reading a forward-only stream of rows from a SQL Server database。第一次使用后无法重新启动。

您需要在一个循环中读取所有数据,然后根据需要构建列表
但是,我不明白你为什么要这样划分信息。

首先声明一个poco来保存属性:

class Person
{
    ...
}

然后是一种辅助方法:

private static IEnumerable<Person> ReadReader(IDataReader reader)
{
    using (reader)
    {
        while (reader.Read())
        {
            yield return new Person
            {
                FirstName = (string)reader["FirstName"],
                LastName = (string)reader["LastName"],
                Email = (string)reader["Email"],
                PhoneNumber = (string)reader["PhoneNumber"]
            }
        }
    }
}

用法:

List<Person> list = RaderReader(command.ExecuteReader()).ToList();

相关内容

  • 没有找到相关文章

最新更新