一、安装mongodb
npm i mongodb --save-dev
二、创建工具类 mongodbHelper.js
const dbInfo = {
host: "127.0.0.1",
port: "27017",
dbName: "xxx"
};
const {
dbInfo
} = require("../../config/server.config.js");
const MongoClient = require('mongodb').MongoClient;
class mongodbHelper {
/***连接数据库***/
connection() {
return new Promise(function (resolve, reject) {
var url = `mongodb://${dbInfo.host}:${dbInfo.port}/${dbInfo.dbName}`;
MongoClient.connect(url, {
useUnifiedTopology: true,
useNewUrlParser: true
}, function (err, db) {
if (err) {
reject(err);
}
console.log("连接成功！", url);
resolve(db);
});
})
}
/**关闭数据库连接
*db:数据库实例
***/
close(db) {
db.close;
}
/**创建集合
* db:数据库实例
* collectionName：集合名称
* **/
createCollection(collectionName) {
return new Promise((resolve, reject) => {
this.connection().then(db => {
var dbase = db.db(dbInfo.dbName);
dbase.createCollection(collectionName, function (err, res) {
db.close();
if (err) {
reject(err);
}
resolve(1);
});
}).catch(err => {
reject(err);
})
})
}
/**添加一条数据
* collectionName：集合名称
* data：数据，Object
* */
insertOne(collectionName, data) {
return new Promise((resolve, reject) => {
this.connection().then(db => {
var dbase = db.db(dbInfo.dbName);
dbase.collection(collectionName).insertOne(data, function (err, res) {
db.close();
if (err) {
reject(err);
}
resolve(1);
});
}).catch(err => {
reject(err);
})
})
}
/**添加多条数据
*collectionName：数据集合
*datas：数据，Array
****/
insertMany(collectionName, datas) {
return new Promise((resolve, reject) => {
this.connection().then(db => {
var dbase = db.db(dbInfo.dbName);
dbase.collection(collectionName).insertMany(datas, function (err, res) {
db.close();
if (err) {
reject(err);
}
resolve(datas.length);
});
}).catch(err => {
reject(err);
})
})
}
/**查询
*collectionName：集合名称
*search：查询条件
* **/
find(collectionName, search) {
return new Promise((resolve, reject) => {
this.connection().then(db => {
var dbase = db.db(dbInfo.dbName);
dbase.collection(collectionName).find(search).toArray(function (err, result) {
db.close();
if (err) {
reject(err);
}
resolve(result);
});
}).catch(err => {
reject(err);
})
})
}
/**修改数据
* collectionName：表名
* query：查询条件，Object
* update：更新的数据，Object
* option={upsert, multi}
*/
update(collectionName, query, update) {
return new Promise((resolve, reject) => {
this.connection().then(db => {
var dbase = db.db(dbInfo.dbName);
dbase.collection(collectionName).updateOne(query, {
$set: update
}, function (err, res) {
db.close();
if (err) {
reject(err);
}
resolve(1);
});
}).catch(err => {
reject(err);
})
})
}
/**修改数据
* collectionName：表名
* query：查询条件，Object
* update：更新的数据，Object
* option={upsert, multi}
*/
delete(collectionName, obj) {
return new Promise((resolve, reject) => {
this.connection().then(db => {
var dbase = db.db(dbInfo.dbName);
dbase.collection(collectionName).remove(obj, function (err, res) {
db.close();
if (err) {
reject(err);
}
resolve(1);
});
}).catch(err => {
reject(err);
})
});
}
}
module.exports = mongodbHelper
三、使用，创建类 userModel.js
const dbHelper = require("./mongodbHelper .js")();
class userModel {
constructor() {
this.tbName = "tb_user";
this.email = "";
this.userName = "";
this.loginName = "";
this.email = "";
this.phone = "";
this.time = "";
}
async add(user) {
if (!user) {
user = {
userName: this.userName,
loginName: this.loginName,
email: this.email,
phone: this.phone,
}
}
user.time = new Date();
let result = await dbHelper.insertOne(this.tbName, user);
return result;
}
async getOne(searchObj) {
let list = await this.getList(searchObj);
if (list && list.length) {
return list[0];
}
return null;
}
async getList(searchObj) {
let list = await dbHelper.find(this.tbName, searchObj);
return list;
}
}
module.exports = userModel;
五，对外接口(userInfo.js)
const router = require("koa-router")();
const UserModel = require("../../model/userModel.js");
router.post('/addUser', async (ctx) => {
let result = new ctx.Result();//新加的一个结果类，返回结果同一个格式app.context.Result = Result;
try {
let user = new UserModel();
let userInfo = ctx.request.body.userInfo;
let ret = await user.add(userInfo);
ctx.body = result.setDatas(ret);
} catch (e) {
ctx.body = result.setError(e.message);
}
})
router.post('/getUser', async (ctx) => {
let result = new ctx.Result();
try {
let user = new UserModel();
let userInfo = ctx.request.body.userInfo;
let ret = await user.getList(userInfo);
ctx.body = result.setDatas(ret);
} catch (e) {
ctx.body = result.setError(e.message);
}
})
module.exports = router;
六、mongodb环境安装
下载地址：
https://www.mongodb.com/download-center/community
启动命令：mongod --dbpath "D:\数据文件夹路径"
出现以下信息就可以正常读写数据了
image.png
