Node.js는 트랜잭션을 사용하여 연결을 자동으로 재활용하는 mysql 연결 풀 방법을 구현합니다.

이 기사에서는 트랜잭션을 사용하여 자동으로 연결을 재활용하는 Node.js의 방법을 주로 소개합니다. mysql 연결 풀을 운영하는 node.js의 관련 기술을 분석하여 트랜잭션 기반 연결 재활용 작업을 예제 형식으로 설명합니다. 필요한 친구들은 참고해서 모두에게 도움이 되길 바랍니다.

이 문서의 예에서는 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();
}

관련 권장 사항:

php에서 세션의 자동 재활용 메커니즘에 대한 자세한 설명

위 내용은 Node.js는 트랜잭션을 사용하여 연결을 자동으로 재활용하는 mysql 연결 풀 방법을 구현합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!