MongoDB GroupBy

Question

У меня есть коллекция MongoDB как этот

{ 
    "_id" : "EkKTRrpH4FY9AuRLj", 
    "stage" : 10, 
}, 
{ 
    "_id" : "EkKTRrpH4FY9AuRLj", 
    "stage" : 10, 
}, 
{ 
    "_id" : "EkKTRrpH4FY9AuRLj", 
    "stage" : 20, 
} 

И я хочу, чтобы сгруппировать его в

stage: 10 in paid 
stage: 20 in unpaid 

Результат должен выглядеть следующим образом

{ 
    "paid": [ 
     { 
      "_id" : "EkKTRrpH4FY9AuRLj", 
      "stage" : 10, 
     }, 
     { 
      "_id" : "EkKTRrpH4FY9AuRLj", 
      "stage" : 10, 
     } 
    ], 
    "unpaid": [ 
     { 
      "_id" : "EkKTRrpH4FY9AuRLj", 
      "stage" : 20, 
     } 
    ] 
} 

Как я могу идти об этом ?

Answer 1

бы предложить, используя для этого aggregation framework, где вам нужно, чтобы запустить первоначальный $group поставил трубопровод, который использует операторы $push для создания новых массивов, и $cond оценить некоторые условия и использовать логику для встраивания правильных документов.

Окончательный $project шаг трубопроводов необходимо обрезать некоторые из элементов массива из предыдущего трубопровода, которые являются избыточными, т.е. отфильтровать [FALSE] значения с помощью оператора на $setDifference.

Считайте, выполнив следующее агрегирование трубопровода, который показывает выше в Монго оболочке:

db.collection.aggregate([ 
    { 
     "$group": { 
      "_id": null, 
      "paid": { 
       "$push": { 
        "$cond": [ 
         { "$eq": [ "$stage", 10 ] }, 
         { "_id": "$_id", "stage": "$stage" }, 
         false 
        ] 
       } 
      }, 
      "unpaid": { 
       "$push": { 
        "$cond": [ 
         { "$eq": [ "$stage", 20 ] }, 
         { "_id": "$_id", "stage": "$stage" }, 
         false 
        ] 
       } 
      } 
     } 
    }, 
    { 
     "$project": { 
      "_id": 0, 
      "paid": { 
       "$setDifference": [ "$paid", [false] ] 
      }, 
      "unpaid": { 
       "$setDifference": [ "$unpaid", [false] ] 
      } 
     } 
    } 
]) 

---

Добавьте пакет meteorhacks:aggregate, который предоставляет .aggregate() метода для экземпляров Mongo.Collection. Обратите внимание, что это работает только на стороне сервера, и нет никакой поддержки или реактивности просмотра удаленных объектов встраивается.

Добавить в приложение с

meteor add meteorhacks:aggregate