JavaScript

超轻量级php框架startmvc

node.js操作mongodb简单示例分享

更新时间:2020-05-14 08:54 作者:startmvc
前两篇文章我们介绍了nodejs操作redis和MySQL,下面简要测试一下nodejs操作mongodb:首先安装node

前两篇文章我们介绍了nodejs操作redis和MySQL,下面简要测试一下nodejs操作mongodb:

首先安装nodejs mongodb


npm install mongodb

代码


var mongodb = require('mongodb');
var server = new mongodb.Server('localhost', 27017, {auto_reconnect:true});
var db = new mongodb.Db('mydb', server, {safe:true});

//连接db
db.open(function(err, db){
 if(!err){
 console.log('connect db');
 // 连接Collection(可以认为是mysql的table)
 // 第1种连接方式
 // db.collection('mycoll',{safe:true}, function(err, collection){
 // if(err){
 // console.log(err);
 // }
 // });
 // 第2种连接方式
 db.createCollection('mycoll', {safe:true}, function(err, collection){
 if(err){
 console.log(err);
 }else{
 //新增数据
 // var tmp1 = {id:'1',title:'hello',number:1};
 // collection.insert(tmp1,{safe:true},function(err, result){
 // console.log(result);
 // }); 
 //更新数据
 // collection.update({title:'hello'}, {$set:{number:3}}, {safe:true}, function(err, result){
 // console.log(result);
 // });
 // 删除数据
 // collection.remove({title:'hello'},{safe:true},function(err,result){
 // console.log(result);
 // });

 // console.log(collection);
 // 查询数据
 var tmp1 = {title:'hello'};
 var tmp2 = {title:'world'};
 collection.insert([tmp1,tmp2],{safe:true},function(err,result){
 console.log(result);
 }); 
 collection.find().toArray(function(err,docs){
 console.log('find');
 console.log(docs);
 }); 
 collection.findOne(function(err,doc){
 console.log('findOne');
 console.log(doc);
 }); 
 }

 });
 // console.log('delete ...');
 // //删除Collection
 // db.dropCollection('mycoll',{safe:true},function(err,result){

 // if(err){
 
 // console.log('err:');
 // console.log(err);
 // }else{
 // console.log('ok:');
 // console.log(result);
 // }
 // }); 
 }else{
 console.log(err);
 }
});