如何在Node.js中间件中使用MongoDB查询保存数据（附代码示例）

Hey there! Let's walk through exactly how to save data to MongoDB within Node.js middleware, with practical code examples you can copy and tweak for your own use case.

1. 先搞定依赖安装 #

First, you'll need two core packages: express for setting up your Node.js server/middleware, and mongoose (a popular MongoDB ODM) to simplify database interactions. Install them via npm:

npm install express mongoose

2. 连接到MongoDB #

Before writing any middleware, we need to establish a connection to our MongoDB database. Here's how to do that with Mongoose:

const express = require('express');
const mongoose = require('mongoose');
const app = express();

// 解析JSON请求体（必须，不然拿不到POST过来的数据）
app.use(express.json());

// 连接MongoDB
mongoose.connect('mongodb://localhost:27017/your-db-name')
  .then(() => console.log('Connected to MongoDB successfully!'))
  .catch(err => console.error('MongoDB connection error:', err));

Replace your-db-name with the actual name of your database.

3. 定义数据模型 #

Next, we need a Mongoose Schema and Model to define the structure of the data we want to save. Let's use a simple "User" example:

// 定义User Schema
const userSchema = new mongoose.Schema({
  name: {
    type: String,
    required: true
  },
  email: {
    type: String,
    required: true,
    unique: true
  },
  createdAt: {
    type: Date,
    default: Date.now
  }
});

// 创建User Model
const User = mongoose.model('User', userSchema);

4. 编写中间件实现数据保存 #

Now we can create a middleware function that takes incoming request data, validates it, and saves it to MongoDB. We can either use this middleware directly in a route, or as a reusable function across multiple routes.

示例1：路由内的中间件（直接处理保存） #

// 定义POST路由，中间件内完成数据保存
app.post('/api/users', async (req, res, next) => {
  try {
    // 从请求体获取数据
    const userData = req.body;
    
    // 创建新User实例并保存
    const newUser = new User(userData);
    const savedUser = await newUser.save();
    
    // 返回成功响应
    res.status(201).json({
      message: 'User saved successfully',
      user: savedUser
    });
  } catch (err) {
    // 处理错误：比如邮箱重复、必填字段缺失等
    res.status(400).json({
      error: err.message
    });
  }
});

示例2：可复用的独立中间件 #

If you want to reuse the save logic across multiple routes, you can extract it into a separate middleware function:

// 独立的保存用户中间件
const saveUserMiddleware = async (req, res, next) => {
  try {
    const userData = req.body;
    const newUser = new User(userData);
    req.savedUser = await newUser.save(); // 将保存后的用户数据挂载到req对象，供后续中间件使用
    next(); // 调用下一个中间件/路由处理函数
  } catch (err) {
    res.status(400).json({ error: err.message });
  }
};

// 使用这个中间件的路由
app.post('/api/users', saveUserMiddleware, (req, res) => {
  // 这里可以使用req.savedUser做后续处理
  res.status(201).json({
    message: 'User saved successfully',
    user: req.savedUser
  });
});

关键注意事项 #

• Always parse JSON request bodies: Don't forget app.use(express.json())—without it, req.body will be undefined.
• Handle errors properly: Using async/await with try/catch ensures you catch validation errors (like missing required fields) or database errors (like duplicate unique fields).
• Validate input: For production use, consider adding input validation libraries like joi or using Mongoose's built-in validation features to ensure data integrity.

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