myExpressModel
1. 安装
npm install --save my-express-model
2.使用：
在express项目的根目录下添加model文件夹，并添加一个所有数据表的父类，并在父类设置数据库配置。
通常做法是添加一个名为BaseModel.js文件，然后文件中声明一个类，代码如下
var Model = require("my-express-model");
var databaseConfig = require("../config/databaseConfig");
class BaseModel extends Model{
constructor(){
super(databaseConfig);
}
static instance: BaseModel ; // typescript 类静态属性，es6/7 无此语法。可以写成BaseModel.instacne
static getInstance() {
if (this.instance === undefined) {
this.instance = new this();
}
return this.instance;
}
}
// 使用连接池长连接模式，创建持久复用的连接池
if(databaseConfig.connectType === "pool"){
BaseModel.createPool(databaseConfig);
}
module.exports = BaseModel;
配置
在a步骤require进来的config文件里面配置数据库的端等参数：
module.exports = {
engin : "mysql",//开发中使用的数据库引擎，如果要更换数据库，修改配置即可(让然目前只提供mysql数据库)
host : 'localhost',
user : 'root',
password : 'password',
databaseName : 'databaseName',
connectType : "pool" //连接类型,连接池最大请求数默认 为100个。需要自定义，可以通过limit 配置项修改
}
在models层下面建立Model类，继承BaseModel,设置fields和该Model在数据库中对应的table名称，例如：
var BaseModel = require("./BaseModel");
class CategoryModel extends BaseModel{
id : number
name : string
avatar : string
static tableName: string = "FbUser"
static fields: Object = {
id: {
type: 'integer',
pk : true, // primary key 主键，当不设置任何条件的时候则按主键的值进行更新
generated : true, // 自增字段，插入时跳过该字段
validator: ['presence']
},
name: {
type: 'string',
validator: ['presence']
},
avatar: {
type: 'string',
validator: ['presence']
}
}
constructor(options){
super(options);
}
};
module.exports = CategoryModel;
创建连接
在配置文件中，可以配置连接的方式：连接池和普通连接。
连接方式
1）连接池：长连接的方式。 connectType : "pool" //连接类型 2）普通连接：建议短连接的方式。 connectType : "connection" //连接类型。
创建连接-->连接池
在上述BaseModel 的例子中，统一创建了连接池。在后续的数据库操作的API中，会有限判断参数列表的connection 是否可用 如果不可用，并且pool 不为空，会自动创建。
if(databaseConfig.connectType === "pool"){
BaseModel.createPool(databaseConfig);
}
创建连接-->短连接
遵循一次请求一个连接的方式：
import Model from xxxx;
(req,res) = >{
let connection = Model.createConnection();
try{
await connection.connect();
}catch(e){}
// Promise 的异步操作可以通过catch 来捕获，async await 只能通过try catch 来捕获
const insertOp = Model.getOperateObj("insert",connection);
//todo
connection.release();
}
在controller中使用Model
获取操作数据库的对象 getOperateObj(type,connection?)
每个数据表类，继承Model之后，就继承了getOperateObj 的请求方法。 该方法提供了增删改查四个操作对象的获取。
参数 type
type 包括： 1）insert 增 2) update 改 3) delete 删 4) query 查
参数 connection
使用短连接的方式，需要传递connection 参数，使用连接池的方式，在connection 为空的时候，会使用连接池获取一个可用连接。
使用案例
1）使用连接池的方式： let insertOp = await Model.getOperateObj("insert"); 2）使用短简介方式
let connection = Model.createConnection();
await connection.connect();
let insertOp = await Model.getOperateObj("insert",connection);
connection.end();
添加记录
1.新增一条纪录：
1.1 save(connection?,callback?);
使用连接池的方式，不需要传递connection. save 返回值是一个Promise对象，也支持回调函数的方式调用。 当Model 对象执行save操作的时候，会判断是id属性是否为空或者该id在数据库是否已经存在。 满足两个否条件，则执行插入操作，否则执行更新操作
var CategoryModel = require("../../models/Category");
var categoryModel = new CategoryModel();
categoryModel.set("id",0);
categoryModel.set("name","JiangquanWu");
categoryModel.set("time",new Date());
categoryModel.save(function(err,result){
//to do
}).then(({errmsg,result})=>{
});
1.2 insertRecord(record,connection?);
使用连接池的方式，则不需要connection。否则需要传递connection.并且在响应用户请求之前结束连接。
var CategoryModel = require("../../models/Category");
CategoryModel.insertRecord({
id : 0,
name : "JiangquanWu",
time : new Date()
})
.then(({errmsg,result})=>{
})
2. 通过insert对象批量新增 insertOp.batchInsert(records,callback?)
2.1 参数records
records 是要批量插入的对象
2.2 返回值
返回提供了Promise 和 回调函数两种方式。 callback(errmsg,result); resolve({errmsg,result});
2.3 调用案例
var insertOp = CategoryModel.getOperateObj("insert",connection);//连接池模式不需要connection 参数
insertOp.batchInsert(categories,function(err,result){
//to do
});
修改纪录:
1. 跟新增纪录一样，修改一条记录。
使用方式参考上面的save操作，区别在于，当前Model 的实例的主健是否为空。
2. 通过update对象根据条件更新 updateRecord(record,callback?)
2.1 参数records
records 需要更新的对象
2.2 返回值
返回提供了Promise 和 回调函数两种方式。 callback(errmsg,result); resolve({errmsg,result});
2.3 调用案例
//修改所有品类名称为“衣服”的时间
var categoryModel = new CategoryModel();
categoryModel.set("time",new Date());
var updateOp = CategoryModel.getOperateObj("update",connection?);//连接池的方式不需要传递conection
updateOp.equalTo("name","衣服");
updateOp.updateRecord(categoryModel,function(err,result){
//to do
});
3. 批量更新多条记录，batchUpdateById(records,callback?)
3.1 参数records
records 需要更新的对象
3.2 返回值
返回提供了Promise 和 回调函数两种方式。 callback(errmsg,result); resolve({errmsg,result});
3.3 调用案例
var categoryModel = new CategoryModel();
var updateOp = categoryModel.getOperateObj("update",connection?);//连接池的方式不需要传递conection
//@parameter categories 是一个categoryModel数组，所有categoryModel都必须有id属性；
updateOp.batchUpdateById(categories,function(err,result){
//to do
});
查找：
1. 通过model对象简单的查找，Model.get(connection?,callback?);
1.1 参数connection
使用连接池的时候不需要传递这个参数，否则需要。
1.2 参数callback
回调函数，也可以使用Promise 的异步处理方式处理回调
1.3 案例
比如查找id等于1的品类：
CategoryModel.get("id=1",callback);
//CategoryModel.get(callback);则返回所有记录
2. 通过model对象获取所有的记录 getAll(connection?,callback?)
方法1如果只传入一个回调函数作为参数，也可以获取所有记录
2.1 参数connection
使用连接池的时候不需要传递这个参数，否则需要。
2.2 参数callback
回调函数，也可以使用Promise 的异步处理方式处理回调
2.3 案例
CategoryModel.getAll(callback);
3. 复杂的条件查询，Model.getOperateObj("query",connection?)
3.1 参数type
在前面介绍过getOperateObj的使用，查找类的type 为 “query”
3.2 参数connection
使用连接池的时候不需要传递这个参数，否则需要。
3.3 查询条件的设置
可以通过下面的条件设置罗列的API设置条件。 这个例子中使用了limit、skip、descending、notMoreThan 等API
3.4 案例
var queryObj = CategoryModel.getOperateObj("query");
queryObj.limit(pageSize);//分页；
queryObj.skip((pageNumber-1)*pageSize);//跳过前几条；
queryObj.descending("time");//根据时间降序；
queryObj.notMoreThan("time",time);//查找所有time时间点之前添加的品类
queryObj.find(callback);
4. 连接查询
通过model对象的 opSqlSetament 方法进行
var sql = "连接查询语句";
CategoryModel.opSqlSetament(sql,callback);
删除:
1. 通过model对象简单地根据id条件删除，Model.deleteByIds(id,connection?,callback?)
1.1 参数id
需要删除的ID
1.2 参数connection
使用连接池的时候不需要传递这个参数，否则需要。
1.3 参数callback
回调函数，也可以使用Promise 的异步处理方式处理回调
1.4 案例
CategoryModel.deleteByIds(1,callback);
//CategoryModel.deleteByIds([1,2,3,4,5,6,7,8],callback);
2. 通过delete对象执行复杂的条件判断删除，delete(connection?,callback?)
Model.getOperateObj("delete",conection?);
2.1 参数connection
使用连接池的时候不需要传递这个参数，否则需要。
2.2 参数callback
回调函数，也可以使用Promise 的异步处理方式处理回调
2.3 案例
var deleteOp = CategoryModel.getOperateObj("delete");
deleteOp.equalTo("name",'衣服');//更多的条件设置方法请看后面文档;
deleteOp.delete(cllback);
3. 通过delete对象 批量删除所有ID deleteInBatchByIds(ids,connection?,callback?)
3.1 参数ids
需要删除的ID
3.2 参数connection
使用连接池的时候不需要传递这个参数，否则需要。
3.3 参数callback
回调函数，也可以使用Promise 的异步处理方式处理回调
3.4 案例
var deleteOp = CategoryModel.getOperateObj("delete");
deleteOp.deleteInBatchByIds([1,2,3],callback);
条件设置
上面的删查改都可能要设置复杂的条件，通过model对象的getOperateObj方法获取的数据库操作对象可以执行的设置复杂条件的方法
说明：每个方法最后都有一个logic参数，是用来设置数据库语句中条件之间的与或逻辑的.如果是或，参数值设置"or"。如果是与，参数值为"and"。缺省值为and.
equalTo(fieldName,value,logic)
参数1.是字段名，参数2是 字段值。字段名等于某值
notEqualTo(fieldName,value,logic)
参数1.是字段名，参数2是 字段值。字段名不等于某值
lessThan(fieldName,value,logic)
参数1.是字段名，参数2是 字段值。字段名小于某值
moreThan(fieldName,value,logic)
参数1.是字段名，参数2是 字段值。字段名大于某值
notLessThan(fieldName,value,logic)
参数1.是字段名，参数2是 字段值。字段名大于等于某值
notMoreThan(fieldName,value,logic)
参数1.是字段名，参数2是 字段值。字段名小于等于某值
between(fieldName,startValue,endvalue,logic)
参数1是字段名，参数2和参数3是字段值的开区间(不包含开始值和结束值)，
like(fieldName,charList)
模糊查询。参数1字段名，参数2.模糊值
likeStartAs(fieldName,charList)
以某值开头的模糊查询。参数1字段名，参数2.模糊值
likeEndWidth(fieldName,charList);
以某值结束的模糊查询。参数1字段名，参数2.模糊值
in(fieldName,valueArray,logic)
查找某只段在valueArray数组的所有记录.参数1字段名，参数2.字段的值数组
查找操作还有下面这些特殊的条件设置方法：
skip(count); 跳过前count条查询，参数count是跳过条数的数值
limit(count);
限制查询的条数， 参数count是查询条数的数值
ascending(fieldName);
查询结果根据某字段升序排列. 参数fieldName是字段名
descending(fieldName);
查询结果根据某字段降序排列。参数fieldName是字段名