1.23Node.js 中操作 mongodb

Mongoose是Node.js 操作 MongoDB 的优雅解决方案

Mongoose 是一个基于 Node.js 的 MongoDB 对象建模工具，它为 Node.js 与 MongoDB 之间提供了一个高级抽象层，使开发者可以更便捷地操作 MongoDB。

1. 安装与基本设置

首先安装 Mongoose：

npm install mongoose

连接到 MongoDB 数据库：

const mongoose = require('mongoose');async function connectDB() {try {await mongoose.connect('mongodb://localhost:27017/mydatabase', {useNewUrlParser: true,useUnifiedTopology: true,useCreateIndex: true,useFindAndModify: false});console.log('Connected to MongoDB');} catch (error) {console.error('Error connecting to MongoDB:', error);process.exit(1);}
}connectDB();

2. 核心概念：Schema、Model 和 Document

Schema（模式）

定义数据结构和验证规则：

const mongoose = require('mongoose');
const { Schema } = mongoose;const userSchema = new Schema({name: {type: String,required: true,trim: true},email: {type: String,required: true,unique: true,lowercase: true,validate: {validator: (value) => {return /^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(value);},message: 'Invalid email address'}},age: {type: Number,min: 1,max: 150},createdAt: {type: Date,default: Date.now}
});

Model（模型）

基于 Schema 创建数据模型：

const User = mongoose.model('User', userSchema);

Document（文档）

模型的实例，代表 MongoDB 中的一个文档：

const newUser = new User({name: 'John Doe',email: 'john@example.com',age: 30
});newUser.save().then(user => console.log('User saved:', user)).catch(error => console.error('Error saving user:', error));

3. 数据验证

Mongoose 提供内置和自定义验证器：

const productSchema = new Schema({name: {type: String,required: [true, 'Product name is required'],minlength: [3, 'Name must be at least 3 characters']},price: {type: Number,required: true,validate: {validator: (value) => value > 0,message: 'Price must be greater than 0'}},category: {type: String,enum: {values: ['electronics', 'clothing', 'books'],message: '{VALUE} is not a valid category'}}
});

4. 数据操作

创建文档

// 单个创建
User.create({ name: 'Alice', email: 'alice@example.com', age: 25 }).then(user => console.log('Created user:', user)).catch(error => console.error('Error creating user:', error));// 批量创建
User.insertMany([{ name: 'Bob', email: 'bob@example.com', age: 30 },{ name: 'Charlie', email: 'charlie@example.com', age: 35 }
]).then(users => console.log('Created users:', users)).catch(error => console.error('Error creating users:', error));

查询文档

// 查找所有用户
User.find().then(users => console.log('All users:', users)).catch(error => console.error('Error finding users:', error));// 按条件查找
User.findOne({ age: { $gte: 30 } }).then(user => console.log('User over 30:', user)).catch(error => console.error('Error finding user:', error));// 按 ID 查找
User.findById('6123456789abcdef12345678').then(user => console.log('User by ID:', user)).catch(error => console.error('Error finding user by ID:', error));// 高级查询
User.find().where('age').gte(25).lte(40).sort('-age').select('name email').limit(10).then(users => console.log('Filtered users:', users)).catch(error => console.error('Error filtering users:', error));

更新文档

// 按 ID 更新
User.findByIdAndUpdate('6123456789abcdef12345678',{ age: 31 },{ new: true, runValidators: true }
).then(updatedUser => console.log('Updated user:', updatedUser)).catch(error => console.error('Error updating user:', error));// 按条件更新
User.updateOne({ email: 'john@example.com' },{ $set: { name: 'John Smith' } }
).then(result => console.log('Update result:', result)).catch(error => console.error('Error updating user:', error));

删除文档

// 按 ID 删除
User.findByIdAndDelete('6123456789abcdef12345678').then(deletedUser => console.log('Deleted user:', deletedUser)).catch(error => console.error('Error deleting user:', error));// 按条件删除
User.deleteMany({ age: { $lt: 25 } }).then(result => console.log('Deleted users:', result.deletedCount)).catch(error => console.error('Error deleting users:', error));

5. 中间件（Middleware）

在文档操作前后执行自定义逻辑：

// 保存前的中间件
userSchema.pre('save', function(next) {// 对密码进行哈希处理if (this.isModified('password')) {this.password = bcrypt.hashSync(this.password, 10);}next();
});// 保存后的中间件
userSchema.post('save', function(doc, next) {console.log('User saved:', doc._id);next();
});// 查询后的中间件
userSchema.post('find', function(docs, next) {console.log(`Returned ${docs.length} users`);next();
});

6. 虚拟字段（Virtuals）

定义不存储在数据库中的计算字段：

userSchema.virtual('fullName').get(function() {return `${this.firstName} ${this.lastName}`;
});userSchema.virtual('isAdult').get(function() {return this.age >= 18;
});// 使用虚拟字段
User.findOne({ email: 'john@example.com' }).then(user => {console.log('Full name:', user.fullName);console.log('Is adult:', user.isAdult);}).catch(error => console.error('Error fetching user:', error));

7. 关联（Population）

处理文档间的关系：

// 定义作者模式
const authorSchema = new Schema({name: String,country: String
});// 定义书籍模式
const bookSchema = new Schema({title: String,author: {type: Schema.Types.ObjectId,ref: 'Author'}
});// 关联查询
Book.findOne({ title: 'Mongoose Guide' }).populate('author', 'name country -_id') // 选择要返回的字段.then(book => console.log('Book with author:', book)).catch(error => console.error('Error fetching book:', error));

8. 聚合（Aggregation）

执行复杂的数据处理：

User.aggregate([// 匹配年龄大于25的用户{ $match: { age: { $gt: 25 } } },// 按国家分组并计算每组的平均年龄和用户数{ $group: {_id: '$country',averageAge: { $avg: '$age' },count: { $sum: 1 }} },// 按平均年龄降序排序{ $sort: { averageAge: -1 } },// 限制结果数量{ $limit: 5 }
]).then(results => console.log('Aggregation results:', results)).catch(error => console.error('Error in aggregation:', error));

Mongoose 为 MongoDB 提供了强大而灵活的抽象层，使 Node.js 开发者能够更高效地处理数据库操作，同时保持代码的整洁和可维护性。通过合理使用 Schema、Model、验证、中间件等特性，可以构建出健壮的数据库层。