Node の MongoDB Driver

序

在之前的

《Node の MongoDB 安装》

 一文当中，主要说的是如何安装

MongoDB

和其可视化界面

Compass

。

现在来说说node怎么连接使用

MongoDB

，对于node连接，可以使用两种方式，都是下载库：

• mongodb： MongoDB有一个基础库
  mongodb
  (Node.js MongoDB Driver)

• Mongoose: 现在主流使用的库，在代码量上更优，只需增删改查推荐

mongodb

这是基础库，不过基本的功能都是有的，如果需求不是太多使用这个即可。

下载

安装命令：

yarn add mongodb

可参考：

https://www.mongodb.org.cn/drivers/5.html

然后创建mongo文件夹和index.js，里面写

mongodb

库的使用方法。

nodemon运行的主程序是main.js

连接

首先测试mongodb数据库是否存在，能否进行相连。

从

mongodb

库中导入

MongoClient

客户端模块，该模块可以用来连接数据库

测试方法如下：(这里的baseUrl是依据之前数据库的地址，也可以在可视化界面中查看要连接的数据库url)

const MongoClient = require('mongodb').MongoClient;

const baseUrl = 'mongodb://127.0.0.1:27017/mongodbTest'
function TestConnect() {
 MongoClient.connect(baseUrl, function(err, db) {
 if (err) throw err;
 console.log("数据库已创建!");
 db.close();
 });
}


运行：

但其实此时数据库

mongodbTest

没有创建出来，在可视化界面

compass

或者cmd中都没有

然后，我在网上找了半天，发现这只是连接到了27017那里，没有将不存在的数据库创建出来。（这里菜鸟教程上的代码应该是不对的）

所以这里自己先手动创建一个数据库吧，可以在可视化界面中创建，简单一点，然后可以在数据库中再创建一个集合。

慢着，接下来我去mongodb官网进行了一波搜索，终于成功用代码创建上了数据库了，并且菜鸟上的方法确实不行了。

PS: 这里发了一波沸点，还有掘友给了比较完整的回复，哈哈哈

在之前的测试连接方法中可以稍作修改，使用async和await来进行，这样让代码看上去更舒服一些。

mongodb官方API：

https://mongodb.github.io/node-mongodb-native/4.5/

这里用到了

MongoClient.db

方法，此方法会使用或者建立一个数据库，但是，如果没有给这个数据库创建集合，那么此数据库也不会生成出来的。

const baseUrl = 'mongodb://127.0.0.1:27017'
// 创建对象
const client = new MongoClient(baseUrl);

async function TestConnect() {
 try {
 // 连接到数据库
 await client.connect();
 // 使用之前手动创建的mongodbTest数据库
 const db = await client.db('mongodbTest');
 console.log(db.databaseName)

 // 创建一个新的集合 (如果是代码新建的数据库，那么必须创建一个集合)
 db.createCollection('collection01')
 } catch(e) {
 console.log(e)
 await client.close();
 }
}

module.exports = { TestConnect }


获取集合列表

既然成功创建了数据库，那么尝试获取该数据库下的所有集合信息

collections

，可以使用

collectionName

将这些集合的名称打印出来

// 连接到数据库
await client.connect();
// 使用之前手动创建的mongodbTest数据库
const db = await client.db('mongodbTest');
// 获取当前数据库下所有集合
let collections = await db.collections();
// 打印集合名称
collections.forEach(item=>{
 console.log(item.collectionName)
})


集合列表名称：

上面对数据库和集合列表简单使用完了之后，可以对单个集合进行操作。

PS: 对于数据库db的操作方法可以参考具体的API文档，里面的方法也比较全面

创建集合并插入数据

这里使用db中的

createCollection

方法，可以用来创建新的集合

createCollection

方法参数：

测试代码：

// 创建新集合
db.createCollection('collection03', { autoIndexId: true }, (err, res)=>{
 if (err) console.log('集合创建失败');
 console.log(res.collectionName) // collection03
})

创建完一个空集合后，就该给此集合插入数据了

在mongodb中，集合中大部分都是文档，或者前端可以看成键值对的JSON数据

实例：定义一个文档，并使用

insertOne

插入到目标集合当中：

// 使用集合collection03
let c3 = db.collection('collection03');
// 定义文档
let doc = {
 name: '张三',
 age: 18,
 hobby: '打李四',
}
// 将文档插入集合
const result = await c3.insertOne(doc);


insertOne插入如果成功，将会返回当前文档在集合中的id

关于插入文档到集合中的方法有以下3种：（这三种方法的返回值都是Promise，可以使用async和await来解决回调）

• insert： 将单个文档或文档数组插入MongoDB。如果传入的文档不包含\u id字段，驱动程序将向缺少该字段的每个文档中添加一个，从而改变文档

• insertMany： 将文档数组插入MongoDB。如果传入的文档不包含\u id字段，驱动程序将向缺少该字段的每个文档中添加一个，从而改变文档

• insertOne： 将单个文档插入MongoDB。如果传入的文档不包含\u id字段，驱动程序将向缺少该字段的每个文档中添加一个，从而改变文档

接下来试试插入文档数组：

let doc = [
 {
 name: '李四',
 age: 18,
 hobby: '打王五',
 },
 {
 name: '王五',
 age: 18,
 hobby: '打张三',
 },
]
// 将文档插入集合
const result = await c3.insertMany(doc);


读取集合中的数据

在上面已经将文档内容插入到数据库的集合当中了，那么如何将数据从数据库中读取出来呢？

MongoDB

库提供了

find

方法

示例: 这里需要用toArray转换一下，或者也可以使用回调方法查看

// 读取集合中数据
const res = await c3.find().toArray();
console.log(res)

如果检索数据时，需要过滤掉一些无用的数据，那么可以在

find

中写入参数进行配置。

这里使用

projection

限制返回的字段，将不需要读取的属性设置为0，或者将需要读取的内容设置为1。

注意，这里最好不要同时设置出0和1，只需要设置读取

或者

不读取即可。否则可能会出现报错：

MongoServerError: Cannot do inclusion on field name in exclusion projection

 （如果在同一对象中同时指定0和1值，则会出现错误，除非其中一个字段是\u id字段）

以下示例就是将

_id

和

age

不进行读取：

// 读取集合中数据
const res = await c3.find({}, { 
 projection: { _id: 0, age: 0 }
}).toArray();
console.log(res)

结果：

在上面的示例中，会发现

find

方法中第一个参数是

{}

，因为这是查询对象，用于限制搜索的。可以使用来筛选。

query示例：

// 读取集合中数据
const res = await c3.find({
 name: /张/
}, { 
 projection: { _id: 0, age: 0 }
}).toArray();
console.log(res)

这样返回的结果只有张三的信息了：

删除集合信息

现在尝试去将之前存入的文档从集合中删除

同样也有delete删除方法

// 读取集合中数据
const res = await c3.deleteOne({
 name: /张/
});
console.log(res) // { acknowledged: true, deletedCount: 1 }

更新集合

上面已经写好了增删查，现在curd还剩下更新

示例：

// 读取集合中数据
let newvalue = { $set: { hobby: '打李四' } }
const res = await c3.updateOne({
 name: /王/
}, newvalue);
console.log(res)


此时，数据库中王五的爱好就从打张三变成了打李四

以上就是mongodb库的基本使用，没想到会写这么多。

mongoose留到下次了...