Mongoose快速上手：数据库安装与CRUD操作指南

一、环境准备与数据库安装

1.1 MongoDB安装与启动

MongoDB是Mongoose依赖的NoSQL数据库，支持文档型数据存储。根据操作系统选择安装方式：

• Windows：从官网下载MSI安装包，安装时勾选”Install MongoDB Compass”可视化工具
• macOS：使用Homebrew安装brew tap mongodb/brew && brew install mongodb-community
• Linux：添加官方仓库后sudo apt-get install -y mongodb-org

安装完成后启动服务：

# Windows系统
net start MongoDB
# Linux/macOS系统
sudo service mongod start

验证服务状态：

mongo --eval "db.adminCommand('listDatabases')"

1.2 Node.js项目初始化

创建新项目并安装依赖：

mkdir mongoose-demo && cd mongoose-demo
npm init -y
npm install mongoose express

二、Mongoose基础配置

2.1 连接数据库

在db.js中配置连接：

const mongoose = require('mongoose');
async function connectDB() {
  try {
    await mongoose.connect('mongodb://localhost:27017/demoDB', {
      useNewUrlParser: true,
      useUnifiedTopology: true
    });
    console.log('数据库连接成功');
  } catch (error) {
    console.error('数据库连接失败:', error);
    process.exit(1);
  }
}
module.exports = connectDB;

2.2 定义数据模型

创建models/User.js定义用户模型：

const mongoose = require('mongoose');
const userSchema = new mongoose.Schema({
  username: {
    type: String,
    required: [true, '用户名不能为空'],
    unique: true,
    trim: true,
    minlength: [3, '用户名至少3个字符']
  },
  email: {
    type: String,
    required: true,
    validate: {
      validator: (v) => /^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(v),
      message: '请输入有效的邮箱地址'
    }
  },
  age: {
    type: Number,
    min: [18, '年龄不能小于18岁'],
    max: 120
  },
  createdAt: {
    type: Date,
    default: Date.now
  }
});
module.exports = mongoose.model('User', userSchema);

三、CRUD操作详解

3.1 创建文档（Create）

3.1.1 单个文档创建

const User = require('./models/User');
async function createUser() {
  try {
    const newUser = new User({
      username: 'john_doe',
      email: 'john@example.com',
      age: 25
    });
    const savedUser = await newUser.save();
    console.log('用户创建成功:', savedUser);
  } catch (error) {
    console.error('创建用户失败:', error);
  }
}

3.1.2 批量插入

async function createMultipleUsers() {
  try {
    const users = [
      { username: 'user1', email: 'user1@example.com', age: 22 },
      { username: 'user2', email: 'user2@example.com', age: 28 }
    ];
    const result = await User.insertMany(users);
    console.log('批量创建成功:', result);
  } catch (error) {
    console.error('批量创建失败:', error);
  }
}

3.2 查询文档（Read）

3.2.1 基本查询

async function findUsers() {
  try {
    // 查询所有用户
    const allUsers = await User.find();
    console.log('所有用户:', allUsers);
    // 条件查询
    const specificUser = await User.findOne({ username: 'john_doe' });
    console.log('特定用户:', specificUser);
    // 分页查询
    const paginatedUsers = await User.find()
      .skip(10) // 跳过前10条
      .limit(5); // 限制返回5条
  } catch (error) {
    console.error('查询失败:', error);
  }
}

3.2.2 高级查询

async function advancedQuery() {
  try {
    // 条件组合
    const result = await User.find({
      age: { $gt: 20 }, // 年龄大于20
      $or: [ // 或条件
        { username: /^john/ }, // 用户名以john开头
        { email: /@test\.com$/ } // 邮箱以@test.com结尾
      ]
    });
    // 字段选择
    const minimalData = await User.find({}, 'username email');
    // 排序
    const sortedUsers = await User.find().sort({ age: -1 }); // 年龄降序
  } catch (error) {
    console.error('高级查询失败:', error);
  }
}

3.3 更新文档（Update）

3.3.1 更新单个文档

async function updateUser() {
  try {
    // 更新第一个匹配的文档
    const updated = await User.updateOne(
      { username: 'john_doe' },
      { $set: { age: 26 } }
    );
    console.log('更新结果:', updated);
    // 更新并返回修改后的文档
    const findAndUpdate = await User.findOneAndUpdate(
      { username: 'john_doe' },
      { $inc: { age: 1 } }, // 年龄+1
      { new: true } // 返回更新后的文档
    );
  } catch (error) {
    console.error('更新失败:', error);
  }
}

3.3.2 批量更新

async function bulkUpdate() {
  try {
    const result = await User.updateMany(
      { age: { $lt: 25 } }, // 年龄小于25
      { $set: { status: 'young' } }
    );
    console.log('批量更新结果:', result);
  } catch (error) {
    console.error('批量更新失败:', error);
  }
}

3.4 删除文档（Delete）

3.4.1 删除单个文档

async function deleteUser() {
  try {
    // 删除第一个匹配的文档
    const result = await User.deleteOne({ username: 'john_doe' });
    console.log('删除结果:', result);
    // 查找并删除
    const deletedUser = await User.findOneAndDelete({ username: 'user1' });
  } catch (error) {
    console.error('删除失败:', error);
  }
}

3.4.2 批量删除

async function bulkDelete() {
  try {
    const result = await User.deleteMany({ status: 'young' });
    console.log('批量删除结果:', result);
  } catch (error) {
    console.error('批量删除失败:', error);
  }
}

四、最佳实践与注意事项

1. 连接管理：

   • 使用连接池，避免频繁创建/销毁连接
   • 推荐使用mongoose.connection.on('error')监听错误

2. 错误处理：

   • 区分验证错误和数据库错误
   • 使用try/catch处理异步操作

3. 性能优化：

   • 合理使用索引（在Schema中定义）
   • 避免返回不必要的字段
   • 批量操作优于循环单条操作

4. 安全实践：

   • 使用环境变量存储敏感信息
   • 实现输入数据验证
   • 限制查询结果数量防止内存溢出

五、完整示例整合

const express = require('express');
const connectDB = require('./db');
const User = require('./models/User');
const app = express();
app.use(express.json());
// 连接数据库
connectDB();
// 创建用户路由
app.post('/users', async (req, res) => {
  try {
    const user = new User(req.body);
    const savedUser = await user.save();
    res.status(201).json(savedUser);
  } catch (error) {
    res.status(400).json({ error: error.message });
  }
});
// 查询用户路由
app.get('/users', async (req, res) => {
  try {
    const users = await User.find()
      .skip(parseInt(req.query.skip || 0))
      .limit(parseInt(req.query.limit || 10));
    res.json(users);
  } catch (error) {
    res.status(500).json({ error: error.message });
  }
});
const PORT = 3000;
app.listen(PORT, () => {
  console.log(`服务器运行在 http://localhost:${PORT}`);
});

六、总结与扩展

通过本文的学习，您已经掌握了：

1. MongoDB的安装与基本管理
2. Mongoose的连接配置和模型定义
3. 完整的CRUD操作实现
4. 实用的查询技巧和错误处理

建议进一步学习：

• Mongoose中间件（pre/post hooks）
• 事务处理
• 聚合管道查询
• 人口统计等复杂查询场景

记住，实践是掌握Mongoose的关键。建议从简单的CRUD应用开始，逐步增加复杂度，最终能够熟练处理各种数据库操作场景。