MongoDBで重複する名前ごとの最大スコアを取得する方法

コレクション内のドキュメントをグループ化して最大スコアを取得するには、group()メソッドを使用します。まず、サンプルドキュメントを含むコレクションを作成しましょう。

> db.demo114.insertOne({"Score":60,"Name":"Chris"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e2efc57d8f64a552dae6354")
}
> db.demo114.insertOne({"Score":87,"Name":"Chris"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e2efc5ad8f64a552dae6355")
}
> db.demo114.insertOne({"Score":45,"Name":"David"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e2efc5dd8f64a552dae6356")
}
> db.demo114.insertOne({"Score":67,"Name":"Chris"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e2efc68d8f64a552dae6357")
}
> db.demo114.insertOne({"Score":38,"Name":"David"});
{
   "acknowledged" : true,
   "insertedId" : ObjectId("5e2efc74d8f64a552dae6358")
}

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

> db.demo114.find();

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

{ "_id" : ObjectId("5e2efc57d8f64a552dae6354"), "Score" : 60, "Name" : "Chris" }
{ "_id" : ObjectId("5e2efc5ad8f64a552dae6355"), "Score" : 87, "Name" : "Chris" }
{ "_id" : ObjectId("5e2efc5dd8f64a552dae6356"), "Score" : 45, "Name" : "David" }
{ "_id" : ObjectId("5e2efc68d8f64a552dae6357"), "Score" : 67, "Name" : "Chris" }
{ "_id" : ObjectId("5e2efc74d8f64a552dae6358"), "Score" : 38, "Name" : "David" }

重複する名前ごとの最大スコアを求めるクエリ

以下のクエリでは、重複する名前の値(「Chris」や「David」など)ごとにドキュメントをグループ化し、それぞれの名前における最大スコアを計算しています。

> db.demo114.group(
...    {key: {Name:true},
...    reduce: function(c,p) {
...       if (p.maximumScore < c.Score) {
...          p.maximumScore = c.Score;
...       }
...    },
...    initial: { maximumScore: 0 }}
... );

実行すると、以下の結果が得られます。

[
   {
       "Name" : "Chris",
       "maximumScore" : 87
   },
   {
       "Name" : "David",
       "maximumScore" : 45
   }
]

この結果から、「Chris」の最大スコアは87、「David」の最大スコアは45であることがわかります。reduce関数内で、現在のドキュメントのスコアがそれまでの最大値より大きい場合に値を更新することで、グループごとの最大スコアを求めています。

補足：集計パイプラインによる代替方法

なお、group()コマンドは現在非推奨(deprecated)となっています。最新のMongoDBでは、集計パイプラインの$groupステージと$max演算子を組み合わせる方法が推奨されています。同じ結果は、以下のクエリでも取得できます。

> db.demo114.aggregate([
...    { $group: { _id: "$Name", maximumScore: { $max: "$Score" } } }
... ]);

集計パイプラインを使うことで、より簡潔かつパフォーマンスの高い集計処理が可能になります。新規プロジェクトでは、こちらの方法を採用することをおすすめします。