mongoose 中间件常用CRUD
安装mongoose
npm install mongoose --save
导入中间件
var express = require('express');
var router = express.Router();
var mongoose = require('mongoose');
链接数据库
var db = mongoose.createConnection('localhost','lwtTest');
定义Schema，也就是传统意义的表结构
var personSchema = new mongoose.Schema({
_name:String, //定义一个属性name，类型为String
_phone:Number
});
定义Model
var personModel = db.model('lwtArr',personSchema);
常用操作 CRUD
测试数据
var obj = {
_name:'lwt',
_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');
}
});
注意:
删除条件一定是唯一的,不然就清库啦
