nodejs操作mongodb的增删改查功能实例
更新时间：2017年11月09日 12:10:01 作者：专注前端30年
这篇文章主要介绍了nodejs操作mongodb的增删改查功能,简单分析了mongodb模块的安装并结合实例形式分析了nodejs操作mongodb数据库进行增删改查的相关实现技巧,需要的朋友可以参考下
本文实例讲述了nodejs操作mongodb的增删改查功能。分享给大家供大家参考，具体如下：
安装相关模块
如果使用这个的话，你需要先自己安装一下他需要的模块，在根目录输入
npm install mongodb --save
进行模块安装，安装成功以后就可以进行以下的步骤。
文件的引入
以下是我书写的相关代码，放到你可以引用的相关目录，本人放到了express的根目录
function Mongo(options) {
this.settings = {
url: 'mongodb://localhost:27017/jk',
MongoClient:require('mongodb').MongoClient,
assert:require('assert')
};
for(let i in options){
this.settings[i] = options[i];
}
this._run = function (fun) {
let that = this;
let settings = this.settings;
this.settings.MongoClient.connect(this.settings.url, function (err, db) {
settings.assert.equal(null, err);
console.log("Connected correctly to server");
fun(db, function () {
db.close();
});
});
};
this.insert = function (collectionName, data, func) {
//增加数据
let insertDocuments = function (db, callback) {
let collection = db.collection(collectionName);
collection.insertMany([
data
], function (err, result) {
if (!err) {
func(true);
} else {
func(false);
}
callback(result);
});
};
this._run(insertDocuments);
};
this.update = function (collectionName, updateData, data, func) {
//更新数据
let updateDocument = function (db, callback) {
let collection = db.collection(collectionName);
collection.updateOne(updateData
, {$set: data}, function (err, result) {
if (!err) {
func(true);
} else {
func(false);
}
callback(result);
});
};
this._run(updateDocument);
};
this.delete = function (collectionName, data, func) {
//删除数据
let deleteDocument = function (db, callback) {
let collection = db.collection(collectionName);
collection.deleteOne(data, function (err, result) {
if (!err) {
func(true);
} else {
func(false);
}
callback(result);
});
};
this._run(deleteDocument);
};
this.find = function (collectionName, data, func) {
//查找数据
let findDocuments = function (db, callback) {
// Get the documents collection
let collection = db.collection(collectionName);
// Find some documents
collection.find(data).toArray(function (err, docs) {
if (!err) {
func(true,docs);
}
else {
func(false, err);
}
callback(docs);
});
};
this._run(findDocuments);
};
}
module.exports = Mongo;
我存入到了一个名字叫server.js的文件名内
使用
我们在需要使用页面先将模块引入，比如我在路由文件index.js里面引入：
const Server = require("../server.js");
然后需要实例化对象，如下：
let server = new Server();
如果需要配置相关信息，可以在实例化的时候传入一个对象配置，可以配置数据库的地址：
let server = new Server({url:"mongodb://localhost:27017/mydb"});
里面封装了四个方法，添删改查，分别是
添加方法
server.insert(数据表名,需要插入的数据（键值对的对象）,回调函数);
更新方法
server.update(数据表名,查询的数据（对象）,更新的数据（对象）,回调函数);
删除方法
server.delete(数据表名,查询的数据（对象）,回调函数);
查找方法
server.find(数据表名,查询的数据（对象）,回调函数);
回调函数都会返回两个值，第一个布尔类型，是否处理成功，第二个值，查找返回查找到的个数，别的都返回处理成功的个数（现在一次只处理一条）
使用案例
比如我需要在一个路由里面查找数据，我就需要这样：
server.find("users",{username:"username"},function (bool,data) {
if(bool){
console.log("查询到数据为"+data.length+"条");
}
else{
console.log(data);
}
});
});
上面的代码是查询了users表里面username为username的字段的数据，如果成功，后面data就会返回一个数组，如果出现错误，就直接返回data错误。
希望本文所述对大家nodejs程序设计有所帮助。
相关文章
下面小编就为大家带来一篇nodejs操作mysql实现增删改查的实例。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-05-05
这篇文章主要介绍了node连接kafka2.0,nodejs连接kafka2.0的实现方法,结合实例形式分析了kafka2.0的功能、原理、以及node.js连接kafka2.0的具体实现技巧,需要的朋友可以参考下2023-05-05
本篇文章主要介绍了Node连接mysql数据库方法介绍。详细的介绍了怎样连接和操作数据库，并举例说明，有兴趣的可以了解一下。2017-02-02
JWT是为了在网络应用环境间传递声明而执行的一种基于JSON的开放标准，其组成部分为Header、Payload、Signature.Payload部分才是真正的用户信息，它是用户信息经过加密之后生成的字符串，Header和Signature是安全性相关的部分，只是为了保证token的安全性2023-02-02
详解NodeJs项目 CentOs linux服务器线上部署
这篇文章主要介绍了NodeJs项目 CentOs linux服务器线上部署，本文给大家介绍的非常详细，具有一定的参考借鉴价值,需要的朋友可以参考下2019-09-09
这篇文章主要介绍了express框架下使用session的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-07-07
这篇文章主要为大家详细介绍了nodejs个人博客开发的数据分页，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-04-04
这篇文章主要介绍了Node.js中的Async和Await函数的相关知识，非常不错，具有参考借鉴价值,需要的朋友可以参考下2018-02-02
Node.js实现http请求服务与Mysql数据库操作方法详解
这篇文章主要介绍了Node.js实现http请求服务与Mysql数据库操作方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习吧2022-10-10
这篇文章主要为大家介绍了基于Node.js的http模块来搭建HTTP服务器的示例过程详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步2022-02-02
最新评论