MongoDB .NET Driver：匹配阶段$in使用及语句转换问题

一、聚合管道实现（解决$in运算符问题） #

原生MongoDB聚合示例 #

假设你的集合结构如下：

• PostInfo：包含_id（帖子ID）、UserId（发布者ID）、Content（帖子内容）等字段
• UserInfo：包含_id（用户ID）、Friends（好友ID数组）等字段

要筛选出给定targetUserId的好友发布的帖子，原生聚合管道可以这么写：

db.PostInfo.aggregate([
  // 关联UserInfo，匹配发布者的用户信息
  {
    $lookup: {
      from: "UserInfo",
      localField: "UserId",
      foreignField: "_id",
      as: "AsUser"
    }
  },
  // 展开AsUser数组（lookup返回的是数组结构）
  { $unwind: "$AsUser" },
  // 筛选给定userid存在于AsUser.Friends的帖子
  {
    $match: {
      "AsUser.Friends": { $in: [ObjectId("targetUserId")] }
    }
  },
  // 可选：投影需要的字段，剔除冗余数据
  {
    $project: {
      _id: 1,
      Content: 1,
      UserId: 1,
      "AsUser._id": 1,
      "AsUser.Friends": 1
    }
  }
])

对应的C#代码实现 #

使用MongoDB.Driver（假设已注入IMongoDatabase实例）：

var targetUserId = ObjectId.Parse("你的目标用户ID");

var aggregation = _mongoDatabase.GetCollection<PostInfo>("PostInfo")
    .Aggregate()
    // 关联UserInfo集合
    .Lookup<UserInfo, PostInfoWithUser>(
        foreignCollection: _mongoDatabase.GetCollection<UserInfo>("UserInfo"),
        localField: post => post.UserId,
        foreignField: user => user.Id,
        @as: result => result.AsUser
    )
    // 展开AsUser数组
    .Unwind<PostInfoWithUser>(result => result.AsUser)
    // 筛选目标用户ID在AsUser.Friends中的帖子
    .Match(result => result.AsUser.Friends.Contains(targetUserId))
    // 投影需要的字段
    .Project(result => new 
    {
        result.Id,
        result.Content,
        result.UserId,
        AsUserId = result.AsUser.Id,
        AsUserFriends = result.AsUser.Friends
    });

// 执行聚合并获取结果
var result = await aggregation.ToListAsync();

// 对应的实体类定义
public class PostInfo
{
    public ObjectId Id { get; set; }
    public ObjectId UserId { get; set; }
    public string Content { get; set; }
}

public class UserInfo
{
    public ObjectId Id { get; set; }
    public List<ObjectId> Friends { get; set; } = new List<ObjectId>();
}

public class PostInfoWithUser : PostInfo
{
    public List<UserInfo> AsUser { get; set; } = new List<UserInfo>();
}

二、将MongoDB的eq查询转换为C#格式 #

如果你提到的eq查询是指判断目标用户ID是否存在于AsUser.Friends中（单值匹配场景），对应的MongoDB查询语句可能是：

db.PostInfo.find({
  $expr: {
    $in: [ObjectId("targetUserId"), "$AsUser.Friends"]
  }
})

转换为C#的FilterDefinition写法有两种：

var targetUserId = ObjectId.Parse("你的目标用户ID");

// 方法1：Lambda表达式写法
var filter = Builders<PostInfoWithUser>.Filter.Where(
    post => post.AsUser.Any(user => user.Friends.Contains(targetUserId))
);

// 方法2：原生BsonDocument构建写法
var filterBson = new BsonDocument("$expr", new BsonDocument(
    "$in", new BsonArray { targetUserId, "$AsUser.Friends" }
));

// 使用filter执行查询
var posts = await _mongoDatabase.GetCollection<PostInfoWithUser>("PostInfo")
    .Find(filter)
    .ToListAsync();

注意事项 #

• 确保UserId和Friends中的ID类型一致（统一用ObjectId或字符串），避免类型不匹配导致筛选失效
• 若AsUser数组可能为空，Unwind阶段默认会过滤空数组，无需额外配置
• 给UserInfo.Friends和PostInfo.UserId建立索引，可大幅提升聚合查询效率

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