Node.js连接mongodb实例代码

前面介绍了node.js操作关系型数据库以及redis的内容，这里继续学习操作mongodb的内容。

安装驱动

安装命令

cnpm安装mongodb安装成功

数据库操作

因为mongodb是文档类型的数据库，与关系型数据库有很大不同，mongodb会自动创建数据库和集合，并不需要提前进行手动创建。

插入

var MongoClient=require(' MongoDB ').MongoClientvar DB _ CONN _ STR=' MongoDB ://sa :[电子邮件保护]:27017/test _ DB '；var insertData=函数(分贝，回调){ //连接数据表my _ firsrt _ collection var collection=db。集合(' my _ firsrt _ collection ')；var data=[{ ' name ' : ' wolf 1 '，' age': 20 }，{ ' name ' : ' wolf 2 '，' age ' : 20 }]集合。insert(数据，函数(err，结果){ if(err){ console。日志('错误： ' err)；返回；};回调（结果);});};蒙古客户端。connect(DB _ CONN _ STR)，function (err，db) { if (err) { console.log('连接失败：' err)；返回；};console.log('连接成功');插入数据(数据库)，函数(结果){控制台。日志(结果)；db。close()；});});结果

查询数据

var MongoClient=require(' MongoDB ').MongoClientvar DB _ CONN _ STR=' MongoDB ://sa :[电子邮件保护]:27017/test _ DB '；//查询var queryData=函数(分贝，回调){ //连接数据表my _ firsrt _ collection var collection=db。集合(' my _ firsrt _ collection ')；//查询条件定义变量其中={ ' name ' : ' wolf y1 ' }；收集.找到(在哪里).toArray(函数(错误，结果){ if(错误){ console。日志('错误： ' err)；返回；};回调（结果);});};蒙古客户端。connect(DB _ CONN _ STR)，function (err，db) { if (err) { console.log('连接失败：' err)；返回；};console.log('连接成功');queryData(db)，function(result){ console。日志(结果)；db。close()；});});结果

更新数据

var MongoClient=require(' MongoDB ').MongoClientvar DB _ CONN _ STR=' MongoDB ://sa :[电子邮件保护]:27017/test _ DB '；//查询var updateData=函数(分贝，回调){ //连接数据表my _ firsrt _ collection var collection=db。集合(' my _ firsrt _ collection ')；//查询条件定义变量其中={ ' name ' : ' wolf y1 ' }；var updateStr={ $ set : { ' address ' : ' http://www。cn博客。com/wolf-sun/' } }；collection.update(where，updateStr，function (err，result){ if(err){ console。日志('错误： ' err)；返回；};回调（结果);});};蒙古客户端。connect(DB _ CONN _ STR)，function (err，db) { if (err) { console.log('连接失败：' err)；返回；};console.log('连接成功');updateData(db)，function(result){ console。日志(结果)；db。close()；});});结果

删除数据

var MongoClient=require(' MongoDB ').MongoClientvar DB _ CONN _ STR=' MongoDB ://sa :[电子邮件保护]:27017/test _ DB '；//删除var deleteData=函数(分贝，回调){ //连接数据表my _ firsrt _ collection var collection=db。集合(' my _ firsrt _ collection ')；//查询条件定义变量其中={ ' name ' : ' wolf y1 ' }；collection.remove(where，function (err，result){ if(err){ console。日志('错误： ' err)；返回；};回调（结果);});};蒙古客户端。connect(DB _ CONN _ STR)，function (err，db) { if (err) { console.log('连接失败：' err)；返回；};console.log('连接成功');deleteData(db)，function(result){ console。日志(结果)；db。close()；});});结果

总结

到这里就简单实现了node.js操作mongodb的实例。希望对大家的学习有所帮助，也希望大家多多支持我们。