使用C# MongoDB多条件关联查询未达预期结果求助

我太懂这种在MongoDB C#驱动里卡关联查询的滋味了！你说的UserDetails和ReportDetails多条件关联出不来预期结果的问题，我帮你捋捋思路，结合你的集合数据来拆解下：

先再明确下你的集合数据：

// UserDetails集合
{ "_id" : ObjectId("585bc1b137bd32466cfe1472"), "NTID" : "kram", "FirstName" : "KRamesh" }
{ "_id" : ObjectId("585bc1b137bd32466cfe1473"), "NTID" : "raj", "FirstName" : "Rajan" }

// ReportDetails集合
{ "_id" : ObjectId("59d347c77ab9655380bdb452"), "FaxID" : "123", "CreatedBy" : "kram", "CreatedDate" : ISODate("2017-10-03T08:14:18.323Z") }

第一步：先确认实体类映射正确 #

首先得把C#实体和MongoDB字段对应上，避免因为映射问题导致关联失败：

public class UserDetails
{
    [BsonId]
    public ObjectId Id { get; set; }
    public string NTID { get; set; }
    public string FirstName { get; set; }
    // 用来存储关联后的报告列表
    public List<ReportDetails> AssociatedReports { get; set; }
}

public class ReportDetails
{
    [BsonId]
    public ObjectId Id { get; set; }
    public string FaxID { get; set; }
    public string CreatedBy { get; set; }
    public DateTime CreatedDate { get; set; }
}

第二步：分场景写关联查询 #

场景1：单条件关联（仅匹配NTID和CreatedBy）

如果你的需求只是把用户和其创建的报告关联，用基础的Lookup就能解决：

var mongoClient = new MongoClient("你的MongoDB连接字符串");
var database = mongoClient.GetDatabase("你的数据库名称");

var userCollection = database.GetCollection<UserDetails>("UserDetails");
var reportCollection = database.GetCollection<ReportDetails>("ReportDetails");

// 左关联：获取所有用户，以及他们对应的报告（没有报告的用户也会保留）
var queryResult = await userCollection.Aggregate()
    .Lookup<ReportDetails, UserDetails>(
        foreignCollection: reportCollection,
        localField: u => u.NTID,
        foreignField: r => r.CreatedBy,
        @as: u => u.AssociatedReports
    )
    .ToListAsync();

// 验证结果
foreach (var user in queryResult)
{
    Console.WriteLine($"用户：{user.FirstName}，关联报告数：{user.AssociatedReports?.Count ?? 0}");
}

场景2：多条件关联（比如加日期/其他字段筛选）

如果需要多条件（比如不仅匹配CreatedBy，还要筛选CreatedDate在某个区间、FaxID等于特定值），必须用带Pipeline的Lookup——默认Lookup只支持单字段匹配，多条件得自定义匹配逻辑：

var queryResult = await userCollection.Aggregate()
    .Lookup<UserDetails, ReportDetails, UserDetails>(
        foreignCollection: reportCollection,
        pipeline: new BsonDocument[]
        {
            // 多条件匹配：CreatedBy等于当前用户的NTID，且CreatedDate晚于2017-10-01
            new BsonDocument("$match", new BsonDocument
            {
                { "CreatedBy", new BsonDocument("$eq", "$$ROOT.NTID") },
                { "CreatedDate", new BsonDocument("$gte", new DateTime(2017, 10, 1)) }
            })
        },
        @as: u => u.AssociatedReports
    )
    .ToListAsync();

最容易踩的坑，帮你排查下 #

1. 字段类型不匹配：检查NTID和CreatedBy是不是都是string类型，要是一个是ObjectId一个是string，绝对匹配不上——这是关联失败的头号原因！
2. 多条件没用到Pipeline：别指望默认Lookup能传多个字段，多条件必须用Pipeline方式写匹配逻辑。
3. 异步方法没加await：MongoDB C#驱动的聚合方法大多是异步的，直接调用ToList()而不是ToListAsync()，大概率拿不到正确结果。
4. 过滤条件太严格：如果加了Match只保留有报告的用户，那没有对应报告的用户会被过滤掉，根据需求调整就行。

你可以先在MongoDB Compass里跑对应的聚合命令验证结果，再转成C#代码，这样更容易定位问题：

// Compass里的多条件聚合示例
db.UserDetails.aggregate([
    {
        $lookup: {
            from: "ReportDetails",
            pipeline: [
                {
                    $match: {
                        $and: [
                            { CreatedBy: { $eq: "$$ROOT.NTID" } },
                            { CreatedDate: { $gte: ISODate("2017-10-01") } }
                        ]
                    }
                }
            ],
            as: "AssociatedReports"
        }
    }
])

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