MongoDB一对多关联问题：populate('pricelines')返回空数组

你遇到的核心问题是双向关联的引用只维护了一边：你在创建Priceline时正确设置了hotel字段关联到对应的Hotel ID，但没有把新创建的Priceline的ID添加到Hotel文档的pricelines数组中。这就导致Hotel文档里的pricelines始终是空数组，调用populate('pricelines')自然返回空结果。

我们需要在批量插入Priceline后，手动更新对应的Hotel文档，把新生成的Priceline ID追加到pricelines数组里。同时还要修正代码里的几处小问题：

1. 修正错误处理逻辑 #

第一个waterfall步骤里的错误处理写错了，应该把错误对象传给callback，而不是hotel：

Hotel.findOne({ name: req.body.name })
  .populate("pricelines")
  .exec(function (err, hotel) {
    if (err) return callback(err) // 这里原来传的是hotel，改成err
    return callback(null, hotel)
  })

2. 插入Priceline后更新Hotel的关联数组 #

修改第二个waterfall步骤，插入Priceline后，提取新文档的ID并更新Hotel：

function (hotel, callback) {
  // 简化Priceline数据构建
  const pricelineData = req.body.pricelines.map(pl => ({
    source: pl.source,
    price: pl.price,
    hotel: hotel._id
  }))

  Priceline.insertMany(pricelineData)
    .then(docs => {
      // 获取所有新创建的Priceline的ID
      const pricelineIds = docs.map(doc => doc._id)
      // 更新Hotel的pricelines数组，批量追加新ID
      return Hotel.findByIdAndUpdate(
        hotel._id,
        { $push: { pricelines: { $each: pricelineIds } } },
        { new: true } // 返回更新后的最新Hotel文档
      ).populate('pricelines') // 直接在这里完成关联查询
    })
    .then(updatedHotel => callback(null, updatedHotel))
    .catch(err => callback(err))
}

3. 调整最终回调的返回值 #

因为我们已经在更新时完成了populate，最终回调直接返回更新后的Hotel即可：

function (error, updatedHotel) {
  if (error) {
    res.status(500).jsonp({ errors: [error] })
    return
  }
  res.status(200).jsonp(updatedHotel)
}

如果不想每次手动更新Hotel，你可以给PricelineSchema添加一个post-save钩子，每次保存Priceline时自动更新对应的Hotel：

// 在schemas.js的PricelineSchema定义后添加
PricelineSchema.post('save', function(doc) {
  Hotel.findByIdAndUpdate(doc.hotel, { $push: { pricelines: doc._id } })
    .catch(err => console.error('Failed to update hotel pricelines:', err))
})

这样后续创建Priceline时，会自动维护Hotel的关联数组，不用再手动写更新逻辑。

内容的提问来源于stack exchange，提问作者Alireza Bashiri