1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
// 1. 引入并连接 MongoDB
const mongoose = require('mongoose');
// 连接本地 MongoDB（test 是数据库名，不存在会自动创建）
async function connectDB() {
try {
await mongoose.connect('mongodb://127.0.0.1:27017/test');
console.log('MongoDB 连接成功！');
} catch (err) {
console.error('MongoDB 连接失败：', err);
process.exit(1); // 连接失败退出进程
}
}
// 2. 定义 Schema（用户模式）
const userSchema = new mongoose.Schema({
name: {
type: String, // 字段类型
required: [true, '姓名不能为空'], // 必填 + 自定义错误提示
trim: true, // 自动去除首尾空格
maxlength: [20, '姓名长度不能超过 20 个字符'] // 长度限制
},
age: {
type: Number,
min: [1, '年龄不能小于 1'], // 最小值限制
max: [120, '年龄不能大于 120'] // 最大值限制
},
email: {
type: String,
required: true,
unique: true, // 唯一索引（避免重复邮箱）
match: [/^\w+([.-]?\w+)*@\w+([.-]?\w+)*(\.\w{2,3})+$/, '请输入正确的邮箱格式'] // 正则校验
},
gender: {
type: String,
enum: ['男', '女', '其他'], // 枚举值限制
default: '其他' // 默认值
},
createTime: {
type: Date,
default: Date.now // 默认当前时间
}
});
// 3. 定义中间件（钩子函数）：保存前执行
userSchema.pre('save', function (next) {
// this 指向当前文档实例
console.log(`准备保存用户：${this.name}`);
next(); // 必须调用 next() 继续执行
});
// 4. 编译 Schema 为 Model（模型名：User，对应集合名：users）
const User = mongoose.model('User', userSchema);
// 5. 核心 CRUD 操作
async function main() {
// 先连接数据库
await connectDB();
// ========== 新增数据 ==========
try {
const newUser = new User({
name: '张三',
age: 25,
email: 'zhangsan@test.com',
gender: '男'
});
const savedUser = await newUser.save(); // 保存到数据库
console.log('新增用户成功：', savedUser);
} catch (err) {
console.error('新增用户失败：', err.message);
}
// ========== 查询数据 ==========
// 1. 查询所有用户
const allUsers = await User.find();
console.log('所有用户：', allUsers);
// 2. 条件查询（年龄 > 20 且性别为男）
const filterUsers = await User.find({ age: { $gt: 20 }, gender: '男' })
.select('name age email') // 只返回指定字段
.sort({ createTime: -1 }); // 按创建时间降序
console.log('条件查询结果：', filterUsers);
// 3. 查询单个用户（按 ID）
// 先取第一个用户的 ID
const firstUserId = allUsers[0]?._id;
if (firstUserId) {
const singleUser = await User.findById(firstUserId);
console.log('单个用户：', singleUser);
}
// ========== 更新数据 ==========
if (firstUserId) {
const updatedUser = await User.findByIdAndUpdate(
firstUserId,
{ age: 26 }, // 要更新的字段
{ new: true, runValidators: true } // new: 返回更新后的数据；runValidators: 执行校验
);
console.log('更新后用户：', updatedUser);
}
// ========== 删除数据 ==========
// 示例：删除邮箱为 zhangsan@test.com 的用户（注释掉避免误删）
// const deleteResult = await User.deleteOne({ email: 'zhangsan@test.com' });
// console.log('删除结果：', deleteResult);
}
// 执行主函数
main().catch(err => console.error('执行失败：', err));
|