.NET 6 EF Core全局查询过滤器动态关联实体问题求助

问题场景 #

在.NET 6 EF Core项目中使用全局查询过滤器时，多数场景运行正常，但遇到特殊需求无法实现：

• 需要通过Table A的数据过滤Table B
• 当Table A和Table B的特性指向同一张表且RecordId值相同时，需依据特性表中的表名动态关联对应实体，判断该实体的IsExpired状态来过滤Table B
• 现有代码无法在全局查询过滤器中基于表名动态引用实体，尝试过FromSqlRaw、反射、Set(entityName)等方法均未解决

现有问题代码 #

!TableA.Characteristic.IsTableBased && !TableB.Characteristic.IsTableBased
             && TableA.Characteristic.TableName == TableB.Characteristic.TableName
             && TableA.RecordId == TableB.RecordId
             && this.Set<BaseEntity<int>>(TableA.Characteristic.TableName).First(x => x.Id == gradeCharacteristic.RecordId).!IsExpired

注：代码中.!IsExpired应为.IsExpired的取反写法，且First()会触发客户端求值，无法被EF Core解析为SQL。

解决思路与实现 #

EF Core全局查询过滤器要求表达式能被解析为SQL，动态调用Set<T>(tableName)无法被EF的表达式树解析，因此需通过表达式树动态构建关联条件或预定义表-实体映射来解决。

方案1：表达式树动态构建过滤条件 #

核心思路是提前维护表名与实体类型的映射，通过表达式树动态生成EXISTS子查询（用Any()代替First()），让EF能解析为合法的SQL关联。

实现代码

// 提前定义表名到实体类型的映射（根据实际项目补充）
private static readonly Dictionary<string, Type> _tableEntityMap = new()
{
    ["Student"] = typeof(Student),
    ["Course"] = typeof(Course),
    ["Grade"] = typeof(Grade)
};

// 在DbContext的OnModelCreating中配置TableB的全局查询过滤器
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.Entity<TableB>().HasQueryFilter(BuildTableBFilterExpression());
}

// 构建动态过滤表达式的辅助方法
private Expression<Func<TableB, bool>> BuildTableBFilterExpression()
{
    // 定义TableB的参数表达式
    var bParam = Expression.Parameter(typeof(TableB), "b");
    
    // 基础条件表达式：特性非表基、表名一致、RecordId一致
    var baseCondition = Expression.AndAlso(
        Expression.AndAlso(
            Expression.Not(Expression.Property(bParam, nameof(TableB.Characteristic.IsTableBased))),
            Expression.Equal(
                Expression.Property(Expression.Property(bParam, nameof(TableB.TableA)), nameof(TableA.Characteristic.TableName)),
                Expression.Property(bParam, nameof(TableB.Characteristic.TableName))
            )
        ),
        Expression.Equal(
            Expression.Property(Expression.Property(bParam, nameof(TableB.TableA)), nameof(TableA.RecordId)),
            Expression.Property(bParam, nameof(TableB.RecordId))
        )
    );

    // 动态构建关联实体的IsExpired判断表达式
    var tableNameProperty = Expression.Property(Expression.Property(bParam, nameof(TableB.TableA)), nameof(TableA.Characteristic.TableName));
    var recordIdProperty = Expression.Property(Expression.Property(bParam, nameof(TableB.TableA)), nameof(TableA.RecordId));
    
    // 调用辅助方法生成动态判断表达式
    var isExpiredCondition = BuildDynamicIsExpiredExpression(tableNameProperty, recordIdProperty);

    // 合并基础条件与动态条件
    var finalCondition = Expression.AndAlso(baseCondition, isExpiredCondition);
    
    return Expression.Lambda<Func<TableB, bool>>(finalCondition, bParam);
}

// 构建动态关联实体的IsExpired判断表达式
private Expression BuildDynamicIsExpiredExpression(Expression tableNameExpr, Expression recordIdExpr)
{
    // 创建一个switch表达式，根据表名映射到对应实体的判断逻辑
    var cases = new List<SwitchCase>();
    foreach (var (tableName, entityType) in _tableEntityMap)
    {
        // 构建该实体的EXISTS子查询：EXISTS(SELECT 1 FROM [Table] WHERE Id = RecordId AND IsExpired = false)
        var dbSet = Expression.Call(
            typeof(DbContext).GetMethod(nameof(DbContext.Set)).MakeGenericMethod(entityType),
            Expression.Constant(this)
        );
        
        var entityParam = Expression.Parameter(entityType, "e");
        var idEquals = Expression.Equal(
            Expression.Property(entityParam, nameof(BaseEntity<int>.Id)),
            recordIdExpr
        );
        var notExpired = Expression.Not(Expression.Property(entityParam, nameof(BaseEntity<int>.IsExpired)));
        var whereLambda = Expression.Lambda(Expression.AndAlso(idEquals, notExpired), entityParam);
        
        var anyCall = Expression.Call(
            typeof(Queryable).GetMethods().First(m => m.Name == nameof(Queryable.Any) && m.GetParameters().Length == 2)
                .MakeGenericMethod(entityType),
            dbSet,
            whereLambda
        );
        
        // 添加switch case
        cases.Add(Expression.SwitchCase(anyCall, Expression.Constant(tableName)));
    }

    // 默认返回true（或根据需求调整为false，即未匹配到表名时的默认逻辑）
    var defaultCase = Expression.Constant(true);
    
    // 构建switch表达式
    return Expression.Switch(tableNameExpr, defaultCase, cases.ToArray());
}

方案2：数据库视图映射 #

如果动态表达式实现复杂，可将关联逻辑提前写入数据库视图：

1. 创建数据库视图，关联Table A、Table B及对应特性表，计算出IsValid字段（即对应实体未过期）
2. 将视图映射为EF Core实体
3. 直接在全局查询过滤器中使用视图的IsValid字段过滤

关键注意事项 #

• 避免使用First()/Single()等会触发客户端求值的方法，改用Any()生成EXISTS子查询，确保EF能解析为SQL
• 表名与实体类型的映射需提前维护，确保覆盖所有可能的业务场景
• 动态表达式需在OnModelCreating中构建，确保EF能正确解析并缓存查询计划

内容的提问来源于stack exchange，提问作者David Abou Karam