ExpandoObjectに複数のデータセット

Question

私は現在sprocを呼び出しています。 sprocから返されたデータは、IDictionary<string, object>のExpandoObjectを返しました。これは、sprocごとに1つのデータセットに対して完全に正常に機能します。今私はsprocに出くわしました。これは2つの異なるテーブルにデータを返します。関数を呼び出すと、最初のテーブルからデータが取得されます。だから私の質問は、次のデータセットのデータも返すことができます。

注 - 私はSPROCを

私がこれまで持っているコードを変更する権限を持っていないです：それは大したことを見ていない一見

using(SqlDataReader reader = cmd.ExecuteReader()) 
{ 
    var names = Enumerable.Range(0, reader.FieldCount).Select(reader.GetName).ToList(); 

    foreach (IDataRecord record in reader as IEnumerable) 
    { 
     IDictionary<string, object> expando = new ExpandoObject() as IDictionary<string, object>; 
     foreach (var name in names) 
     expando[name] = record[name]; 

     yield return expando; //yield return to keep the reader open 
    } 
} 

Answer 1

。 foreachをReadおよびNextResultのメソッドを使用して2つのネストしたループに置き換え、メソッドの戻り値の型をIEnumerable<dynamic>からIEnumerable<IEnumerable<dynamic>>（またはdynamicの代わりにIDictionary<string, object>）に変更します。

しかし、問題はIEnumerableが遅れて評価され、DataReaderが順方向のカーソルであり、1回しか消費できないということです。

1つの解決策は、呼び出し元に返す前にすべての結果（データセット）をメモリにバッファリングすることです（たとえば、List<dynamic>を使用します）が、遅延実行のメリットはありません。 Indexフィールドは、結果が含まれます

public struct QueryResult 
{ 
    public readonly int Index; 
    public readonly dynamic Data; 
    internal QueryResult(int index, dynamic data) 
    { 
     Index = index; 
     Data = data; 
    } 
} 

（データセット）インデックス（0：次のタイプのフラットな結果セットを返すメソッド -

むしろバッファリングを行うよりも、私はあなたに別のアプローチを示唆しています、1,2など）。これは、最も適切な方法を使用して遅延実行の利点を維持し、呼び出し側のプロセスを聞かせ - foreachループ（複数可）を使用して、インスタンスのために、LINQ GroupBy、MoreLINQGroupAdjacentなど

その設計上の決定では実装が簡単です：

static IEnumerable<QueryResult> GetData(SqlCommand command) 
{ 
    using (var reader = command.ExecuteReader()) 
    { 
     int index = 0; 
     do 
     { 
      while (reader.Read()) 
      { 
       IDictionary<string, object> expando = new ExpandoObject(); 
       for (int i = 0; i < reader.FieldCount; i++) 
        expando.Add(reader.GetName(i), reader.GetValue(i)); 
       yield return new QueryResult(index, expando); 
      } 
      index++; 
     } 
     while (reader.NextResult()); 
    } 
}