說起ORM,Object Relational Mapping蘸炸,有Hibernate躬络,JPA等成熟的Java框架。 Sequelize是JS端的hibernate搭儒,可以和十分著名的Express js server一起使用穷当,完成server端到數據庫的CRUD等等操作提茁。
Promise based, Sequelize和Hibernate最大的區(qū)別在于,它的調用基于bluebird的異步調用引擎馁菜,我們知道茴扁,在Javascript的世界里,很多調用是通過Callback函數來完成的而并非是順序執(zhí)行的火邓,使用Sequelize丹弱,我們也要注意這一點。
從模型說起
Promise要把Javascript Object轉換成數據庫的一行铲咨,首先躲胳,它需要知道數據庫表結構,當然纤勒,Sequelize主要是支持Postgres, Mysql之類的關系型數據庫坯苹。
npm install -g sequelize-auto
sequelize-auto -h 127.0.0.1 -d ocsp -u root -x 123 -p 3306 ---dialect mysql -o "./server/models/"
sequelize-auto是一個幫助我們快速生成表結構的工具,上面給出了一個通過連接mysql生成數據庫表結構代碼的例子摇天。
/* jshint indent: 2 */
"use strict";
module.exports = function(sequelize, DataTypes) {
return sequelize.define('STREAM_EVENT', {
id: {
type: DataTypes.INTEGER(16),
allowNull: false,
primaryKey: true,
autoIncrement: true
},
name: {
type: DataTypes.STRING,
allowNull: false
}, {
createdAt: false,
updatedAt: false,
tableName: 'STREAM_EVENT'
});
};
首先生成的代碼沒有使用"use strict";
粹湃,如果是需要運行在嚴格模式下,需要自己添加泉坐。其次为鳄,createdAt和updateAt要寫成false,默認true需要數據庫表里面有這兩個字段腕让。
錯誤處理
Javascript Promise的錯誤處理有讓人迷糊的地方孤钦。
p.then(onFulfilled, onRejected);
p.then(function(value) {
// fulfillment
}, function(reason) {
// rejection
});
p.catch(onRejected);
p.catch(function(reason) {
// 拒絕
});
首先是ES6里面Promise的then提供兩個參數,分別是success和error的兩個callback函數纯丸,另外偏形,Promise提供catch方法,用來處理error的情況觉鼻,所以從某種角度上說俊扭,第二個callback函數的作用和catch是一樣的。
Tips: 在這里坠陈,我們推薦使用catch函數萨惑,因為catch返回的還是一個Promise,這對于Promise chain的調用很有好處仇矾,例如官方給出了以下例子咒钟。可以看出若未,catch后面還有then。
Warning:在最新版本的Angular里面倾鲫,已經徹底刪除了Promise的success和error方法粗合,因為對Promise chain的傳遞有影響萍嬉,一般then(function(item){})這里面的item,要再次解析隙疚,例如包裝在item.data里面壤追,而在success中則直接是data的值,這對于Promise chain有混淆供屉,所以success被廢棄了行冰,這里不推薦使用。
var p1 = new Promise(function(resolve, reject) {
resolve('Success');
});
p1.then(function(value) {
console.log(value); // "成功!"
throw 'oh, no!';
}).catch(function(e) {
console.log(e); // "oh, no!"
}).then(function(){
console.log('after a catch the chain is restored');
}, function () {
console.log('Not fired due to the catch');
});
// 以下行為與上述相同
p1.then(function(value) {
console.log(value); // "成功!"
return Promise.reject('oh, no!');
}).catch(function(e) {
console.log(e); // "oh, no!"
}).then(function(){
console.log('after a catch the chain is restored');
}, function () {
console.log('Not fired due to the catch');
});
使用事務
sequelize的事務處理非常強大伶丐。以下給出一個transaction使用的例子悼做,注意在transaction里面使用的return函數來返回promise的方式,用來保證sequelize執(zhí)行同步哗魂。
sequelize.transaction(function(t) {
return EventDef.find({where: {id: req.params.id}, transaction: t}).then(function (event) {
let result = event.dataValues;
if(result.status === status){
return sequelize.Promise.reject();
}
if(result.owner !== username){
return sequelize.Promise.reject();
}
result.status = status;
return EventDef.update(result, {where: {id: req.params.id}, transaction: t});
});
}).then(function(){
res.send({success: true});
}).catch(function (e) {
console.log(e);
res.status(500).send(trans.databaseError);
});
使用關聯關系
Sequelize中使用include hook可以方便的進行表關聯肛走。
let EventDef = require('../model/STREAM_EVENT')(sequelize, Sequelize);
let CEP = require('../model/STREAM_EVENT_CEP')(sequelize, Sequelize);
EventDef.hasOne(CEP, {foreignKey:'event_id', targetKey:'id'});
EventDef.find({
where:{
id: req.params.id
},
include: {
model: CEP
}
}).then(function(event){
res.send(event);
}, function(){
res.status(500).send(trans.databaseError);
});
Warning: 一般我們使用sequelize都是在express router里面,注意的是在一個router里面录别,只能有一個response朽色,由于sequelize是異步的,注意是否進行了多次返回组题。
router.put('/:id', function(req, res){
let event = req.body.event;
EventDef.find({attributes: ["owner"], where: {id: event.id}}).then((owner)=> {
res.send({success: true});
});
//res.send()葫男,這里不能出現,注意
小結
Sequelize是一個非常優(yōu)秀的ORM工具崔列,了解Promise的運行機制梢褐,注意它的異步性,就能利用好它做數據庫操作了峻呕。