SQL 'UNION ALL' как реализация в MongoDB - PullRequest
0 голосов
/ 09 октября 2018

Существует две коллекции:

Продажи

{
  "_id" : ObjectId("5ba0bfb8d1acdc0de716e839"),
  "invoiceNumber" : 1,
  "saleDate" : ISODate("2018-09-01T00:00:00.000Z"),
  "totalTaxAmount" : 613,
  "subTotalAmount" : 2000,
  "totalAmount" : 2613,
  "balance" : 2613,
  "financialYear" : "2018-2019",
  "modeOfPayment" : "Digital Transfer",
  "customerName": "Acme Inc"
}

Транзакции

{
  "_id" : ObjectId("5bbb4e131fb8af0dc645212d"),
  "transactionNumber" : 1    
  "transactionDate" : ISODate("2018-09-03T00:00:00.000Z"),
  "transactionType" : "Income",
  "partyName" : "Acme Inc",
  "transactionMode" : "Digital Transfer",
  "amount" : 2613,
  "paidItems" : [ 
      {
          "orderId" : "5b90a7d62bb5a21be4ff97e3",
          "invoiceNumber" : "1",
          "orderType" : "sale",
          "totalAmount" : 2613,
          "balance" : 613,
          "payingAmount" : 2000
      }
   ]
}

Мне нужно извлечь продажи и транзакции в качестве «заголовка» для конкретной стороны (то есть customerName, partyName) между двумя датами (т.е. saleDate ,actionDate), упорядоченными по дате;следующим образом:

[
  {
    "date": ISODate("2018-09-01T00:00:00.000Z"),
    "heading": "Sale",
    "particulars": "Invoice # 1",
    "amount": 2613
  },
  {
    "date": ISODate("2018-09-03T00:00:00.000Z"),
    "heading": "Payment by Digital Transfer",
    "particulars": "Transaction # 1",
    "amount": 2000
  }
]

Я исследовал и попробовал с агрегацией , $ lookup , но он не возвращает желаемого.

Переключение с SQL наMongoDB.В SQL следующий запрос работает нормально:

select sale_date as dated, 'Sale' as heading, 'Invoice # ' + 
convert(varchar(12),invoice_number) as particulars, 
convert(varchar(12), total) as amount, 
from sales where sale_date between @from_date AND @to_date AND 
customer_name=@customer_name
UNION ALL
select transaction_date as dated, 'Payment by ' + transaction_mode as 
heading, 'Transaction # ' + convert(varchar(12), transaction_id) as 
particulars, convert(varchar(12), amount) as amount from transactions 
where transaction_date between @from_date AND @to_date AND 
party_name=@customer_name
order by dated DESC

В сообществе MongoDB подан запрос функции , и он "не решен".

Хотелось бы узнать, есть ли способ для этого в драйвере mongoShell или MongoDB (mongoose / JS).Использование текущих стабильных версий MongoDB, nodejs, express и mongoose.Спасибо!

Ответы [ 3 ]

0 голосов
/ 09 октября 2018

Отказ от ответственности: методика, представленная ниже, не совсем рекомендуется.;) Это особенно верно при работе с большими коллекциями.Однако его можно использовать для достижения того же эффекта, что и SQL UNION ALL из MongoDB v3.6 и далее.

Для данной коллекции first и для коллекции second:

db.first.aggregate([{
    $group: { // create an array to hold all documents of the first collection
        "_id": null,
        "first": {
            $push: "$$ROOT"
        }
    }
}, {
    $lookup: { // perform some kind of ridiculous lookup which will return all documents from the second collection in an array
        from: "second",
        let: { /* we do not need any variables */ },
        pipeline: [ { $match: { /* this filter will match every document */ } } ],
        as: "second"
    }
}, {
    $project: {
        "all": { $concatArrays: [ "$first", "$second" ] } // merge the two collections
    }
}, {
    $unwind: "$all" // flatten the resulting array
}, {
    $replaceRoot: { "newRoot": "$all" } // move content of "all" field all the way up 
}], {
    allowDiskUse: true // make sure we do not run into memory issues
})
0 голосов
/ 13 октября 2018

Вы можете попробовать ниже агрегации

db.sales.aggregate([
  { "$limit": 1 },
  { "$facet": {
    "collection1": [
      { "$limit": 1 },
      { "$lookup": {
        "from": "sales",
        "pipeline": [
          { "$match": {
            "date": { "$gte": ISODate("2018-09-01"), "$lte": ISODate("2018-09-10") },
            "customer.name": customerName
          }},
          { "$project": {
            "_id":0, "dated": "$saleDate", "heading": "Sale", "particulars": "$invoiceNumber",
            "amount": "$totalAmount", "modeOfPayment": null
          }}
        ],
        "as": "collection1"
      }}
    ],
    "collection2": [
      { "$limit": 1 },
      { "$lookup": {
        "from": "transactions",
        "pipeline": [
          { "$match": {
            "transactionDate": { "$gte": ISODate("2018-09-01"), "$lte": ISODate("2018-09-10") },
            "userId": userId, "partyName": customerName
          }},
          { "$project": {
            "_id":0, "dated": "$transactionDate", "heading": "Payment","particulars": "$transactionNumber",
            "amount": "$amount", "paymentMode": "$transactionMode"
          }}
        ],
        "as": "collection2"
      }}
    ]
  }},
  { "$project": {
    "data": {
      "$concatArrays": [
        { "$arrayElemAt": ["$collection1.collection1", 0] },
        { "$arrayElemAt": ["$collection2.collection2", 0] },
      ]
    }
  }},
  { "$unwind": "$data" },
  { "$replaceRoot": { "newRoot": "$data" } },
  { "$sort": { "dated": -1 }}
])
0 голосов
/ 09 октября 2018

Я не думаю, что вы можете выполнить объединение для 2 разных коллекций в mongodb.

Однако вы можете получить данные из обеих коллекций, используя q.all, а затем сделать из них объединение, используя вашу собственную функцию илиможет быть сторонним модулем типа lodash.

Единственный способ выполнить объединение в mongodb - это как упомянуто здесь.https://docs.mongodb.com/manual/reference/operator/aggregation/setUnion/

...