Метод расширения IEnumerable и Datareader, необходимые предложения

Question

Ниже приведен метод расширения для преобразования datareader в объект с использованием класса «DataReaderInjection» на основе инжектора OMU.

public static IEnumerable<T> MapTo<T>(this IDataReader reader) where T : new() { 
    return reader.MapTo<T>(null); 
} 

public static IEnumerable<T> MapTo<T>(this IDataReader reader, Action<IDataReader, T> customMappingFunction) where T : new() { 
    using (reader) 
     while (!reader.IsClosed && reader.Read()) { 
      var nextItem = new T(); 
      nextItem.InjectFrom<DataReaderInjection>(reader); 
      if (customMappingFunction != null) 
       customMappingFunction(reader, nextItem); 
      yield return nextItem; 
     } 
} 

этот метод имеет ошибку, так как только вы вызываете этот метод и DataReader закрывается, следующий вызов вернет пустой IEnumerable, чтобы исправить это я изменил выше код к следующему.

public static class DataAccessExtensions 
{ 
    public static IEnumerable<T> MapTo<T>(this IDataReader reader) where T : new() { 
     return reader.MapTo<T>(null); 
    } 

    private static Dictionary<int, IEnumerable> dataReaderCache = new Dictionary<int, IEnumerable>(); 
    private static object lockObj = new object(); 

    public static IEnumerable<T> MapTo<T>(this IDataReader reader, Action<IDataReader, T> customMappingFunction) where T : new() { 
     lock (lockObj) 
     { 
      if (dataReaderCache.ContainsKey(reader.GetHashCode())) 
       return dataReaderCache[reader.GetHashCode()] as IEnumerable<T>; 
     } 
     List<T> finalList = new List<T>(); 
     using (reader) { 
      while (!reader.IsClosed && reader.Read()) { 
       var nextItem = new T(); 
       nextItem 
        .InjectFrom<DataReaderInjection>(reader); 
       if (customMappingFunction != null) 
        customMappingFunction(reader, nextItem); 
       finalList.Add(nextItem); 
      } 
     } 
     lock (lockObj) 
     { 
      dataReaderCache.Add(reader.GetHashCode(), finalList); 
     } 
     return finalList; 
    } 

}

Что вы, ребята, думаете это будет работать

Answer 1

... этот метод имеет ошибку, так как только вы вызываете этот метод и DataReader закрывается, следующий вызов будет возвращать пустой IEnumerable

Это не ошибка, datareaders - это только итераторы только для начала, вы можете только перебирать их один раз. Если вам нужно повторять результаты более одного раза, кешируйте возвращаемый IEnumerable. Самый простой способ сделать это - обернуть его в List<T>, или вы можете кэшировать его лениво, используя Rx's MemoizeAll()