sql >> Database >  >> NoSQL >> MongoDB

mongoDB aggregatie opzoeken op geneste array van objecten

U kunt de onderstaande aggregatiepijplijn gebruiken.

$lookup om de agent te vullen, gevolgd door $reduce en $concatArrays om alle klant-ID's te verzamelen en $lookup om de klantgegevens te krijgen.

$addFields met $map om de missie-array te herhalen en voor elke klant de klantinformatie van de vorige fase in kaart te brengen door op te zoeken op client-ID en $mergeObjects om de andere velden te behouden. $project-fase om de extra velden te verwijderen.

Mongo db 3.6 en hoger

Model.aggregate([
 {"$lookup":{
  "from":"agents",
  "localField":"agent",
  "foreignField":"_id",
  "as":"agent"
 }},
 {"$addFields":{"agent":{"$arrayElemAt":["$agent",0]}}},
 {"$addFields":{
   "client_ids":{
     "$reduce":{
       "input":"$missions",
       "initialValue":[],
       "in": {"$concatArrays":["$$value","$$this.clients.client"]}
     }
   }
 }},
 {"$lookup":{
   "from":"clients",
   "localField":"client_ids",
   "foreignField":"_id",
   "as":"client_info"
 }},
 {"$addFields":{
   "missions":{
     "$map":{
       "input":"$missions",
       "in":{
         "$mergeObjects":[
           "$$this",
           {"clients":{"$map":{
             "input":"$$this.clients",
             "in":{"$mergeObjects":[
               "$$this",
              {"client":{"$arrayElemAt":[
                "$client_info",
                {"$indexOfArray":["$client_ids","$$this._id"]}
              ]}}
            ]}
           }}}
         ]
       }
     }
   }
 }},
 {"$project":{"client_ids":0,"client_info":0}}
])

Mongo db minder dan 3,6

$lookup om de agent in te vullen gevolgd door $unwind om de klant te bereiken en kijk omhoog om de klantgegevens te krijgen. Spoel terug met $group om terug te keren naar de oorspronkelijke structuur met ingevulde waarden.

Model.aggregate([
 {"$lookup":{
  "from":"agents",
  "localField":"agent",
  "foreignField":"_id",
  "as":"agent"
 }},
 {"$addFields":{"agent":{"$arrayElemAt":["$agent",0]}}},
 {"$unwind":"$missions"},
 {"$unwind":"$missions.clients"},
 {"$lookup":{
   "from":"clients",
   "localField":"missions.clients.client",
   "foreignField":"_id",
   "as":"missions.clients.client"
 }},
 {"$addFields":{"missions.clients.client":{"$arrayElemAt":["$missions.clients.client",0]}}},
 {"$group":{
   "_id":{"_id":"$_id","mission_id":"$missions._id"},
   "agent":{"$first":"$agent"},
   "title":{"$first":"$missions.title"},
   "clients":{"$push":"$missions.clients"}
 }},
 {"$group":{
   "_id":"$_id._id",
   "agent":{"$first":"$agent"},
   "missions":{
     "$push":{
       "_id":"$_id.mission_id",
       "title":"$title",
       "clients":"$clients"
      }
    }
 }}
])



  1. Mongoose dubbele sleutelfout met upsert

  2. Hoe ik de grootte van mijn document in MongoDB weet met de ruby-driver?

  3. MongoDB-documenten bijwerken met arrays van subdocumenten

  4. Eenvoudige MySQL-database converteren naar een NoSQL-oplossing