Монго Агрегация сопоставления и запрос для выборки записей для конкретного года с использованием шаблона Монго

Question

Я использую шаблон монго для запроса документов на основе состояния и почтового индекса, что было достигнуто с использованием подхода Criteria и Query, как показано ниже:

List<ModelClass> modelClass = null;
Criteria criteria = new Criteria();
if(request.getState()!=null) {
  criteria = criteria.and("state").is(request.getState());
}
if(request.getZipcode()!=null) {
 criteria = criteria.and("zipcode").is(request.getZipcode());
}
Query query = new Query(criteria);

modelClass = mongoTemplate.find(query, ModelClass.class, "collectionName");

Ниже представлена ​​структура моей коллекции:

{
  "id": "5c59508688c12c9a3dc2dfe2",
  "zipcode": "12345",
  "state": "NY",
  "date": "2019-02-05T08:59:50.703",
  "status": "pass"
},
{
   "id": "5c5957216f4b9613c0c0b1ed",
    "zipcode": "45678",
    "state": "CO",
    "date": "2018-01-05T08:59:50.703",
    "status": "fail"
},
etc....

Только для прошедшего года (например, 2019.) Теперь мне нужно извлечь соответствующие записи, извлекая часть месяца из даты и используя поле статуса в моей коллекции, чтобы обработать пропущенные и ошибочные записи для пользовательского интерфейса.Есть много примеров, использующих прямой запрос mongoShell, но нужна помощь с синтаксисом, использующим шаблон mongo и необходимое сопоставление классов pojo для достижения того же самого.Также возможно ли выполнить обработку пропущенных и неудачных записей для каждого месяца, используя сам запрос агрегации mongo?

Ожидается некоторая помощь / вход от экспертов mongo относительно правильного способа сделать это в одной операции выборки для прохода исценарий сбоя.

Answer 1

Наконец, я смог выполнить вышеупомянутое требование, используя саму реализацию монго.Там могут быть лучшие решения с использованием последних версий МонгоЯ использую spring-data-mongodb-1.8.2.RELEASE, так что это может помочь любому, кто ищет подобное решение.

Создать класс для поддержки операции агрегирования:

import org.springframework.data.mongodb.core.aggregation.AggregationOperation;
import org.springframework.data.mongodb.core.aggregation.AggregationOperationContext;

import com.mongodb.DBObject;

public class CustomProjectAggregationOperation implements AggregationOperation {

    private DBObject operation;

    public CustomProjectAggregationOperation (DBObject operation) {
        this.operation = operation;
    }

    @Override
    public DBObject toDBObject(AggregationOperationContext context) {
        return context.getMappedObject(operation);
    }
}

Реализация:

Criteria criteria = new Criteria();
criteria = criteria.and("date").gte(fromDate).lte(endDate).exists(true);

DBObject operation = (DBObject)new BasicDBObject("$group",
                          new BasicDBObject("_id", new BasicDBObject("month", 
                            new BasicDBObject("$month", "$date")))
                            .append("passCount", new BasicDBObject("$sum", 
                               new BasicDBObject("$cond", new Object[]{
                                 new BasicDBObject("$eq", new Object[]{ "$status", 
                                                               "Pass"}),1,0}))
                            ).append("failCount", new BasicDBObject(    
                                "$sum", new BasicDBObject("$cond", new Object[]{ 
                                   new BasicDBObject("$eq", new Object[]{ "$status", 
                                                            "Fail"}),1,0}))
                            ));

Aggregation agg = newAggregation(match(criteria),new 
                          CustomProjectAggregationOperation(operation));

List<ModelClass> modelList= mongoTemplate.aggregate(agg,"collectionName",ModelClass.class).getMappedResults();

Модель класса Ссылка для любых новичков монго, как я:

public class ModelClass{

    private String month;
    private int passCount;
    private int failCount;

    public String getMonth() {
        return month;
    }
    public void setMonth(String month) {
        this.month= month;
    }
    public int getPassCount() {
        return passCount;
    }
    public void setPassCount(int passCount) {
        this.passCount= passCount;
    }
    public int getFailCount() {
        return failCount;
    }
    public void setFailCount(int failCount) {
        this.failCount = failCount;
    }   
}

Пожалуйста, не забудьте создатьМодель pojo с похожими именами, указанными в запросе для отображения монго на работу.

Эквивалент Mongo Shell:

db.collectionName.aggregate([
    {
        "$match": {
            "date": {
                "$gte": {
                    "$date": "2018-12-31T18:30:00.000Z"
                },
                "$lte": {
                    "$date": "2019-12-31T13:43:17.106Z"
                },
                "$exists": true
            }
        }
    }, {
        "$group": {
            "_id": {
                "month": {
                    "$month": "$date"
                }
            },
            "passCount": {
                "$sum": {
                    "$cond": [{
                        "$eq": ["$status", "Pass"]
                    }, 1, 0]
                }
            },
            "failCount": {
                "$sum": {
                    "$cond": [{
                        "$eq": ["$status", "Fail"]
                    }, 1, 0]
                }
            }
        }
    }
]);