0

Linqを使用して2つのDataColumnsで2つのDataTablesを内部結合しようとしていますが、Linqを使用して行を取得できますが、列を取得できません。以下に示すように、列を取得するために何をしようとしたかをコメントアウトしました。

これを行う理由。

DataTableを返すLEFTJOIN、FULL JOIN、INNER JOINの3つのメソッドを作成することを計画しています。可能な限り一般的なものにしようとしていますが、以下が適切かどうかは示されていません。可能な限り最適化するためにこれを行います。

     public static DataTable InnerJoin
     (DataTable dt1, DataTable dt2,DataColumn Parent,DataColumn Child)
     {
          DataTable result = new DataTable();


          var query =
              from d in dt1.AsEnumerable()
              join c in dt2.AsEnumerable() on d[Parent] equals c[Child]
              select new { d, c };
         /*
         var columns  = from d in dt1.Columns.Cast<DataColumn>()
                        from c in dt2.Columns.Cast<DataColumn>()
                          select new{c,d}
          foreach (var column in columns)
          {
              result.Columns.Add(column);
          }
          **/

          foreach (var row in query)
          {
              result.Rows.Add(row);
          }

         return result;
     }
4

1 に答える 1

1

をとるオーバーロードがあるため、コードはコンパイルされますparams object[]。ただし、タイプが。の2つの列を追加する必要がありますDataRow。

public static DataTable InnerJoin(DataTable dt1, DataTable dt2, DataColumn Parent, DataColumn Child)
{
    DataTable result = new DataTable();
    result.Columns.Add("Row1", typeof(DataRow));
    result.Columns.Add("Row2", typeof(DataRow));

    var query =
        from row1 in dt1.AsEnumerable()
        join row2 in dt2.AsEnumerable() on row1[Parent] equals row2[Child]
        select new { row1, row2 };

    foreach (var x in query)
    {
        result.Rows.Add(x.row1, x.row2);
    }

    return result;
}

それが必要な場合は、機能するはずです。

編集:そしてこれが（動作中の）テストです

DataTable table1 = new DataTable("table1");
table1.Columns.Add("ID", typeof(int));
table1.Columns.Add("Name", typeof(String));

object[] a1 = { 1, "T1Row1Name" };
object[] a2 = { 2, "T1Row2Name" };
object[] a3 = { 3, "T1Row3Name" };
object[] a4 = { 4, "T1Row4Name" };
table1.Rows.Add(a1);
table1.Rows.Add(a2);
table1.Rows.Add(a3);
table1.Rows.Add(a4);

DataTable table2 = new DataTable("table2");
table2.Columns.Add("ID", typeof(int));
table2.Columns.Add("Name", typeof(String));
table2.Columns.Add("Table1ID", typeof(int));


object[] b1 = { 1, "T2Row1Name", 1 };
object[] b2 = { 2, "T2Row2Name", 2 };
object[] b3 = { 3, "T2Row3Name", 2 };
object[] b4 = { 4, "T2Row4Name", 2 };
object[] b5 = { 5, "T2Row5Name", 3 };
table2.Rows.Add(b1);
table2.Rows.Add(b2);
table2.Rows.Add(b3);
table2.Rows.Add(b4);
table2.Rows.Add(b5);

var joinedTable = InnerJoin(table1, table2, table1.Columns["ID"], table2.Columns["Table1ID"]);

foreach (DataRow r in joinedTable.Rows)
{
    DataRow r1 = r.Field<DataRow>("Row1");
    DataRow r2 = r.Field<DataRow>("Row2");
    String r1Name = r1.Field<String>("Name");
    String r2Name = r2.Field<String>("Name");
}
于 2012-10-18T07:11:07.013 に答える