首页 > MongoDB操作的模块手动封装

MongoDB操作的模块手动封装

MongoDB操作的模块手动封装

在nodejs目录下创建一个模块文件*.js,以便调用,以下是模块代码:
function MongoDBModel(dbname,dataform) {
  var MongoClient;
  var DB_CONN_STR;
  this.init = function() {
      MongoClient = require('MongoDB').MongoClient;
      DB_CONN_STR = 'MongoDB://localhost:27017/' + dbname;
  }
  /*这里是插入数据*/
  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);
      })
    })
  }
  /*这里是删除数据*/
  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;

如何使用:
在同目录下创建一个调用文件*.js
var MongoDBModel = require('./MongoDBModel');
var MongoDBObject = new MongoDBModel('seraph','singer');
MongoDBObject.init();
/*这里是插入*/
MongoDBObject.insert({name:'啊xx'},function(err,data){
  if(err){
    console.log(err);
  }else{
    console.log(data);
  }
})
/*这是删除*/
MongoDBObject.remove({name:'啊xiao'},function(err,data){
  if(err){
    console.log(err);
  }else{
    console.log('成功删除指定数据');
  }
})
/*这里是修改*/
MongoDBObject.update({name:'小李'},{$set:{name:'小勇'}},function(err,data){
  if(err){
    console.log(err);
  }else{
    console.log(data);
  }
})
/*这里是条件查询*/
MongoDBObject.find({name:'李洛克'},function(err,data){
  if(err){
    console.log(err);
  }else{
    console.log(data);
  }
})

相关参数:
dbname:是指要操作的database;
dataform:是指要操作的数据表;
data:表示需要插入或者查询或者修改的数据;
updata:表示修改后的数据;

注意:这些代码都是基于nodejs进行的。

MongoDB推荐
MongoDB常用的身份验证方式
MongoDB查询操作的实例详解
详解MongoDB数据库基础操作及实例
MongoDB操作的模块手动封装