MongoDB
 sql >> база данни >  >> NoSQL >> MongoDB

Рекурсивната заявка на Mongodb не работи според очакванията с $graphLookup

Можете да използвате $graphLookup и други полезни оператори за масиви,

  • $match филтър, който записва само sponsor е ""
  • $graphLookup за получаване на дъщерни записи и номер на дълбочина в deepField level
  • $unwind деконструирайте downline масив и позволява да не се премахват празни деца
  • $sort по ниво на дълбочина поле level в низходящ ред
  • $group от id поле и реконструирайте downline масив
  • $addFields сега намерете децата на вложеното ниво и разпределете към неговото ниво,
    • $reduce за итериране на цикъл на downline масив.
    • инициализиране на полето по подразбиране level стойността по подразбиране е -1, presentChild е [], prevChild е [] за целта на условията
    • $let за инициализиране на полета:
      • prev според условието, ако и двете level са равни, тогава връща prevChild в противен случай връща presentChild
      • current според условието, ако и двете level са равни, тогава връща presentChild в противен случай []
    • in за връщане на level поле и prevChild поле от инициализирани полета
      • presentChild $filter downline от prev масив и връщане, обединяване на текущи обекти с downline масив с помощта на $mergeObjects и concat с current масив от let с помощта на $concatArrays
  • $addFields за да върне само presentChild масив, защото изисквахме само този обработен масив
db.collection.aggregate([
  { $match: { sponsor: "" } },
  {
    $graphLookup: {
      from: "collection",
      startWith: "$_id",
      connectFromField: "_id",
      connectToField: "sponsor",
      depthField: "level",
      as: "downline"
    }
  },
  {
    $unwind: {
      path: "$downline",
      preserveNullAndEmptyArrays: true
    }
  },
  { $sort: { "downline.level": -1 } },
  {
    $group: {
      _id: "$_id",
      sponsor: { $first: "$sponsor" },
      companyname: { $first: "$companyname" },
      downline: { $push: "$downline" }
    }
  },
  {
    $addFields: {
      downline: {
        $reduce: {
          input: "$downline",
          initialValue: { level: -1, presentChild: [], prevChild: [] },
          in: {
            $let: {
              vars: {
                prev: {
                  $cond: [{ $eq: ["$$value.level", "$$this.level"] }, "$$value.prevChild", "$$value.presentChild"]
                },
                current: {
                  $cond: [{ $eq: ["$$value.level", "$$this.level"] }, "$$value.presentChild", []]
                }
              },
              in: {
                level: "$$this.level",
                prevChild: "$$prev",
                presentChild: {
                  $concatArrays: [
                    "$$current",
                    [
                      {
                        $mergeObjects: [
                          "$$this",
                          {
                            downline: {
                              $filter: {
                                input: "$$prev",
                                as: "e",
                                cond: { $eq: ["$$e.sponsor", "$$this._id"] }
                              }
                            }
                          }
                        ]
                      }
                    ]
                  ]
                }
              }
            }
          }
        }
      }
    }
  },
  { $addFields: { downline: "$downline.presentChild" } }
])

Playground




  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Как да изпълнявате такива заявки за филтриране в mongoengine върху вложени dicts или масиви, съдържащи се в dict с python?

  2. Конфигуриране на MongoDB в Windows

  3. Как да търсите в масив от обекти в mongodb

  4. как да получите върнатата стойност на findAndModify func в MongoDB с mongoose?

  5. Как да (КЪДЕ) колона =колона в Mongo?