เพื่อดึงคู่ค่าที่ไม่ซ้ำกัน (distinct pair) พร้อมข้อมูลย่อย ให้ใช้ $group ใน Aggregation Pipeline
> db.demo522.insertOne({"Name": "John", "Score": 45});
{ "acknowledged" : true, "insertedId" : ObjectId("5e89b646b3fbf26334ef611b") }
> db.demo522.insertOne({"Name": "Bob", "Score": 67});
{ "acknowledged" : true, "insertedId" : ObjectId("5e89b64eb3fbf26334ef611c") }
> db.demo522.insertOne({"Name": "John", "Score": 55});
{ "acknowledged" : true, "insertedId" : ObjectId("5e89b655b3fbf26334ef611d") }
> db.demo522.insertOne({"Name": "Bob", "Score": 33});
{ "acknowledged" : true, "insertedId" : ObjectId("5e89b65cb3fbf26334ef611e") }
แสดงข้อมูล:
> db.demo522.find();
{ "_id" : ObjectId("5e89b646b3fbf26334ef611b"), "Name" : "John", "Score" : 45 }
{ "_id" : ObjectId("5e89b64eb3fbf26334ef611c"), "Name" : "Bob", "Score" : 67 }
{ "_id" : ObjectId("5e89b655b3fbf26334ef611d"), "Name" : "John", "Score" : 55 }
{ "_id" : ObjectId("5e89b65cb3fbf26334ef611e"), "Name" : "Bob", "Score" : 33 }
คิวรีจัดกลุ่มและรวมคะแนน (Sum) ต่อคน
> var query = [
... { "$group": { "_id": "$Name", "Score": { "$sum": "$Score" } } },
... { "$project": { "Name": "$_id", "_id": 0, "Score": 1 } }
... ];
> db.demo522.aggregate(query);
ผลลัพธ์ - ผลรวมคะแนนของแต่ละคน:
{ "Score" : 100, "Name" : "Bob" }
{ "Score" : 100, "Name" : "John" }
คำอธิบาย
- $group _id: "$Name": จัดกลุ่มตามชื่อ
- $sum: "$Score": รวมคะแนนในแต่ละกลุ่ม
- $project: จัดรูปแบบ output ให้อ่านง่าย (เปลี่ยน _id เป็น Name)
สามารถปรับเปลี่ยนได้ เช่น ใช้ $avg หาค่าเฉลี่ย, $max หาค่าสูงสุด, หรือ $push เก็บรายการคะแนนทั้งหมดไว้ด้วย
