MongoDB与Node.js中最高评分排序后last_rec_id分页不准确问题

问题根源 #

你这个分页错误的核心在于**"Highest Rated"的分页条件逻辑完全错误**：

• 原代码硬写了rating: { $lte: 5 }，既没考虑上一页最后一条记录的实际评分，也只覆盖了rating=5的场景，完全忽略了其他评分区间的分页需求。
• 排序规则是rating降序，同评分下_id降序，但分页条件没有匹配这个复合排序规则，导致无法正确定位下一页的起始位置。

修复步骤 #

要实现符合排序规则的分页，你需要基于上一页最后一条记录的**rating和_id**两个字段构建条件，而非仅依赖last_rec_id。

第一步：获取上一页最后一条记录的评分

在构建分页条件前，先查询last_rec_id对应记录的rating值：

// 替换成你的集合名称
const lastRecord = await db.collection('reviews').findOne({ _id: new ObjectId(last_rec_id) });
if (!lastRecord) {
  // 处理记录不存在的情况，直接返回空结果
  pipeline.push({ $match: { _id: null } });
}
const lastRating = lastRecord.rating;

第二步：重构分页匹配条件

把原来错误的query替换为符合复合排序规则的逻辑：

query = {
  $or: [
    // 情况1：评分小于上一页最后一条的评分（降序下，更低评分的记录排在后面）
    { rating: { $lt: lastRating } },
    // 情况2：评分等于上一页最后一条的评分，但_id更小（同评分下，更早的记录排在后面）
    {
      rating: lastRating,
      _id: { $lt: new ObjectId(last_rec_id) }
    }
  ]
};
pipeline.push({ $match: query });

完整修复后的代码片段

/* Initialize pipeline */
const pipeline = [];

/* All reviews of Auth Host */
pipeline.push({
  $match: { host_id: new ObjectId(host_id) },
});

/* High rated on top */
if (filter && filter == "Highest Rated") {
  pipeline.push({
    $sort: {
      rating: -1,
      _id: -1,
    },
  });
} else if (filter && filter == "Newest") {
  /* Newest on top */
  pipeline.push({
    $sort: {
      _id: -1,
    },
  });
} else if (filter && filter == "Oldest") {
  /* Oldest on top */
  pipeline.push({
    $sort: {
      _id: 1,
    },
  });
}

/* Pagination */
if (last_rec_id) {
  let query;
  if (filter !== "Highest Rated") {
    query = filter === "Oldest" || !filter ? { $gt: new ObjectId(last_rec_id) } : { $lt: new ObjectId(last_rec_id) };

    pipeline.push({
      $match: {
        _id: query,
      },
    });
  } else {
    // 修复：先获取上一页最后一条记录的rating
    const lastRecord = await db.collection('reviews').findOne({ _id: new ObjectId(last_rec_id) });
    if (!lastRecord) {
      pipeline.push({ $match: { _id: null } });
    } else {
      const lastRating = lastRecord.rating;
      // 构建符合复合排序的分页条件
      query = {
        $or: [
          { rating: { $lt: lastRating } },
          {
            rating: lastRating,
            _id: { $lt: new ObjectId(last_rec_id) }
          }
        ]
      };
      pipeline.push({ $match: query });
    }
  }
}

修复逻辑说明 #

因为你的排序规则是先按rating从高到低排列，同评分下按_id从大到小（最新记录在前），所以下一页的记录必须满足：

• 要么评分低于上一页最后一条，这类记录必然排在后面；
• 要么评分相同，但_id比上一页最后一条小，这类记录在同评分组里排在后面。

这样就能严格匹配排序规则，分页结果会完全符合预期。

内容的提问来源于stack exchange，提问作者Muhammad Ubaid Nawaz