MongoDB C# Driver如何复用B类FilterDefinition查询A类单嵌套属性

核心场景 #

现有存储A类的MongoCollection，已经封装了针对B类的FilterDefinition生成逻辑，集合类型的嵌套属性可通过ElemMatch直接复用B类过滤器，但单嵌套属性无法直接复用。要求不能重复编写B类过滤逻辑，也不能使用IMongoQueryable实现查询。

解决方案 #

MongoDB C# Driver 2.10及以上版本的FilterDefinitionBuilder提供了原生重载，支持将子类型过滤器直接套用到父类的嵌套字段上，无需硬编码字段逻辑，完全复用现有B类的过滤规则。

改造后的代码实现 #

public async Task<ICollection<A>> SearchAsync(IMongoCollection<A> collection)
{
    // 复用原有B类过滤器生成逻辑
    var bFilter = FilterProvider.SearchValue("Oleh");
    
    var cursor = await collection.FindAsync(
        Builders<A>.Filter.And( 
            // 集合属性仍用原有ElemMatch复用逻辑
            Builders<A>.Filter.ElemMatch(x => x.NestedBCollection, bFilter),
            // 单嵌套属性直接使用「字段+子过滤器」重载实现复用
            Builders<A>.Filter.Where(x => x.NestedB, bFilter)
        )
    );
    return await cursor.ToListAsync();
}

低版本驱动兼容方案 #

如果使用的驱动版本低于2.10，没有上述原生重载，可以通过自定义扩展方法实现相同效果：

public static class FilterDefinitionExtensions
{
    public static FilterDefinition<TParent> ForNested<TParent, TChild>(
        this FilterDefinition<TChild> childFilter, 
        Expression<Func<TParent, TChild>> nestedFieldExpr)
    {
        // 渲染子过滤器为Bson文档
        var childSerializer = BsonSerializer.SerializerRegistry.GetSerializer<TChild>();
        var childBson = childFilter.Render(childSerializer, BsonSerializer.SerializerRegistry);
        
        // 给子过滤器所有字段添加嵌套路径前缀
        var fieldPrefix = new ExpressionFieldDefinition<TParent, TChild>(nestedFieldExpr).ElementName;
        var parentBson = new BsonDocument();
        foreach (var element in childBson.Elements)
        {
            parentBson.Add($"{fieldPrefix}.{element.Name}", element.Value);
        }
        
        return parentBson;
    }
}

扩展方法调用示例：

var bFilter = FilterProvider.SearchValue("Oleh");
var nestedBFilter = bFilter.ForNested<A, B>(x => x.NestedB);

方案合规性说明 #

• 完全复用FilterProvider中所有B类的过滤逻辑，没有重复代码，后续修改B类过滤规则时不需要调整A类的查询代码
• 未使用IMongoQueryable，满足所有限制条件
• 兼容单嵌套对象的任意复杂过滤场景，无论B类的过滤器逻辑多复杂都可以直接复用

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