bzyaocom
2017-12-09 09:16:44
nodejs连接mongodb示例,实现对数据的增删改查操作(跳过不必要的坑) Windows版
第一步:安装nodejs
1.1.官网下载 版本:nodejs v6.9.2(对应npm v3.10.9)下载地址:https://nodejs.org/dist/
1.2.详细安装步骤,请参考https://www.cnblogs.com/sese/p/5182783.html
第二步:安装mongodb及驱动(注意版本兼容)
2.1.官网下载版本:mongodb v3.0.0 驱动版本:v2.2.33 下载地址:https://www.mongodb.com/download-center?jmp=nav#community
2.2.mongodb详细安装步骤,请参考https://www.cnblogs.com/wyhlightstar/p/6271251.html
2.3.驱动安装
首先打开nodejs进行全局安装mongodb驱动器 输入命令npm install mongodb -g
再在新建的项目安装中 命令 npm install mongodb --save 此步骤安装时还需要配置package.json文件(请放在项目的根目录下)
package.json 内容如下:
{ "name": "nodejs02", "version": "0.0.0", "private": true, "scripts": { "start": "node ./bin/www" }, "dependencies": { "body-parser": "~1.15.2", "cookie-parser": "~1.4.3", "debug": "~2.2.0", "ejs": "~2.5.2", "express": "^4.14.1", "mongodb": "^2.2.33", "morgan": "~1.7.0", "serve-favicon": "~2.3.0" } }
第三步:nodejs操作mongodb 实现增删改查示例
nodejs和mongodb已经全部安装完毕,所需驱动模板mongodb也已安装,下面开始利用nodejs来操作mongodb吧
3.1.在项目的根目录下新建一个app.js文件实现增加
//引入mongodb模块,获得客户端对象 var MongoClient = require('mongodb').MongoClient; //连接字符串 var DB_CONN_STR = 'mongodb://localhost:27017/gomall'; //定义函数表达式,用于操作数据库并返回结果 var insertData = function(db, callback) { //获得指定的集合 var collection = db.collection('users'); //插入数据 var data = [{_id:7,"name":'rose',"age":21},{_id:8,"name":'mark',"age":22}]; collection.insert(data, function(err, result) { //如果存在错误 if(err) { console.log('Error:'+ err); return; } //调用传入的回调方法,将操作结果返回 callback(result); }); } //使用客户端连接数据,并指定完成时的回调方法 MongoClient.connect(DB_CONN_STR, function(err, db) { console.log("连接成功!"); //执行插入数据操作,调用自定义方法 insertData(db, function(result) { //显示结果 console.log(result); //关闭数据库 db.close(); }); });
运行结果:
连接成功! { result: { ok: 1, n: 2 }, ops: [ { _id: 7, name: 'rose', age: 21 }, { _id: 8, name: 'mark', age: 22 } ], insertedCount: 2, insertedIds: [ 7, 8 ] }
3.2 修改操作示例
//引入mongodb模块,获得客户端对象 var MongoClient = require('mongodb').MongoClient; //连接字符串 var DB_CONN_STR = 'mongodb://localhost:27017/gomall'; //定义函数表达式,用于操作数据库并返回结果 var updateData = function(db, callback) { //获得指定的集合 var collection = db.collection('users'); //要修改数据的条件,>=10岁的用户 var where={age:{"$gte":10}}; //要修改的结果 var set={$set:{age:95}}; collection.updateMany(where,set, function(err, result) { //如果存在错误 if(err) { console.log('Error:'+ err); return; } //调用传入的回调方法,将操作结果返回 callback(result); }); }
3.3 查询示例
//引入mongodb模块,获得客户端对象 var MongoClient = require('mongodb').MongoClient; //连接字符串 var DB_CONN_STR = 'mongodb://localhost:27017/gomall'; //定义函数表达式,用于操作数据库并返回结果 var findData = function(db, callback) { //获得指定的集合 var collection = db.collection('users'); //要查询数据的条件,<=10岁的用户 var where={age:{"$lte":10}}; //要显示的字段 var set={name:1,age:1}; collection.find(where,set).toArray(function(err, result) { //如果存在错误 if(err) { console.log('Error:'+ err); return; } //调用传入的回调方法,将操作结果返回 callback(result); }); } //使用客户端连接数据,并指定完成时的回调方法 MongoClient.connect(DB_CONN_STR, function(err, db) { console.log("连接成功!"); //执行插入数据操作,调用自定义方法 findData(db, function(result) { //显示结果 console.log(result); //关闭数据库 db.close(); }); });
3.4删除示例
//引入mongodb模块,获得客户端对象 var MongoClient = require('mongodb').MongoClient; //连接字符串 var DB_CONN_STR = 'mongodb://localhost:27017/gomall'; //定义函数表达式,用于操作数据库并返回结果 var findData = function(db, callback) { //获得指定的集合 var collection = db.collection('users'); //要删除数据的条件,_id>2的用户删除 var where={_id:{"$gt":2}}; collection.remove(where,function(err, result) { //如果存在错误 if(err) { console.log('Error:'+ err); return; } //调用传入的回调方法,将操作结果返回 callback(result); }); } //使用客户端连接数据,并指定完成时的回调方法 MongoClient.connect(DB_CONN_STR, function(err, db) { console.log("连接成功!"); //执行插入数据操作,调用自定义方法 findData(db, function(result) { //显示结果 console.log(result); //关闭数据库 db.close(); }); });
评论
最近浏览
孟陆同学 LV7
2018年3月20日
Evil_dong LV4
2018年3月7日
上世纪风景 LV11
2018年1月12日
zyl LV34
2018年1月8日
KimOHHH LV5
2018年1月3日
jeremygilbert LV21
2017年12月26日
yikong LV8
2017年12月21日
hjy100200 LV6
2017年12月20日
水心木支 LV4
2017年12月18日
tianlin1995 LV3
2017年12月17日