nodejs连接mongodb数据库实现增删改查

准备

1.通过npm命令安装mongodb

2.安装mongodb数据库，这里不详细介绍了，安装网址：http://www.jb51.net/article/82522.htm
CRUD操作
在此之前应对MongoDB数据库有所了解，知道它的一些增删查改命令。
1.增加

var MongoClient = require（"mongodb"）.MongoClient;var DB_URL = "mongodb://localhost:27017/chm";function insertData（db）{var devices = db.collection（"vip"）;var data = {"name":"node","age":22,"addr":"nb","addTime":new Date（）};devices.insert（data,function（error, result）{if（error）{console.log（"Error:"+ error）;}else{console.log（result.result.n）;}db.close（）;}）;} MongoClient.connect（DB_URL, function（error, db）{console.log（"连接成功！"）;insertData（db）;}）;

2.查找

var mongodb = require（"mongodb"）var MongoClient = require（"mongodb"）.MongoClient;var DB_CONN_STR = "mongodb://localhost:27017/chm"; var selectData = function（db, callback） {//连接到表var collection = db.collection（"vip"）; //查询数据 var whereStr = {"name":"node"}; collection.find（whereStr,function（error, cursor）{cursor.each（function（error,doc）{if（doc）{//console.log（doc）;if （doc.addTime） {console.log（"addTime: "+doc.addTime）;}}}）; }）;}MongoClient.connect（DB_CONN_STR, function（err, db） { console.log（"连接成功！"）; selectData（db, function（result） {console.log（result）;db.close（）; }）;}）;

3.更新

var MongoClient = require（"mongodb"）.MongoClient;var DB_URL = "mongodb://localhost:27017/chm";MongoClient.connect（DB_URL, function（error, db）{console.log（"连接成功！"）;updateData（db）;}）;function updateData（db）{var devices = db.collection（"vip"）;var whereData = {"name":"node"}var updateDat = {$set: {"age":26}}; //如果不用$set，替换整条数据devices.update（whereData, updateDat, function（error, result）{if （error） {console.log（"Error:"+ error）;}else{console.log（result）;}db.close（）;}）;}

4.删除

var MongoClient = require（"mongodb"）.MongoClient;var DB_URL = "mongodb://localhost:27017/chm";MongoClient.connect（DB_URL, function（error, db）{console.log（"连接成功"）;deleteData（db）;}）;function deleteData（db）{var devices = db.collection（"vip"）;var data = {"name":"node"};devices.remove（data, function（error, result）{if （error） {console.log（"Error:"+ error）;}else{console.log（result.result.n）;}db.close（）;}）}

存储过程
在mongodb中创建存储过程

所有存储过程都存放在db.system.js中，通过db.eval（“存储过程ID（）”）;调用存储过程。
在代码中调用：

var MongoClient = require（"mongodb"）.MongoClient;var DB_URL = "mongodb://localhost:27017/chm";MongoClient.connect（DB_URL, function（error,db）{console.log（"连接成功！"）;callProcess（db）}）;function callProcess（db）{db.eval（"get_vip_count（）",function（error, result）{if （error） {console.log（error）;}else{console.log（"count:"+result）;}db.close（）;}）;}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。