如何将Node.js中MongoDB聚合查询优雅转换为LINQ？

AI 小北

2026-6-18

解决方案

直接通过MongoDB的聚合管道就能一步完成所有需求，无需额外查询。核心思路是先按作者和目标排序字段预排序，再分组时用$last提取每组最后一条数据的指定字段，最后完成排序和分页。

聚合管道步骤说明

预排序：先按author升序、return_date降序（或你定义的“最后一条”的排序依据，比如文档_id）排序，确保同一作者的目标最后一条数据处于分组后的末尾位置。
分组统计：按author分组，统计书籍数量，同时用$last提取该组最后一条数据的return_date和title。
二次排序：按统计数量降序、作者升序排序。
分页取数：限制结果为前20条。

Node.js代码实现（MongoDB驱动）

const { MongoClient } = require('mongodb');

async function getAuthorBookStats() {
  const client = new MongoClient('your-mongodb-connection-string');
  await client.connect();
  const db = client.db('your-database-name');
  const booksCollection = db.collection('books');

  const pipeline = [
    // 预排序：同一作者下，按return_date降序（最新的排在前面，也可换为_id按插入时间排序）
    {
      $sort: {
        author: 1,
        return_date: -1
      }
    },
    // 分组统计+提取最后一条数据的字段
    {
      $group: {
        _id: '$author',
        bookCount: { $sum: 1 },
        lastReturnDate: { $last: '$return_date' },
        lastBookTitle: { $last: '$title' }
      }
    },
    // 按数量降序、作者升序排序
    {
      $sort: {
        bookCount: -1,
        _id: 1
      }
    },
    // 取前20条
    { $limit: 20 }
  ];

  const result = await booksCollection.aggregate(pipeline).toArray();
  console.log(result);
  await client.close();
}

getAuthorBookStats().catch(console.error);