使用IDataReader正确读取值

本文关键字：读取 IDataReader 使用 | 更新日期: 2023-09-27 18:17:29

我使用sqlcommand从sqltable检索一些值。现在，当我第一次执行读取器来选择值并将它们分配给RemovedRows变量时，它可以完美地工作。但是当下一次执行填充adddrows变量时，它什么也不返回。现在，如果我交换变量位置，adddrows将有值，而后者将没有任何值。所以基本上reader只执行一次，下一次它不会执行也不会给出任何错误，比如reader已关闭等等

using (IDataReader reader = _changeTable.ExecuteReader())
{
   RemovedRows = reader.Select(r => new { LogID = r["LogID"], Operation = r["SYS_CHANGE_OPERATION"] })
                       .Where(r => r.Operation.Equals("D")).Select(r => (long)r.LogID).ToList();
   AddedRows = reader.Select(r => new { LogID = r["LogID"], Operation = r["SYS_CHANGE_OPERATION"] })
                     .Where(r => r.Operation.Equals("I")).Select(r => (long)r.LogID).ToList();
}
public static IEnumerable<T> Select<T>(this IDataReader reader,
                                           Func<IDataReader, T> projection)
{
    while (reader.Read())
    {
        yield return projection(reader);
    }
}

一种解决方案是将reader的值放在new List<T>中，并访问新的列表值，而不必担心reader的状态。我能够创建一个列表，但由于属性是匿名类型，我无法访问它。

我创建new List<T>并像这样使用它:

    public static List<T> CreateList<T>(params T[] elements)
    {
       return new List<T>(elements);
    }

 var values = reader.Select(r => new { LogID = r["LogID"], Operation = r["SYS_CHANGE_OPERATION"] }).ToList();
 var newList = Helper.CreateList(values);
 RemovedRows = newList.Where(r => r.Operation.Equals("D")).Select(r => (long)r.LogID).ToList();

这里它不允许我访问匿名类型的Operation和LogID属性。

所以我的问题是如何执行阅读器(下面的代码)，并在关闭阅读器后使用它的值:

var values = reader.Select(r => new { LogID = r["LogID"], Operation = r["SYS_CHANGE_OPERATION"] }).ToList();

使用IDataReader正确读取值

reader已经被枚举，并且只允许一次性的仅向前访问，因此尝试再次枚举它以获得空集合中的AddedRows结果。我建议将所有相关行读入内存，然后过滤成单独的查询:

string[] ops = {"D","I"};
IEnumerable<long> removedRows;
IEnumerable<long> addedRows;
using (IDataReader reader = _changeTable.ExecuteReader())
{
    var allRows = reader.Select(r => new { LogID = r["LogID"], Operation = r["SYS_CHANGE_OPERATION"] })
                        .Where(r => ops.Contains(r.Operation)
                        .ToList();
    removedRows = allRows.Where(r => r.Operation.Equals("D"))
                         .Select(r => (long)r.LogID);
    addedRows = allRows.Where(r => r.Operation.Equals("I"))
                       .Select(r => (long)r.LogID);
}

您也可以使用GroupBy或ToLookup来获得类似的结果，但是除非您有重大的性能问题，否则请使用对您最有意义的任何选项。

相关文章：