La meilleure méthode à utiliser IDataReader comme IEnumerable<T>?

J'ai besoin d'utiliser Linq sur toute IDataReader implémentations comme ce

var c = sqlDataReader.AsEnumerable().Count();

Exemple:

public abstract class Test
{
    public abstract SqlDataReader GetSqlDataReader();

    public void Foo()
    {
        SqlDataReader sqlDataReader = GetSqlDataReader();
        IEnumerable<SqlDataReader> sqlEnumerable = sqlDataReader.AsEnumerable();
        var c = sqlEnumerable.Count();
        var s = sqlEnumerable.Sum();
        SqlDataReader first = sqlEnumerable.First();
        var t = first.GetSqlXml(10);
    }
}

Quelle est la meilleure méthode pour écrire cela.
Veuillez écrire votre code.

InformationsquelleAutor b2Lord | 2011-08-04
  1. 8

    Essayer, c':

    public static class DataReaderExtension
{
    public class EnumeratorWrapper<T>
    {
        private readonly Func<bool> moveNext;
        private readonly Func<T> current;

        public EnumeratorWrapper(Func<bool> moveNext, Func<T> current)
        {
            this.moveNext = moveNext;
            this.current = current;
        }

        public EnumeratorWrapper<T> GetEnumerator()
        {
            return this;
        }

        public bool MoveNext()
        {
            return moveNext();
        }

        public T Current
        {
            get { return current(); }
        }
    }

    private static IEnumerable<T> BuildEnumerable<T>(
            Func<bool> moveNext, Func<T> current)
    {
        var po = new EnumeratorWrapper<T>(moveNext, current);
        foreach (var s in po)
            yield return s;
    }

    public static IEnumerable<T> AsEnumerable<T>(this T source) where T : IDataReader
    {
        return BuildEnumerable(source.Read, () => source);
    }
}
    • Excellent travail, merci
    InformationsquelleAutor halorty
  2. 14

    Vous pouvez utiliser ceci:

    MyDataReader.Cast<IDataRecord>()

    Mais n'oubliez pas de linq instruction execute avant de fermer le DataReader.

    à l'aide de ToList() par exemple

    • +1 pour ToList astuce
    InformationsquelleAutor Serge
  3. 8

    Vous pouvez créer une méthode d'extension pour ce faire (voir mises en garde ci-dessous):

    public static class DataReaderExtension
{
    public static IEnumerable<Object[]> AsEnumerable(this System.Data.IDataReader source)
    {
        if (source == null)
            throw new ArgumentNullException("source");

        while (source.Read())
        {
            Object[] row = new Object[source.FieldCount];
            source.GetValues(row);
            yield return row;
        }
    }
}

    Trouve ici: http://www.thinqlinq.com/default/Consuming-a-DataReader-with-LINQ.aspx

    Comme l'a souligné @LukeH, notez que comme IDataReader prend uniquement en charge la lecture une fois, en avant, seulement, vous serez en mesure d'interroger le énumérable une fois. (Pour obtenir autour de ce que vous pourriez appeler ToList/ToArray, puis requête).

    Noter que SqlDataReader déjà impliments IEnumerable de sorte que vous n'aurez pas besoin de faire cela dans l'exemple que vous avez donné.

    Aussi, sachez que c'est probablement mieux de le faire tout de filtrage/aggrigating sur le serveur (via LINQ to SQL par exemple)

    • Notez que cela ne leur permet pas de faire Count suivie par Sum suivit par First comme dans l'exemple. (Bien que faire de ce qu'ils avaient besoin de ré-interroger la db trois fois, ou les résultats en mémoire tampon en quelque sorte, qui ont tous deux écueils potentiels.)
    • Bonne prise, édité.
    • Duckett "Notez que SqlDataReader déjà impliments IEnumerable de sorte que vous n'aurez pas besoin de faire cela dans l'exemple que vous avez donné.", oui c'est vrai mais j'ai besoin de IEnumerable<SqlDataReader> utiliser par exemple la méthode "GetSqlXml"
    • "IEnumerable<Object[]> AsEnumerable", j'ai besoin de IEnumerable<SqlDataReader>
    • "seulement, vous serez en mesure d'interroger le énumérable une fois" je sais, mais je peux utiliser "AsQueryable()" pour ce faire.
    • n'a pas de sens car vous avez seulement un SqlDataReader, vous n'êtes pas à l'énumération sur plus d'un SqlDataReader.
    • while (reader.Read()) { // Dans cette boucle, il est possible de faire quelque chose avec le "lecteur", moi aussi je veux donc quelque chose dans tout enumerabled élément }
    • mais le énumérées élément n'est pas le SqlDataReader, le SqlDataReader est la chose à faire l'énumération. Je suis désolé, je n'ai toujours pas de suivre votre cas d'utilisation.
    • Je suis à la recherche des définitions pour les deux SqlDataReader et IDataReader, ni de leur mise en œuvre IEnumerable...?

    InformationsquelleAutor George Duckett
  4. 5

    Voici mes deux cents :

    public static IEnumerable<T> Enumerate<T>(this T reader) where T: IDataReader 
{ 
   using(reader) 
      while(reader.Read()) 
         yield return reader; 
} 

public void Test()
{
  var Res =
    from Dr in MyDataReader.Enumerate()
    select new {
      ID = (Guid)Dr["ID"],
      Description = Dr["Desc"] as string
    };
}

    J'ai ressenti l'envie de publier ce post, car il est très important de disposer d'un DataReader après utilisation, et pas de réponse mentionné.

    C'est pourquoi mon application a un using déclaration autour de la while boucle. De cette façon, je peux le faire "d'une part" les requêtes sans se soucier de la DataReader disposition.

    • Il semble ok pour ton code, mais avec plus de tableaux complexes, il pourrait être une erreur qui serait arrêter l'itération et ne jetez jamais le lecteur. J'ai eu ce problème et j'ai créé un "DisposableEnumerable" classe afin que l'aide se fait à l'extérieur de la Énumérer méthode et les appels en Disposer en cas de problème.
    • +1 pour faire des suggestions à propos de la using instruction et de l'importance de la fermeture de la datareader. Dans certains environnements, le DataReader pourrait effectivement Lock une base de données, table, feuilles, etc.
    InformationsquelleAutor Larry
  5. 4

    Vous pouvez simplement charger le DataReader dans un DataTable et puis Select():

    DataTable dt = new DataTable();
dt.Load(dataReader);
DataRow[] rows = dt.Select();        //DataRow[] Implements IEnumerable

    ou

    IEnumerable<DataRow> rows = dt.AsEnumerable();
    InformationsquelleAutor Gabriel Kniznik
  6. 0

    J'ai utilisé ce qui suit, mais j'aime @Serge suggestion du mieux et il rappelle de ce que je crois que j'ai utilisé pour faire, mais ensuite il a oublié que IDataReader implémente 

    var reader = command.ExecuteReader();
var records = Enumerable
    .Range(0, int.MaxValue)
    .TakeWhile(i => reader.Read())
    .Select(i => reader as IDataRecord);
    InformationsquelleAutor jpierson