运行时构建LINQ动态表连接查询无结果问题求助

问题描述 #

我正在尝试用LINQ实现动态查询，目标是解析JSON后在运行时构建查询。目前已经用Dynamic LINQ实现了select和where过滤，但动态表连接（join）功能遇到问题——运行时构建的连接查询没有返回结果。用普通的LINQ join查询能正常获取结果，且两张表都有数据。

现有代码 #

主查询代码 #

DataTable Table1 = xml.DataSet.Tables["PageA"];
DataTable Table2 = xml.DataSet.Tables["PageADetails"];

Dictionary<string, string> dictcolumnMapping = new Dictionary<string, string>();            
dictcolumnMapping.Add("ID", "PageADetailID");


var joins = from filerow in Table1.AsEnumerable()
            from dbrow in Table2.AsEnumerable().AsQueryable().WhereByMapping2(filerow, dictcolumnMapping)
            select new { filerecord = filerow, db = dbrow };

扩展方法代码 #

public static class DynamicQueryableExtender
{                
    public static IQueryable<DataRow> WhereByMapping2(this IQueryable<DataRow> source, DataRow parentSource, Dictionary<string, string> dictcolumnMapping)
    {
        foreach (var map in dictcolumnMapping)
        {
            source = source.Where(r => parentSource[map.Key] == r[map.Value]);
        }

        return source;
    }

}       

问题分析 #

你的代码用嵌套查询（from...from...）模拟join，但核心问题出在值类型比较逻辑：DataRow[]返回的是object类型，直接用==比较的是对象引用而非实际值内容。比如int类型字段会被装箱成object，此时==判断的是两个装箱对象的引用是否相等，而非数值本身是否一致。

另外，把Table2.AsEnumerable()转成IQueryable没有实际意义——AsEnumerable()已经将DataTable转为内存枚举集合，后续Where都是内存中执行，转IQueryable只会增加不必要的复杂度。

解决方案 #

方案1：修正值比较逻辑 #

修改扩展方法，用object.Equals()比较值内容而非引用，同时直接使用IEnumerable替代IQueryable：

public static class DynamicQueryableExtender
{                
    public static IEnumerable<DataRow> WhereByMapping2(this IEnumerable<DataRow> source, DataRow parentSource, Dictionary<string, string> dictcolumnMapping)
    {
        foreach (var map in dictcolumnMapping)
        {
            var parentValue = parentSource[map.Key];
            source = source.Where(r => object.Equals(parentValue, r[map.Value]));
        }

        return source;
    }
}

主查询代码简化为：

var joins = from filerow in Table1.AsEnumerable()
            from dbrow in Table2.AsEnumerable().WhereByMapping2(filerow, dictcolumnMapping)
            select new { filerecord = filerow, db = dbrow };

方案2：动态构建标准Join（更贴合动态查询需求） #

如果需要支持多字段连接、运行时灵活配置连接条件，可以用表达式树自定义动态Join逻辑：

public static class DynamicJoinExtender
{
    public static IEnumerable<TResult> DynamicJoin<TOuter, TInner, TResult>(
        this IEnumerable<TOuter> outer,
        IEnumerable<TInner> inner,
        Dictionary<string, string> columnMappings,
        Func<TOuter, TInner, TResult> resultSelector)
        where TOuter : DataRow
        where TInner : DataRow
    {
        Func<TOuter, TInner, bool> joinPredicate = (outerRow, innerRow) =>
        {
            foreach (var map in columnMappings)
            {
                if (!object.Equals(outerRow[map.Key], innerRow[map.Value]))
                    return false;
            }
            return true;
        };

        return outer.Join(inner, 
                         outerRow => outerRow, 
                         innerRow => innerRow, 
                         resultSelector, 
                         new DataRowEqualityComparer(joinPredicate));
    }

    private class DataRowEqualityComparer : IEqualityComparer<DataRow>
    {
        private readonly Func<DataRow, DataRow, bool> _predicate;

        public DataRowEqualityComparer(Func<DataRow, DataRow, bool> predicate)
        {
            _predicate = predicate;
        }

        public bool Equals(DataRow x, DataRow y)
        {
            return _predicate(x, y);
        }

        public int GetHashCode(DataRow obj)
        {
            return obj.ItemArray.Aggregate(0, (hash, val) => hash ^ (val?.GetHashCode() ?? 0));
        }
    }
}

使用方式：

var joins = Table1.AsEnumerable().DynamicJoin(
    Table2.AsEnumerable(),
    dictcolumnMapping,
    (filerow, dbrow) => new { filerecord = filerow, db = dbrow });

验证步骤 #

• 单独测试WhereByMapping2：取Table1中一行数据传入方法，确认是否能从Table2筛选出匹配行，验证条件是否生效。
• 检查连接字段类型：确保Table1和Table2的连接字段类型一致（如均为int），避免类型不匹配导致比较失败。
• 处理null值：如果连接字段可能为null，object.Equals()会正确处理null比较，而直接==会出现异常或判断错误。

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