MongoDBでネストされた$groupと$sumを使って同一ProductIDの在庫数を取得する方法

MongoDBの$group演算子とは

MongoDBの$groupは、指定した_id式に基づいて入力ドキュメントをグループ化するための集計演算子です。$sumや$addToSetなどのアキュムレータと組み合わせることで、合計値の算出やユニークな値の収集が可能になります。

本記事では、ネストされた$groupと$sumを活用して、同じProductIDを持つ商品の在庫数を取得する方法を具体的なサンプルコードとともに解説します。

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

まず、ドキュメントを含むコレクションを作成しましょう。

> db.demo466.insertOne(
... {
...
... "ProductPrice" :150,
... "ProductQuantity" : 1,
... "ProductName" : "Product-1",
... "ActualAmount" :110,
... "ProductProfit" : 40,
... "ProductId" : 1
... }
... );
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5e80477cb0f3fa88e2279066")
}
>
> db.demo466.insertOne(
... {
...
... "ProductPrice" :150,
... "ProductQuantity" : 1,
... "ProductName" : "Product-1",
... "ActualAmount" :110,
... "ProductProfit" : 40,
... "ProductId" : 2
... }
... );
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5e80477db0f3fa88e2279067")
}
> db.demo466.insertOne(
... {
...
... "ProductPrice" :170,
... "ProductQuantity" : 2,
... "ProductName" : "Product-2",
... "ActualAmount" :130,
... "ProductProfit" : 50,
... "ProductId" : 3
... }
... );
{
    "acknowledged" : true,
    "insertedId" : ObjectId("5e80477eb0f3fa88e2279068")
}

登録データの確認

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

> db.demo466.find();

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

{ "_id" : ObjectId("5e80477cb0f3fa88e2279066"), "ProductPrice" : 150, "ProductQuantity" : 1,
"ProductName" : "Product-1", "ActualAmount" : 110, "ProductProfit" : 40, "ProductId" : 1 }
{ "_id" : ObjectId("5e80477db0f3fa88e2279067"), "ProductPrice" : 150, "ProductQuantity" : 1,
"ProductName" : "Product-1", "ActualAmount" : 110, "ProductProfit" : 40, "ProductId" : 2 }
{ "_id" : ObjectId("5e80477eb0f3fa88e2279068"), "ProductPrice" : 170, "ProductQuantity" : 2,
"ProductName" : "Product-2", "ActualAmount" : 130, "ProductProfit" : 50, "ProductId" : 3 }

ネストされた$groupと$sumを使用した集計クエリ

以下は、MongoDBでネストされた$groupと$sumを使用して在庫数を集計するクエリの例です。$addToSetでユニークなProductIdを収集し、$projectステージで$size演算子を使ってその件数を「NumberOfProductInStock」として算出しています。

> db.demo466.aggregate([
... {
...     '$group': {
...        '_id': {
...           'ProductName': '$ProductName',
...        },
...        'ActualAmount': {'$sum': '$ActualAmount'},
...        'ProductQuantity': {'$sum': '$ProductQuantity'},
...        'ProductId': {'$addToSet': '$ProductId'},
...     },
... },
... {
...     '$project': {
...        'ProductQuantity': true,
...        'ActualAmount': true,
...        'NumberOfProductInStock': {'$size': '$ProductId'}
...     }
... }])

実行結果

上記の集計パイプラインを実行すると、次のような結果が出力されます。

{ "_id" : { "ProductName" : "Product-2" }, "ActualAmount" : 130, "ProductQuantity" : 2,
"NumberOfProductInStock" : 1 }
{ "_id" : { "ProductName" : "Product-1" }, "ActualAmount" : 220, "ProductQuantity" : 2,
"NumberOfProductInStock" : 2 }

結果のポイント

• Product-1: ActualAmount（実際金額）の合計は220（110×2）、ProductQuantity（数量）の合計は2、在庫数は2件です。
• Product-2: ActualAmountの合計は130、ProductQuantityの合計は2、在庫数は1件です。

$addToSetによって重複のないProductIdが配列として収集され、$sizeでその要素数をカウントすることで、各商品名ごとの在庫数を効率的に取得できます。この手法は、売上集計や在庫管理など、グループごとの統計情報が必要なシーンで幅広く活用できます。