MongoDB: последняя запись для каждой категории по метке времени - PullRequest
Новая
       5

MongoDB: последняя запись для каждой категории по метке времени

1 голос
/ 05 марта 2020

Я новичок в мире MongoDb. У меня есть следующий сценарий:

Коллекция продаж со следующими данными: 

db.sales.insert({ "_id" : 1, "item" : "abc", "date" : ISODate("2014-01-01T08:00:00.0Z"), "price" : 10, "quantity" : 20 })
db.sales.insert({ "_id" : 2, "item" : "jkl", "date" : ISODate("2014-02-03T09:00:00.0Z"), "price" : 20, "quantity" : 1 })
db.sales.insert({ "_id" : 3, "item" : "xyz", "date" : ISODate("2014-02-03T09:05:00.0Z"), "price" : 5, "quantity" : 5 })
db.sales.insert({ "_id" : 4, "item" : "abc", "date" : ISODate("2014-02-15T08:00:00.0Z"), "price" : 10, "quantity" : 10 })
db.sales.insert({ "_id" : 5, "item" : "xyz", "date" : ISODate("2014-02-15T09:05:00.0Z"), "price" : 5, "quantity" : 10 })
db.sales.insert({ "_id" : 6, "item" : "xyz", "date" : ISODate("2014-02-15T12:05:10.0Z"), "price" : 5, "quantity" : 5 })
db.sales.insert({ "_id" : 7, "item" : "xyz", "date" : ISODate("2014-02-15T14:12:12.0Z"), "price" : 5, "quantity" : 10 })
db.sales.insert({ "_id" : 8, "item" : "abc", "date" : ISODate("2014-02-10T08:00:00.0Z"), "price" : 10, "quantity" : 30 })

Я хочу выбрать самую последнюю продажу (весь документ) для каждого товара.

Ожидаемый результат: 

 [
  { "_id" : 2, "item" : "jkl", "date" : "2014-02-03T09:00:00Z", "price" : 20, "quantity" : 1 },
  { "_id" : 4, "item" : "abc", "date" : "2014-02-15T08:00:00Z", "price" : 10, "quantity" : 10 },
  { "_id" : 7, "item" : "xyz", "date" : "2014-02-15T14:12:12Z", "price" : 5, "quantity" : 10 }
 ]

Я искал это, но не смог найти решение, которое может извлечь самый последний целый документ для каждой категории.

Я пробовал следующее, но я получаю только _id и lastSalesDate. 

db.sales.aggregate(
   [
     { $sort: { item: 1, date: 1 } },
     {
       $group:
         {
           _id: "$item",
           lastSalesDate: { $last: "$date" }
         }
     }
   ]
)

Как я могу получить все поля?

Я использую драйвер MongoDB и приложение scala, где мне нужно получить ожидаемый результат. Тем не менее, любое решение в формате запросов MongoDB также приветствуется.

Спасибо!

1 Ответ

2 голосов
/ 05 марта 2020

Попробуйте этот запрос, 

db.sales.aggregate([ 

  // Sort by date (Use -1 to sort in descending order to get most recent date)
  { $sort: { date: -1 } }, 

  // Group by Item and Store First Sorted Whole Document in itemObj
  { $group: { _id: "$item", itemObj : { $first: "$$ROOT" }} }, 

  // Replace the Document with itemObj Object
  { $replaceRoot: { newRoot: "$itemObj"} }  
])
...