MongoDB 分页查询

在开发 Web 应用或者其他需要处理大量数据的项目中，常常需要实现数据分页查询功能。MongoDB 是一种流行的 NoSQL 数据库，其也提供了分页查询的功能，本文将详细介绍 MongoDB 分页查询的实现方法和注意事项。

一、MongoDB 分页查询的基本概念

MongoDB 分页查询是指根据指定的查询条件，将文档集合分成多个页面进行查询。通常，在网页应用中，我们会将查询结果分成多个页面展示给用户，每个页面显示固定数量的文档。

MongoDB 的分页查询可以通过 limit() 方法和 skip() 方法实现。其中，limit() 方法用于限制查询结果的数量，skip() 方法用于跳过指定数量的文档。

二、MongoDB 分页查询的实现方法

下面，我们将介绍如何在 MongoDB 中实现分页查询的功能。

1. 创建示例数据集合

首先，我们需要在 MongoDB 中创建一个示例的数据集合。假设我们的集合名为 users，包含以下文档：

{ "_id" : ObjectId("60976a1593a6cc17e88937da"), "name" : "Alice", "age" : 26 }
{ "_id" : ObjectId("60976a1593a6cc17e88937db"), "name" : "Bob", "age" : 30 }
{ "_id" : ObjectId("60976a1593a6cc17e88937dc"), "name" : "Charlie", "age" : 28 }
{ "_id" : ObjectId("60976a1593a6cc17e88937dd"), "name" : "David", "age" : 32 }
{ "_id" : ObjectId("60976a1593a6cc17e88937de"), "name" : "Eve", "age" : 24 }

2. 分页查询示例

假设每页的文档数量为 2，我们可以通过以下代码实现 MongoDB 的分页查询：

const MongoClient = require('mongodb').MongoClient;

const url = 'mongodb://localhost:27017';
const dbName = 'mydb';

async function paginate(query, page, pageSize) {
  const client = await MongoClient.connect(url);
  const db = client.db(dbName);
  const collection = db.collection('users');

  const totalDocuments = await collection.countDocuments(query);

  const totalPages = Math.ceil(totalDocuments / pageSize);

  const documents = await collection.find(query)
                                    .skip((page - 1) * pageSize)
                                    .limit(pageSize)
                                    .toArray();

  return {
    documents,
    page,
    pageSize,
    totalPages,
    totalDocuments
  };
}

// 示例查询：查询年纪大于等于 28 岁的用户，返回第 2 页，每页 2 条数据
const page = 2;
const pageSize = 2;
const query = { age: { $gte: 28 } };

paginate(query, page, pageSize)
  .then(result => console.log(result))
  .catch(err => console.error(err))
  .finally(() => client.close());

上述代码中，通过 paginate() 函数实现了分页查询。该函数接收三个参数：查询条件 query、页码 page 和每页文档数 pageSize。在函数内部，我们先获取符合查询条件的文档总数 totalDocuments，然后根据总数和每页文档数计算总页数 totalPages。最后，使用 skip() 和 limit() 方法进行查询，并返回查询结果以及分页信息。