安装

安装MongoDB

npm install mongodb --save

引入中间件

引入mongodb下面的连接模块MongoClient

// 引入MongoDB 连接模块

const MongoClient = MongoDB.MongoClient;

配置中间件

定义数据库连接的地址以及配置数据库的名称

let url = "mongodb://localhost:27017/";

let dbName = "koa";

连接数据库

nodejs连接数据库

MongoClient.connect(url,(err,client)=>{

if(err){

console.log(err);

return false;

}

let db = client.db(dbName); //数据库db对象

});

操作数据库

MongoClient.connect(url,(err,client)=>{

if(err){

console.log(err);

return false;

}

let db = client.db(dbName); //数据库db对象

db.collection('user').insertOne({'name':'张三'}, function(err, result){

if(!err){

console.log('数据增加成功');

clinet.close(); //关闭连接

}

});

let cx = db.collection('user').find({});

cx.toArray((err,docs)=>{

console.log(docs);

});

});

封装MongoDB库，优化【连接数据库】和【操作数据库】操作

最终会有两个文件，一个是 MongoDB配置文件MongoDB.config.js和一个是MongoDB封装文件MongoDB.db.js。

MongoDB.config.js文件：

// MongoDB数据库配置文件

const app = {

// 定义数据库地址

'dbUrl' : 'mongodb://localhost:27017/',

// 定义数据库名字

'dbName' : 'koa'

};

module.exports = app;

MongoDB.db.js文件：

/*

封装DB库操作

*/

// 引入MongoDB 模块

const MongoDB = require("mongodb");

// 引入MongoDB 连接模块

const MongoClient = MongoDB.MongoClient;

// 引入MongoDB ObjectID模块

const ObjectID = MongoDB.ObjectID;

// 引入配置文件

const Config = require("./MongoDB.config.js");

class Db {

// 单例模式，解决多次实例化时候每次创建连接对象不共享的问题，实现共享连接数据库状态

static getInstance() {

if (!Db.instance) {

Db.instance = new Db();

}

return Db.instance;

}

constructor() {

// 属性 存放db对象

this.dbClient = "";

// 实例化的时候就连接数据库，增加连接数据库速度

this.connect();

}

// 连接数据库

connect() {

return new Promise((resolve, reject) => {

// 解决数据库多次连接的问题，要不然每次操作数据都会进行一次连接数据库的操作，比较慢

if (!this.dbClient) {

// 第一次的时候连接数据库

MongoClient.connect(Config.dbUrl, (err, client) => {

if (err) {

reject(err);

} else {

// 将连接数据库的状态赋值给属性，保持长连接状态

this.dbClient = client.db(Config.dbName);

resolve(this.dbClient);

}

});

} else {

// 第二次之后直接返回dbClient

resolve(this.dbClient);

}

});

}

/**

* 查询数据库

* 使用方法： let result = await DB.find('user',{});

* @param {String} collectionName 集合名称、数据表名

* @param {Object} json 查询的条件

*/

find(collectionName, json) {

return new Promise((resolve, reject) => {

this.connect().then((db) => {

// 操作db库里的某一个表，返回符合条件的内容，json查找的条件

let result = db.collection(collectionName).find(json);

result.toArray(function (err, docs) {

if (err) {

reject(err);

return;

}

resolve(docs);

});

});

});

}

/**

* 更新数据库

* 使用方法： let result = await DB.update('user',{'username':'lisi'},{'username':'李四'});

* @param {String} collectionName 集合名称、数据表名

* @param {Object} json1 需要更新数据的条件

* @param {Object} json2 新数据的内容

*/

update(collectionName, json1, json2) {

return new Promise((resolve, reject) => {

this.connect().then((db) => {

// 操作db库里的某一个表，更新一条数据，json1查找的内容，json2更新的新内容，回调函数

db.collection(collectionName).updateOne(

json1,

{

$set: json2,

},

(err, result) => {

if (err) {

reject(err);

} else {

resolve(result);

}

}

);

});

});

}

/**

* 插入数据库

* 使用方法： let result = await DB.insert('user',{'username':'赵六666','age':30,'sex':'女','status':'2'});

* @param {String} collectionName 集合名称、数据表名

* @param {Object} json 插入的新数据

*/

insert(collectionName, json) {

return new Promise((resolve, reject) => {

this.connect().then((db) => {

// 操作db库里的某一个表，插入一条数据，json插入的新内容，回调函数

db.collection(collectionName).insertOne(json, (err, result) => {

if (err) {

reject(err);

} else {

resolve(result);

}

});

});

});

}

/**

* 批量插入数据库

* 使用方法： let result = await DB.insert('user',[{'username':'赵六666','age':30,'sex':'女','status':'2'},{'username':'赵六666','age':30,'sex':'女','status':'2'},{'username':'赵六666','age':30,'sex':'女','status':'2'}...]);

* @param {String} collectionName 集合名称、数据表名

* @param {Array} json 批量插入的新数据

*/

insertMany(collectionName, arr) {

return new Promise((resolve, reject) => {

this.connect().then((db) => {

// 操作db库里的某一个表，批量插入一组数据，arr批量插入的新内容，回调函数

db.collection(collectionName).insertMany(arr, (err, result) => {

if (err) {

reject(err);

} else {

resolve(result);

}

});

});

});

}

/**

* 删除数据

* 使用方法： let result = await DB.remove('user',{'username':'李四'});

* @param {String} collectionName 集合名称、数据表名

* @param {Object} json 删除数据的条件

*/

remove(collectionName, json) {

return new Promise((resolve, reject) => {

this.connect().then((db) => {

db.collection(collectionName).removeOne(json, (err, result) => {

if (err) {

reject(err);

} else {

resolve(result);

}

});

});

});

}

/**

* 通过id查询数据时候需要用到此方法，MongoDB里面查询_id ，把字符串转换成对象

* MongoDB数据库里的_id是自动生成的，通过dind方法查询结果可以看到形式如： {"_id": ObjectId("5aad299bc166236421c99d229")},直接传入5aad299bc166236421c99d229，是查询不到结果的，所以需要包装一下

* 使用方法： let result = await DB.find('user',{'_id': DB.getObjectID(xxxxx)});

* @param {String} id 要查询的id

*/

getObjectID(id) {

return new ObjectID(id);

}

}

module.exports = Db.getInstance();