如何基于多列对两个DataTable执行Left Join？以及增量上传场景下如何筛选源DataTable中的未匹配新行

Hey，我刚好做过不少这类增量数据同步的场景，给你一步步拆解怎么用LINQ实现需求：

我们要完成两个关键操作：

1. 对两个DataTable基于多列匹配执行Left Join
2. 从源DataTable中筛选出未匹配右表的行（也就是增量数据），用于上传同步

DataTable直接用LINQ操作不够灵活，先把它转成匿名类型的集合（如果有实体类的话用实体类更方便），同时提取出匹配用的键列和需要上传的业务字段：

// 源表（待上传的数据源）
var sourceRows = sourceTable.AsEnumerable()
    .Select(row => new 
    {
        // 多列匹配的键，这里示例用ID和Code两列
        MatchKey1 = row.Field<int>("ID"),
        MatchKey2 = row.Field<string>("Code"),
        // 需要上传的业务字段
        ProductName = row.Field<string>("ProductName"),
        Price = row.Field<decimal>("Price"),
        Stock = row.Field<int>("Stock")
    });

// 目标表（已上传的历史数据）
var targetRows = targetTable.AsEnumerable()
    .Select(row => new 
    {
        // 必须和源表的键属性名、类型完全一致
        MatchKey1 = row.Field<int>("ID"),
        MatchKey2 = row.Field<string>("Code")
        // 目标表只需要匹配键，不需要其他字段
    });

这里用AsEnumerable()把DataTable转为IEnumerable<DataRow>，Field<T>()方法可以安全地获取列值，避免类型转换异常。

方式一：LINQ Left Join语法（直观易读） #

用标准的左连接语法，通过匿名类实现多列匹配，然后筛选出右表无匹配的行：

var incrementalRows = from s in sourceRows
                      join t in targetRows 
                      // 多列匹配：匿名类的属性名+类型完全一致才会匹配成功
                      on new { s.MatchKey1, s.MatchKey2 } equals new { t.MatchKey1, t.MatchKey2 } into joinedGroup
                      // Left Join的核心：如果没有匹配项，用DefaultIfEmpty()返回null
                      from matchedRow in joinedGroup.DefaultIfEmpty()
                      // 筛选出右表无匹配的行，就是需要上传的增量数据
                      where matchedRow == null
                      select s;

方式二：HashSet匹配（大数据量场景更高效） #

如果两个表的数据量很大，Left Join的O(n*m)复杂度会影响性能，这时候可以把目标表的键存入HashSet，用O(1)的Contains操作来筛选：

// 把目标表的多列键转成Tuple存入HashSet
var targetKeySet = new HashSet<Tuple<int, string>>(
    targetRows.Select(t => Tuple.Create(t.MatchKey1, t.MatchKey2))
);

// 筛选源表中不在目标键集合里的行
var incrementalRows = sourceRows.Where(s => 
    !targetKeySet.Contains(Tuple.Create(s.MatchKey1, s.MatchKey2))
);

这种方式性能提升明显，尤其是当目标表有上万条数据的时候。

如果你的上传接口要求传入DataTable格式，可以把筛选后的集合转回去：

// 创建和源表结构一致的空DataTable
DataTable incrementalTable = sourceTable.Clone();

foreach (var row in incrementalRows)
{
    incrementalTable.Rows.Add(
        row.MatchKey1,
        row.MatchKey2,
        row.ProductName,
        row.Price,
        row.Stock
    );
}

用Clone()可以直接复制源表的列结构，比手动添加列更高效。

• 匹配列的一致性：多列匹配时，源表和目标表的键列必须类型完全一致，匿名类的属性名也要相同，否则匹配会失败。
• 空值处理：如果匹配列可能为空，要提前处理（比如用row.Field<T?>()或者默认值），避免匹配逻辑出错。
• 性能优化：大数据量场景优先用HashSet方式，或者给目标表的匹配列建立数据库索引（如果目标表来自数据库）。

内容的提问来源于stack exchange，提问作者rajquest