0

感谢您阅读本文。

这是我的目标:我有两个从 Excel 工作表中读取的数据表。数据表具有相同的架构(Datatable1 中的 A、B、C 列...与 Datatable2 中的 A、B、C 列...具有相同类型的数据)。

我需要按任意列比较表中的数据(即仅用于比较 A 列和 C 列,但我需要将数据保留在 A、B、C、...、N 列中)。

由于我是从 Excel 工作表中读取这些内容,因此无法预期该架构。例如,如果我加载一组不同的工作表,比较列可能会有所不同。由于这个原因,我不能使用 LINQ,它就像一个硬编码的 SQL 语句。

我需要执行相当于 FULL OUTER JOIN 的操作。我正在尝试显示所有数据,包括任一数据表中未出现在另一个数据表中的缺失数据。

我已经阅读了一些关于 DataRelations 的内容,但我不确定如何使用它们。

请提供示例代码。

提前致谢!

4

1 回答 1

1

给定一对DataTable具有任意列数的 s,并给定一个函数,该函数可以从这两个 s 中的每一个中创建一个合理类型的分组值DataTable,您可以使用 Linq 为您完成大部分工作。

DataTable让我们从一个从s中提取连接键的函数开始。只返回一个很好object[],但它们的比较不好。然而,我们可以用 a 来做到这一点Tuple<object, object>- 那些很好地为此目的工作。如果您需要更多列,您可以添加更多列:P

// Produces a JoinKey as Tuple containing columns 'A' and 'C' (0 and 2)
public Tuple<object, object> GetJoinKey(DataRow row)
{
    return Tuple.Create(row[0], row[2]);
}

现在加入。我们不能直接进行完全外连接,但我们可以通过两种方式和Union结果进行外连接:

// given DataTables table1 & table2:
var outerjoin = 
    (
        from row1 in table1.AsEnumerable()
        join row2 in table2.AsEnumerable() 
            on GetJoinKey(row1) equals GetJoinKey(row2)
            into matches
        from row2 in matches.DefaultIfEmpty()
        select new { key = GetJoinKey(row1), row1, row2 }
    ).Union(
        from row2 in table2.AsEnumerable()
        join row1 in table1.AsEnumerable()
            on GetJoinKey(row2) equals GetJoinKey(row1)
            into matches
        from row1 in matches.DefaultIfEmpty()
        select new { key = GetJoinKey(row2), row1, row2 }
    );

接下来,您必须创建一个合适的输出格式 - 一个DataTable包含来自两个来源的所有行,以及一个包含有关键的一些信息的字段:

DataTable result = new DataTable();
// add column for string value of key:
result.Columns.Add("__key", typeof(string));
// add columns from table1:
foreach (var col in table1.Columns.OfType<DataColumn>())
    result.Columns.Add("T1_" + col.ColumnName, col.DataType);
// add columns from table2:
foreach (var col in table2.Columns.OfType<DataColumn>())
    result.Columns.Add("T2_" + col.ColumnName, col.DataType);

最后,从查询中填写表格:

var row1def = new object[table1.Columns.Count];
var row2def = new object[table2.Columns.Count];
foreach (var src in outerjoin)
{
    // extract values from each row where present
    var data1 = (src.row1 == null ? row1def : src.row1.ItemArray);
    var data2 = (src.row2 == null ? row2def : src.row2.ItemArray);

    // create row with key string and row values
    result.Rows.Add(new object[] { src.key.ToString() }.Concat(data1).Concat(data2).ToArray());
}

当然,我们可以缩短其中的几个操作来获得一个为我们完成 99% 工作的 Linq 查询。如果听起来很有趣,我会把它留给你玩。

这是完整的方法,作为连接键生成器的通用函数的扩展完成,使其相当通用:

public static DataTable FullOuterJoin<T>(this DataTable table1, DataTable table2, Func<DataRow, T> keygen)
{
    // perform inital outer join operation
    var outerjoin = 
        (
            from row1 in table1.AsEnumerable()
            join row2 in table2.AsEnumerable() 
                on keygen(row1) equals keygen(row2)
                into matches
            from row2 in matches.DefaultIfEmpty()
            select new { key = keygen(row1), row1, row2 }
        ).Union(
            from row2 in table2.AsEnumerable()
            join row1 in table1.AsEnumerable()
                on keygen(row2) equals keygen(row1)
                into matches
            from row1 in matches.DefaultIfEmpty()
            select new { key = keygen(row2), row1, row2 }
        );

    // Create result table
    DataTable result = new DataTable();
    result.Columns.Add("__key", typeof(string));
    foreach (var col in table1.Columns.OfType<DataColumn>())
        result.Columns.Add("T1_" + col.ColumnName, col.DataType);
    foreach (var col in table2.Columns.OfType<DataColumn>())
        result.Columns.Add("T2_" + col.ColumnName, col.DataType);

    // fill table from join query
    var row1def = new object[table1.Columns.Count];
    var row2def = new object[table2.Columns.Count];
    foreach (var src in outerjoin)
    {
        // extract values from each row where present
        var data1 = (src.row1 == null ? row1def : src.row1.ItemArray);
        var data2 = (src.row2 == null ? row2def : src.row2.ItemArray);

        // create row with key string and row values
        result.Rows.Add(new object[] { src.key.ToString() }.Concat(data1).Concat(data2).ToArray());
    }

    return result;
}

现在,如果表具有相同的架构(上面不关心),您可以做几乎完全相同的事情 - 修改结果表生成以克隆其中一个表,然后在加载中添加一些合并逻辑环形。

这是上面的要点,通过测试和验证它正在做它所说的。把它放到你的编译器中,看看你会得到什么。

于 2014-07-25T06:23:02.633 回答