node连接mongodb
2017-09-29 本文已影响39人
bestvist
原文链接
node连接mongodb
mongodb安装
mongodb基本命令
创建数据库(如果存在则切换到数据库)
use [database]
例如
use db_test
删除数据库
db.dropDatabase()
插入数据
db.[collection].insert({data})
例如
db.col.insert({
name: 'vist',
age: 24
})
查询数据
db.[collection].find({options})
例如
db.col.find({name:'vist'});
修改数据
db.[collection].update([query],[update],{upsert,multi,writeConcern})
query: update的查询条件
update: update的对象
upsert: 可选,如果不存在记录,是否插入objNew,true为插入,默认为false
multi: 可选,只更新第一条记录,true为更新全部查找结果,默认为false
writeConcern: 可选,抛出异常的级别
删除数据
db.[collection].remove([query],{justOne,writeConcern})
query: remove的查询条件
justOne: 可选,删除记录数,如果为true或1,删除一条数据
node连接mongodb
引入模块
npm install mongodb
连接
var mongodb=require('mongodb');
var server=new mongodb.Server('localhost',27017,{auto_reconnect:true});
var db=new mongodb.Db('db_test',server,{safe:true});
db.open(function(err,db){
if(!err){
console.log('connect');
}else{
console.log(err);
}
});
查询数据
db.collection('col',function(err,col){
col.find().toArray(function(err,docs){
console.log(docs);
})
})
新增数据
db.collection('col',function(err,col){
col.insert({name:'bestvist',age:20},function(err,docs){
console.log(docs);
})
})
修改数据
db.collection('col',function(err,col){
col.update({name:'bestvist'},{$set:{age:24}},function(err,docs){
console.log(docs);
});
})
删除数据
db.collection('col',fnction(err,col){
col.remove({name:'bestvist'},function(err,docs){
console.log(docs);
});
})
断开连接
db.close();