问题阐述：动态获取集合中最新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" }阶段将解构出来的文档提升为新的根文档，从而得到最终的、符合条件的记录列表。
注意事项
- 日期字段索引： 为了保证查询性能，请确保你的日期字段（例如dt或fechaOrden）上存在索引。
- 字段名替换： 示例代码中的dt字段需要替换为你集合中实际存储日期的字段名。
- N年值调整： range: [-2, 0]中的-2可以根据你的需求调整为任意负数，例如-5表示最近5年。
- 时间单位： unit: "year"可以根据需要更改为"month"、"day"等。
- 性能考量： 对于非常大的数据集，$setWindowFields操作可能会消耗较多资源。在生产环境中，请务必进行性能测试。
总结
通过上述聚合管道，我们成功地实现了一个动态、灵活的MongoDB查询，能够获取集合中最新N年的数据，而无需硬编码日期或依赖当前年份。这种方法充分利用了MongoDB的聚合框架的强大功能，为处理复杂的日期时间查询提供了优雅的解决方案。
