Tengo una colección que necesito agrupar por año. Mi tubería de agregación es como tal:
const WorkHistoryByYear = await this.workHistroyModel.aggregate([ { $group: { _id: '$year', history: { $push: '$$ROOT' } } } ]);Que funciona como se esperaba, devolviendo:
[{ "_id": 2003, "history": [ { "_id": "600331b3d84ac418877a0e5a", "tasksPerformed": [ "5fffb180a477c4f78ad67331", "5fffb18aa477c4f78ad67332" ], "year": 2003 }, { "_id": "600331dcd84ac418877a0e5c", "tasksPerformed": [ "5fffb180a477c4f78ad67331" ], "year": 2003 } ] }]pero me gustaría llenar un campo si es posible.
El esquema WorkHistory tiene un campo, tasksPerformed , que es una matriz de referencias de ObjectId. Aquí está el esquema de Task :
export const TaskSchema = new Schema({ active: { type: Schema.Types.Boolean, default: true, }, title: { type: Schema.Types.String, required: true, }, order: { type: Schema.Types.Number, index: true, } });¿Es posible completar los modelos referenciados dentro de la agregación? $lookup parece ser lo que necesito, pero todavía tengo que hacerlo funcionar al seguir la documentación.
No trabajo mucho con la base de datos, por lo que tengo algunas dificultades para encontrar los operadores correctos para usar, y he visto preguntas similares, pero no una respuesta definitiva.
Editar:
Después de agregar el código de la respuesta de @varman, mi regreso ahora es:
{ "_id": 2003, "history": { "_id": "600331b3d84ac418877a0e5a", "tasksPerformed": [ "5fffb180a477c4f78ad67331", "5fffb18aa477c4f78ad67332" ], "year": 2003, "history": { "tasksPerformed": [] } } }Convertí las referencias de ObjectId en cadenas en un esfuerzo por ayudar a la coincidencia, pero aún me estoy quedando corto.
Puedes hacer la búsqueda para unir ambas colecciones.
$unwind para deconstruir la matriz. (Matriz a Objetos)$lookup para unirse a las colecciones$group para reconstruir la matriz deconstruida nuevamenteEl script para el resultado anterior es
db.workHistory.aggregate([ { "$unwind": "$history" }, { "$lookup": { "from": "taskSchema", "localField": "history.tasksPerformed", "foreignField": "_id", "as": "history.tasksPerformed" } }, { "$group": { "_id": "$_id", "history": { "$push": "$history" } } } ])Zona de juegos Mongo en funcionamiento
Pero antes de agrupar, tienes una colección como esta
db={ "workHistory": [ { "_id": 2003, "history": [ { "_id": "600331b3d84ac418877a0e5a", "tasksPerformed": [ "5fffb180a477c4f78ad67331", "5fffb18aa477c4f78ad67332" ], "year": 2003 }, { "_id": "600331dcd84ac418877a0e5c", "tasksPerformed": [ "5fffb180a477c4f78ad67331" ], "year": 2003 } ] } ], "taskSchema": [ { "_id": "5fffb180a477c4f78ad67331", "active": true, "title": "first" }, { "_id": "5fffb18aa477c4f78ad67332", "active": true, "title": "second" } ] } Dado que $unwind es caro, podríamos haber hecho una agregación
db.workHistory.aggregate([ { "$lookup": { "from": "taskSchema", "localField": "tasksPerformed", "foreignField": "_id", "as": "tasksPerformed" } }, { $group: { _id: "$year", history: { $push: "$$ROOT" } } } ])También puedes hacerlo sin desconectar :
db.WorkHistory.aggregate( [ { $lookup: { from: "Tasks", localField: "tasksPerformed", foreignField: "_id", as: "tasksPerformed" } }, { $group: { _id: "$year", history: { $push: "$$ROOT" } } } ])