这个库有没有做“事务”的处理啊？

[yylol]

createPool是有可能公用链接的，会影响事务，不知道mysql本身有没有对“事务”的封装？

[dresende]

Sorry? Transactions? Please right your ticket in english.

[yylol]

yes,Transactions,api for Transactions is what?
I can't find 'connection.startTransaction' in the lastest source code.
How to white code when I need Transactions in my progrome?
can 'transaction' work with 'createPool'?

[imkira]

yylol, as far as I know, you need to wrap your queries with BEGIN and COMMIT/ROLLBACK.

pool.getConnection(function(err, connection) {
  if (err) {
    // log error, whatever
    return;
  }

  // begin transaction
  connection.query('BEGIN', function(err, rows) {
    if (err) {
      connection.end();
      // log error, whatever
      return;
    }

    // execute your query or set of queries
    connection.query('UPDATE ...', function(err, rows) {
      if (err) {
        connection.query('ROLLBACK', connection.end);
        // log error, whatever
        return;
      }

      connection.query('COMMIT', connection.end);
    });
  });
});

Note that the code above is just sample code.
Please consider using an async library for avoiding such deeply nested code.

[yylol]

If I have more than one sql code, how can I code then?

[imkira]

yylol, please consider using something like https://github.com/caolan/async

pool.getConnection(function(err, connection) {
  if (err) {
    // log error, whatever
    return;
  }

  // begin transaction
  connection.query('BEGIN', function(err, rows) {
    if (err) {
      connection.end();
      // log error, whatever
      return;
    }

    async.series([
        function(callback) {
          connection.query('INSERT ...', callback);
        },
        function(callback) {
          connection.query('UPDATE ...', callback);
        },
        function(callback) {
          connection.query('DELETE ...', callback);
        }
      ],
      function(err) {
        var q;
        if (err) {
          q = 'ROLLBACK';
          // log error, whatever
        }
        else {
          q = 'COMMIT';
        }
        connection.query(q, connection.end);
      });
    });
  });
});