原创投稿
  1. 创想鸟首页
  2. 用户投稿

关于NodeJs如何使用Mysql模块实现事务处理实例

程序猿 • • 用户投稿

本篇文章主要介绍了nodejs使用mysql模块实现事务处理 ，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧

依赖模块：

1. mysql

npm install mysql --save

2. async

npm install async --save

(ps: async模块可换成其它Promise模块如bluebird、q等) 

因为Node.js的mysql模块本身对于事务的封装过于简单，而且直接使用会有很严重callback hell，故我们封装了两个方法，一个用来初始化sql & params，一个用来执行事务。

初始化sql & params：

function _getNewSqlParamEntity(sql, params, callback) {  if (callback) {    return callback(null, {      sql: sql,      params: params    });  }  return {    sql: sql,    params: params  };}

如果你要执行多条sql语句，则需要：

var sqlParamsEntity = [];var sql1 = "insert table set a=?, b=? where 1=1";var param1 = {a:1, b:2};sqlParamsEntity.push(_getNewSqlParamEntity(sql1, param1));var sql2 = "update ...";sqlParamsEntity.push(_getNewSqlParamEntity(sql1, []));//...更多要事务执行的sql

然后我在我自己的dbHelper.js里封装了execTrans的函数，用来执行事务

var mysql = require('mysql');var async = require("async");module.exports = {  execTrans: execTrans,}var pool = mysql.createPool({  host: "mysql host",  user: "mysql login user",  password: "mysql login pwd",  database: "target db name",  connectionLimit: 10,  port: "mysql db port",  waitForConnections: false});function execTrans(sqlparamsEntities, callback) {  pool.getConnection(function (err, connection) {    if (err) {      return callback(err, null);    }    connection.beginTransaction(function (err) {      if (err) {        return callback(err, null);      }      console.log("开始执行transaction，共执行" + sqlparamsEntities.length + "条数据");      var funcAry = [];      sqlparamsEntities.forEach(function (sql_param) {        var temp = function (cb) {          var sql = sql_param.sql;          var param = sql_param.params;          connection.query(sql, param, function (tErr, rows, fields) {            if (tErr) {              connection.rollback(function () {                console.log("事务失败，" + sql_param + "，ERROR：" + tErr);                throw tErr;              });            } else {              return cb(null, 'ok');            }          })        };        funcAry.push(temp);      });      async.series(funcAry, function (err, result) {        console.log("transaction error: " + err);        if (err) {          connection.rollback(function (err) {            console.log("transaction error: " + err);            connection.release();            return callback(err, null);          });        } else {          connection.commit(function (err, info) {            console.log("transaction info: " + JSON.stringify(info));            if (err) {              console.log("执行事务失败，" + err);              connection.rollback(function (err) {                console.log("transaction error: " + err);                connection.release();                return callback(err, null);              });            } else {              connection.release();              return callback(null, info);            }          })        }      })    });  });}

这样就可以执行事务了：

execTrans(sqlParamsEntity, function(err, info){if(err){  console.error("事务执行失败");}else{  console.log("done.");}})

以上就是关于NodeJs如何使用Mysql模块实现事务处理实例的详细内容，更多请关注创想鸟其它相关文章！

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1042027.html

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
0 0

关于作者

程序猿的头像

程序猿签约作者

413.8K 文章
0 评论
2 粉丝
这个人很懒，什么都没有留下～
上一篇 2025年12月2日 04:54:35
Yandex搜索引擎一键访问入口_俄罗斯Yandex官网免登录
下一篇 2025年12月2日 04:54:42

相关推荐

发表回复

登录后才能评论
关注微信