MongoDB Advanced Aggregations With Spring Boot and Amazon Corretto

1
export JAVA_HOME=/Library/Java/JavaVirtualMachines/amazon-corretto-21.jdk/Contents/Home 

1
java --version
2
openjdk 21.0.2 2024-01-16 LTS
3
OpenJDK Runtime Environment Corretto-21.0.2.13.1 (build 21.0.2+13-LTS)
4
OpenJDK 64-Bit Server VM Corretto-21.0.2.13.1 (build 21.0.2+13-LTS, mixed mode, sharing)

1
git clone https://github.com/mongodb-developer/spring-boot-mongodb-aggregations.git

1
db.sales.aggregate([{ $match: { "storeLocation": "London"}}])

1
@Override
2
public List<SalesDTO> matchOp(String matchValue) {
3
MatchOperation matchStage = match(new Criteria("storeLocation").is(matchValue));
4
Aggregation aggregation = newAggregation(matchStage);
5
AggregationResults<SalesDTO> results = mongoTemplate.aggregate(aggregation, "sales", SalesDTO.class);
6
return results.getMappedResults();
7
}

1
@Override
2
public List<GroupDTO> groupOp(String matchValue) {
3
MatchOperation matchStage = match(new Criteria("storeLocation").is(matchValue));
4
GroupOperation groupStage = group("storeLocation").count()
5
                                                          .as("totalSales")
6
                                                          .avg("customer.satisfaction")
7
                                                          .as("averageSatisfaction");
8
ProjectionOperation projectStage = project("storeLocation", "totalSales", "averageSatisfaction");
9
Aggregation aggregation = newAggregation(matchStage, groupStage, projectStage);
10
AggregationResults<GroupDTO> results = mongoTemplate.aggregate(aggregation, "sales", GroupDTO.class);
11
return results.getMappedResults();
12
}

1
curl http://localhost:8080/api/sales/aggregation/groupStage/Denver | jq

1
@Override
2
public List<TotalSalesDTO> TotalSales() {
3
GroupOperation groupStage = group("storeLocation").count().as("totalSales");
4
SkipOperation skipStage = skip(0);
5
LimitOperation limitStage = limit(10);
6
Aggregation aggregation = newAggregation(groupStage, skipStage, limitStage);
7
AggregationResults<TotalSalesDTO> results = mongoTemplate.aggregate(aggregation, "sales", TotalSalesDTO.class);
8
return results.getMappedResults();
9
}

1
curl http://localhost:8080/api/sales/aggregation/TotalSales | jq

1
@Override
2
public List<PopularDTO> findPopularItems() {
3
UnwindOperation unwindStage = unwind("items");
4
GroupOperation groupStage = group("$items.name").sum("items.quantity").as("totalQuantity");
5
SortOperation sortStage = sort(Sort.Direction.DESC, "totalQuantity");
6
LimitOperation limitStage = limit(5);
7
Aggregation aggregation = newAggregation(unwindStage,groupStage, sortStage, limitStage);
8
return mongoTemplate.aggregate(aggregation, "sales", PopularDTO.class).getMappedResults();
9
}

1
curl http://localhost:8080/api/sales/aggregation/PopularItem | jq

1
@Override
2
public List<BucketsDTO> findTotalSpend(){
3
ProjectionOperation projectStage = project()
4
                .and(ArrayOperators.Size.lengthOfArray("items")).as("numItems")
5
                .and(ArithmeticOperators.Multiply.valueOf("price")
6
                        .multiplyBy("quantity")).as("totalAmount");
7
8
BucketOperation bucketStage = bucket("numItems")
9
                .withBoundaries(0, 3, 6, 9)
10
                .withDefaultBucket("Other")
11
                .andOutputCount().as("count")
12
                .andOutput("totalAmount").sum().as("totalAmount");
13
14
Aggregation aggregation = newAggregation(projectStage, bucketStage);
15
return mongoTemplate.aggregate(aggregation, "sales", BucketsDTO.class).getMappedResults();
16
}

1
curl http://localhost:8080/api/sales/aggregation/buckets | jq