1. 程式人生 > >自己封裝的mongodb操作的模組

自己封裝的mongodb操作的模組

[注]:這些程式碼都是基於nodejs進行的.
在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:表示修改後的資料;

個人在封裝的時候,callback()是個難點