nodejs对mongodb数据库的增加修删该查实例代码
以下是实例代码：
/**
1.npminstallmongodb--save-dev/cnpminstallmongodb--save-dev
2.varMongoClient=require('mongodb').MongoClient;
varurl='mongodb://localhost:27017/test';连接数据库的地址
3.连接数据库
MongoClient.connect(url,function(err,db){
});
4.实现增加修改删除
MongoClient.connect(url,function(err,db){
db.collection('user').insertOne({'name':'zhangsan'},function(error,data){
})
});
*/
varhttp=require('http');
varejs=require('ejs');
varMongoClient=require('mongodb').MongoClient;/*引入数据库MongoClient*/
varDBurl='mongodb://localhost:27017/userDb';//连接数据库的地址student表示数据库的名称
varurl=require('url');/*引入url模块*/
varapp=require('./model/express-route.js');
http.createServer(app).listen(3000);
app.get('/',function(req,res){
varmsg='这是数据库的数据'
ejs.renderFile('views/index.ejs',{msg:msg},function(err,data){
res.send(data);
})
})
app.get('/add',function(req,res){
//增加数据
MongoClient.connect(DBurl,function(err,db){/*连接数据库*/
if(err){
console.log(err);
console.log('数据库连接失败');
return;
}
//增加数据
db.collection('user').insertOne({
"name":"loaderman",
"age":10
},function(error,result){
if(error){
console.log('增加数据失败');
return;
}
res.send('增加数据成功');
db.close();/*关闭数据库*/
})
})
})
app.get('/edit',function(req,res){
//增加数据
//res.send('修改数据成功');
MongoClient.connect(DBurl,function(err,db){
if(err){
console.log(err);
console.log('数据库连接失败');
return;
}
db.collection('user').updateOne({"name":"loaderman"},{$set:{
"age":666
}},function(error,data){
if(error){
console.log('修改数据失败');
return;
}
console.log(data);
res.send('修改数据成功');
db.close();/*关闭数据库*/
})
})
})
app.get('/delete',function(req,res){
//增加数据
//delete?name=lisi
//console.log(url.parse(req.url,true));
varquery=url.parse(req.url,true).query;
//console.log(query.name);
varname=query.name;
MongoClient.connect(DBurl,function(err,db){
if(err){
console.log(err);
console.log('数据库连接失败');
return;
}
db.collection('user').deleteOne({"name":name},function(error,data){
if(error){
console.log('删除失败');
return;
}
console.log(data);
res.send('删除数据成功');
db.close();
})
})
})
app.get('/query',function(req,res){
MongoClient.connect(DBurl,function(err,db){
if(err){
console.log('连接数据库失败');
return;
}
//查询数据
varlist=[];/*放数据库里面查询的所有数据*/
varresult=db.collection('user').find({});
result.each(function(error,doc){
//console.log(doc);
if(error){
console.log(error);
}else{
if(doc!=null){
list.push(doc);
}else{/*doc==null表示数据循环完成*/
/*获取数据以后*/
//console.log(list);
ejs.renderFile('views/index.ejs',{list:list},function(err,data){
res.send(data);
})
}
}
})
//console.log(result);
})
})
插入数据
/**
*插入单条数据
*@paramtable_name表名
*@paraminsertData插入的数据
*@paramcallback回调方法
*/
MongoDbAction.insertData=function(table_name,insertData,callback){
varnode_model=this.getConnection(table_name);
node_model.insertOne(insertData,function(err,res){
if(err){
callback(err);
}else{
callback(null,res);
}
});
};
查询数据
/**
*查询单条数据
*@paramtable_name表名
*@paramconditions查询条件
*@paramcallback回调方法
*/
MongoDbAction.findOne=function(table_name,conditions,callback){
varnode_model=this.getConnection(table_name);
node_model.findOne(conditions,function(err,res){
if(err){
callback(err);
}else{
callback(null,res);
}
});
};
更新数据
/**
*更新单条数据
*@paramtable_name表名
*@paramconditions查询条件{"name":'jackson影琪'};
*@paramupdateStr更新数据{$set:{"url":"https://www.cnblogs.com/jackson-zhangjiang"}};
*@paramcallback回调方法
*/
MongoDbAction.updateOne=function(table_name,conditions，updateStr,callback){
varnode_model=this.getConnection(table_name);
node_model.updateOne(conditions，updateStr,function(err,res){
if(err){
callback(err);
}else{
callback(null,res);
}
});
};
以上就是本次介绍的全部相关知识点，感谢大家的学习。如果有任何补充，可以联系小编。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。