sql >> Databasteknik >  >> NoSQL >> MongoDB

Hur gör man en Mongo-aggregationsfråga i Spring Data?

Även om detta är gammal tråd, men jag hoppas att den som hittade den här tråden nu säkert kan göra flerstegs/pipeline-aggregation (inte helt säker på vad det heter) i MongoRepository. Eftersom jag också kämpar för att leta efter ledtrådar och exempel på aggregering i mongo-repository utan mongo-mall .

Men nu kan jag göra Aggregation-pipeline enligt vårdokumentationen här

Min sammanställning ser ut så här i 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'}
     }}
 ])

Medan jag omvandlar det till @Aggregation-annotering i MongoRepository blir det så här nedan (jag tar bort aposthrephen och ersätter även med metodparametrar):

@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);

Mitt dokument ser ut så här:

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

Och SumPrice-klassen för håll projektionerna:

@Data
public class SumPrice {
  private BigDecimal totalPrice;
}

Jag hoppas att det här svaret kan hjälpa alla som försöker göra aggregering i mongorepository utan att använda mongotemplate .



  1. Redis-gränsen för anslutning/buffertstorlek har överskridits

  2. Visuell hantering av MongoDB-dokument och samlingar

  3. MongoDB begränsa lagringsstorleken?

  4. Hur man frågar MongoDB med like