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

以下是实例代码：

/**
1.npm install mongodb --save-dev / cnpm install mongodb --save-dev
2.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;								 
 1/2    1 2 下一页 尾页