Mongodb在切片前反转一个数组字段

Question

我有这个 mongo 查询来获取线程中的消息列表。

await db
      .collection("threads")
      .find({
        _id: ObjectId(req.query.thread_id),
      })
      .project({
        messages: {
          $slice: [parseInt(req.query.offset), parseInt(req.query.limit)],
        },
        _id: 1,
        date_created: 1,
      })
      .toArray();

限制和偏移量由客户端设置以支持无限加载。问题是查询按它们添加的顺序获取结果，而它应该首先使用最后添加的消息进行分页。我该怎么做？是否有可能我可以在获取之前反转数组还是负载太大？

这是我的线程架构：

{
   "_id":{
      "$oid":"5f7b32c014014100176c2a55"
   },
   "thread_name":"personal",
   "messages":[
      {
         "_id":{
            "$oid":"5f7b32d414014100176c2a56"
         },
         "sender":{
            "$oid":"5f7b329114014100176c2a52"
         },
         "type":"text",
         "date_created":{
            "$date":"2020-10-05T14:51:00.716Z"
         },
         "content":"hi"
      },
      {
         "_id":{
            "$oid":"5f7b32df14014100176c2a57"
         },
         "sender":{
            "$oid":"5f7b329114014100176c2a52"
         },
         "type":"text",
         "date_created":{
            "$date":"2020-10-05T14:51:11.302Z"
         },
         "content":"hello"
      },
   ],
   "date_created":{
      "$date":"2020-10-05T14:50:40.271Z"
   },
}

Answer 1

您可以在聚合中使用$reverseArray 选项

使用aggregate，您可以先使用$match（它将替换您的find 部分），然后使用$project，您可以添加新属性，如reversedMessages，您将在其中使用$reverseArray和$slice结合

所以，查询应该是这样的

db.collection("threads").aggregate([
  {
    $match: {
      _id: ObjectId(req.query.thread_id),
    },
  },
  {
    $project: {
      _id: 1,
      date_created: 1,
      reverseMessages: {
        $slice: [
          { $reverseArray: "$messages" },
          0,
          parseInt(req.query.limit), // I guess you want to return latest n messages, where n is a limit from query
        ],
      },
    },
  },
]);

Answer 2

“我可以在获取之前反转数组吗？”你无法扭转你没有的东西。我已经看到了$reverseArray 的另一个答案，但是当您可以只使用$slice 最后一个元素时，为什么还要花费资源来反转数组呢？

如果为负，$slice 最多返回数组中的最后 n 个元素。如果指定了 n 则无法解析为负数

db.collection("threads").aggregate([
  {
    $match: {
      _id: ObjectId(req.query.thread_id),
    },
  },
  {
    $project: {
      _id: 1,
      date_created: 1,
      reverseMessages: {
        $slice: [
          "$messages",
          parseInt(req.query.limit) * -1
        ]
      }
    }
  }
]);