如何在C#中使用MongoDB LINQ关联数组类型字段？

你需要实现类似Node.js Mongoose里populate的集合关联功能，尤其是处理数组类型的外键列表（activityPerimeters）。原来的join写法不适用，因为数组无法和单个ID直接做等值匹配，这里用MongoDB .NET驱动的Lookup来实现，以下是两种可行方案：

方式一：LINQ查询结合分组处理数组关联 #

先定义一个DTO来存储关联后的结果：

public class UserWithActivities
{
    public Users User { get; set; }
    public Activities MainActivity { get; set; }
    public List<Activities> PerimeterActivities { get; set; }
}

然后编写LINQ查询：

var userWithActivities = (from user in mongoContext.Users
                          // 关联单个activity字段
                          join mainActivity in mongoContext.Activities 
                              on user.activity equals mainActivity.Id into mainActivityGroup
                          let mainActivity = mainActivityGroup.FirstOrDefault()
                          // 筛选出activityPerimeters包含的Activities文档
                          from perimeterActivity in mongoContext.Activities
                              .Where(a => user.activityPerimeters != null && user.activityPerimeters.Contains(a.Id))
                              .DefaultIfEmpty()
                          // 按用户和主活动分组，收集所有关联的周边活动
                          group perimeterActivity by new { user, mainActivity } into grouped
                          select new UserWithActivities
                          {
                              User = grouped.Key.user,
                              MainActivity = grouped.Key.mainActivity,
                              PerimeterActivities = grouped.Where(a => a != null).ToList()
                          }).ToList();

方式二：聚合管道的Lookup（贴近MongoDB原生逻辑） #

这种方式直接对应MongoDB的$lookup聚合操作，和Mongoose的populate逻辑完全一致，适合复杂关联场景：

先定义中间类接收第一次Lookup的结果：

public class UserWithMainActivity : Users
{
    public List<Activities> MainActivities { get; set; }
}

构建聚合查询：

var result = mongoContext.Users.Aggregate()
    // 关联单个activity：匹配Users.activity与Activities.Id
    .Lookup<Users, Activities, UserWithMainActivity>(
        foreignCollection: mongoContext.Activities,
        localField: u => u.activity,
        foreignField: a => a.Id,
        @as: uwma => uwma.MainActivities)
    // 提取主活动（Lookup返回数组，取第一个）
    .Project(uwma => new UserWithActivities
    {
        User = uwma,
        MainActivity = uwma.MainActivities.FirstOrDefault(),
        PerimeterActivities = new List<Activities>()
    })
    // 关联activityPerimeters数组：匹配Users.activityPerimeters列表与Activities.Id
    .Lookup<UserWithActivities, Activities, UserWithActivities>(
        foreignCollection: mongoContext.Activities,
        localField: uwa => uwa.User.activityPerimeters,
        foreignField: a => a.Id,
        @as: uwa => uwa.PerimeterActivities)
    .ToList();

关键说明 #

• 原join写法失效原因：关系型数据库的join是单个字段的等值匹配，但activityPerimeters是List<ObjectId>，无法直接和单个a.Id匹配，必须用Lookup或Where+Contains处理“数组包含ID”的关联逻辑。
• Lookup就是MongoDB官方对应的集合关联方案，和Mongoose的populate功能等价，支持单个字段和数组字段的关联。
• 空值处理：加入user.activityPerimeters != null判断避免空引用，DefaultIfEmpty()保证无关联数据时返回空列表而非报错。

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