MongoDB集計入門：$groupで同じIDを持つ製品価格を合計する方法

はじめに

MongoDBで、同じID（Product_Id）を持つ複数のドキュメントの価格を合計したい場合は、集計パイプライン（aggregation pipeline）の $group ステージを使用します。_id にグループ化のキーとなる式を指定し、$sum 演算子と組み合わせることで、グループごとの合計値を簡単に求められます。

サンプルコレクションの作成

まず、ドキュメントを含むコレクションを作成しましょう。ここでは「aggregateDemo」というコレクションに4つのドキュメントを挿入します。

> db.aggregateDemo.insertOne({"Product_Id":1,"ProductPrice":50});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e06d3c025ddae1f53b621d9")
}
> db.aggregateDemo.insertOne({"Product_Id":2,"ProductPrice":100});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e06d3c625ddae1f53b621da")
}
> db.aggregateDemo.insertOne({"Product_Id":2,"ProductPrice":500});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e06d3cb25ddae1f53b621db")
}
> db.aggregateDemo.insertOne({"Product_Id":1,"ProductPrice":150});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e06d3d125ddae1f53b621dc")
}

登録済みドキュメントの確認

find() メソッドを使えば、コレクション内のすべてのドキュメントを表示できます。

> db.aggregateDemo.find().pretty();

上記のクエリを実行すると、次のような出力が得られます。

{
   "_id" : ObjectId("5e06d3c025ddae1f53b621d9"),
   "Product_Id" : 1,
   "ProductPrice" : 50
}
{
   "_id" : ObjectId("5e06d3c625ddae1f53b621da"),
   "Product_Id" : 2,
   "ProductPrice" : 100
}
{
   "_id" : ObjectId("5e06d3cb25ddae1f53b621db"),
   "Product_Id" : 2,
   "ProductPrice" : 500
}
{
   "_id" : ObjectId("5e06d3d125ddae1f53b621dc"),
   "Product_Id" : 1,
   "ProductPrice" : 150
}

このように、同じ Product_Id を持つドキュメントが複数存在していることが確認できます。

$groupによる集計で価格を合計する

それでは、$Product_Id をグループ化のキーとして指定し、$sum で ProductPrice を合計する集計クエリを見ていきましょう。

> db.aggregateDemo.aggregate([
...    {
...       $group: {
...          _id: "$Product_Id",
...          TotalValue: {$sum: "$ProductPrice"}
...       }
...    }
... ]
... );

このクエリを実行すると、次のような出力が得られます。

{ "_id" : 2, "TotalValue" : 600 }
{ "_id" : 1, "TotalValue" : 200 }

結果の読み方

出力結果を見ると、Product_Id が 1 のグループでは 50 + 150 = 200、Product_Id が 2 のグループでは 100 + 500 = 600 となっており、同じIDを持つドキュメントの価格が正しく合計されていることがわかります。なお、$group の結果が出力される順序は保証されないため、必要に応じて $sort ステージを組み合わせるとよいでしょう。

まとめ

$group ステージの _id にグループ化のキーとなるフィールドを指定し、$sum を使うことで、同一IDを持つドキュメントの数値フィールドを簡単に合計できます。売上集計や在庫管理など、実務のさまざまなシーンで役立つ基本的かつ強力なテクニックなので、ぜひマスターしておきましょう。