1.mysql 及 promise-mysql
nodejs 连接 mysql 有成熟的npm包 mysql ,如果需要promise，建议使用 promise-mysql；
npm：https://www.npmjs.com/package/mysql
https://www.npmjs.com/package/promised-mysql
在实际开发中，单独的connection 并不能满足业务需要，需要使用连接池进行连接的建立及释放，promise-mysql 建立连接池非常简单：
const config = {
host:'xxxxxx', // ip也行域名也行
user:'root',
password:'123456',
connectionLimit:30,
database:'movie', // database
port:'8306'
};
// 建立连接池
const pool = mysql.createPool(config);
// 使用pool.query 快速连接执行sql
pool.query('xxxx');
// 用using/dispsoer 模式构建自动释放资源的连接
function getSqlConnection(){
return pool.getConnection().disposer((c)=>{
pool.releaseConnection(c);
});
}
// 需要使用bluebird 封装具有dispsoer功能的promise对象
function query(sql){
return Promise.using(getSqlConnection(),(con)=>{
return sql?con.query(sql):con;
})
}
经过对mysql 连接的promise封装，我们可以使用async/await方式进行愉快的编程
2.通过promise-mysql执行事务
通过connection对象的beginTransaction、commit 及 rollback 即可实现
async function execAffairs(){
console.log('begin execAffairs');
// 写事务
const conn = await query();
await conn.beginTransaction(); // begin;
try{
await conn.query('select * from movie_detail where m_id=242167 for update');
await conn.query('update movie_detail set m_record=7.5 where m_id=242167');
await conn.commit();// commit
console.log('commit 完毕');
} catch(e){
console.log('事务出错',e);
await conn.rollback();
}
/******
// 无需release
finally{
conn.release();
}
*/
}
由于本示例使用了promise-mysql 的disposer 模式，所以无需额外处理 连接的 release
相关代码请见：https://github.com/JhoneLee/nodeScheduleMySql