MongoDB Node.js驱动v3.0.4中nextObject方法不可用的解决办法咨询

嘿，这个问题我熟！你遇到的这个类型错误，根源在于MongoDB Node.js驱动从3.0版本开始，就废弃并移除了Cursor对象上的nextObject()方法，取而代之的是next()方法。

先看看你原来的代码：

import {Collection, MongoClient, ServerOptions} from 'mongodb';

MongoClient.connect(this.uri).then(function (client) {
      const db = client.db('local');
      const coll = db.collection('oplog.rs');
      const q = coll.find({}, {ts: 1})
         .sort({$natural: -1})
         .limit(1)
         .nextObject();
  });

运行后抛出的错误：

TypeError: coll.find(...).sort(...).limit(...).nextObject is not a function

替代方案：使用next()方法 #

next()方法是nextObject()的替代，它返回一个Promise，你可以用.then()链式调用处理结果，或者配合async/await写出更简洁易读的代码。

方案1：用.then()链式调用修改代码

import {Collection, MongoClient, ServerOptions} from 'mongodb';

MongoClient.connect(this.uri).then(function (client) {
  const db = client.db('local');
  const coll = db.collection('oplog.rs');
  coll.find({}, {ts: 1})
    .sort({$natural: -1})
    .limit(1)
    .next() // 替换nextObject()为next()
    .then(doc => {
      if (doc) {
        console.log('获取到最新的oplog文档:', doc);
      } else {
        console.log('没有找到匹配的文档');
      }
      // 别忘了关闭数据库连接
      client.close();
    })
    .catch(err => {
      console.error('查询过程出错:', err);
      client.close();
    });
});

方案2：用async/await（推荐，代码更清晰）

import {Collection, MongoClient, ServerOptions} from 'mongodb';

async function getLatestOplogEntry() {
  try {
    // 建立数据库连接
    const client = await MongoClient.connect(this.uri);
    const db = client.db('local');
    const coll = db.collection('oplog.rs');
    
    // 查询最新的oplog文档
    const latestDoc = await coll.find({}, {ts: 1})
      .sort({$natural: -1})
      .limit(1)
      .next();
    
    if (latestDoc) {
      console.log('最新oplog条目:', latestDoc);
    } else {
      console.log('oplog集合中没有数据');
    }
    
    // 关闭连接
    client.close();
  } catch (error) {
    console.error('操作失败:', error);
  }
}

// 调用函数执行查询
getLatestOplogEntry();

补充说明 #

在MongoDB Node.js驱动3.x版本中，Cursor API做了不少更新，除了nextObject()替换为next()，还有一些其他方法也有变更（比如each()换成了forEach()）。如果后续遇到类似“方法不存在”的错误，可以优先核对你使用的驱动版本对应的官方API文档，确认方法名称的变化。

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