# 扩展mongoose模型

业务分层

service(多个模型)->dao单个模型->model 模型定义

service(多个模型)->dao单个模型->model (模型定义+扩展方法)

# 2. statics 对类进行扩展 [#](#t12. statics 对类进行扩展)

根据用户名查找用户文档

 //this指向model
PersonSchema.statics.findByUsername = function (username, callback) {
    return this.findOne({ username }, callback);
}
Person.findByUsername('zxmf', function (err, doc) {
    console.log(doc);
});

# 3. methods 对实例进行扩展 [#](#t23. methods 对实例进行扩展)

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: 'zxmf', password: '123456', phone: '010-6255889', firstname: 'first', lastname: 'last' });
person.exist(function (err, doc) {
    console.log(err, doc);
});

# 4. virutal虚拟属性 [#](#t34. virutal虚拟属性)

• virtual是虚拟属性的意思，即原来Schema定义里是不存在该属性，后来通过virutal方法赋予的属性。

• Schema中定义的属性是要保存到数据库里的，而virtual属性基于已有属性做的二次定义。

  模型属性 = 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: 'zxmf', password: '123456', phone: '010-6255889', firstname: 'first', lastname: 'last' });
  console.log(person.fullname, person.area, person.number);
  

# 5. hook [#](#t45. hook)

在用户注册保存的时候，需要先把密码通过salt生成hash密码，并再次赋给password

PersonSchema.pre('save', function (next) {
    this.password = crypto.createHmac('sha256', 'zxmf').update(this.password).digest('hex');
    next();
});

PersonSchema.statics.login = function (username, password, callback) {
    password = crypto.createHmac('sha256', 'zxmf').update(password).digest('hex');
    return this.findOne({ username, password }, callback);
}

Person.login('zxmf', '123456', function (err, doc) {
    console.log(err, doc);
});

# 6. schema 插件 [#](#t56. schema 插件)

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});

• Person 是用户自己定义的Schema

• Person.plugin 是为Person增加plugin

• plugin有2个参数

  • 插件对象 plugin
  • 配置项 {index:true}

  schema.add({age:Number});
  

# 7.MongoDB 聚合 [#](#t67.MongoDB 聚合)

MongoDB中聚合(aggregate)主要用于处理数据(诸如统计平均值,求和等)，并返回计算后的数据结果。有点类似sql语句中的 count(*)。 aggregate() 方法 MongoDB中聚合的方法使用aggregate()。

# 7.1 语法 [#](#t77.1 语法)

aggregate() 方法的基本语法格式如下所示：

>db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)

# 7.2 分组 [#](#t87.2 分组)

现在我们通过以上集合计算每个作者所写的文章数，使用aggregate()计算结果如下：

> db.article.insert({uid:1,content:'1'});
> db.article.insert({uid:2,content:'2'});
> db.article.insert({uid:1,content:'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

# 7.3 聚合的表达式 [#](#t97.3 聚合的表达式)

db.article.insert({uid:1,content:'3',url:'url1'});
db.article.aggregate([{$group : {_id : "$uid", url : {$push: "$url"}}}])

# 7.4 管道的概念 [#](#t107.4 管道的概念)

管道在Unix和Linux中一般用于将当前命令的输出结果作为下一个命令的参数。 MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。管道操作是可以重复的。

• $project：修改输入文档的结构。可以用来重命名、增加或删除域，也可以用于创建计算结果以及嵌套文档。
• $match：用于过滤数据，只输出符合条件的文档。$match使用MongoDB的标准查询操作。
• $limit：用来限制MongoDB聚合管道返回的文档数。
• $skip：在聚合管道中跳过指定数量的文档，并返回余下的文档。
• $unwind：将文档中的某一个数组类型字段拆分成多条，每条包含数组中的一个值。
• $group：将集合中的文档分组，可用于统计结果。
• $sort：将输入文档排序后输出。

# 7.4.1 过滤显示字段 [#](#t117.4.1 过滤显示字段)

db.article.aggregate(
    { $project : {
        _id:0,
        content : 1 ,
    }}
 );

# 7.4.2 过滤文档 [#](#t127.4.2 过滤文档)

db.article.aggregate( [
  { $match : { visit : { $gt : 10, $lte : 200 } } },
  { $group: { _id: '$uid', count: { $sum: 1 } } }
] );

# 7.4.3 跳过指定数量 [#](#t137.4.3 跳过指定数量)

db.article.aggregate( [
  { $match : { visit : { $gt : 10, $lte : 200 } } },
  { $group: { _id: '$uid', count: { $sum: 1 } } },
  { $skip : 1 }
] );

# 7.4.4 Mongoose中使用 [#](#t147.4.4 Mongoose中使用)

Article.aggregate([
  { $match : { visit : { $gt : 10, $lte : 200 } } },
  { $group: { _id: '$uid', count: { $sum: 1 } } },
  { $skip : 1 }
 ])
                .

• MongoDemo