在Entity Framework与C#中自定义DbSet的LINQ Where子句处理

要实现对特定DbContext的查询前置处理，且对调用方完全透明，可通过自定义表达式访问器+EF Core查询拦截器实现，以下是具体步骤：

1. 实现自定义表达式访问器 #

该访问器负责解析Where子句的表达式树，提取目标属性、比较器和参数值，再根据需求修改表达式（如替换参数为哈希值）或记录查询参数：

// 需要引用 using System.Security.Cryptography; using System.Text;
public class PersonQueryVisitor : ExpressionVisitor
{
    protected override Expression VisitBinary(BinaryExpression node)
    {
        // 识别针对person.Name的相等比较逻辑
        if (node.NodeType == ExpressionType.Equal && IsPersonNameProperty(node.Left))
        {
            // 提取原始查询参数值
            var valueExpr = node.Right as ConstantExpression;
            if (valueExpr != null)
            {
                var originalName = valueExpr.Value.ToString();
                
                // 示例1：记录被查询的Name参数
                Console.WriteLine($"被查询的Name：{originalName}");
                
                // 示例2：将Name替换为哈希值后再查询
                using var md5 = MD5.Create();
                var hashBytes = md5.ComputeHash(Encoding.UTF8.GetBytes(originalName));
                var hashedName = BitConverter.ToString(hashBytes).Replace("-", "").ToLower();
                
                // 返回修改后的相等表达式
                return Expression.Equal(node.Left, Expression.Constant(hashedName));
            }
        }
        return base.VisitBinary(node);
    }

    // 判断表达式是否为person.Name属性的访问
    private bool IsPersonNameProperty(Expression expression)
    {
        var memberExpr = expression as MemberExpression;
        return memberExpr != null && 
               memberExpr.Member.DeclaringType == typeof(person) && 
               memberExpr.Member.Name == nameof(person.Name);
    }
}

2. 为特定DbContext注册查询拦截器 #

在MyContext中注册自定义拦截器，仅对当前DbContext的查询生效，拦截并修改查询表达式：

public class MyContext : DbContext
{
    public DbSet<person> persons { get; set; }

    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        // 注册查询表达式拦截器，仅作用于当前MyContext
        optionsBuilder.AddInterceptors(new PersonQueryInterceptor());
        // 添加你的数据库连接配置，例如SQL Server：
        // optionsBuilder.UseSqlServer("your_connection_string");
    }

    // 自定义查询拦截器
    private class PersonQueryInterceptor : IQueryExpressionInterceptor
    {
        public Expression QueryCreating(Expression queryExpression, QueryExpressionEventData eventData)
        {
            // 用自定义访问器修改查询表达式树
            return new PersonQueryVisitor().Visit(queryExpression);
        }
    }
}

3. 调用方无感知使用 #

原有调用代码无需任何修改，拦截器会自动在查询执行前完成前置处理：

using(MyContext context = new MyContext())
{
    var results = context.persons
                .Where(p => p.Name == "someName")
                .FirstOrDefault();
}

关键说明 #

• 范围控制：拦截器仅注册在MyContext中，其他DbContext的查询不受影响。
• 灵活扩展：可在PersonQueryVisitor中扩展逻辑，比如处理Contains/StartsWith等其他比较器，或针对其他属性做前置处理。
• 复杂参数处理：如果查询参数不是直接常量（如变量、方法返回值），可扩展访问器逻辑解析MemberExpression/MethodCallExpression来获取参数值。

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