首先,我们先引入mysql库。创建与mysql的连接池。
config里储存这数据库的信息。
用Promise封装sql语句(用promise封装可以很好的防止回调地狱的现象)
首先,从连接池中取出一个实例。建立连接。然后执行sql语句。如果发生错误,Promise状态变成error。成功获取到result数据,Promise状态变成resolve。然后释放线程池连接。(这里的回调函数要符合node.js 错误优先的原则,即回调函数第一个参数为err)
然后是关于 数据库事务的封装。
connection.beginTransaction()表示事务的开始。然后执行query封装的sql语句。如果执行过程中有出错。那就执行rollback回滚。如果执行成功就执行commit.