如何使用Spring Mongo Template查询日期差大于validity字段值的MongoDB文档

嘿，刚好我之前处理过类似的需求，给你一个基于Spring MongoTemplate的完整实现方案！

要实现这个需求，我们需要通过MongoDB的聚合管道来完成日期差值计算和字段对比过滤，Spring MongoTemplate完美支持这种复杂查询场景。

思路分析 #

1. 首先计算campaignDuration.startDate与当前日期的天数差值，这里可以用MongoDB的内置日期函数简化操作。
2. 然后将计算出的天数差值和同文档的attributes.validity字段做对比，筛选出差值更大的文档。

代码实现（MongoDB 5.0+ 版本） #

MongoDB 5.0新增了$dateDiff函数，能直接计算两个日期的间隔天数，用起来更简洁直观：

import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.aggregation.Aggregation;
import org.springframework.data.mongodb.core.aggregation.MatchOperation;
import org.springframework.data.mongodb.core.aggregation.ProjectionOperation;
import static org.springframework.data.mongodb.core.aggregation.Aggregation.*;

// 假设你的实体类是CampaignDocument
public List<CampaignDocument> findExpiredCampaigns(MongoTemplate mongoTemplate) {
    // 1. 投影阶段：计算天数差值并添加为临时字段，同时保留原文档所有字段
    ProjectionOperation calculateDaysDiff = project("*")
            .andExpression("dateDiff(currentDate(), '$campaignDuration.startDate', 'day')")
            .as("daysDifference");

    // 2. 匹配阶段：筛选天数差值大于validity的文档
    MatchOperation filterByValidity = match(Criteria.where("daysDifference").gt("attributes.validity"));

    // 构建聚合管道
    Aggregation aggregation = newAggregation(calculateDaysDiff, filterByValidity);

    // 执行聚合查询并映射到实体类
    return mongoTemplate.aggregate(aggregation, "your-collection-name", CampaignDocument.class)
            .getMappedResults();
}

兼容低版本MongoDB（5.0以下） #

如果你的MongoDB版本低于5.0，需要通过毫秒数相除的方式手动计算天数差：

ProjectionOperation calculateDaysDiff = project("*")
        .andExpression("floor((currentDate() - '$campaignDuration.startDate') / (1000 * 60 * 60 * 24))")
        .as("daysDifference");

这里的逻辑是：

• currentDate()和startDate都是毫秒级时间戳，相减得到时间差的毫秒数
• 除以一天的毫秒数（1000*60*60*24），再用floor取整得到完整天数

实体类参考 #

对应你的文档结构，实体类可以这样定义：

public class CampaignDocument {
    private CampaignDuration campaignDuration;
    private Attributes attributes;

    // Getters and Setters

    public static class CampaignDuration {
        private Date startDate;
        // Getter and Setter
    }

    public static class Attributes {
        private int validity;
        // Getter and Setter
    }
}

注意事项 #

• 替换代码中的your-collection-name为你实际的MongoDB集合名称
• 确保Spring MongoTemplate已经正确配置，能连接到你的MongoDB实例
• 如果不需要保留原文档的所有字段，可以把project("*")改成只保留需要的字段（比如project("attributes")），减少数据传输开销

内容的提问来源于stack exchange，提问作者sgarg5