Mejor forma de consumir un IEnumerable <IEnumerable <string>>

Question

Estoy llamando a un procedimiento almacenado con varios conjuntos de resultados (siempre 2) y escribiendo los resultados para separar los archivos (en formato delimitado por tuberías). No puedo dividir los conjuntos de resultados en procesos almacenados separados. Estoy usando IDataReader e IEnumerable para mantener tan poca memoria en el proceso.

¿Hay alguna manera más clara de consumir mi IEnumerable<IEnumerable<string>> que usar GetEnumerator/MoveNext/Current para obtener el IEnumerable<string> interno para pasar a File.AppendAllLines?

public void Execute() 
    { 
     var reader = GetLines(); 

     using (var enumerator = reader.GetEnumerator()) 
     { 
      enumerator.MoveNext(); 

      File.AppendAllLines("file1.dat", enumerator.Current); 
      enumerator.MoveNext(); 

      File.AppendAllLines("file2.dat", enumerator.Current); 
     } 
    } 

    public IEnumerable<IEnumerable<string>> GetLines() 
    { 
     Database db = DatabaseFactory.CreateDatabase("connectionStringKey"); 
     using (var command = db.GetStoredProcCommand("getdata_sp")) 
     { 
      var reader = db.ExecuteReader(command); 
      yield return GetInnerEnumerable(reader); 
      reader.NextResult(); 
      yield return GetInnerEnumerable(reader); 
     } 
    } 

    private IEnumerable<string> GetInnerEnumerable(IDataReader reader) 
    { 
     while (reader.Read()) 
     { 
      object[] rowValues = new object[reader.FieldCount]; 
      reader.GetValues(rowValues); 
      yield return String.Join("|", rowValues); 
     } 
    } 

Answer 1

¿Por qué no un foreach loop? Eso es lo más básico.

Answer 2

Personalmente, sólo tiene que utilizar un bucle foreach con una variable independiente para el seguimiento de qué archivo para escribir en, algo así como:

public void Execute() 
{ 
    var reader = GetLines(); 

    int i = 0; 
    foreach (var inner in reader) 
    { 
     if (i % 2 == 0) 
      File.AppendAllLines("file1.dat", inner); 
     else 
      File.AppendAllLines("file2.dat", inner); 
     ++i; 
    } 
} 

Answer 3

Tal vez gire el resultado de GetLines() en una matriz y acceder a ella por el índice (ya que dijiste que siempre habrá 2 conjuntos de resultados)?

public void Execute() 
{ 
    IEnumerable<string>[] rows = GetLines().ToArray(); 

    File.AppendAllLines("file1.dat", rows[0]); 
    File.AppendAllLines("file2.dat", rows[1]); 
} 

Answer 4

Usted podría utilizar SelectMany() para aplanar la enumeración, ya que sólo está interesado en los propios valores.

Editar:

Según comentario SelectMany() es inadecuada dado el caso de uso, así que lo mejor es utilizar un bucle foreach:

var reader = GetLines(); 
int index = 0; 
foreach(var lines in reader) 
    File.AppendAllLines(string.Format("file{0}.dat", index++%2 + 1), lines); 

Answer 5

foreach es apoyado implícitamente por IEnumerable. Por lo tanto:

public void Execute() 
{ 
    var reader = GetLines(); 

    using (var enumerator = reader.GetEnumerator()) 
    { 
     enumerator.MoveNext(); 

     File.AppendAllLines("file1.dat", enumerator.Current); 
     enumerator.MoveNext(); 

     File.AppendAllLines("file2.dat", enumerator.Current); 
    } 
} 

se convierte en:

public void Execute() 
{ 
    var reader = GetLines(); 

    int index = 0; 

    foreach (string line in reader) 
    { 
     if ((index % 2) == 0) 
      File.AppendAllLines("file1.dat", line); 

     else 
      File.AppendAllLines("file2.dat", line); 

     index++; 
    } 
} 

O:

public void Execute() 
{ 
    var reader = GetLines(); 

    var evenLines = reader.Where((str, i) => i % 2 == 0); 
    var oddLines = reader.Where((str, i) => i % 2 != 0); 

    foreach (string line in evenLines) 
     File.AppendAllLines("file1.dat", line); 

    foreach (string line in oddLines) 
     File.AppendAllLines("file2.dat", line); 
} 

Answer 6

me acaba de cambiar mi método GetLines a la siguiente

public IEnumerable<string> GetLines() 
{ 
    Database db = DatabaseFactory.CreateDatabase("connectionStringKey"); 
    using (var command = db.GetStoredProcCommand("getdata_sp")) 
    { 
     var reader = db.ExecuteReader(command); 
     for (var i = 0; i < 2; i++) 
     { 
      foreach(var cur in GetInnerEnumerable(reader)) 
      { 
      yield return cur; 
      } 
      reader.NextResult(); 
     } 
    } 
} 

Tener que devolver un IEnumerable<IEnumerable<string>> w producir una carga innecesaria para los consumidores de la API. Supongo que todos preferirán ver esto como IEnumerable<string>.

Answer 7

Puede comprimir sus resultados en un Tuple<> con los nombres de archivo de esta manera:

using System.Linq; 
using FileZip = System.Tuple< 
    System.String, 
    System.Collections.Generic.IEnumerable< 
     System.String>>; 

public void Execute() 
{ 
    var files = new string[] { "file1.dat", "file2.dat" }; 
    var results = GetLines(); 

    foreach (var file in files.Zip(results, (f, r) => new FileZip(f, r))) 
    { 
     File.AppendAllLines(file.Item1, file.Item2); 
    } 
} 

Por supuesto, estoy bastante seguro de que esto va a lanzar tan pronto como regrese un número diferente de filas, pero hará lo que estás buscando.