nodejs对mongodb数据库的增删改查操作
2016-07-15 17:23
549 查看
转自:http://jm1999.iteye.com/blog/2026227
首先要确保mongodb的正确安装,安装参照:
http://docs.mongodb.org/manual/tutorial/install-mongodb-on-debian-or-ubuntu-linux
然后下载nodejs的mongodb的driver
npm install mongodb
编写一个测试的程序:
如果最终显示connect则说明成功。
对mongodb的collection的操作
有两种方法链接collection,分别为:
db.collection(‘mycoll’,function(err,coll){});
db.createCollection(‘mycoll’,function(err,coll){});
这两种方法还有第二个可选参数{safe:true},这个参数的作用对于第一种方法,如果加上了这个参数,那么当collection不存在的时候则报错,对于第二种方法,则当collection存在的时候报错
示例:
示例:
删除collection则使用dropCollection函数即可:
示例:
示例:
(2)对数据进行更新:
示例:
(3)对数据进行删除使用remove函数
示例:
如果remove没有任何的参数,则删除全部。
(4)查找操作,查找操作有两个方法一个是find,一个是findOne
示例:
首先要确保mongodb的正确安装,安装参照:
http://docs.mongodb.org/manual/tutorial/install-mongodb-on-debian-or-ubuntu-linux
然后下载nodejs的mongodb的driver
npm install mongodb
编写一个测试的程序:
1 var mongodb = require('mongodb'); 2 var server = new mongodb.Server('localhost',27017,{auto_reconnect:true}); 3 var db = new mongodb.Db('mydb',server,{safe:true}); 4 db.open(function(err,db){ 5 if(!err) 6 { 7 console.log('connect'); 8 }else{ 9 console.log(err); 10 } 11 12 });
如果最终显示connect则说明成功。
对mongodb的collection的操作
有两种方法链接collection,分别为:
db.collection(‘mycoll’,function(err,coll){});
db.createCollection(‘mycoll’,function(err,coll){});
这两种方法还有第二个可选参数{safe:true},这个参数的作用对于第一种方法,如果加上了这个参数,那么当collection不存在的时候则报错,对于第二种方法,则当collection存在的时候报错
示例:
1 var mongodb = require('mongodb'); 2 var server = new mongodb.Server('localhost',27017,{auto_reconnect:true}); 3 var db = new mongodb.Db('mydb',server,{safe:true}); 4 db.open(function(err,db){ 5 if(!err) 6 { 7 console.log('connect'); 8 db.collection('mycoll',{safe:true},function(err,collection){ 9 if(err){ 10 console.log(err); 11 } 12 }); 13 14 }else{ 15 console.log(err); 16 } 17 18 });
示例:
1 var mongodb = require('mongodb'); 2 var server = new mongodb.Server('localhost',27017,{auto_reconnect:true}); 3 var db = new mongodb.Db('mydb',server,{safe:true}); 4 db.open(function(err,db){ 5 if(!err) 6 { 7 console.log('connect'); 8 db.createCollection('mycoll',{safe:true},function(err,collection){ 9 if(err){ 10 console.log(err); 11 } 12 }); 13 14 }else{ 15 console.log(err); 16 } 17 18 });
删除collection则使用dropCollection函数即可:
示例:
1 var mongodb = require('mongodb'); 2 var server = new mongodb.Server('localhost',27017,{auto_reconnect:true}); 3 var db = new mongodb.Db('mydb',server,{safe:true}); 4 db.open(function(err,db){ 5 if(!err) 6 { 7 console.log('connect'); 8 db.dropCollection('mycoll',{safe:true},function(err,result){ 9 console.log(result); 10 }); 11 12 }else{ 13 console.log(err); 14 } 15 });
对collection进行增删改查
(1)向collection添加数据使用insert函数示例:
1 var mongodb = require('mongodb'); 2 var server = new mongodb.Server('localhost',27017,{auto_reconnect:true}); 3 var db = new mongodb.Db('mydb',server,{safe:true}); 4 db.open(function(err,db){ 5 if(!err) 6 { 7 db.collection('mycoll',{safe:true},function(err,collection){ 8 var tmp1 = {title:'hello',number:1}; 9 collection.insert(tmp1,{safe:true},function(err,result){ 10 console.log(result); 11 }); 12 }); 13 }else{ 14 console.log(err); 15 } 16 17 });
(2)对数据进行更新:
示例:
1 var mongodb = require('mongodb'); 2 var server = new mongodb.Server('localhost',27017,{auto_reconnect:true}); 3 var db = new mongodb.Db('mydb',server,{safe:true}); 4 db.open(function(err,db){ 5 if(!err) 6 { 7 db.collection('mycoll',{safe:true},function(err,collection){ 8 collection.update({title:'hello'},{$set:{number:3}},{safe:true},function(err,result){ 9 console.log(result); 10 }); 11 12 }else{ 13 console.log(err); 14 } 15 16 }); 17
(3)对数据进行删除使用remove函数
示例:
1 var mongodb = require('mongodb'); 2 var server = new mongodb.Server('localhost',27017,{auto_reconnect:true}); 3 var db = new mongodb.Db('mydb',server,{safe:true}); 4 db.open(function(err,db){ 5 if(!err) 6 { 7 db.collection('mycoll',{safe:true},function(err,collection){ 8 collection.remove({title:'hello'},{safe:true},function(err,result){ 9 console.log(result); 10 }); 11 12 }else{ 13 console.log(err); 14 } 15 16 });
如果remove没有任何的参数,则删除全部。
(4)查找操作,查找操作有两个方法一个是find,一个是findOne
示例:
1 var mongodb = require('mongodb'); 2 var server = new mongodb.Server('localhost',27017,{auto_reconnect:true}); 3 var db = new mongodb.Db('mydb',server,{safe:true}); 4 db.open(function(err,db){ 5 if(!err) 6 { 7 db.collection('mycoll',{safe:true},function(err,collection){ 8 var tmp1 = {title:'hello'}; 9 var tmp2 = {title:'world'}; 10 collection.insert([tmp1,tmp2],{safe:true},function(err,result){ 11 console.log(result); 12 }); 13 collection.find({type:"food",price: {$lt:10}})).toArray(function(err,docs){ 14 console.log('find'); 15 console.log(docs); 16 }); 17 collection.findOne(function(err,doc){ 18 console.log('findOne'); 19 console.log(doc); 20 }); 21 });
相关文章推荐
- 分享微信开发Html5轻游戏中的几个坑
- 如何在 Fedora 上安装 MongoDB 服务器
- PHP添加yaf xhprof mongodb 同理
- mongodb安装
- 如何在 Ubuntu 上安装 MongoDB
- 信息安全聚合 Sec-News 的重构之路
- Ruby on Rails框架程序连接MongoDB的教程
- 使用ruby部署工具mina快速部署nodejs应用教程
- perl操作MongoDB报错undefined symbol: HeUTF8解决方法
- Google官方支持的NodeJS访问API,提供后台登录授权
- 浅谈Nodejs观察者模式
- nodejs教程之环境安装及运行
- nodejs中的fiber(纤程)库详解
- 基于NodeJS的前后端分离的思考与实践(五)多终端适配
- 基于NodeJS的前后端分离的思考与实践(二)模版探索
- 实例详解Nodejs 保存 payload 发送过来的文件
- 我的NodeJs学习小结(一)
- Node.js 应用跑得更快 10 个技巧
- nodejs中实现sleep功能实例
- Nodejs异步回调的优雅处理方法