当前位置：首页 > 文章列表 > 文章 > 前端 > MongoDB查询最近N年数据教程

MongoDB查询最近N年数据教程

2025-10-18 17:45:40 0浏览收藏

本教程针对MongoDB中常见的日期范围查询难题，提出了一种动态获取集合中最新N年数据的高效解决方案。传统方法依赖硬编码日期或基于当前年份计算，缺乏灵活性，难以满足实际业务需求。本文巧妙地结合了MongoDB的聚合管道功能，特别是利用`$setWindowFields`操作符创建时间窗口，并结合`$sort`和`$limit`定位集合中的最新记录。通过这种方式，可以动态地识别集合中的最新日期，并以此为基准向前推算N年，避免了手动更新日期范围的繁琐。本教程提供了详细的代码示例和步骤说明，帮助开发者轻松实现灵活高效的日期范围查询，提升数据处理效率。适用于需要从MongoDB数据库中动态提取最新N年数据的场景，例如报表生成、数据分析等。

MongoDB：动态查询集合中最新N年数据的教程

本教程介绍如何在MongoDB中动态查询集合中最新N年的数据，而非硬编码日期或基于当前年份。通过结合使用$setWindowFields获取每条记录的近期窗口，并利用$sort和$limit定位集合中的最新记录，最终提取出该最新记录对应的N年内数据，避免了手动更新日期范围的繁琐，实现了灵活高效的日期范围查询。

问题阐述：动态获取集合中最新N年数据

在MongoDB中进行日期范围查询是常见的操作，但通常面临两种挑战：一是硬编码日期，导致查询条件需要定期手动更新；二是基于当前年份进行计算，这可能与业务需求不符。例如，如果集合中最新记录的年份是2021年，而我们希望获取的是该集合中“最新2年”的数据，那么正确的范围应该是2019-2021年，而非基于当前年份2023计算出的2021-2023年。这种需求要求我们能够动态地识别集合中的最新日期，并以此为基准向前推算N年。

传统的$match操作通常需要预先确定日期范围，例如：

{
  $match: {
    fechaOrden: {
      $gte: ISODate("2018-01-01"),
      $lt: ISODate("2020-02-01"),
    }, 
  },
}

这种硬编码的方式缺乏灵活性，无法满足动态获取“集合中最新N年”数据的需求。

核心策略：利用$setWindowFields与$sort、$limit组合

为了解决上述问题，我们可以采用MongoDB的聚合管道，特别是利用$setWindowFields操作符，结合$sort和$limit来动态地确定日期范围。

1. 使用$setWindowFields创建时间窗口

$setWindowFields是一个强大的聚合管道操作符，它允许我们在一个有序的窗口内执行聚合操作。在这里，我们可以利用它为每个文档计算一个“最近N年”的记录数组。

sortBy: { dt: 1 }：指定按日期字段（例如dt或fechaOrden）升序排序，这是定义时间窗口的基础。
output: { recentRecords: { $push: "$$ROOT", window: { range: [-2, 0], unit: "year" } } }：
- $push: "$$ROOT"：将当前窗口内的所有文档作为数组元素推入recentRecords字段。
- window: { range: [-2, 0], unit: "year" }：这是关键所在。它定义了一个相对时间窗口，以当前文档的日期为基准，向前推2年（-2）到当前日期（0）。unit: "year"指定了时间单位。这意味着对于集合中的每一条记录，recentRecords字段都会包含其自身以及其之前两年内的所有记录。

2. 定位集合中的最新记录

在对每个文档创建了recentRecords数组后，我们需要找到整个集合中日期最新的那条记录。这条记录的recentRecords数组将包含我们所需的所有“集合中最新N年”的数据。

$sort: { dt: -1 }：将所有文档按日期字段降序排序，使最新记录排在最前面。
$limit: 1：只保留排序后的第一条文档，即整个集合中日期最新的那条文档。

3. 整合解决方案并进行后处理

将上述步骤整合到聚合管道中，并进行必要的后处理以获取最终的文档列表。

db.collection.aggregate([
  // 1. 使用$setWindowFields为每个文档计算其最近N年的记录窗口
  {
    $setWindowFields: {
      sortBy: {
        dt: 1 // 替换为你的日期字段名，例如：fechaOrden
      },
      output: {
        recentRecords: {
          $push: "$$ROOT",
          window: {
            range: [
              -2, // N年的值，例如 -2 表示最近2年
              0
            ],
            unit: "year" // 时间单位，可以是 "year", "month", "day" 等
          }
        }
      }
    }
  },
  // 2. 找到整个集合中日期最新的文档
  {
    "$sort": {
      dt: -1 // 替换为你的日期字段名
    }
  },
  {
    $limit: 1 // 只保留最新的一条文档
  },
  // 3. 后处理：展开 recentRecords 数组并替换根文档
  {
    "$unwind": "$recentRecords" // 展开 latestRecord 中的 recentRecords 数组
  },
  {
    "$replaceRoot": {
      "newRoot": "$recentRecords" // 将展开后的 recentRecords 作为新的根文档
    }
  }
])

代码解释：

第一个$setWindowFields阶段会遍历集合中的每个文档，并根据dt字段（请替换为你的实际日期字段，如fechaOrden）创建一个名为recentRecords的数组。这个数组包含了当前文档日期之前的两年内的所有文档。
$sort阶段将所有文档按dt字段降序排列，这样日期最新的文档会排在最前面。
$limit: 1阶段只保留了排序后的第一条文档，这条文档就是整个集合中日期最新的那条。其recentRecords数组包含了集合中最新日期之前的两年内的所有文档。
$unwind: "$recentRecords"阶段将recentRecords数组中的每个元素解构为一个独立的文档。
$replaceRoot: { "newRoot": "$recentRecords" }阶段将解构出来的文档提升为新的根文档，从而得到最终的、符合条件的记录列表。