业务分层
service(多个模型)->dao单个模型->model 模型定义
service(多个模型)->dao单个模型->model (模型定义+扩展方法)
根据用户名查找用户文档
//this指向model
PersonSchema.statics.findByUsername = function (username, callback) {
return this.findOne({ username }, callback);
}
Person.findByUsername('zfpx', function (err, doc) {
console.log(doc);
});
PersonSchema.methods.exist = function (callback) {
let query = { username: this.username, password: this.password };
return this.model('Person').findOne(query, callback);
}
let person = new Person({ username: 'zfpx', password: '123456', phone: '010-6255889', firstname: 'first', lastname: 'last' });
person.exist(function (err, doc) {
console.log(err, doc);
});
模型属性 = Schema定义的属性+virtual属性
PersonSchema.virtual('area').get(function () {
//this指向实例
return this.phone.split('-')[0];
});
PersonSchema.virtual('number').get(function () {
return this.phone.split('-')[1];
});
let Person = conn.model('Person', PersonSchema);
let person = new Person({ username: 'zfpx', password: '123456', phone: '010-6255889', firstname: 'first', lastname: 'last' });
console.log(person.fullname, person.area, person.number);
在用户注册保存的时候,需要先把密码通过salt生成hash密码,并再次赋给password
PersonSchema.pre('save', function (next) {
this.password = crypto.createHmac('sha256', 'zfpx').update(this.password).digest('hex');
next();
});
PersonSchema.statics.login = function (username, password, callback) {
password = crypto.createHmac('sha256', 'zfpx').update(password).digest('hex');
return this.findOne({ username, password }, callback);
}
Person.login('zfpx', '123456', function (err, doc) {
console.log(err, doc);
});
Schemas是可插拔的,也就是说,它们提供在应用预先打包能力来扩展他们的功能。
module.exports = exports = function lastModified(schema,options){
schema.add({lastModify:Date});
schema.pre('save',function(next){
this.lastModify = new Date;
next();
});
if(options&& options.index){
schema.path('lastModify').index(options.index);
}
}
let plugin = require('./plugin');
let Person = new Schema({});
Person.plugin(plugin,{index:true});
schema.add({age:Number});
>db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)
现在我们通过以上集合计算每个作者所写的文章数,使用aggregate()计算结果如下:
> db.article.insert({uid:1,content:'1',visit:1});
> db.article.insert({uid:2,content:'2',visit:2});
> db.article.insert({uid:1,content:'3',visit:3});
db.article.aggregate([{$group:{_id:'$uid',total:{$sum:1}}}]);
{ "_id" : 2, "total" : 1 }
{ "_id" : 1, "total" : 2 }
`
select uid, count(*) total from article group by uid
表达式 | 描述 | 实例 |
---|---|---|
$sum | 计算总和。 | db.article.aggregate([{$group : {_id : "$uid", num_tutorial : {$sum : "$visit"}}}]) |
$avg | 计算平均值 | db.article.aggregate([{$group : {_id : "$uid", num_tutorial : {$avg : "$visit"}}}]) |
$min | 获取集合中所有文档对应值得最小值。 | db.article.aggregate([{$group : {_id : "$uid", num_tutorial : {$min : "$visit"}}}]) |
$max | 获取集合中所有文档对应值得最大值。 | db.article.aggregate([{$group : {_id : "$uid", num_tutorial : {$max : "$visit"}}}]) |
$push | 把某列的所有值都放到一个数组中 | db.article.aggregate([{$group : {_id : "$uid", url : {$push: "$url"}}}]) |
$addToSet | 返回一组文档中所有文档所选字段的全部唯一值的数组 | db.article.aggregate([{$group : {_id : "$uid", url : {$addToSet : "$url"}}}]) |
$first | 根据资源文档的排序获取第一个文档数据,可能为null | db.article.aggregate([{$group : {_id : "$uid", first_url : {$first : "$url"}}}]) |
$last | 根据资源文档的排序获取最后一个文档数据,可能为null | db.article.aggregate([{$group : {_id : "$uid", last_url : {$last : "$url"}}}]) |
db.article.insert({uid:1,content:'3',url:'url1'});
db.article.insert({uid:1,content:'4',url:'url1'});
db.article.insert({uid:1,content:'5',url:'url2'});
把某列的所有值都放到一个数组中
db.article.aggregate([{$group : {_id : "$uid", url : {$push: "$url"}}}])
{ "_id" : 1, "url" : [ "url1", "url1", "url2"] }
管道在Unix和Linux中一般用于将当前命令的输出结果作为下一个命令的参数。 MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。管道操作是可以重复的。
db.article.aggregate(
{ $project : {
_id:0,
content : 1 ,
}}
);
db.article.aggregate( [
{ $match : { visit : { $gt : 10, $lte : 200 } } },
{ $group: { _id: '$uid', count: { $sum: 1 } } }
]);
`
js
var db = connect('school');
var vistors = [];
for(var i=1;i<=20;i++){
vistors.push({uid:i,visit:i});
}
print(vistors.length);
db.vistors.insert(vistors);db.vistors.aggregate( [ { $match : { visit : { $gt : 10, $lte : 200 } } }, { $group: { _id: '$uid', count: { $sum: 1 } } }, { $skip : 1 } ] );
#### 7.4.5 $unwind
- 将文档中的某一个数组类型字段拆分成多条,每条包含数组中的一个值。
- 使用$unwind可以将weekday中的每个数据都被分解成一个文档,并且除了weekday的值不同外,其他的值都是相同的
```js
db.vistors.aggregate( [
{ $project : {_id:1,uid:1,type:1,visit:1}},
{ $match : { visit : { $gte : 1, $lte : 10 } } },
{ $unwind:'$type'}
]);
db.vistors.aggregate( [
{ $project : {_id:1,uid:1,type:1,visit:1}},
{ $match : { visit : { $gte : 1, $lte : 10 } } },
{ $unwind:'$type'},
{ $group: { _id: '$uid', count: { $sum: 1 } } },
{ $sort: {_id:1} },
{ $skip : 5 },
{ $limit: 5 }
]);
Article.aggregate([
{ $match : { visit : { $gt : 10, $lte : 200 } } },
{ $group: { _id: '$uid', count: { $sum: 1 } } },
{ $skip : 1 }
])
.