MongoDB同集合聚合查询求助：判断指定收发方是否已有聊天记录

原查询的核心错误 #

1. 不必要的自联结$lookup：你要查询的就是messages集合中符合条件的文档，完全不需要用$lookup自联结同一张表，这会导致逻辑冗余且结果异常。
2. 匹配逻辑错误：$eq: ["$members", "$$receivern"]是将整个members数组（两个元素）和单个接收者ID做相等比较，永远不会匹配成功，正确逻辑应该是检查数组是否包含接收者ID。
3. 类型一致性问题：确保查询时将字符串ID转换为ObjectId类型，和数据库存储的类型保持一致。

正确的查询方案 #

1. 检查是否存在历史记录 #

根据你的需求，members数组第一个是发送者、第二个是接收者，严格匹配顺序的查询如下：

const sender = new ObjectId("631012d34a181605afe342c1");
const receiver = new ObjectId("62e8845c3e1d191dfdc1a244");

// 查询是否存在指定双方的聊天记录
const existingChat = db.messages.findOne({
  members: [sender, receiver]
});

如果允许聊天记录的members数组顺序不固定（比如接收者先发消息的场景），可以用$all+$size匹配：

const existingChat = db.messages.findOne({
  members: {
    $all: [sender, receiver],
    $size: 2
  }
});

2. 原子化查询+新建（推荐） #

用findOneAndUpdate配合upsert选项，实现“存在则返回，不存在则创建”的原子操作，避免并发场景下的重复创建问题：

const sender = new ObjectId("631012d34a181605afe342c1");
const receiver = new ObjectId("62e8845c3e1d191dfdc1a244");

const chatRecord = db.messages.findOneAndUpdate(
  { members: [sender, receiver] }, // 匹配条件
  {
    $setOnInsert: {
      message: [] // 新文档初始消息数组为空
    }
  },
  {
    upsert: true, // 不存在则插入新文档
    returnDocument: "after" // 返回操作后的文档（插入或查询到的）
  }
);

// 判断是否是新创建的记录
if (chatRecord.lastErrorObject.upserted) {
  console.log("已创建新聊天记录");
} else {
  console.log("找到已有聊天记录");
}

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