在Node.js中如何实现mysql事务自动回收连接

这篇文章主要介绍了node.js实现mysql连接池使用事务自动回收连接的方法,结合实例形式分析了node.js操作mysql连接池实现基于事务的连接回收操作相关技巧,需要的朋友可以参考下

本文实例讲述了Node.js实现mysql连接池使用事务自动回收连接的方法。分享给大家供大家参考，具体如下：

var mysql = require('mysql'),  Connection = require('mysql/lib/Connection.js');var pool = mysql.createPool({  host: '127.0.0.1',  database: 'myDB',  port: 3306,  user: 'root',  password: 'root',  debug: false,  connectionLimit: 3});var execPool = function() {  pool.getConnection(function(err, conn) {    transAutoRelease(conn);    conn.beginTransaction(function(err) {      if (err) throw err;      conn.query("INSERT INTO test(id,name,date,test) values(1,'123',now(),1)",        function(err, ret) {          if (err) {            console.error(err);            conn.rollback(function() {});          } else {            console.log(ret);            conn.query('UPDATE test set id=12321312 where id=1', function(err, ret) {              if (err) {                console.error(err);                conn.rollback(function() {                });              } else {                conn.commit(function() {                  console.log('success' + JSON.stringify(ret));                });              }            });          }        });    });  });}function after(fn, cb) { return function() {    fn.apply(this, arguments);    cb();  }}function transAutoRelease(conn) {  if (conn.commit == Connection.prototype.commit)    conn.commit = after(conn.commit, release);  if (conn.rollback == Connection.prototype.rollback)    conn.rollback = after(conn.rollback, release);  function release() {    if (conn) {      conn.release();    }  }}var intervalStartProcess = function() {  setInterval(function() {    execPool();  }, 1000);}for (var i = 5 - 1; i >= 0; i--) {  intervalStartProcess();}

登录后复制

上面是我整理给大家的，希望今后会对大家有帮助。

相关文章：

为什么Node.js会成为Web应用开发？

为什么Node.js会成为Web应用开发？

为什么Node.js会成为Web应用开发？

以上就是在Node.js中如何实现mysql事务自动回收连接的详细内容，更多请关注【创想鸟】其它相关文章！