EF Core 6中如何在DbCommand拦截器内修改LINQ查询实现统一用户ID过滤

直接修改SQL命令文本的方式确实容易踩坑——要处理WHERE子句存在与否、AND连接符的添加，甚至还要考虑子查询、联合查询等复杂场景，维护成本极高。更靠谱的方案是用EF Core官方提供的全局查询筛选器（Global Query Filters），它能自动为指定实体的所有查询注入过滤条件，完全不用手动操作SQL字符串。

实现步骤 #

1. 在DbContext中配置全局筛选器
   在OnModelCreating方法里，遍历所有继承自FullEntity的实体类型，统一添加UserId过滤逻辑：

   protected override void OnModelCreating(ModelBuilder modelBuilder)
   {
       // 获取当前登录用户的UserId，根据你的业务场景调整获取方式
       var userId = GetCurrentUserId();
   
       // 筛选所有继承FullEntity的实体
       foreach (var entityType in modelBuilder.Model.GetEntityTypes()
           .Where(t => typeof(FullEntity).IsAssignableFrom(t.ClrType)))
       {
           // 构建Lambda表达式：entity => entity.UserId == 当前用户Id
           var param = Expression.Parameter(entityType.ClrType, "entity");
           var userIdProp = Expression.Property(param, "UserId");
           var constant = Expression.Constant(userId);
           var filterExpr = Expression.Equal(userIdProp, constant);
           var filterLambda = Expression.Lambda(filterExpr, param);
   
           // 为实体应用全局筛选器
           modelBuilder.Entity(entityType.ClrType).HasQueryFilter(filterLambda);
       }
   
       base.OnModelCreating(modelBuilder);
   }
   

2. 获取当前用户的UserId
   如果是ASP.NET Core项目，可以通过IHttpContextAccessor获取当前登录用户的标识：

   private readonly IHttpContextAccessor _httpContextAccessor;
   
   public YourDbContext(DbContextOptions<YourDbContext> options, IHttpContextAccessor httpContextAccessor)
       : base(options)
   {
       _httpContextAccessor = httpContextAccessor;
   }
   
   private string GetCurrentUserId()
   {
       return _httpContextAccessor.HttpContext?.User.FindFirstValue(ClaimTypes.NameIdentifier);
   }
   

   注意要在Program.cs中注册IHttpContextAccessor：

   builder.Services.AddHttpContextAccessor();
   

3. 跳过筛选器的场景
   如果某些特殊查询不需要这个全局过滤，可以用IgnoreQueryFilters()方法临时关闭：

   // 忽略全局筛选器，查询所有数据
   var allEntities = await dbContext.YourEntities.IgnoreQueryFilters().ToListAsync();
   

为什么选这个方案 #

• 无需处理SQL字符串的各种边界情况，EF Core会自动将过滤条件注入到所有LINQ查询、Include关联查询、子查询中
• 逻辑集中维护，不用在每个查询里手动加Where条件
• 支持临时跳过筛选，满足特殊业务需求

内容的提问来源于stack exchange，提问作者Gabriel di domenico