Node.js+Express连接MongoDB Atlas调用insertOne报错：Insert命令不支持

错误原因 #

1. 同时混用原生MongoDB驱动（MongoClient）和Mongoose，且错误地通过Mongoose的connection对象调用原生驱动的insertOne方法，两者API不兼容导致报错。
2. 冗余的MongoClient连接代码在连接后立即关闭，无实际作用还可能造成连接资源混乱。
3. 使用body-parser.raw处理JSON数据，需要手动解析req.body，增加出错概率，且不如Express内置的JSON解析便捷。
4. Schema中_id定义为Object类型，不符合MongoDB的ObjectId规范，可能导致插入时类型不匹配。

修复步骤 #

1. 移除冗余的MongoClient代码 #

删除const { MongoClient } = require("mongodb");以及对应的run函数和调用，只保留Mongoose的连接逻辑。

2. 替换body解析方式 #

用Express内置的express.json()替代body-parser.raw，自动解析JSON格式的请求体，无需手动调用JSON.parse(req.body)。

3. 使用Mongoose模型的正确插入方法 #

使用Mongoose模型实例的save()方法或模型的create()方法插入数据，不要混用原生驱动的insertOne。

4. 修正Schema的_id类型 #

将_id: Object改为_id: mongoose.Types.ObjectId，或者直接省略该字段，让Mongoose自动生成唯一的ObjectId（推荐）。

5. 完善接口响应 #

在POST接口中向前端返回成功或失败的响应，而非仅在控制台输出信息。

修改后的完整代码 #

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

const app = express();

// 使用Express内置的JSON解析器
app.use(express.json({ limit: '100kb' }));

app.get("/", (req, res) => {
  console.log("MAIN");
  res.send("API is running");
});

// 仅保留Mongoose连接逻辑
const mongoUrl = 'MONGO URL DB';
mongoose.connect(mongoUrl, { useNewUrlParser: true, useUnifiedTopology: true });
const db = mongoose.connection;
db.on('error', console.error.bind(console, 'MongoDB connection error:'));
db.once('open', () => {
  console.log("Connected to MongoDB via Mongoose");
});

// 定义User Schema，推荐省略_id让Mongoose自动生成
const userSchema = new mongoose.Schema({
  username: { type: String, required: true },
  password: { type: String, required: true },
  name: String,
  email: { type: String, required: true },
  phone_number: String
});

// 定义User模型
const User = mongoose.model('User', userSchema);

// POST接口：添加用户
app.post('/addUser', async (req, res) => {
  try {
    // 直接使用解析后的req.body创建实例
    const newUser = new User(req.body);
    await newUser.save();
    // 也可以使用User.create(req.body)替代上述两行

    console.log("ADDED TO DB SUCCESSFULLY!");
    res.status(201).json({ message: "用户添加成功", user: newUser });
  } catch (err) {
    console.error(err);
    res.status(500).json({ message: "添加用户失败", error: err.message });
  }
});

app.listen(3001, () => {
  console.log(`Listening on port 3001`);
});

额外说明 #

• 如果需要手动指定_id，需确保前端传入的是有效的ObjectId字符串，同时在Schema中定义_id: mongoose.Types.ObjectId，创建实例时需转换类型：_id: new mongoose.Types.ObjectId(req.body._id)。
• 密码建议存入数据库前使用bcrypt等工具进行哈希加密，避免明文存储。

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