サンプルデータ:
(注)MongoDBテーブルには必ず「_id」フィールドが入っていますが敢えて表示しないようになっています。質問の「id」フィールド名をそのまま使います。
db.hoge.find()
{ "_id" : ObjectId("5841f3d27261c6e2fca154d4"), "id" : "1", "reply" : null }
{ "_id" : ObjectId("5841f3d27261c6e2fca154d5"), "id" : "2", "reply" : "1" }
{ "_id" : ObjectId("5841f3d27261c6e2fca154d6"), "id" : "3", "reply" : "2" }
{ "_id" : ObjectId("5841f3d27261c6e2fca154d7"), "id" : "4", "reply" : "1" }
> db.hoge.find({}, {_id: false})
{ "id" : "1", "reply" : null }
{ "id" : "2", "reply" : "1" }
{ "id" : "3", "reply" : "2" }
{ "id" : "4", "reply" : "1" }
基本的に以下二つの結果を合流することになります。「id」と「reply」の項目:
> db.hoge.find({}, {_id: false, "id": true, "reply": true}).sort({"id": 1})
{ "id" : "1", "reply" : null }
{ "id" : "2", "reply" : "1" }
{ "id" : "3", "reply" : "2" }
{ "id" : "4", "reply" : "1" }
さらにこの集計結果。
(注)「_id」フィールドは集計結果のキーです。今回ご質問のサンプルデータにあるリプライ元の「id」フィールドと同じ意味です。
> db.hoge.aggregate([
{$group: {_id: "$reply", "replyCount": {$sum: 1}}},
{$match: {"_id": {$ne: null}}},
{$sort: {"_id": 1}}])
{ "_id" : "1", "replyCount" : 2 }
{ "_id" : "2", "replyCount" : 1 }
つまり、方法の一つは「この2つの結果をクライント側(アプリケーション側)でマージする」です。
もう一つは$lookupの集計ステージと集計配列$sizeのオペレーターを適用してこのように出力する方法です。
> db.hoge.aggregate([
{$project: {"_id": false, "id": "$id", "reply": "$reply"}},
{$lookup: {from: "hoge", localField: "id", foreignField: "reply", as: "replies"}},
{$project: {"id": "$id", "reply": "$reply", "replyCount": {$size: "$replies"}}}] )
{ "id" : "1", "reply" : null, "replyCount" : 2 }
{ "id" : "2", "reply" : "1", "replyCount" : 1 }
{ "id" : "3", "reply" : "2", "replyCount" : 0 }
{ "id" : "4", "reply" : "1", "replyCount" : 0 }