如何在C# LINQ中实现泛型Join()方法关联两个DBSets？

需求背景 #

需要实现一个泛型Join函数，关联两个DbSet（TEntity类型实体集与TParent类型父实体集），返回IQueryable<cObjectNames>结果集，每个对象包含实体主键Id（映射到eId）和父实体的指定名称列值（映射到name）。

约束条件：

• TEntity与TParent均实现IBaseEntity接口，Id字段可用
• 需通过参数指定TEntity的外键列与TParent的名称列
• 禁止使用Dynamic LINQ，必须基于LINQ表达式树实现

相关类型定义：

public class cObjectNames 
{
    public int eId{ get; set; }
    public string name{ get; set; }
}

public interface IBaseEntity
{
    int Id { get; set; }
    DateTimeOffset Created { get; set; }
    DateTimeOffset? Lastupdated { get; set; }
    DateTimeOffset? Deleted { get; set; }
}

解决方案代码 #

using System;
using System.Linq;
using System.Linq.Expressions;
using System.Reflection;

public static class QueryExtensions
{
    public static IQueryable<cObjectNames> Join<TEntity, TParent>(
        this IQueryable<TEntity> entities,
        IQueryable<TParent> parentEntities,
        string fkCol,
        string parentNameCol)
        where TEntity : class, IBaseEntity
        where TParent : class, IBaseEntity
    {
        // 获取TEntity的外键属性，不存在则抛出异常
        var fkProperty = typeof(TEntity).GetProperty(fkCol) 
            ?? throw new ArgumentException($"属性 {fkCol} 不存在于类型 {typeof(TEntity)}");
        var entityParam = Expression.Parameter(typeof(TEntity), "e");
        var fkAccessExpr = Expression.Property(entityParam, fkProperty);
        var entityKeySelector = Expression.Lambda<Func<TEntity, int>>(fkAccessExpr, entityParam);

        // 获取TParent的Id属性，作为关联匹配键
        var parentIdProperty = typeof(TParent).GetProperty(nameof(IBaseEntity.Id));
        var parentParam = Expression.Parameter(typeof(TParent), "p");
        var parentIdAccessExpr = Expression.Property(parentParam, parentIdProperty);
        var parentKeySelector = Expression.Lambda<Func<TParent, int>>(parentIdAccessExpr, parentParam);

        // 获取TParent的名称属性，不存在则抛出异常
        var parentNameProperty = typeof(TParent).GetProperty(parentNameCol)
            ?? throw new ArgumentException($"属性 {parentNameCol} 不存在于类型 {typeof(TParent)}");
        var parentNameAccessExpr = Expression.Property(parentParam, parentNameProperty);

        // 获取TEntity的Id属性
        var entityIdProperty = typeof(TEntity).GetProperty(nameof(IBaseEntity.Id));
        var entityIdAccessExpr = Expression.Property(entityParam, entityIdProperty);

        // 构建cObjectNames的初始化表达式，映射字段值
        var resultInit = Expression.MemberInit(
            Expression.New(typeof(cObjectNames)),
            Expression.Bind(typeof(cObjectNames).GetProperty(nameof(cObjectNames.eId)), entityIdAccessExpr),
            Expression.Bind(typeof(cObjectNames).GetProperty(nameof(cObjectNames.name)), parentNameAccessExpr));
        
        var resultSelector = Expression.Lambda<Func<TEntity, TParent, cObjectNames>>(resultInit, entityParam, parentParam);

        // 执行Join查询并返回结果
        return entities.Join(parentEntities, entityKeySelector, parentKeySelector, resultSelector);
    }
}

实现说明 #

• 属性安全校验：通过GetProperty获取属性信息，若属性不存在则抛出明确异常，避免隐式运行时错误
• 表达式树构建：手动构建键选择器与结果投影的lambda表达式，确保EF Core能正确解析并转换为SQL查询
• 强类型映射：通过MemberInitExpression将实体属性值映射到cObjectNames的对应字段，保证类型安全

使用示例 #

// 假设存在Order实体（外键CustomerId）和Customer实体（名称列Name）
var orders = dbContext.Orders;
var customers = dbContext.Customers;

// 调用泛型Join方法
var queryResult = orders.Join(customers, nameof(Order.CustomerId), nameof(Customer.Name));

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