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

Zpětné volání NodeJS po několika asynchronních funkcích ve for-loop

Existuje několik přístupů, které zde můžete použít podle svého pohodlí

Pomocí asynchronního čekání

let article = await Article.findOne({ _id: articleid }).lean().exec()

await Promise.all(
  article.comment.map(async(obj) => {
    const user = await User.findOne({ _id: obj.user })
    obj.username = user.username
  })
)

console.log(article)

Pomocí $lookup agregace 3.6

Protože mongodb má svůj vlastní výkonný $lookup operátor agregace pro připojení více kolekcí a pravděpodobně lepší přístup bez jakékoli iterace

Article.aggregate([
  { "$match": { "_id": mongoose.Types.ObjectId(articleid) }},
  { "$unwind": "$comment" },
  { "$lookup": {
    "from": "users",
    "let": { "userId": "$comment.user" },
    "pipeline": [
      { "$match": { "$expr": { "$eq": ["$$userId", "$_id"] }}}
    ],
    "as": "comment.user"
  }},
  { "$unwind": "$comment.user" },
  { "$group": {
    "_id": "$_id",
    "comment": { "$push": "$comment" },
    "completed": { "$first": "$completed" },
    "completedAt": { "$first": "$completedAt" }
  }}
])

Pomocí $lookup agregace 3.4

Article.aggregate([
  { "$match": { "_id": mongoose.Types.ObjectId(articleid) }},
  { "$unwind": "$comment" },
  { "$lookup": {
    "from": "users",
    "localField": "comment.user",
    "foreignField": "_id",
    "as": "comment.user"
  }}
  { "$unwind": "$comment.user" },
  { "$group": {
    "_id": "$_id",
    "comment": { "$push": "$comment" },
    "completed": { "$first": "$completed" },
    "completedAt": { "$first": "$completedAt" }
  }}
])


  1. MongoDB $first Aggregation Pipeline Operator

  2. Případy použití pro skóre Redis a funkce hodnocení pro sady

  3. Mongoose – efektivní aktualizace indexovaného pole mongoose.Schema.Types.Mixed

  4. Jak odstranit spoustu sbírek mongodb najednou?