多次读取IDataReader时出错

本文关键字：出错 IDataReader 读取 | 更新日期: 2024-10-24 00:11:28

我正在尝试将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。更奇怪的是，如果我评论掉第一个，第二个会起作用，但其他的就不行了。第三个和第四个也是如此。

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

多次读取IDataReader时出错

我假设您有一个类似于以下的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();
相关文章：