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(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。