MongoDB：动态查询集合中最新N年数据的教程_石家庄创泽智能科技有限公司

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

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

2025-10-07

浏览次数：次

返回列表

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

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

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

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

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

{
  $match: {
    fechaOrden: {
      $gte: ISODate("2018-01-01"),
      $lt: ISODate("2025-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年”的数据。

新快购物系统

新快购物系统是集合目前网络所有购物系统为参考而开发，不管从速度还是安全我们都努力做到最好，此版虽为免费版但是功能齐全，无任何错误，特点有：专业的、全面的电子商务解决方案，使您可以轻松实现网上销售；自助式开放性的数据平台，为您提供充满个性化的设计空间；功能全面、操作简单的远程管理系统，让您在家中也可实现正常销售管理；严谨实用的全新商品数据库，便于查询搜索您的商品。

0 查看详情新快购物系统

$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: &quot;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" }阶段将解构出来的文档提升为新的根文档，从而得到最终的、符合条件的记录列表。