Node.js implementiert die Methode des MySQL-Verbindungspools mithilfe von Transaktionen, um Verbindungen automatisch wiederzuverwenden

In diesem Artikel wird hauptsächlich die Methode von Node.js zum Implementieren des MySQL-Verbindungspools mithilfe von Transaktionen zum automatischen Recycling von Verbindungen vorgestellt Beispiele. Freunde, die es brauchen, können sich darauf beziehen. Ich hoffe, es kann allen helfen.

Das Beispiel in diesem Artikel beschreibt, wie Node.js den MySQL-Verbindungspool implementiert, um Verbindungen mithilfe von Transaktionen automatisch wiederzuverwenden. Teilen Sie es als Referenz mit allen. Die Details lauten wie folgt:

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

Verwandte Empfehlungen:

Detaillierte Erläuterung des automatischen Recyclings Mechanismus der Sitzung in PHP

Das obige ist der detaillierte Inhalt vonNode.js implementiert die Methode des MySQL-Verbindungspools mithilfe von Transaktionen, um Verbindungen automatisch wiederzuverwenden. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!