這個DB類也算是我經歷了3個實際項目應用的，現分享出來，有需要的請借鑒批評。

上面的注釋都挺詳細的，我使用到了nodejs的插件mongoose，用mongoose操作mongodb其實蠻方便的。

關于mongoose的安裝就是 npm install -g mongoose

這個DB類的數據庫配置是基于auth認證的，如果您的數據庫沒有賬號與密碼則留空即可。

/** * mongoose操作類(封裝mongodb) */var fs = require('fs');var path = require('path');var mongoose = require('mongoose');var logger = require('pomelo-logger').getLogger('mongodb-log');var options = {  db_user: "game",  db_pwd: "12345678",  db_host: "192.168.2.20",  db_port: 27017,  db_name: "dbname"};var dbURL = "mongodb://" + options.db_user + ":" + options.db_pwd + "@" + options.db_host + ":" + options.db_port + "/" + options.db_name;mongoose.connect(dbURL);mongoose.connection.on('connected', function (err) {  if (err) logger.error('Database connection failure');});mongoose.connection.on('error', function (err) {  logger.error('Mongoose connected error ' + err);});mongoose.connection.on('disconnected', function () {  logger.error('Mongoose disconnected');});process.on('SIGINT', function () {  mongoose.connection.close(function () {    logger.info('Mongoose disconnected through app termination');    process.exit(0);  });});var DB = function () {  this.mongoClient = {};  var filename = path.join(path.dirname(__dirname).replace('app', ''), 'config/table.json');  this.tabConf = JSON.parse(fs.readFileSync(path.normalize(filename)));};/** * 初始化mongoose model * @param table_name 表名稱(集合名稱) */DB.prototype.getConnection = function (table_name) {  if (!table_name) return;  if (!this.tabConf[table_name]) {    logger.error('No table structure');    return false;  }  var client = this.mongoClient[table_name];  if (!client) {    //構建用戶信息表結構    var nodeSchema = new mongoose.Schema(this.tabConf[table_name]);    //構建model    client = mongoose.model(table_name, nodeSchema, table_name);    this.mongoClient[table_name] = client;  }  return client;};/** * 保存數據 * @param table_name 表名 * @param fields 表數據 * @param callback 回調方法 */DB.prototype.save = function (table_name, fields, callback) {  if (!fields) {    if (callback) callback({msg: 'Field is not allowed for null'});    return false;  }  var err_num = 0;  for (var i in fields) {    if (!this.tabConf[table_name][i]) err_num ++;  }  if (err_num > 0) {    if (callback) callback({msg: 'Wrong field name'});    return false;  }  var node_model = this.getConnection(table_name);  var mongooseEntity = new node_model(fields);  mongooseEntity.save(function (err, res) {    if (err) {      if (callback) callback(err);    } else {      if (callback) callback(null, res);    }  });};/** * 更新數據 * @param table_name 表名 * @param conditions 更新需要的條件 {_id: id, user_name: name} * @param update_fields 要更新的字段 {age: 21, sex: 1} * @param callback 回調方法 */DB.prototype.update = function (table_name, conditions, update_fields, callback) {  if (!update_fields || !conditions) {    if (callback) callback({msg: 'Parameter error'});    return;  }  var node_model = this.getConnection(table_name);  node_model.update(conditions, {$set: update_fields}, {multi: true, upsert: true}, function (err, res) {    if (err) {      if (callback) callback(err);    } else {      if (callback) callback(null, res);    }  });};/** * 更新數據方法(帶操作符的) * @param table_name 數據表名 * @param conditions 更新條件 {_id: id, user_name: name} * @param update_fields 更新的操作符 {$set: {id: 123}} * @param callback 回調方法 */DB.prototype.updateData = function (table_name, conditions, update_fields, callback) {  if (!update_fields || !conditions) {    if (callback) callback({msg: 'Parameter error'});    return;  }  var node_model = this.getConnection(table_name);  node_model.findOneAndUpdate(conditions, update_fields, {multi: true, upsert: true}, function (err, data) {    if (callback) callback(err, data);  });};/** * 刪除數據 * @param table_name 表名 * @param conditions 刪除需要的條件 {_id: id} * @param callback 回調方法 */DB.prototype.remove = function (table_name, conditions, callback) {  var node_model = this.getConnection(table_name);  node_model.remove(conditions, function (err, res) {    if (err) {      if (callback) callback(err);    } else {      if (callback) callback(null, res);    }  });};/** * 查詢數據 * @param table_name 表名 * @param conditions 查詢條件 * @param fields 待返回字段 * @param callback 回調方法 */DB.prototype.find = function (table_name, conditions, fields, callback) {  var node_model = this.getConnection(table_name);  node_model.find(conditions, fields || null, {}, function (err, res) {    if (err) {      callback(err);    } else {      callback(null, res);    }  });};/** * 查詢單條數據 * @param table_name 表名 * @param conditions 查詢條件 * @param callback 回調方法 */DB.prototype.findOne = function (table_name, conditions, callback) {  var node_model = this.getConnection(table_name);  node_model.findOne(conditions, function (err, res) {    if (err) {      callback(err);    } else {      callback(null, res);    }  });};/** * 根據_id查詢指定的數據 * @param table_name 表名 * @param _id 可以是字符串或 ObjectId 對象。 * @param callback 回調方法 */DB.prototype.findById = function (table_name, _id, callback) {  var node_model = this.getConnection(table_name);  node_model.findById(_id, function (err, res){    if (err) {      callback(err);    } else {      callback(null, res);    }  });};/** * 返回符合條件的文檔數 * @param table_name 表名 * @param conditions 查詢條件 * @param callback 回調方法 */DB.prototype.count = function (table_name, conditions, callback) {  var node_model = this.getConnection(table_name);  node_model.count(conditions, function (err, res) {    if (err) {      callback(err);    } else {      callback(null, res);    }  });};/** * 查詢符合條件的文檔并返回根據鍵分組的結果 * @param table_name 表名 * @param field 待返回的鍵值 * @param conditions 查詢條件 * @param callback 回調方法 */DB.prototype.distinct = function (table_name, field, conditions, callback) {  var node_model = this.getConnection(table_name);  node_model.distinct(field, conditions, function (err, res) {    if (err) {      callback(err);    } else {      callback(null, res);    }  });};/** * 連寫查詢 * @param table_name 表名 * @param conditions 查詢條件 {a:1, b:2} * @param options 選項：{fields: "a b c", sort: {time: -1}, limit: 10} * @param callback 回調方法 */DB.prototype.where = function (table_name, conditions, options, callback) {  var node_model = this.getConnection(table_name);  node_model.find(conditions)    .select(options.fields || '')    .sort(options.sort || {})    .limit(options.limit || {})    .exec(function (err, res) {      if (err) {        callback(err);      } else {        callback(null, res);      }    });};module.exports = new DB();