nodejs对mongodb数据库的增加修删该查实例代码

前端  /  管理员 发布于 4年前   291

以下是实例代码：

/**1.npm install mongodb --save-dev / cnpm install mongodb --save-dev2.var MongoClient = require('mongodb').MongoClient; var url = '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){  })}); */var http=require('http');var ejs=require('ejs');var MongoClient = require('mongodb').MongoClient; /*引入数据库 MongoClient*/var DBurl = 'mongodb://localhost:27017/userDb'; // 连接数据库的地址  student表示数据库的名称var url=require('url'); /*引入url模块*/var app=require('./model/express-route.js');http.createServer(app).listen(3000);app.get('/',function(req,res){  var msg='这是数据库的数据'  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));  var query=url.parse(req.url,true).query;  //console.log(query.name);  var name=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;    }    //查询数据    var list=[]; /*放数据库里面查询的所有数据*/    var result=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);  })})

插入数据

/** * 插入单条数据 * @param table_name 表名 * @param insertData 插入的数据 * @param callback 回调方法 */MongoDbAction.insertData= function (table_name, insertData , callback) {  var node_model = this.getConnection(table_name);  node_model.insertOne(insertData , function (err, res) {    if (err) {      callback(err);    } else {      callback(null, res);    }  });};

查询数据

/** * 查询单条数据 * @param table_name 表名 * @param conditions 查询条件 * @param callback 回调方法 */MongoDbAction.findOne = function (table_name, conditions, callback) {  var node_model = this.getConnection(table_name);  node_model.findOne(conditions, function (err, res) {    if (err) {      callback(err);    } else {      callback(null, res);    }  });};

更新数据

/** * 更新单条数据 * @param table_name 表名 * @param conditions 查询条件 {"name":'jackson影琪'};  * @param updateStr 更新数据 {$set: { "url" : "https://www.cnblogs.com/jackson-zhangjiang" }}; * @param callback 回调方法 */MongoDbAction.updateOne= function (table_name, conditions，updateStr , callback) {  var node_model = this.getConnection(table_name);  node_model.updateOne(conditions，updateStr, function (err, res) {    if (err) {      callback(err);    } else {      callback(null, res);    }  });};

以上就是本次介绍的全部相关知识点，感谢大家的学习。如果有任何补充，可以联系小编。

您可能感兴趣的文章:

• MongoDB 数据库的命名、设计规范详解
• 28个MongoDB经典面试题详解
• MongoDB常用数据库命令大全
• 修复 Mac brew 安装 mongodb 报 Error: No available formula with the name ‘mongodb’ 问题详解
• MongoDB启动报错 28663 Cannot start server
• Node.js操作MongoDB数据库实例分析
• MongoDB数据库安装配置、基本操作实例详解
• Windows10安装MongoDB4.0详细步骤及启动配置教程
• mongodb基本命令实例小结
• Win10 64位安装MongoDB数据库的详细教程
• linux下安装mongodb教程
• Python操作redis和mongoDB的方法
• dotnet core链接mongodb代码实例
• Zabbix3.4监控mongodb数据库状态的方法
• Windows安装压缩版MongoDB的教程
• 在Laravel中使用MongoDB的方法示例
• 关于MongoDB谨防索引seek的效率问题详析
• MongoDB中数据的替换方法实现类Replace()函数功能详解