Можете да използвате по-долу тръбопровода за агрегиране.
Заявката по-долу ще $unwind
tag_id
последвано от $group
за преброяване на email
и $cond
оператор за преброяване на unread
електронна поща.
db.collection.aggregate(
{$unwind:{path:"$tag_id", preserveNullAndEmptyArrays:true}},
{$group:{
_id:"$tag_id",
count_email:{$sum:1},
unread:{$sum:{$cond:[{$eq:["$unread", "false"]}, 0, 1]}}
}
}
);