MongoDBの$groupと$pushを使って値のリストを取得する方法

MongoDBの$groupと$pushで値のリストを取得する方法

MongoDBでフィールドの値をグループごとにリスト形式でまとめたい場合、集計フレームワーク（Aggregation Pipeline）の $group ステージと $push 演算子を組み合わせることで実現できます。

この記事では、実際にコレクションを作成し、ユーザーごとに科目（Subject）のリストを取得する手順を解説します。

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

まずは、ドキュメントを含むコレクションを作成しましょう。以下では insertOne() メソッドを使って5件のドキュメントを挿入しています。

> db.groupByDemo.insertOne({"UserName":"John","Subject":"MongoDB"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5cd69f0457806ebf1256f136")
}
> db.groupByDemo.insertOne({"UserName":"Larry","Subject":"MySQL"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5cd69f0657806ebf1256f137")
}
> db.groupByDemo.insertOne({"UserName":"John","Subject":"Java"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5cd69f0d57806ebf1256f138")
}
> db.groupByDemo.insertOne({"UserName":"John","Subject":"C"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5cd69f1357806ebf1256f139")
}
> db.groupByDemo.insertOne({"UserName":"Larry","Subject":"SQL Server"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5cd69f1c57806ebf1256f13a")
}

このコレクションには、「John」と「Larry」の2人のユーザーが存在し、それぞれ複数の科目を持っています。

2. 登録されたドキュメントの確認

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

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

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

{
   "_id" : ObjectId("5cd69f0457806ebf1256f136"),
   "UserName" : "John",
   "Subject" : "MongoDB"
}
{
   "_id" : ObjectId("5cd69f0657806ebf1256f137"),
   "UserName" : "Larry",
   "Subject" : "MySQL"
}
{
   "_id" : ObjectId("5cd69f0d57806ebf1256f138"),
   "UserName" : "John",
   "Subject" : "Java"
}
{
   "_id" : ObjectId("5cd69f1357806ebf1256f139"),
   "UserName" : "John",
   "Subject" : "C"
}
{
   "_id" : ObjectId("5cd69f1c57806ebf1256f13a"),
   "UserName" : "Larry",
   "Subject" : "SQL Server"
}

3. $groupと$pushで値のリストを取得する

ここからが本題です。$group ステージで _id にグループ化の基準となるフィールド（ここでは $UserName）を指定し、$push 演算子を使うことで、各グループに属する値を配列として収集できます。

> db.groupByDemo.aggregate({$group: { '_id': '$UserName', 'Subject': { $push: '$Subject'}}});

実行結果は以下の通りです。

{ "_id" : "Larry", "Subject" : [ "MySQL", "SQL Server" ] }
{ "_id" : "John", "Subject" : [ "MongoDB", "Java", "C" ] }

実行結果のポイント

• Larry の場合：「MySQL」「SQL Server」の2つの科目が配列としてまとめられています。
• John の場合：「MongoDB」「Java」「C」の3つの科目が配列としてまとめられています。

このように $push 演算子は、SQLにおける GROUP_CONCAT や STRING_AGG（配列バージョン）に相当する役割を果たします。重複を除外したい場合は、代わりに $addToSet 演算子を使用するとよいでしょう。