mongodb操作的模塊手動(dòng)封裝

[注]：這些代碼都是基于nodejs進(jìn)行的.

在nodejs目錄下創(chuàng)建一個(gè)模塊文件*.js，以便調(diào)用，

以下是模塊代碼：

function mongodbModel(dbname,dataform) {
  var MongoClient;
  var DB_CONN_STR;
  this.init = function() {
      MongoClient = require('mongodb').MongoClient;
      DB_CONN_STR = 'mongodb://localhost:27017/' + dbname;
  }
  /*這里是插入數(shù)據(jù)*/
  this.insert = function(data,callback) {
    MongoClient.connect(DB_CONN_STR, function(err, db) {
      console.log('連接成功')
      var collection = db.collection(dataform);
      collection.insert(data, function(err,result){
        callback(err,result);
      })
    })
  }
  /*這里是刪除數(shù)據(jù)*/
  this.remove = function(data,callback){
    MongoClient.connect(DB_CONN_STR, function(err, db) {
      console.log('連接成功')
      var collection = db.collection(dataform);
      collection.remove(data, function(err,result){
        callback(err,result);
      })
    })
  }
  /*這里是修改*/
  this.update=function(data,updata,callback){
    MongoClient.connect(DB_CONN_STR, function(err, db) {
      console.log('連接成功')
      var collection = db.collection(dataform);
      collection.update(data,updata,function(err,data){
        callback(err,data);
      })
    })
  }
  /*這里是查詢*/
  this.find=function(data,callback){
    MongoClient.connect(DB_CONN_STR, function(err, db) {
      console.log('連接成功')
      var collection = db.collection(dataform);
      collection.find(data).toArray(function(err,data){
        callback(err,data);
      })
    })
  }
}

module.exports = mongodbModel;