MongoDB Node驱动中Bulk.getOperations()不可用，如何获取更新文档ID？

我希望查看批量操作的结果，尤其是获取被更新文档的ID。了解到MongoDB手册中的Bulk.getOperations()方法可提供该信息，但我使用的MongoDB NodeJS库中似乎没有这个方法。

请问我是否存在操作错误？以下是我的代码：

const bulk = db.collection('companies').initializeOrderedBulkOp()
const results = getLatestFinanicialResults() // 从远程API获取

results.forEach(result => 
  bulk.find({ 
    name: result.companyName, 
    report: { $ne: result.report } 
  }).updateOne([
    { $unset: 'prevReport' },
    { $set: { prevReport: '$report' } },
    { $unset: 'report' },
    { $set: { report: result.report } }
  ]))

await bulk.execute()
await bulk.getOperations() // <-- 报错，Typescript库中该方法未定义

我收到的IDE静态错误：

Uncaught TypeError: bulk.getOperations is not a function

问题原因 #

Bulk.getOperations()是MongoDB Shell专属的方法，NodeJS驱动并未实现这个API。你混淆了Shell API与NodeJS驱动API的差异，这是报错的核心原因。

解决方案：通过execute()返回结果获取更新信息 #

NodeJS驱动中，bulk.execute()会返回BulkWriteResult对象，包含批量操作的完整统计和细节。默认不返回更新文档ID，需调整操作配置来实现：

1. 简化更新逻辑并配置返回选项

你的更新逻辑无需多次$unset+$set，可以合并为单个$set操作，同时指定returnDocument来获取更新后的文档：

const bulk = db.collection('companies').initializeOrderedBulkOp()
const results = getLatestFinanicialResults()

results.forEach(result => {
  bulk.find({ 
    name: result.companyName, 
    report: { $ne: result.report } 
  }).updateOne(
    {
      $set: {
        prevReport: '$report',
        report: result.report
      }
    },
    { returnDocument: 'after' } // 指定返回更新后的文档内容
  )
})

2. 从执行结果中提取文档ID

执行批量操作后，通过getRawResponse()获取包含更新文档的原始响应：

const bulkResult = await bulk.execute()

// 基础统计信息
console.log('匹配文档数:', bulkResult.nMatched)
console.log('修改文档数:', bulkResult.nModified)

// 提取被更新文档的ID
const rawResponse = bulkResult.getRawResponse()
const updatedIds = rawResponse.modifiedDocs?.map(doc => doc._id)
console.log('被更新的文档ID:', updatedIds)

推荐：使用新版bulkWrite()API #

MongoDB NodeJS驱动4.0+推荐使用bulkWrite()替代旧版的initializeOrderedBulkOp()，API更简洁且结果处理更直观：

const operations = results.map(result => ({
  updateOne: {
    filter: { name: result.companyName, report: { $ne: result.report } },
    update: {
      $set: {
        prevReport: '$report',
        report: result.report
      }
    },
    returnDocument: 'after'
  }
}))

const bulkResult = await db.collection('companies').bulkWrite(operations)
const rawResponse = bulkResult.getRawResponse()
const updatedIds = rawResponse.modifiedDocs?.map(doc => doc._id)
console.log('被更新的文档ID:', updatedIds)

补充说明 #

• 如果批量操作包含upsert（插入新文档），可从bulkResult.upserted数组中获取插入的文档ID，每个元素包含_id字段。
• returnDocument: 'after'仅在驱动版本支持时有效，确保你的NodeJS驱动版本为4.0及以上。

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