Nodejs使用Mongoose对MongoDB进行增删改查等基本操作

链接数据库#

1
//导入Mongoose包
2
const mongoose = require('mongoose');
3
//链接MongoDB
4
mongoose.connect('mongodb://localhost:27017/bilibili');
5

6
//设置回调
7
mongoose.connection.once('open', () => {
8
    console.log('链接数据库成功');
9
});
10
mongoose.connection.once('error', () => {
11
    console.log('链接数据库失败');
12
});
13
mongoose.connection.once('close', () => {
14
    console.log('和数据库的链接中断');
15
});
16
setTimeout(() => {
17
    mongoose.disconnect();
18
}, 2000);

once和on的区别在于once只会执行一次回调函数，而on会每次都执行，如果将端口侦听写在回调中，则一定要用once。

创建新文档#

1
mongoose.connection.once('open', () => {
2
    console.log('链接数据库成功');
3
    //创建文档的结构对象，设置集合中文档的属性以及属性值类型
4
    let bookSchema = new mongoose.Schema({
5
        name: String,
6
        author: String,
7
        price: Number
8
    });
9

10
    //创建模型对象，即对之前的文档操作的封装对象
11
    let bookModel = mongoose.model('books', bookSchema);
12
    //新增
13
    createBook(bookModel);
14
    //bookModel.create({name: '西游记', author: '吴承恩',price: 19.9});
15
});

异步执行写入操作，返回插入数据对象本身。这里原本可以卸载create的回调函数中，但是从Mongoose7开始create方法不在支持回调函数，因此只能通过异步操作方式获得返回对象。

1
async function createBook(bookModel){
2
    try{
3
        const data = await bookModel.create({ name: '红楼梦', author: '曹雪芹', price: 19.9 });
4
        console.log(data);
5
    }catch (err){
6
        console.log(err);
7
    }
8
}

字段类型#

有以下的数据类型

类型	描述
String	字符串
Number	数字
Boolean	布尔值
Array	数组类型，也可以用[]表示
Date	日期
Buffer	Buffer对象，比如多媒体文件的二进制码
Mixed	任意类型，需要使用mongoose.Schema.Types.Mixed指定
ObjectId	对象ID，需要使用mongoose.Schema.Types.ObjectId指定
Decimal128	高精度数字，需要使用mongoose.Schema.Types.Decimal128指定

举例#

1
mongoose.connection.once('open', () => {
2
    let bookSchema = new mongoose.Schema({
3
        name: String,
4
        author: String,
5
        price: Number,
6
        isHot: Boolean,
7
        tags: Array,
8
        publish: Date
9
    });
10
    let bookModel = mongoose.model('books', bookSchema);
11
    createBook(bookModel);
12
});
13
async function createBook(bookModel){
14
    const data = await bookModel.create({ name: '红楼梦', author: '曹雪芹', price: 19.9, isHot: true, tags: ['古典', '社会', '情感'], publish: new Date() });
15
}

字段验证#

有以下几种验证方法

类型	作用
required	表示该字段为必填字段
unique	是否为唯一值(必须在新集合中实现)
enum	枚举类型，复赋值是必须为枚举类型中所规定的值
default	字段的默认值

举例#

1
mongoose.connection.once('open', () => {
2
    let bookSchema = new mongoose.Schema({
3
        id: {type: String, unique: true}, //unique: 是否为唯一值(必须在新集合中实现)
4
        name: {type: String, required: true}, //required: 表示该字段为必填字段
5
        author: {type: String, default: 佚名}, //default: 字段的默认值
6
        source: {type: String, enum: ['中文', '外文']}, //enum: 枚举类型，复赋值是必须为枚举类型中所规定的值。
7
        price: Number
8
    });
9
    let bookModel = mongoose.model('books', bookSchema);
10
    createBook(bookModel);
11
});

删除文档#

基于两个核心方法deleteOne和deleteMany可以分别删除单条文档和多条文档

1
mongoose.connection.once('open', () => {
2
    console.log('链接数据库成功');
3
    let bookSchema = new mongoose.Schema({
4
        name: String,
5
        author: String,
6
        price: Number,
7
        is_hot: Boolean
8
    });
9
    let bookModel = mongoose.model('novels', bookSchema);
10
    //删除单条
11
    deleteRecords(bookModel, {author: '余华'}, bookModel.deleteOne);
12
    //删除多条
13
    deleteRecords(bookModel, {author: '余华'}, bookModel.deleteMany);
14
});
15
async function deleteRecords(model, query, deleteFunction){
16
    try{
17
        const data = await deleteFunction.call(model, query);
18
        console.log(data);
19
    }catch(err){
20
        console.log(err);
21
    }
22
}

更新文档#

基于updateOne和updateMany两个函数

1
mongoose.connection.once('open', () => {
2
    console.log('链接数据库成功');
3
    let bookSchema = new mongoose.Schema({
4
        name: String,
5
        author: String,
6
        price: Number,
7
        is_hot: Boolean
8
    });
9
    let bookModel = mongoose.model('novel', bookSchema);
10
    updateRecords(bookModel, {name: '西游记'}, bookModel.updateOne, {price: 50});
11
});
12
async function updateRecords(model, query, update, newRecord){
13
    try{
14
        const data = await update.call(model, query, newRecord);
15
        console.log(data);
16
    }catch(err){
17
        console.log(err);
18
    }
19
}

读取文档#

同样，基于One和Many两个函数

1
async function findRecords(model, query, search){
2
    try{
3
        const data = await search.call(model, query);
4
        console.log(data);
5
    }catch(err){
6
        console.log('读取失败: ', err);
7
        return;
8
    }
9
}

调用

1
findRecords(bookModel, {author: '曹雪芹'}, bookModel.findOne);
2
findRecords(bookModel, {author: '余华'}, bookModel.findMany);

条件控制#

就像if else可以通过与和或将多个条件结合使用一样，mongodb也可以；MongoDB中有以下几种条件控制

运算符#

运算符	作用
$gt	大于
$lt	小于
$gte	大于等于
$lte	小于等于
$ne	不等于

举例：

1
findRecords(bookModel, {price: {$lt: 20}}, bookModel.findOne);

逻辑运算#

运算符	作用
$or	或运算
$and	与运算

举例：

1
findRecords(bookModel, {
2
    $and: [
3
        {price: {$gt: 30}},
4
        {price: {$lt: 70}}
5
    ]
6
}, bookModel.findOne);

正则匹配#

有两种方法

1
findRecords(bookModel,{name: /三/}, bookModel.findOne);
2
//另一种方法：
3
findRecords(bookModel,{name: new RegExp('三')}, bookModel.findOne);

推荐使用第二种，因为第一种无法读取变量。

个性化读取#

有以下几种方法，可以显示特定的文档

方法	作用
select	字段筛选
sort	排序
skip	跳过多少条记录
limit	向后显示多少条记录

使用方法：

1
//只显示返回的数据的name和author两个字段, 不显示_id字段
2
const data = await model.find(query).select({name: 1, author: 1, _id: 0});
3
//根据返回数据的price字段升序显示(-1为降序)
4
const data = await model.find(query).sort({price: 1}).select({name: 1, price: 1});
5
//只返回数据的前三条
6
const data = await model.find(query).sort({price: 1}).select({name: 1, price: 1}).limit(3);
7
//和skip组合使用
8
//只返回第3到第6条数据
9
const data = await model.find(query).sort({price: 1}).select({name: 1, price: 1}).skip(3).limit(3);