安装 Mongoose

npm install mongoose --save  

导入中间件

var express = require('express');  
var router = express.Router();  
var mongoose = require('mongoose');  

链接数据库

var db = mongoose.createConnection('localhost', 'lyTest');  

定义 Schema, 也就是传统意义的表结构

var personSchema = new mongoose.Schema({  
    _name: String, //定义一个属性 name, 类型为 String
    _phone: Number
});

定义 Model

var personModel = db.model('luoyanArr', personSchema);  

常用操作 CRUD

测试数据

var obj = {  
    _name: 'luoyan',
    _phone: 111
}

添加数据

// 方法 1
var personEntity = new personModel(obj);

personEntity.save(function (err) {  
    if (err) {
      console.log('insert failed');
    } else {
      console.log('insert success');
    }
});

// 方法 2
personModel.create(obj, function (err) {  
    if (err) {
      console.log('insert failed');
    } else {
      console.log('insert success');
    }
});

注意: 在添加数据的时候, 如果不指定 id 属性, id 会默认为一个字符串对象.

区别: Entity 是 model 的对象, 用它来添加数据的时候会把隐藏属性一起存入数据库, 有几率报错 model 只能添加纯净的 json 对象, 不能添加它创建的实体.

修改操作

// 方法 1
personModel.update({_phone: 222}, {$set: {_name: '把222的都改了'}}, { multi: true}, function(err){  
    if (err) { // 错误
       console.log('update failed');
    } else { // 正确
       console.log('update success');
    }
});

// 方法 2
var id = "56fc1bbe7c2bce52c38fc5f8";  
personModel.findById(id, function(err, person){  
     if (err) {
        console.log('update failed');
     } else {
        person._name = 'from_id';
        person.save(function(err){ ... });
        console.log('update success');
     }
});

注意: 如果更新的数据比较少的话, 用方法一很方便的, 其中的 { multi: true } 表示同时更新所有数据, { multi: false } 或者省略则只跟新一条

查询数据

直接查询

personModel.findOne({'_phone': 111}, function (err, person) {  
    if (err) {
       console.log('select failed');
    } else {
       console.log( person );
    }
});

查询一条

var query = personModel.findOne({'_phone': 111});  
query.select();  
query.exec(function(err, person){  
     if (err) {
        console.log('select failed');
     } else {
        console.log(person);
     }
});

查询多条

var query = personModel.find({'_phone': 222});  
query.select();  
query.exec(function(err, person){  
     if (err) {
        console.log('select failed');
     } else {
        console.log(person);
     }
});

链式查询

personModel  
     .where('_phone')
     .where('_name').equals('aaa')
     .limit(2)
     .select()
     .exec(function (err, person) {
          if (err) {
              console.log('select failed');
          } else {
              console.log(person);
          }
     });

另外附详细链式查询表

personModel //model 对象  
     .find({ occupation: /host/ }) // 条件
     .where('name.last').equals('Ghost') //字段 = 值
     .where('age').gt(17).lt(66) // 范围
     .where('likes').in(['vaporizing', 'talking']) // 范围
     .limit(10) // 查几条
     .skip(20) // 跳过几条
     .asc('age') // 排序
     .sort('-occupation')
     .slaveOk()
     .hint({ age: 1, name: 1 })
     .select('name occupation') // 执行查询 () 中的值可以省略, 只是别名
     .exec(callback); // 回调函数, 处理查询结果

删除操作

var personEntity = new personModel();  
personModel.remove({_id:"56fc281ab64732d8c33b4db7"}, function (err) {  
     if (err) {
       console.log('delete failed');
     } else {
       console.log('detete success');
     }
});

注意: 删除条件一定是唯一的, 不然就清库了.

罗彦笔记连接