从 MongoDB 中的两个集合中查询

Question

我正在尝试在 MongoDB 中找到自己的方法。这是我第一次使用这个数据库，来自 MySQL。但对于我正在制作的聊天应用程序，建议使用 MongoDB 更合适。

我有两个收藏：

对话，我在其中存储成员用户 ID（存储在 MySQL 数据库中）和加入日期。

{
    "_id" : ObjectId("5e35f2c840713a43aeeeb3d9"),
    "members" : [ 
        {
            "uID" : "1",
            "j" : 1580580922
        }, 
        {
            "uID" : "4",
            "j" : 1580580922
        }, 
        {
            "uID" : "5",
            "j" : 1580580922
        }
    ]
}

消息，我在其中存储发件人（用户 ID）、消息、时间戳、对话 ID（来自上面的集合）、读取和传递状态

{
    "_id" : ObjectId("5e35ee5f40713a43aeeeb1c5"),
    "c_ID" : ObjectId("5e35f2c840713a43aeeeb3d9"),
    "fromID" : "1",
    "msg" : "What's up?",
    "t" : 1580591922,
    "d" : {
        "4" : 1580592039
    },
    "r" : {
        "4" : 1580592339
    }
}

我现在要做的是查询特定用户的对话，比如 userID 1，以及该对话中发送的最后一条消息。

我想出了以下几点：

db.getCollection('conversations').aggregate(
[{
    $match: {
        "members.uID": "1"
    }
},
{
    $lookup: {
        as: 'lastMessage',
        foreignField: 'c_ID',
        from: 'messages',
        localField: '_id',
    }
},
])

但这里的问题是它列出了所有消息，而不仅仅是最后一条。所以我想将其限制为 1，或者如果有其他方法..请告诉我。

感谢任何帮助！

Answer 1

我想我们可以理解来自时间戳字段的最后一条消息。

在$match和$lookup阶段之后，我们需要$unwind消息，然后$sort通过时间戳。

现在消息数组中的第一条消息是lastMessage，所以当我们group时，我们将第一条消息推送为lastMessage，最后$replaceRoot形成我们的结果。

如果是这样，您可以使用以下聚合：

db.conversations.aggregate([
  {
    $match: {
      "members.uID": "1"
    }
  },
  {
    $lookup: {
      foreignField: "c_ID",
      from: "messages",
      localField: "_id",
      as: "messages"
    }
  },
  {
    "$unwind": "$messages"
  },
  {
    "$sort": {
      "messages.t": -1
    }
  },
  {
    "$group": {
      "_id": "$_id",
      "lastMessage": {
        "$first": "$messages"
      },
      "allFields": {
        "$first": "$$ROOT"
      }
    }
  },
  {
    "$replaceRoot": {
      "newRoot": {
        "$mergeObjects": [
          "$allFields",
          {
            "lastMessage": "$lastMessage"
          }
        ]
      }
    }
  },
  {
    $project: {
      messages: 0
    }
  }
])

如果messages数组已经排序，则可以简化解决方案，但这是一个通用的解决方案。

Playground