MongoDb aggregation query conversion to Spring-data

SHASHANK GAUTAM

I have a aggregate function wherein the structure of the output of the method is :

 {
    "_id" : {
        "vehicleNumber" : "HR55W8395",
        "vehicleType" : "TYPE_32"
    },
    "mileage" : [
        3.4200838876537736,
        3.6082731400212595,
        3.7118590539249254,
        2.9805899622661784,
        5.227747018794297,
        3.222515049264743,
        3.8845896154778603,
        3.548054585322907,
        3.010341324091653
    ]
}

The aggregate function is

db.hop.aggregate([{$group : {_id : {vehicleNumber : "$vehicleNumber", vehicleType : "$vehicleType"}, mileage: {$push : "$mileage"}}}])

and the aggregate in spring written is :

AggregationOperation match = match(Criteria.where("startHubOutTime").gte(startDateTime).and("endHubInTime").lte(endDateTime).and("vehicleNumber").exists(true).and("mileage").exists(true));
        //GroupOperationBuilder group = Aggregation.group("vehicleNumber","vehicleType").push("mileage");
        AggregationOperation grAggregationOperation =Aggregation.group("vehicleNumber","vehicleType").push(new BasicDBObject("mileage","$mileage")).as("mileage"); ;//group.as("_id");
        AggregationOperation project = Aggregation.project("mileage").andInclude("vehicleNumber","vehicleType");
        Aggregation newAggregation = Aggregation.newAggregation(match, grAggregationOperation);
        AggregationResults<AggregatedMileageOutput> aggregatedMileageOutputs = mongoTemplate.aggregate(newAggregation, Hop.class, AggregatedMileageOutput.class);

and the output is : AggregatedMileageOutput

class AggregatedMileageOutput {
    private String vehicleNumber;
    private VehicleType vehicleType;
    private ArrayList<Double> mileage;
}

but during aggregation operation I am getting an error :

Request processing failed; nested exception is org.springframework.data.mapping.model.MappingException: No mapping metadata found for java.lang.Double

Stack trace : 
org.springframework.data.mapping.model.MappingException: No mapping metadata found for java.lang.Double
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:228)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.readCollectionOrArray(MappingMongoConverter.java:906)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.readValue(MappingMongoConverter.java:1183)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.access$200(MappingMongoConverter.java:78)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter$MongoDbPropertyValueProvider.getPropertyValue(MappingMongoConverter.java:1133)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.getValueInternal(MappingMongoConverter.java:869)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter$1.doWithPersistentProperty(MappingMongoConverter.java:282)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter$1.doWithPersistentProperty(MappingMongoConverter.java:270)
    org.springframework.data.mapping.model.BasicPersistentEntity.doWithProperties(BasicPersistentEntity.java:309)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:270)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:231)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:191)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:187)
    org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:78)
    org.springframework.data.mongodb.core.MongoTemplate$ReadDbObjectCallback.doWith(MongoTemplate.java:2215)
    org.springframework.data.mongodb.core.MongoTemplate$UnwrapAndReadDbObjectCallback.doWith(MongoTemplate.java:2248)
    org.springframework.data.mongodb.core.MongoTemplate.returnPotentiallyMappedResults(MongoTemplate.java:1533)
    org.springframework.data.mongodb.core.MongoTemplate.aggregate(MongoTemplate.java:1509)
    org.springframework.data.mongodb.core.MongoTemplate.aggregate(MongoTemplate.java:1435)

Please help for this.

chridam

The error is telling you that one of the variable names in the pipeline is not the same (spelling, upper/lower case) as the names of the fields in your mongodb collection. Try re-writing your aggregation operation as

Aggregation agg = newAggregation(
    match(
        Criteria.where("startHubOutTime").gte(startDateTime)
            .and("endHubInTime").lte(endDateTime)
            .and("vehicleNumber").exists(true)
            .and("mileage").exists(true)
    ),
    group("vehicleNumber", "vehicleType").push("mileage").as("mileage") 
);

AggregationResults<AggregatedMileageOutput> results = mongoTemplate.aggregate(agg,  Hop.class, AggregatedMileageOutput.class);

List<AggregatedMileageOutput> mappedResults = results.getMappedResults();

AggregatedMileageOutput firstItem = mappedResults.get(0);

Collected from the Internet

Please contact [email protected] to delete if infringement.