node.js零基础详细教程：node.js操作mongodb，及操作方法的封装

 1 var mongo = require("mongodb"); //引入mongodb模块
 2 var assert = require("assert"); //引入断言模块
 3 
 4 var MongoClient = mongo.MongoClient;  //开启服务
 5 
 6 var Urls = "mongodb://localhost:27017/demo2";  //url储存  放在连接池中。
 7 
 8 MongoClient.connect(Urls,function(err,db){  //获取连接
 9     assert.equal(null,err);  //使用断言模块代替以前的 if判断
10     
11 
12     //插入数据
13     db.collection("t1").insert({"name":"xiaoming"},function(err,result){ //连接到数据库上面，并使用参数传入集合
14         assert.equal(null,err);
15         console.log(result);
16         db.close();
17     });
18 
19 
20 });

 1 var mongo = require("mongodb"); //引入mongodb模块
 2 var assert = require("assert"); //引入断言模块
 3 
 4 var MongoClient = mongo.MongoClient;  //开启服务
 5 
 6 var Urls = "mongodb://localhost:27017/demo2";  //url储存  放在连接池中。
 7 
 8 MongoClient.connect(Urls,function(err,db){  //获取连接
 9     assert.equal(null,err);  //使用断言模块代替以前的 if判断
10     
11 
12     //查找数据
13     db.collection("t1").find({"name":"xiaoming"}).toArray(function(err,result){
14         assert.equal(null,err);
15         console.log(result);
16         db.close();
17     })
18 
19 
20 });

 1 var mongo = require("mongodb"); //引入mongodb模块
 2 var assert = require("assert"); //引入断言模块
 3 
 4 var MongoClient = mongo.MongoClient;  //开启服务
 5 
 6 var Urls = "mongodb://localhost:27017/demo2";  //url储存  放在连接池中。
 7 
 8 MongoClient.connect(Urls,function(err,db){  //获取连接
 9     assert.equal(null,err);  //使用断言模块代替以前的 if判断
10     
11     //删除数据
12     db.collection("t1").deleteOne({"name":"xiaoming"},function(err,result){ //连接到数据库上面，并使用参数传入集合
13         assert.equal(null,err);
14         console.log(result);
15         db.close();
16     });
17 
18 });

var mongo = require("mongodb"); //引入mongodb模块
var assert = require("assert"); //引入断言模块

var MongoClient = mongo.MongoClient;  //开启服务

var Urls = "mongodb://localhost:27017/demo2";  //url储存  放在连接池中。

MongoClient.connect(Urls,function(err,db){  //获取连接
    assert.equal(null,err);  //使用断言模块代替以前的 if判断
    
    //修改数据
    db.collection("t1").update({"name":"zhangsan1"},{$set:{"name":"xiaoming"}},function(err,result){ //连接到数据库上面，并使用参数传入集合
        assert.equal(null,err);
        console.log(result);
        db.close();
    });

});

var mongo=require("mongodb");//@2.2.11
var MongoClient = mongo.MongoClient;
var assert = require('assert');
var host="localhost";
var port="27017";
var Urls = 'mongodb://localhost:27017/demo2';


//add一条数据
var add = function(db,collections,selector,fn){
  var collection = db.collection(collections);
  collection.insertMany([selector],function(err,result){
    assert.equal(err,null);
    fn(result);
    db.close();
  });
}
//delete
var deletes = function(db,collections,selector,fn){
  var collection = db.collection(collections);
  collection.deleteOne(selector,function(err,result){
    try{assert.equal(err,null)}catch(e){
      console.log(e);
    }
    fn(result);
    db.close();
  });

};
//find
var find = function(db,collections,selector,fn){
  var collection = db.collection(collections);

    collection.find(selector).toArray(function(err,docs){

      try{
        assert.equal(err,null);
      }catch(e){
        console.log(e);
        docs = [];
      }

      fn(docs);
      db.close();
    });

}
//（权限控制） -- 暂时没有用
MongoClient.connect(Urls, function(err, db) {
  find(db,"powers",null,function(d){
    console.log("123s");
    console.log(d.length);
  });
});

//update
var updates = function(db,collections,selector,fn){
  var collection = db.collection(collections);
  console.log(selector);
  collection.updateOne(selector[0],selector[1],function(err,result){
    assert.equal(err,null);
    assert.equal(1,result.result.n);
    fn(result);
    db.close();
  });

}

//方法都赋值到操作对象上，便于调用
var methodType = {
  login:find,
  show:find,
  add:add,
  getpower:find,
  update:updates,
  delete:deletes,
  updatepass:updates,
  adduser:add,
  usershow:find,
  getcategory:find,
  getcourse:find,
  find:find,
  state:find,
  top:find,
  AddDirectory:find,
  updateDirectory:updates,
  deleteDirectory:deletes,
  showlist:find,
  showdir:find
};
//主逻辑
module.exports = function(req,res,collections,selector,fn){
  MongoClient.connect(Urls, function(err, db) {
    assert.equal(null, err);
    console.log("Connected correctly to server");
    methodType[req.query.action](db,collections,selector,fn);
    db.close();
  });

};