nodejs操作mongodb
首先安装nodejs mongodb
npm install mongodb
var mongodb = require('mongodb'),
http = require('http'),
url = require('url');
var server = new mongodb.Server('localhost', 27017, {auto_reconnect:true});
var db = new mongodb.Db('mydb', server, {safe:true});
//插入表数据
function insert(tablename,rowInfo,callback){
db.open(function(err, db){
if(!err){
//db.createCollection
db.createCollection(tablename,{safe:true}, function(err, collection){
if(!err){
collection.insert(rowInfo,{safe:true},function(err, result){
if(!err){
callback(true);
}else{
callback(false);
}
});
}else{
console.log(err);
}
});
}else{
console.log('connect db'+err);
}
});
}
function save(tablename,rowInfo,callback){
db.open(function(err,db){
if(err)return console.error(err);
console.log('* mongodb connected');
db.collection(tablename).save(rowInfo,function(err,result){
callback(result);
db.close();
});
})
}
//修改表数据
function update(tablename,id,rowInfo,callback){
db.open(function(err, db){
if(!err){
db.createCollection(tablename,{safe:true}, function(err, collection){
if(!err){
collection.update(id,rowInfo,{safe:true},function(err, result){
if(!err){
callback(true);
}else{
callback(false);
}
});
}else{
console.log(err);
}
});
}else{
console.log('connect db'+err);
}
});
}
//删除表数据
function del(tablename,id,callback){
db.open(function(err, db){
if(!err){
db.collection(tablename,{safe:true}, function(err, collection){
if(!err){
collection.delete(id,{safe:true},function(err, result){
if(!err){
callback(true);
}else{
callback(false);
}
});
}else{
console.log(err);
}
});
}else{
console.log('connect db'+err);
}
});
}
//查询表数据
function find(tablename,callback){
db.open(function(err, db){
if(!err){
db.collection(tablename,{safe:true}, function(err, collection){
if(!err){
collection.find().toArray(function(err, result){
if(!err){
callback(result);
}else{
console.log(err);
}
});
}else{
console.log(err);
}
});
}else{
console.log('connect db'+err);
}
});
}
//删除Collection
function dropCollection(tablename,callback){
db.open(function(err, db){
if(!err){
db.dropCollection(tablename,{safe:true},function(err,result){
if(!err){
callback(true);
}else{
callback(false);
}
});
}else{
console.log('connect db'+err);
}
});
}
var myres = "";
http.createServer(function(req,res){
var arg = url.parse(req.url,true).query;
var pathname = url.parse(req.url).pathname;
console.log(pathname);
switch(pathname){
case '/find':
find("tb_user",function(data){
myres = data;
console.log(data);
});
break;
case '/insert':
var rowInfo = {'userID':10008,'userName':'ciwei','password':'123456','age':25};
insert("tb_user",rowInfo,function(data){
myres = data;
});
break;
case '/update':
var id = {"userID":10008};
var rowInfo = {$set:{"userName":"ciwei88888","password":"123456","age":25}};
update("tb_user",id,rowInfo,function(data){
myres = data;
});
break;
}
var str = arg.callback + '(' + JSON.stringify(myres) + ')'
console.log(str);
res.end(str);
}).listen(8080,'localhost');
console.log("run on 8080");
更多资料请参见nodejs mongodb官网 http://mongodb.github.io/node-mongodb-native/ 和mongodb官网http://www.mongodb.org/
- 上一篇 »用PHP实现MONGODB的基本操作
- 下一篇 »PHP操作MongoDB学习，转