动态获取集合中最近N年数据
在 mongodb 中进行日期范围查询是常见的操作，但有时需求并非基于当前系统时间，而是需要根据集合中数据的最新日期来动态确定一个时间窗口。例如，我们可能需要获取集合中最近2年的记录，而这“最近2年”应以集合内最新的数据日期为终点，向前推算2年。直接硬编码日期或使用 new date() 都会导致查询缺乏灵活性和适应性。
为了解决这一问题，我们可以利用 MongoDB 强大的聚合管道（Aggregation Pipeline）功能。以下将详细阐述如何构建一个聚合管道来实现这一目标。
聚合管道实现步骤
核心思路是首先识别集合中最新的日期，然后以此日期为锚点，计算出向前N年的起始日期，并最终筛选出符合条件的文档。
以下是实现此功能的聚合管道示例：
db.collection.aggregate([
// 阶段1: 使用 $setWindowFields 为每个文档计算其“最近N年”的记录
// 这里的目标是让拥有集合中最新日期的文档，其 recentRecords 数组包含我们所需的所有数据。
{
$setWindowFields: {
sortBy: { dt: 1 }, // 确保按日期升序排列，以便 window 操作能正确向前追溯
output: {
recentRecords: {
$push: "$$ROOT", // 将当前文档推入数组
window: {
range: [-2, 0], // 定义一个时间窗口，从当前文档日期向前推2年，到当前文档日期
unit: "year" // 单位为年
}
}
}
}
},
// 阶段2: 找到整个集合中日期最新的文档
{
$sort: { dt: -1 } // 按日期降序排序
},
{
$limit: 1 // 只取排序后的第一个文档，即日期最新的文档
},
// 阶段3: 提取并重构结果
// 此时，我们得到的文档是整个集合中日期最新的那一个，
// 并且它的 recentRecords 数组中包含了所有在集合最新日期前2年内的文档。
{
$unwind: "$recentRecords" // 展开 recentRecords 数组，将每个子文档提升为独立的文档
},
{
$replaceRoot: { newRoot: "$recentRecords" } // 将展开后的子文档设置为新的根文档
}
])管道阶段详解
-
$setWindowFields 阶段：
- 此阶段是实现动态日期计算的关键。它允许我们在一个“窗口”内对文档进行操作。
- sortBy: { dt: 1 }：指定窗口操作的排序字段。为了让 range 能够正确地向前追溯，通常需要按日期升序排列。
- output: { recentRecords: { $push: "$$ROOT", window: { range: [-2, 0], unit: "year" } } }：
- recentRecords 是新生成的字段名。
- $push: "$$ROOT"：将当前处理的文档（$$ROOT）推入 recentRecords 数组。
- window: { range: [-2, 0], unit: "year" }：定义了窗口的范围。[-2, 0] 表示从当前文档日期向前推2年（-2）到当前文档日期（0）。unit: "year" 指定了单位是年。
- 重要提示： 在此阶段，每个文档都会有一个 recentRecords 数组，包含以其自身日期为终点的近N年数据。我们后续通过 $sort 和 $limit 来选取其中最有用的那个数组。
-
$sort 阶段：
- $sort: { dt: -1 }：将所有文档按 dt 字段降序排列，这样日期最新的文档就会排在最前面。
-
$limit 阶段：
- $limit: 1：只保留排序后的第一个文档。这个文档就是整个集合中日期最新的文档。此时，这个文档的 recentRecords 数组中包含了所有在集合绝对最新日期前2年内的文档，这正是我们想要的结果。
-
$unwind 阶段：
- $unwind: "$recentRecords"：由于 recentRecords 是一个数组，此阶段会将其展开。如果 recentRecords 数组中有10个元素，那么这个阶段会生成10个新的文档，每个文档的根就是原数组中的一个元素。
-
$replaceRoot 阶段：
- $replaceRoot: { newRoot: "$recentRecords" }：将 unwind 后的 recentRecords 子文档提升为新的根文档，从而得到我们最终想要的原始文档列表。
注意事项与最佳实践
- 日期字段类型： 确保用于日期查询的字段（例如示例中的 dt 或 fechaOrden）是 MongoDB 的 ISODate 类型。如果它们是字符串，则需要先进行类型转换，或者在查询中进行字符串比较，但这通常效率较低且容易出错。
-
索引： 对于大型集合，务必在日期字段（如 dt）上创建索引。这将极大地提高 $sort 和 $setWindowFields 阶段的性能。
db.collection.createIndex({ dt: 1 }); - 灵活性： 要改变查询的年数（例如，从2年改为3年），只需修改 $setWindowFields 阶段中的 range: [-2, 0] 为 range: [-3, 0] 即可。
- 性能考量： 尽管此聚合管道功能强大且灵活，但对于非常大的数据集，$setWindowFields 可能会消耗较多资源。在生产环境中，应进行性能测试并根据实际情况优化。
-
替代方案（两阶段查询）： 如果性能成为瓶颈，一个替代方案是执行两次查询：
- 首先使用 $sort 和 $limit 找到集合中的最大日期。
- 然后使用这个最大日期计算出起始日期，再执行一次普通的 $match 查询。 然而，聚合管道的优势在于它是一个单一的、原子的操作，避免了两次网络往返和潜在的竞态条件。
总结
通过巧妙地结合 MongoDB 的聚合管道操作符，特别是 $setWindowFields，我们能够构建出高度动态和灵活的查询，以获取集合中相对于其自身数据最新日期的“最近N年”记录。这种方法避免了硬编码日期，提升了应用程序的健壮性和可维护性，是处理复杂日期查询场景的推荐方案。
