MongoDB按内部属性排序问题：聚合管道$match阶段失效

问题背景 #

作为MongoDB新手，需要按文档内部属性对数据排序。最初尝试用Find+Sort实现（代码已注释），后改用聚合管道，包含$match、$unwind、$addFields等阶段，但添加基于FilterDefinition构建的$match阶段后查询失效，移除该阶段则正常运行。

相关代码：

FilterDefinitionBuilder<Products> builder = Builders<Products>.Filter;
FilterDefinition<Products> filter = builder.Eq(x => x.Published, true);

if (supplierId > 0)
{
    filter &= builder.Eq(x => x.SupplierId, supplierId);
}
if (categoryIds is not null)
{
    if (categoryIds.Contains(0))
        categoryIds.Remove(0);

    if (categoryIds.Any())
    {
        filter &= builder.All(x => x.AllCategoriesIds, categoryIds);
    }
}

if (discountIds is not null)
{
    if (discountIds.Contains(0))
        discountIds.Remove(0);

    if (discountIds.Any())
    {
        filter &= builder.All(x => x.AllAppliedDiscountIds, discountIds);
    }
}

if (manufacturerIds is not null)
{
    if (manufacturerIds.Contains(0))
        manufacturerIds.Remove(0);

    if (manufacturerIds.Any())
    {
        filter &= builder.All(x => x.AllManufacturerIds, manufacturerIds);
    }
}

if (vendorIds is not null)
{
    if (vendorIds.Contains(0))
        vendorIds.Remove(0);

    if (vendorIds.Any())
    {
        filter &= builder.Where(x => vendorIds.Contains(x.VendorId));
    }
}

if (filteredSpecOptions?.Count > 0)
{
    var specificationAttributeIds = filteredSpecOptions
        .Select(sao => sao.SpecificationAttributeId)
        .Distinct();

    var optionIdsBySpecificationAttribute = filteredSpecOptions.Select(o => o.Id);

    filter &= builder.All(x => x.SpecificationAttributeOptionIds, optionIdsBySpecificationAttribute);
}

// var mongoPrd = _mongoRepo.GetCollection<Products>()
// .Find(filter).Sort(Builders<Products>.Sort
//  .Ascending(x => x.SoldOut)
//  .Ascending(x => x.DisableBuyButton)
//  .Ascending(x => x.ManufacturerProductMapping.Select(x => x.DisplayOrder).FirstOrDefault())
//  .Descending(x => x.HasBogoOfferApplied)
//  .Descending(x => x.MaxDiscountPercentage)
//  .Descending(x => x.HasTopSelling)
//  .Descending(x => x.MarkAsNew)
//  .Ascending(x => x.DisplayOrderProductTable)
//  .Descending(x => x.ProductId));

// var paggedProducts = mongoPrd.Skip(pageIndex * pageSize).Limit(pageSize);

var pipeline = new List<BsonDocument>();
pipeline.Add(new BsonDocument("$match", filter.ToBsonDocument()));

pipeline.Add(BsonDocument.Parse("{ $unwind: \"$ManufacturerProductMapping\" }"));

pipeline.Add(BsonDocument.Parse("{ $addFields: { DisplayOrder: { $cond: { if: { $isArray: \"$ManufacturerProductMapping.DisplayOrder\" }, then: { $arrayElemAt: [ \"$ManufacturerProductMapping.DisplayOrder\", 0 ] }, else: -1 } } } }"));

pipeline.Add(BsonDocument.Parse("{ $sort: { SoldOut: 1, DisableBuyButton: 1, HasBogoOfferApplied: -1, MaxDiscountPercentage: -1, HasTopSelling: -1, MarkAsNew: -1, DisplayOrderProductTable: 1, ProductId: -1 } }"));

pipeline.Add(BsonDocument.Parse("{ $skip: " + (pageIndex * pageSize) + " }"));

pipeline.Add(BsonDocument.Parse("{ $limit: " + pageSize + " }"));

var mongoPrd = _mongoRepo.GetCollection<Products>().Aggregate<BsonDocument>(pipeline);

失效原因 #

1. 字段名映射不匹配：FilterDefinition<Products>转BsonDocument时，实体类属性名（如Published）可能和MongoDB集合中的实际字段名（如published）不一致，导致$match条件无法匹配文档。
2. Lambda表达式序列化问题：针对vendorIds的过滤使用了builder.Where(x => vendorIds.Contains(x.VendorId))，这种Lambda表达式在序列化为BsonDocument时，可能生成不符合预期的查询条件，导致过滤失效。
3. 未验证生成的BsonDocument：没有检查filter.ToBsonDocument()生成的实际查询语句，无法确认条件是否正确对应集合字段。

解决方法 #

方法1：统一字段名映射 #

确保实体类属性与MongoDB集合字段名一致，可通过两种方式实现：

• 给实体类属性添加BsonElement特性，明确映射集合字段：

public class Products
{
    [BsonElement("published")]
    public bool Published { get; set; }
    [BsonElement("supplierId")]
    public int SupplierId { get; set; }
    // 其他属性同理添加对应BsonElement特性
}

• 配置MongoDB驱动自动使用驼峰命名序列化：

var clientSettings = new MongoClientSettings
{
    Server = new MongoServerAddress("你的MongoDB地址", 27017),
    SerializerRegistry = BsonSerializer.CreateRegistry(new CamelCaseSerializer())
};
var client = new MongoClient(clientSettings);

方法2：手动构建BsonDocument过滤条件 #

放弃FilterDefinitionBuilder，直接用BsonDocument编写$match条件，确保字段名完全匹配集合：

var matchCondition = new BsonDocument
{
    { "published", true }
};

if (supplierId > 0)
{
    matchCondition.Add("supplierId", supplierId);
}
if (categoryIds?.Any() == true && !categoryIds.Contains(0))
{
    matchCondition.Add("allCategoriesIds", new BsonDocument("$all", new BsonArray(categoryIds)));
}
// 其他过滤条件按集合字段名依次添加

pipeline.Add(new BsonDocument("$match", matchCondition));

方法3：修正Find+Sort逻辑（无需聚合管道） #

最初的Find+Sort方案可以直接修改排序逻辑，无需使用聚合管道。针对ManufacturerProductMapping的DisplayOrder排序，可直接取数组第一个元素：

var sortDefinition = Builders<Products>.Sort
    .Ascending(x => x.SoldOut)
    .Ascending(x => x.DisableBuyButton)
    .Ascending(Builders<Products>.Expression<Products, int>(x => 
        x.ManufacturerProductMapping == null || !x.ManufacturerProductMapping.Any() 
            ? -1 
            : x.ManufacturerProductMapping.First().DisplayOrder))
    .Descending(x => x.HasBogoOfferApplied)
    .Descending(x => x.MaxDiscountPercentage)
    .Descending(x => x.HasTopSelling)
    .Descending(x => x.MarkAsNew)
    .Ascending(x => x.DisplayOrderProductTable)
    .Descending(x => x.ProductId);

var mongoPrd = _mongoRepo.GetCollection<Products>()
    .Find(filter)
    .Sort(sortDefinition)
    .Skip(pageIndex * pageSize)
    .Limit(pageSize);

方法4：验证生成的过滤条件 #

在添加$match到管道前，输出生成的BsonDocument，检查是否符合预期：

var filterBson = filter.ToBsonDocument();
Console.WriteLine(filterBson.ToJson());

对比MongoDB集合中的字段名，修正大小写或命名方式的差异。

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