CODEWITHSUNDEEP
mongodbmongodb-queryaggregation-framework
byal
byal

Reputation: 167

MongoDB Aggregation, Mongodb Query

I am using Nodejs and MongoDB with expressjs and mongoose library, creating a Blog API having users, articles & comments schema. Below are schemas that I use.

const UsersSchema = new mongoose.Schema({
    username:        { type: String },
    email:           { type: String },
    date_created:    { type: Date },
    last_modified:   { type: Date }
});    




const ArticleSchema = new mongoose.Schema({
    id:              { type: String, required: true },
    text:            { type: String, required: true }, 
    posted_by:       { type: Schema.Types.ObjectId, ref: 'User', required: true },
    images:          [{ type: String }],
    date_created:    { type: Date },
    last_modified:   { type: Date }
});




const CommentSchema = new mongoose.Schema({
    id:             { type: String, required: true },
    commented_by:   { type: Schema.Types.ObjectId, ref: 'User', required: true },
    article:        { type: Schema.Types.ObjectId, ref: 'Article' },
    text:           { type: String, required: true },
    date_created:   { type: Date },
    last_modified:  { type: Date } 
});

Upvotes: 1

Views: 127

Answers (1)

Ashh
Ashh

Reputation: 46481

You can use below $lookup aggregation from mongodb 3.6 and above

Article.aggregate([
  { "$match": { "posted_by": mongoose.Types.ObjectId(id) } },
  { "$lookup": {
    "from": Comment.collection.name,
    "let": { "id": "$_id" },
    "pipeline": [
      { "$match": { "$expr": { "$eq": [ "$article", "$$id" ] } } }
    ],
    "as": "comments"
  }},
  { "$addFields": {
    "comments_no": { "$size": "$comments" },
    "hasCommented": { "$in": [mongoose.Types.ObjectId(id), "$comments.commented_by"] }
  }}
])

Upvotes: 2

Related Questions