MongoDB

think.model.mongo 继承类 think.model.base。

使用 ES6 的语法继承该类

export default class extends think.model.mongo {
  getList(){

  }
}

使用普通方式继承该类

module.exports = think.model('mongo', {
  getList: function(){

  }
})

属性

model.fields

设置字段，如：

export default class extends think.model.mongo {
  init(...args){
    super.init(...args);
    //设置字段
    this.fields = {
      name: {
        type: 'string'
      },
      pwd: {
        type: 'string'
      }
    }
  }
}

注：目前框架并不会对字段进行检查。

model.indexes

设置字段索引，数据操作之前会自动创建索引。

export default class extends think.model.mongo {
  init(...args){
    super.init(...args);
    //配置索引
    this.indexes = { 

    }
  }
}

单字段索引

export default class extends think.model.mongo {
  init(...args){
    super.init(...args);
    //配置索引
    this.indexes = { 
      name: 1
    }
  }
}

唯一索引

通过 $unique 来指定为唯一索引，如：

export default class extends think.model.mongo {
  init(...args){
    super.init(...args);
    //配置索引
    this.indexes = { 
      name: {$unique: 1}
    }
  }
}

多字段索引

可以将多个字段联合索引，如：

export default class extends think.model.mongo {
  init(...args){
    super.init(...args);
    //配置索引
    this.indexes = { 
      email: 1
      test: {
        name: 1,
        title: 1,
        $unique: 1
      }
    }
  }
}

model.pk

主键名，默认为 _id，可以通过 this.getPk 方法获取。

方法

model.where(where)

mongo 模型中的 where 条件设置和关系数据库中不太一样。

等于判断

export default class extends think.model.mongo {
  where1(){
    return this.where({ type: "snacks" }).select();
  }
}

AND 条件

export default class extends think.model.mongo {
  where1(){
    return this.where({ type: 'food', price: { $lt: 9.95 } }).select();
  }
}

OR 条件

export default class extends think.model.mongo {
  where1(){
    return this.where({
     $or: [ { qty: { $gt: 100 } }, { price: { $lt: 9.95 } } ]
    }).select();
  }
  where2(){
    return this.where({
     type: 'food',
     $or: [ { qty: { $gt: 100 } }, { price: { $lt: 9.95 } } ]
   }).select();
  }
}

内嵌文档

export default class extends think.model.mongo {
  where1(){
    return this.where( {
      producer:
        {
          company: 'ABC123',
          address: '123 Street'
        }
    }).select();
  }
  where2(){
    return this.where({ 'producer.company': 'ABC123' } ).select();
  }
}

IN 条件

export default class extends think.model.mongo {
  where1(){
    return this.where({ type: { $in: [ 'food', 'snacks' ] } }).select();
  }
}

更多文档请见 https://docs.mongodb.org/manual/reference/operator/query/#query-selectors。

model.collection()

• return {Promise}

获取操作当前表的句柄。

export default class extends think.model.mongo {
  async getIndexes(){
    let collection = await this.collection();
    return collection.indexes();
  }
}

model.aggregate(options)

聚合查询。具体请见 https://docs.mongodb.org/manual/core/aggregation-introduction/。

model.mapReduce(map, reduce, out)

mapReduce 操作，具体请见 https://docs.mongodb.org/manual/core/map-reduce/。

model.createIndex(indexes, options)

• indexes {Object} 索引配置
• options {Object}

创建索引。

model.getIndexes()

• return {Promise}

获取索引。