sql >> Databáze >  >> NoSQL >> MongoDB

Vyhledávání s polem objektů

V zásadě potřebujete $unwind pole jako první. MongoDB zatím nemůže pracovat s vlastností "inner" objektu v poli jako zdroj pro $lookup .

Pro efektivitu bychom také měli skutečně používat $concatArrays nejprve se „připojí“ ke zdroji pole a poté provede pouze jedno $lookup operace:

Project.aggregate([
  { "$match": { "project_id": projectId} },
  { "$project": {
    "project_id": 1,
    "updated_at": 1,
    "created_at": 1,
    "owner": 1,
    "name": 1,
    "combined": {
      "$concatArrays": [
        { "$map": {
          "input": {
            "$filter": {
              "input": "$uploaded_files",
              "as": "uf",
              "cond": { "$eq": ["$$uf.upload_id", uploadId ] }
            }
          },
          "as": "uf",
          "in": {
            "$arrayToObject": {
              "$concatArrays": [
                { "$objectToArray": "$$uf" },
                [{ "k": "type", "v": "uploaded_files" }]
              ]
            }
          }
        }},
        { "$map": {
          "input": {
            "$filter": {
              "input": "$file_history",
              "as": "fh",
              "cond": { "$eq": ["$$fh.upload_id", uploadId ] }
            }
          },
          "as": "fh",
          "in": {
            "$arrayToObject": {
              "$concatArrays": [
                { "$objectToArray": "$$fh" },
                [{ "k": "type", "v": "file_history" }]
              ]
            }
          }
        }}
      ]
    }
  }},
  { "$unwind": "$combined" },
  { "$lookup": {
    "from": "files",
    "localField": "combined.file",
    "foreignField": "_id",
    "as": "combined.file"
  }},
  { "$unwind": "$combined.file" },
  { "$lookup": {
    "from": "users",
    "localField": "owner",
    "foreignField": "_id",
    "as": "owner"
  }},
  { "$unwind": "$owner" },
  { "$group": {
    "_id": "$_id",
    "project_id": { "$first": "$project_id" },
    "updated_at": { "$first": "$updated_at" },
    "created_at": { "$first": "$created_at" },
    "owner": { "$first": "$owner" },
    "name": { "$first": "$name" },
    "combined": { "$push": "$combined" }
  }},
  { "$project": {
    "project_id": 1,
    "updated_at": 1,
    "created_at": 1,
    "owner": 1,
    "name": 1,
    "uploaded_files": {
      "$filter": {
        "input": "$combined",
        "as": "cf",
        "cond": { "$eq": [ "$$cf.type", "uploaded_files" ] }
      }    
    },
    "file_history": {
      "$filter": {
        "input": "$combined",
        "as": "cf",
        "cond": { "$eq": [ "$$cf.type", "file_history" ] }
      }    
    }
  }}
])

V kostce

  1. Spojte dvě pole dohromady ve zdroji a označte je, poté $unwind první

  2. Proveďte $lookup na kombinovaném detailu a $unwind to

  3. Proveďte $lookup na druhém zahraničním zdroji a $unwind to

  4. $group dokument zpět dohromady s jedním polem.

  5. $filter pomocí pole „názvy značek“ nebo „typ“, které jsme přidali, abychom „oddělili“ pole.

Stejný druh procesu můžete sledovat jednoduše pomocí $unwind na každém poli, poté proveďte "spojení" a seskupte zpět dohromady. Ale ve skutečnosti to vyžaduje mnohem více kroků, než jen „kombinovat“ na prvním místě.




  1. Aktualizujte více dokumentů poskytnutím dokumentů v těle, mongoose/mongodb

  2. Použití QueryBuilder a BasicDBObjectBuilder v MongoDB 3.3.0 výše

  3. Morphia List<Map<String,Object>>> return Embedded element není DBObject při operaci hledání

  4. 2řádková aplikace NodeJS se zhroutí na mongoose.connect() při pokusu o připojení k mongolabské databázi MongoDB