mongodb - mongodb按类别聚合组

Question

我是使用 MongoDB 聚合框架的新手，这里有一个模式：

var bookSoldSchema = new Schema({
   buyer:{
      type: Number
   }
   book: {         
     type: Schema.Types.ObjectId, ref: 'Book'
   } 
});

 var bookSchema = new Schema({
     bookName: { type: String },
     categories: [{ type: Schema.Types.ObjectId, ref: 'BookCategory'}],
 })

每本书都有多个类别，我想显示前 5 个最畅销的类别，我需要的每个类别显示最畅销的前 3 本书，我还需要显示类别名称，我需要的结果是：

[
      {
        categoryId: xxx,
        categoryName:xxx,
        top3books:[
           {bookId:xxx, bookName:xxx},
           {bookId:xxx, bookName:xxx},
           {bookId:xxx, bookName:xxx},
        ]
     },
     {
       categoryId: xxx,
       categoryName:xxx,
       top3books:[
          {bookId:xxx, bookName:xxx},
          {bookId:xxx, bookName:xxx},
          {bookId:xxx, bookName:xxx},
       ]
    }
]

我该如何在 MongoDB 中解决这个问题？

Answer 1

您可以运行以下聚合管道，假设您有一个BookSold使用bookSoldSchema上述books和bookcategories基础集合的模型：

BookSold.aggregate([
    {
        "$lookup": {
            "from": "books",
            "localField": "book",
            "foreignField": "_id",
            "as": "book_join"
        }
    },
    { "$unwind": "$book_join" },
    { "$unwind": "$book_join.categories" },
    {
        "$lookup": {
            "from": "bookcategories",
            "localField": "book_join.categories",
            "foreignField": "_id",
            "as": "categories"
        }
    },
    { "$unwind": "$categories" },
    { "$sort": { "categories.name": 1, "buyer": -1 } }, 
    {
        "$group": {
            "_id": "$categories.name",
            "categoryId": { "$first": "$categories._id" },
            "buyer": { "$first": "$buyer" },
            "books": { 
                "$push": { 
                    "bookId": "$book_join._id", 
                    "bookName": "$book_join.bookName" 
                } 
            }
        }
    },
    { "$sort": { "buyer": -1 } },
    { "$limit": 5 },
    {
       "$project": {
           "_id": 0,
           "categoryId": 1,
           "categoryName": "$_id",
           "top3books": { "$slice": [ "$books", 3 ] }
       }
    }
], function(err, result) {
    if (err) handleError(err);
    console.log(JSON.stringify(result, null, 4));
})