sql >> Database teknologi >  >> NoSQL >> MongoDB

mongoDB samlet opslag på indlejrede array af objekter

Du kan bruge nedenstående aggregeringspipeline.

$lookup for at udfylde agent efterfulgt af $reduce og $concatArrays for at indsamle alle klient-id'er og $lookup for at få klientoplysningerne.

$addFields med $map for at iterere missionarray og for hver klient kortlægge klientoplysningerne fra forrige fase ved opslag efter klient-id og $mergeObjects for at beholde de andre felter. $project fase for at fjerne de ekstra felter.

Mongo db 3.6 og nyere

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 mindre end 3,6

$lookup for at udfylde agent efterfulgt af $unwind for at nå klienten og slå op for at få klientoplysningerne. Spol tilbage med $group for at bringe tilbage til den oprindelige struktur med udfyldte værdier.

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. Får fejl:Route() i rute kan ikke anvendes på streng

  2. Installation af plugins til mongoose - får fejl

  3. Hvordan får man Node-objekt, når man bruger Neo4j jdbc?

  4. opslag med tilstand i mongoose