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

Jak mohu provést agregační filtr Mongodb pro více kolekcí?

Váš předchozí problém jsem vysvětlil v otázce . Protože fakturaInfo je pole a invoiceData také pole uvnitř invoiceInfo , používáme mapu a filtr. Potom musíme vyloučit prázdné pole invoiceData . (To lze provést v předchozím kroku také jako filter-map->filter, ale může to být zdlouhavé, proto jsem to použil v další fázi)

Zde je kód

db.bookings.aggregate([
  {
    "$match": {
      "PaymentStatus": { $ne: "Delivered" }
    }
  },
  {
    $set: {
      "BookingData.products": {
        "$filter": {
          "input": "$BookingData.products",
          "cond": {
            $and: [
              { $ne: [ "$$this.ProductID", undefined ] },
              { $ne: [ "$$this._id", null ] },
              { $ne: [ "$$this.IsDeliveryFailed", "Yes" ] }
            ]
          }
        }
      }
    }
  },
  {
    "$lookup": {
      "from": "invoices",
      "localField": "Invoices",
      "foreignField": "_id",
      "as": "invoiceInfo"
    }
  },
  {
    $set: {
      invoiceInfo: {
        $map: {
          input: "$invoiceInfo",
          as: "info",
          in: {
            InvoiceData: {
              $filter: {
                input: "$$info.InvoiceData",
                as: "data",
                "cond": {
                  $and: [
                    { $ne: [ "$$data.InvoiceID", undefined ] },
                    { $ne: [ "$$data.InvoiceID", null ] },
                    { $ne: [ "$$data.IsPaymentFailed", "Yes" ] }
                  ]
                }
              }
            }
          }
        }
      }
    }
  },
  {
    $set: {
      invoiceInfo: {
        $filter: {
          input: "$invoiceInfo",
          cond: { $ne: [ "$$this.InvoiceData", [] ] }
        }
      }
    }
  },
  {
    $match: {
      $expr: {
        $or: [
          { $ne: [ "$BookingData.products", [] ] },
          { $ne: [ "$invoiceInfo", [] ] }
        ]
      }
    }
  }
])

Pracovní Hřiště Mongo

Doufám, že vám to pomůže. Toto je čas, který potřebujete na hraní/obcházení na základě vašich požadavků. Někdy je potřeba provést vyhledávání před nebo za aktuálním umístěním v ukázce




  1. nelze načíst data z úhlového http

  2. Serializace návratu MongoDB find() do neanonymního pole JSON pomocí PyMongo

  3. MongoDB $indexOfArray

  4. Spring Data REST:vlastní dotaz pro úložiště MongoDB