0.目标

本文主要介绍了在Node.js中使用Express+Mongoose对MongoDB进行操作的一些方法。

欢迎阅读MongoDB相关文章：

MongoDB基础0——MongoDB的安装与可视化管理工具
MongoDB基础1——数据库基本操作
MongoDB基础2——Mongoose的操作指南
MongoDB基础3——Mongoose的数据交互问题
MongoDB基础X——踩过的坑以及解决方案（持续更新中）

---

1.连接数据库

/* ******* config/mongodb.js文件 ******* */
var mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/backup');

exports.mongoose = mongoose;

上面代码连接了名为 backup 的数据库

---

2.建立Schema

在models目录下创建一个task.js文件

/* ******* models/tasks.js文件 ******* */
var mongodb = require('./../config/mongodb');
var Schema = mongodb.mongoose.Schema;
var taskScheMa = new Schema({
 name  : String,
 brief : String, 
 level : String,
 type  : String,
 id    : String, 
 date  : Date,
 logs  : [],
});

这里创建了一个Schema，用于建立对数据库某一个集合操作的模型。
要注意的是，到这一步，还没有把Schema关联到数据库的集合，还需要执行下面代码：

var Task = mongodb.mongoose.model('tasks', taskScheMa); //  与tasks集合关联

接下来，我们需要提供一些接口给外部调用，如查询数据、更新数据、删除数据。基本的框架如下：

var TaskDAO = function(){};

// 提供的外部接口
// ...
/* 例如： 
TaskDAO.prototype.example = function(input, callback) {
  // ...
};
*/

// Export
module.exports = new TaskDAO();

下面，我将对CURD操作数据库的方法进行简单的说明。

---

3.基本查询

3.1——findOne 和 find

使用 findOne 查询，返回单个文档。如果不要求仅返回一个文档，可使用 find 方法

/* Read */
TaskDAO.prototype.getByName = function(name, callback) {
  Task.findOne({name:name}, function(err, obj){
    callback(err, obj);
  });
};

上面代码意思是返回name字段为传入的参数name的值的文档。如果还要增加条件，如id为0，则可写作：

/* Read */
TaskDAO.prototype.getByName = function(name, callback) {
  Task.findOne({name:name, id:0}, function(err, obj){
    callback(err, obj);
  });
};

---

3.2 基本查询2——限制查询结果

在上面定义的Schema中，如果不希望返回logs，则可增加一个限制条件 {"logs":0}，具体代码如下：

TaskDAO.prototype.getByUser_Reduced = function(user, callback) {
  Task.find({releaser:user}, {"logs":0}, function(err, obj){
    callback(err, obj);
  });
};

如果需要限制返回结果的长度（如仅返回5个文档），则可加入限制条件 {limit: 5}，具体代码如下：

TaskDAO.prototype.getByUser_Reduced = function(user, callback) {
  Task.find({releaser:user}, {"logs":0}, {limit: 5}, function(err, obj){
    callback(err, obj);
  });
};

---

3.2 基本查询3——OR查询

如果我们要查找user为“用户1”或者type为“缺省”的文档，可以使用 $or ：

TaskDAO.prototype.getByUser = function(user, callback) {
  var query = { "$or" : [ {user: "用户1"}, {type: "缺省"} ] };
  Task.find(query, function(err, obj){
    callback(err, obj);
  });
};

---

4.插入文档

下面代码将task对象存入数据库。task对象的结构可以和Schema定义的不同，但存入数据库的内容只能是Schema定义了的结构。

TaskDAO.prototype.addFullTask = function(task, callback) {
  var instance = new Task(task);
  instance.save(function(err, obj){
    console.log(err);
    callback();
  });
};

---

5.更新文档

5.1 更新文档内容

使用 $set 修改前可设定一个字段的值，如果这个字段不存在，则创建这个字段。

/* Update */
TaskDAO.prototype.updateByName = function(name, obj, callback) {
  Task.update({name:name}, {$set:{level:obj.level, type:'更新操作'}}, function(err, obj){
    callback(err, obj);
  });
};

上面的代码执行后，会查找name字段为name的文档，并更新该文档的level字段和type字段。（注意，数据库中可以不必预先定义level或type字段，但Schema中必须有该字段，否则在数据库层面是不会对Schema中未定义的字段进行操作的）

5.2 更新文档嵌入内容

以上面定义的Schema为例，如果要将一个对象插入到logs数组中，可以这么写：

// Add to an array
TaskDAO.prototype.updateLogsByIndex = function(id, obj, callback) {
  Task.update({id:id}, {$addToSet:{logs:obj}}, function(err, obj){
    callback(err, obj);
  });
};

执行完上面代码后，会在id为id的文档中，在其logs字段里添加一个对象obj。

---

6.删除文档

使用 remove 来删除文档

/* Delete / remove */
TaskDAO.prototype.delByName = function(name, callback) {
  Task.remove({name:name}, function(err, obj){
    callback(err, obj);
  });
};

---

7.结束

本文介绍了一些基本的操作方法，主要参考了《MongoDB权威指南》以及mongoose相关资料。

---

更多权威资料，请参考下面网站：
http://www.nodeclass.com/api/mongoose.html#quick_start

---

原创文章，未经许可，请勿转载
作者：Mike的读书季
日期：2016.08.08
QQ：1139904786
Blog：http://blog.csdn.net/kkdestiny