MySQL 和 node-mysql——connection.end()何处去

在使用node-mysql时，我们经常需要用到 connection.end() 方法来关闭连接。但是在具体实现中，connection.end() 方法应该放在哪里是一个值得思考的问题。下面来探讨这个问题。

阅读更多：MySQL 教程

关于 connection.end() 方法

在 node-mysql 中，connection 代表一个数据库连接对象，而 connection.end() 方法用来关闭连接。实际上，connection.end() 并非只是简单地关闭连接。它是一个异步方法，主要任务是告知 MySQL 服务器要关闭连接，并确保所有未执行的查询都结束。

当调用 connection.end() 方法后，并不会立即关闭连接。实际上，当连接上仍有查询未完成时，连接会一直保持打开状态，并等待这些查询完成。在这些查询完成后，连接才会真正关闭。

因为 connection.end() 方法是异步的，所以我们无法确保在调用该方法后，所有查询都会立即执行完毕。因此，我们需要正确地把 connection.end() 方法放置在合适的地方。

wrong way

下面是一个错误的示例，我们把 connection.end() 方法放在了查询语句后面：

var mysql = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'user',
  password : 'password',
  database : 'database'
});

connection.query('SELECT * FROM users', function(err, rows, fields) {
  if (err) throw err;

  // 输出查询结果
  console.log(rows);

  // 关闭连接
  connection.end();
});

这么做看上去似乎没有什么问题，但是实际上这是一种错误的做法。因为 connection.end() 是一个异步方法，在执行查询后立即调用它并不能保证所有查询语句都已执行完毕或搭配最后的结果。

如果在查询完成之前执行了 connection.end() 方法，所有未执行完毕的查询会被强制结束。这可能会导致数据丢失、事务回滚等严重问题。所以，我们不能简单地把 connection.end() 放在查询语句的后面。

right way

那么正确的做法是什么呢？为保证所有查询完全执行完毕，我们需要把 connection.end() 放在所有查询的回调函数中。这样可以保证在所有查询语句执行完毕后才调用 connection.end() 方法。

下面是一个示例：

var mysql = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'user',
  password : 'password',
  database : 'database'
});

connection.query('SELECT * FROM users', function(err, rows, fields) {
  if (err) throw err;

  // 输出查询结果
  console.log(rows);
});

connection.query('SELECT * FROM orders', function(err, rows, fields) {
  if (err) throw err;

  // 输出查询结果
  console.log(rows);

  // 关闭连接
  connection.end();
});

在这个示例中，我们把两个查询语句放在了两个回调函数中。connection.end() 方法放在了第二个回调函数的最后。这样的话，在第二个查询执行完毕后，connection.end() 才会被调用，确保了所有查询语句都执行完毕。

总结

在使用 node-mysql 的过程中，我们需要正确地使用 connection.end() 方法，以确保所有查询都已执行完毕。把 connection.end() 放在正确的位置是非常重要的，否则可能会导致数据丢失、事务回滚等严重问题。我们应该在所有查询的回调函数中调用 connection.end() 方法，以保证所有查询均执行完后才关闭连接。

希望本篇文章对您有所帮助，欢迎留言讨论。