mongoDB & Nodejs 访问mongoDB (二)

zzl001

/*　　* @Author: Administrator
　　* @Date:   2017-03-13 17:14:40
　　* @Last Modified by:   Administrator
　　* @Last Modified time: 2017-03-13 20:24:23
　　*/
　　'use strict';
　　const mongoClient = require("mongodb").MongoClient,
　　dburl = require("config").dburl;
　　// 连接数据库,内部函数
　　function _connectDB(callback) {
　　mongoClient.connect(dburl, function(err, db) {
　　if (err) {
　　console.log(err);
　　return;
　　}
　　callback(err, db);
　　}
　　})
　　}
　　exports.find = function(collectionName, json, pageOption, callback) {
　　// 第 0 页,就跳过 0 条,第 1 页,跳过10条 ,取 10条
　　// skip & limit ,如果参数为0,那么就忽略参数
　　var skipNumber = pageOption.page * pageOption.count || 0,
　　takeNumber = pageOption || 0,
　　sort = pageOption.sort || {};
　　_connectDB(function(err, db) {
　　db.collection(collectionName).find(json).skip(skipNumber).limit(takeNumber).sort(sort) toArray(function(err, docs) {
　　callback(err, docs);
　　db.close();
　　});
　　})
　　};
　　exports.insertOne = function(collectionName, json, callback) {
　　_connectDB(function(err, db) {
　　db.insertOne(collectionName).insertOne(function(err, res) {
　　callback(err, res);
　　db.close();
　　})
　　})
　　}
　　exports.insertMany = function(collectionName, json, callback) {
　　_connectDB(function(err, db) {
　　db.insertOne(collectionName).insertMany(function(err, res) {
　　callback(err, res);
　　db.close();
　　})
　　})
　　}
　　exports.deteleOne = function(collectionName, json, callback) {
　　_connectDB(function(err, db) {
　　db.collection(collectionName).deteleOne(json, function(err, res) {
　　callback(err, res);
　　db.close();
　　})
　　})
　　};
　　exports.deteleMany = function(collectionName, json, callback) {
　　_connectDB(function(err, db) {
　　db.collection(collectionName).deteleMany(json, function(err, res) {
　　callback(err, res);
　　db.close();
　　})
　　})
　　};
　　exports.updateOne = function(collectionName, jsonQeury, jsonSet, callback) {
　　_connectDB(function(err, db) {
　　db.collection(collectionName).updateOne(jsonQeury, { $set: jsonSet }, function(err, res) {
　　callback(err, res);
　　db.close();
　　})
　　})
　　};
　　exports.updateMany = function(collectionName, jsonQeury, jsonSet, callback) {
　　_connectDB(function(err, db) {
　　db.collection(collectionName).updateMany(jsonQeury, { $set: jsonSet }, function(err, res) {
　　callback(err, res);
　　db.close();
　　})
　　})
　　};
　　exports.getAllCount = function(collectionName, json, callback) {
　　_connectDB(function(err, db) {
　　db.collection(collectionName).count(json, function(err, count) {
　　callback(err, count);
　　db.close();
　　})
　　})
　　};