如何仅将唯一列与数据连接

Question

我在下面使用这个：

    public static DataTable DataTableJoiner(DataTable dt1, DataTable dt2)
    {
        using (DataTable targetTable = dt1.Clone())
        {
            var dt2Query = dt2.Columns.OfType<DataColumn>().Select(dc =>
                new DataColumn(dc.ColumnName, dc.DataType, dc.Expression, 
                    dc.ColumnMapping));
            var dt2FilterQuery = from dc in dt2Query.AsEnumerable()
                                 where targetTable.Columns
                                       .Contains(dc.ColumnName) == false
                                 select dc;
            targetTable.Columns.AddRange(dt2FilterQuery.ToArray());
            var rowData = from row1 in dt1.AsEnumerable()
                          join row2 in dt2.AsEnumerable()
                          on row1.Field<int>("Code") equals 
                             row2.Field<int>("Code")
                          select row1.ItemArray
                              .Concat(row2.ItemArray
                              .Where(r2 => 
                                  row1.ItemArray.Contains(r2) == false)).ToArray();
            foreach (object[] values in rowData) targetTable.Rows.Add(values);
            return targetTable;
        }
    }

这行有一个问题：

select row1.ItemArray.Concat(row2.ItemArray.Where(r2 => 
     row1.ItemArray.Contains(r2) == false)).ToArray();

它似乎在说，如果这个值（而不是列）已经存在，则不要包含我。

我使用此方法根据两个表共享的列将两个表连接在一起，但我只希望包含两个表数据的唯一列作为最终结果。

有什么想法吗？

Answer 1

我不确定我是否 100% 理解您的要求，但这：

row2.ItemArray.Where(r2 => row1.ItemArray.Contains(r2) == false)

将过滤掉那些恰好出现在表 1 任何列中的项目，而不仅仅是您要加入的列。

所以我想做的是根据索引过滤项目，使用 Where 扩展方法的重载：

// Get the index of the column we are joining on:
int joinColumnIndex = dt2.Columns.IndexOf("Code");

// Now we can filter out the proper item in the rowData query:
row2.ItemArray.Where((r2,idx) => idx != joinColumnIndex)

...

不，等等。这里：

var dt2FilterQuery = from dc in dt2Query.AsEnumerable()
                     where targetTable.Columns
                           .Contains(dc.ColumnName) == false
                     select dc;

你是过滤掉表 2 中名称也出现在表 1 中的所有列。所以您可能想要的是这样的：

public static DataTable DataTableJoiner(DataTable dt1, DataTable dt2)
{
    DataTable targetTable = dt1.Clone();

    var dt2Query = dt2.Columns.OfType<DataColumn>().Select(dc =>
        new DataColumn(dc.ColumnName, dc.DataType, dc.Expression, 
            dc.ColumnMapping));

    var dt2FilterQuery = from dc in dt2Query.AsEnumerable()
                         where !targetTable.Columns.Contains(dc.ColumnName)
                         select dc;

    var columnsToAdd = dt2FilterQuery.ToArray();
    var columnsIndices = columnsToAdd.Select(dc => dt2.Columns.IndexOf(dc.ColumnName));

    targetTable.Columns.AddRange(columnsToAdd);

    var rowData = from row1 in dt1.AsEnumerable()
                      join row2 in dt2.AsEnumerable()
                      on row1.Field<int>("Code") equals 
                         row2.Field<int>("Code")
                      select row1.ItemArray
                          .Concat(row2.ItemArray
                          .Where((r2,idx) => 
                              columnsIndices.Contains(idx))).ToArray();

    foreach (object[] values in rowData) targetTable.Rows.Add(values);
    return targetTable;
}

顺便说一句。我不太明白为什么您将返回的 DataTable 包装在 using 语句中。恕我直言，立即处理您返回给调用者的对象是毫无意义的......