如何计算 mongodb spring 中特定字段的平均值？

Question

如何计算 mongoDB 和 spring 中字段的平均值。我们有供终端使用的 $avg() 函数，但如何使用 mongotemplate 执行它。

例如

 db.sales.aggregate(
    [
     {
       $group:
         {
           _id: "$item",
           avgAmount: { $avg: { $multiply: [ "$price", "$quantity" ] } },
           avgQuantity: { $avg: "$quantity" }
         }
     }
   ]
)

我们在这里计算平均值，所以我们如何使用 mongotemplate 执行它。

现在我正在使用一个函数来获得平均评分

我正在使用这样的功能..

public List getrating() {

    TypedAggregation<RatingReviewModel> agg = newAggregation(RatingReviewModel.class,

           group("hospitalid")            
            .avg("rating").as("avgrating")
    );

    AggregationResults<DBObject> result = operations.aggregate(agg, DBObject.class);
    List<DBObject> resultList = result.getMappedResults();

return resultList;
}

但是在调试时 resultList 是空的，所以它没有返回任何内容。

Answer 1

假设您的 Sale 对象定义为：

class Sale {
    String id;
    String item;
    double price;
    int quantity;
}

使用 mongotemplate 之前，您需要管道中的 $project 阶段来获取计算字段，这可能有点违反直觉，因为本机 MongoDB 聚合全部在一个 $group 操作管道中完成，而不是将聚合分为两个阶段，因此：

import static org.springframework.data.mongodb.core.aggregation.Aggregation.*;

TypedAggregation<Sale> agg = newAggregation(Sale.class,
      project("quantity")
         .andExpression("price * quantity").as("totalAmount"),
      group("item")            
        .avg("totalAmount").as("avgAmount")
        .avg("quantity").as("avgQuantity")
);

AggregationResults<DBObject> result = mongoTemplate.aggregate(agg, DBObject.class);
List<DBObject> resultList = result.getMappedResults();

以上也可以使用原生的Java Driver实现：

ApplicationContext context = new AnnotationConfigApplicationContext(SpringMongoConfig.class);
MongoOperations operation = (MongoOperations) context.getBean("mongoTemplate");

BasicDBList pipeline = new BasicDBList();
String[] multiplier = { "$price", "$quantity" };

pipeline.add(
    new BasicDBObject("$group",
        new BasicDBObject("_id", "$item")
        .append("avgAmount", new BasicDBObject(
            "$avg", new BasicDBObject(
                "$multiply", multiplier
            )
        ))
        .append("avgQuantity", new BasicDBObject("$avg", "$quantity"))
    )
);

BasicDBObject aggregation = new BasicDBObject("aggregate", "sales")
                            .append("pipeline", pipeline);
System.out.println(aggregation);
CommandResult commandResult = operation.executeCommand(aggregation);

如何计算 mongodb spring 中特定字段的平均值？

how to calculate average of a particular field in mongodb spring?

mongodb

spring-mvc

aggregation-framework

mongotemplate