mongodb의 DAO 계층 패키지

//       ；     ，  ，       
module.exports={
    "dburl":'mongodb://localhost:27017/luntan'
}

//          ，        ，  ，                 
var MongoClient=require('mongodb').MongoClient;
var settings=require('../setting');
//     
function _connectDB(callback) {
    var url=settings.dburl;// settings         ；
    MongoClient.connect(url,function (err,db) {
        console.log('     ');
        if(err){
            callback(err,null);
            return;
        }
        callback(err,db);
    })
}

//init         ；
init();
function init() {
    _connectDB(function (err,db) {
        if(err){
            console.log(err);
            return;
        }
        db.collection('users').createIndex(
            {"username":1},
            null,
            function (err,results) {
                if(err){
                    console.log(err);
                    return;
                }
                console.log('      ')
            }
        )
    })
}

//    
exports.insertOne=function (collectionName,json,callback) {
    _connectDB(function (err,db) {
        //          ；
        db.collection(collectionName).insertOne(json,function (err,result) {//       ，         
            callback(err,result);
            db.close();
        })
    })
};

//    ,         
//args   ：1）   2）  
exports.find=function (collectionName,json,args,callback) {
    if(arguments.length==3){
        callback=args;
        args={"page":0,"pageamount":0}
    }
    var result=[];//    ；
    var skip=args.page*args.pageamount;//   
    var limit=Number(args.pageamount);//     
    var sort=args.sort||{};
    _connectDB(function (err,db) {
        var cursor=db.collection(collectionName).find(json).limit(limit).skip(skip).sort(sort);
        cursor.each(function (err,doc) {
            if(err){
                callback(err,null);
                return;
            }
            if(doc != null){
                result.push(doc);
            }else{
                //    ，        
                callback(null,result);
                db.close();
            }
        })
    })
};

//    
exports.deleteMany=function (collectionName,json,callback) {
    _connectDB(function (err,db) {
        db.collection(collectionName).deleteMany(json,function (err,results) {
            callback(err,results);
            db.close();
        })
    })
};

//    ；json2       
exports.updateMany=function (collectionName,json1,json2,callback) {
    _connectDB(function (err,db) {
        db.collection(collectionName).updateMany(json1,json2,function (err,results) {
            callback(err,results);
            db.close();
        })
    })
};

//     
exports.getAllCount=function (collectionName,callback) {
    _connectDB(function (err,db) {
        db.collection(collectionName).count({}).then(function (count) {
            callback(count);
            db.close();
        })

    })
}