How to do a Mongo aggregation query in Spring Data?

by

Although this is old thread, but I hope whoever found this thread can now safely for doing multi stage/pipeline aggregation(not quite sure what it’s call) in MongoRepository.
As I’m also struggling looking for clue and example of aggregation in mongo repository without mongo template.

But now, I’m able to do the Aggregation pipeline as per spring doc said in here

My aggregation looks like this in mongoshell:

db.getCollection('SalesPo').aggregate([
    {$project: {
        month: {$month: '$poDate'},
        year: {$year: '$poDate'},
        amount: 1,
        poDate: 1
     }},
      {$match: {$and : [{year:2020} , {month:7}] 
     }}
      ,
      {$group: { 
          '_id': {
            month: {$month: '$poDate'},
            year: {$year: '$poDate'} 
          },
          totalPrice: {$sum: {$toDecimal:'$amount'}},
          }
      },
    {$project: {
        _id: 0,
        totalPrice: {$toString: '$totalPrice'}
     }}
 ])

While I transform it into @Aggregation annotation in MongoRepository become like this below (I’m removing the aposthrephe and also replace with method params):

@Repository
public interface SalesPoRepository extends MongoRepository<SalesPo, String> {

@Aggregation(pipeline = {"{$project: {\n" +
        "        month: {$month: $poDate},\n" +
        "        year: {$year: $poDate},\n" +
        "        amount: 1,\n" +
        "        poDate: 1\n" +
        "     }}"
        ,"{$match: {$and : [{year:?0} , {month:?1}] \n" +
        "     }}"
        ,"{$group: { \n" +
        "          '_id': {\n" +
        "            month: {$month: $poDate},\n" +
        "            year: {$year: $poDate} \n" +
        "          },\n" +
        "          totalPrice: {$sum: {$toDecimal:$amount}},\n" +
        "          }\n" +
        "      }"
    ,"{$project: {\n" +
        "        _id: 0,\n" +
        "        totalPrice: {$toString: $totalPrice}\n" +
        "     }}"})
    AggregationResults<SumPrice> sumPriceThisYearMonth(Integer year, Integer month);

My Document looks like this:

@Document(collection = "SalesPo")
@Data
public class SalesPo {
  @Id
  private String id;
  @JsonSerialize(using = LocalDateSerializer.class)
  private LocalDate poDate;
  private BigDecimal amount;
}

And the SumPrice class for hold the projections:

@Data
public class SumPrice {
  private BigDecimal totalPrice;
}

I hope this answer can help whoever try to do aggregation in mongorepository without using mongotemplate.

More Related Contents:

  1. What’s the difference between Spring Data’s MongoTemplate and MongoRepository?
  2. Making spring-data-mongodb multi-tenant
  3. spring-data-mongo – optional query parameters?
  4. How To Configure MongoDb Collection Name For a Class in Spring Data
  5. Spring data mongodb – The ‘cursor’ option is required
  6. MongoDB $aggregate $push multiple fields in Java Spring Data
  7. Dynamic spring data jpa repository query with arbitrary AND clauses
  8. What is this spring.jpa.open-in-view=true property in Spring Boot?
  9. setMaxResults for Spring-Data-JPA annotation?
  10. Spring Boot, Spring Data JPA with multiple DataSources
  11. ‘Field required a bean of type that could not be found.’ error spring restful API using mongodb
  12. Using generics in Spring Data JPA repositories
  13. How to fetch FetchType.LAZY associations with JPA and Hibernate in a Spring Controller
  14. What is difference between CrudRepository and JpaRepository interfaces in Spring Data JPA?
  15. Handling soft-deletes with Spring JPA
  16. Implementing custom methods of Spring Data repository and exposing them through REST
  17. Mongodb Increment value inside nested array
  18. Spring-Data FETCH JOIN with Paging is not working
  19. Java SE + Spring Data + Hibernate
  20. Why use returned instance after save() on Spring Data JPA Repository?
  21. How to use @Transactional with Spring Data?
  22. How do I properly do a background thread when using Spring Data and Hibernate?
  23. Spring Data JPA: Query by Example?
  24. java.lang.NoSuchMethodError: javax.persistence.spi.PersistenceUnitInfo.getValidationMode()Ljavax/persistence/ValidationMode;
  25. Set MongoDb converter programmatically
  26. How to store @Query sql in external file for CrudRepository?
  27. Missing CrudRepository#findOne method
  28. How to enable LockModeType.PESSIMISTIC_WRITE when looking up entities with Spring Data JPA?
  29. FetchMode join makes no difference for ManyToMany relations in spring JPA repositories
  30. Spring Data JPA – Is it possible to sort on a calculated property?

Leave a Comment