Introduction détaillée au code de cas sur la façon dont NodeJs utilise le module Mysql pour implémenter le traitement des transactions

Cet article présente principalement NodeJs utilisant le module Mysql pour implémenter le traitement des transactions. L'éditeur pense que c'est plutôt bien. Maintenant, je vais le partager avec. vous et donnez également. Utilisons-le tous comme référence. Suivons l'éditeur pour jeter un œil

Modules dépendants :

mysql

npm install mysql --save

2 async

npm install async --save

.

(ps : le module async peut être remplacé par d'autres Modules Promise tels que bluebird, q, etc.)

Parce que le module mysql de Node.js encapsule lui-même les transactions C'est trop simple, et l'utiliser directement provoquera un sérieux enfer de rappel, nous avons donc encapsulé deux méthodes, une pour initialiser sql et params, et une pour exécuter des transactions.

Initialisez SQL et les paramètres :

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

Si vous souhaitez exécuter plusieurs instructions SQL, vous avez besoin de :

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

Ensuite, je le mets dans mon propre dbHelper. js La fonction de execTrans y est encapsulée, qui est utilisée pour exécuter des transactions

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);
            }
          })
        }
      })
    });
  });
}

De cette manière, la transaction peut être exécutée :

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

.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!