使用Node.js和MongoDB 3.1执行CRUD操作时遇'collection'未定义错误

这个错误其实是两个常见问题叠加导致的：变量作用域错误和异步代码执行顺序问题，咱们一步步拆解解决：

问题根源分析 #

1. 作用域问题：你在MongoClient.connect的回调里用了var db = client.db('testdb')，这里的var会创建一个回调内部的局部变量，完全和外部声明的var db没关系，所以外部的db始终是undefined。
2. 异步执行顺序：MongoClient.connect是异步操作，你的app.post路由在数据库还没连接完成时就已经注册了，用户发起请求时，db还没被赋值，自然就报错了。

修复方案 #

方案1：修正作用域+调整代码执行顺序（回调方式） #

把路由注册和服务器启动逻辑放到数据库连接成功的回调里，同时去掉回调里的var，让外部的db能拿到数据库实例：

const express = require('express')
const bodyParser= require('body-parser')
const MongoClient = require('mongodb').MongoClient
const app = express()
app.use(bodyParser.urlencoded({extended: true}))
const url = 'mongodb://localhost:27017/testdb';
var db

MongoClient.connect(url, function(err, client) {
  if (err) {
    console.error('数据库连接失败:', err)
    return process.exit(1) // 连接失败直接退出进程，避免后续错误
  }
  // 去掉var，直接给外部的db变量赋值
  db = client.db('testdb');
  console.log('数据库连接成功')

  // 现在db已经可用，在这里注册路由
  app.post('/quotes', (req, res) => {
    const collection = db.collection('quotes');
    collection.save(req.body, (err, result) => {
      if (err) {
        console.error('保存数据失败:', err)
        return res.status(500).send('数据保存失败')
      }
      console.log('saved to database')
      res.redirect('/')
    })
  })

  // 最后启动服务器
  app.listen(3000, () => {
    console.log('服务器运行在 http://localhost:3000')
  })
})

方案2：使用async/await（更现代的写法，推荐） #

用异步函数处理数据库连接，让代码逻辑更清晰，避免回调嵌套：

const express = require('express')
const bodyParser= require('body-parser')
const MongoClient = require('mongodb').MongoClient
const app = express()
app.use(bodyParser.urlencoded({extended: true}))
const url = 'mongodb://localhost:27017/testdb';

// 用async函数封装启动逻辑
async function startServer() {
  try {
    // 等待数据库连接完成
    const client = await MongoClient.connect(url)
    const db = client.db('testdb')
    console.log('数据库连接成功')

    // 注册路由
    app.post('/quotes', (req, res) => {
      db.collection('quotes')
        .save(req.body)
        .then(() => {
          console.log('saved to database')
          res.redirect('/')
        })
        .catch(err => {
          console.error('保存数据失败:', err)
          res.status(500).send('数据保存失败')
        })
    })

    // 启动服务器
    app.listen(3000, () => {
      console.log('服务器运行在 http://localhost:3000')
    })
  } catch (err) {
    console.error('数据库连接失败:', err)
    process.exit(1)
  }
}

// 启动服务器
startServer()

验证修复 #

运行修改后的代码，先确认控制台输出数据库连接成功和服务器运行在...，然后发起POST请求到/quotes，就不会再出现Cannot read property 'collection' of undefined的错误了。

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