更好的方式來使用IEnumerable <IEnumerable <string>>

Question

我打電話給多個結果集（總是2）並將結果寫入單獨文件（以管道分隔格式）的存儲過程。我無法將結果集分成單獨存儲的特效。我正在使用IDataReader和IEnumerable在內存中保持儘可能少的內容。

是否有比使用GetEnumerator/MoveNext/Current去內部IEnumerable<string>傳遞給File.AppendAllLines更簡單的方法來使用我的IEnumerable<IEnumerable<string>>？

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

爲什麼不是foreach循環？這是最基本的。

Answer 2

就個人而言，我只想用一個foreach循環與跟蹤一個獨立的變量寫到哪個文件，是這樣的：

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

也許轉的GetLines()結果到一個數組中，並通過索引訪問它（既然你說過總會有2個結果集）？

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

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

Answer 4

您可以使用SelectMany()來枚舉枚舉，因爲您只對值本身感興趣。

編輯：

按照評論SelectMany()不適合給定的用例，所以最好是使用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是隱含IEnumerable的支持。所以：

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 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++; 
    } 
} 

或者：

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

我只想改變我GetLines方法如下

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(); 
     } 
    } 
} 

讓它返回一個IEnumerable<IEnumerable<string>>瓦特虐待給API的消費者帶來不必要的負擔。我的猜測是，他們只會更願意將此視爲IEnumerable<string>。

Answer 7

你可以壓縮你的結果與你的所有文件名，Tuple<>像這樣：

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); 
    } 
} 

當然，我敢肯定，這是怎麼回事，你返回不同的行數，以儘快拋出，但它會做你想要的。