MySQL 如何在Node.js中使用连接池连接MySQL|极客教程

MySQL 如何在Node.js中使用连接池连接MySQL

在Node.js中，操作MySQL数据库是相当常见的任务。连接池是一种用于管理数据库连接的机制，它允许在需要时从连接池中获取连接，并在事务结束后将其返回到池中，以供下一个请求使用。使用连接池可以减少创建和销毁连接的开销，从而提升系统的性能和可用性。

阅读更多：MySQL 教程

安装和配置MySQL

在开始使用Node.js连接MySQL之前，我们需要安装和配置MySQL。这里以Ubuntu操作系统为例，步骤如下：

安装MySQL服务器

sudo apt-get update
sudo apt-get install mysql-server

启动MySQL服务器并设置root用户密码

sudo systemctl start mysql
sudo mysql_secure_installation

创建名为test的测试数据库

sudo mysql -u root -p
CREATE DATABASE test;

创建名为user的测试数据库用户并授权

GRANT ALL PRIVILEGES ON test.* TO 'user'@'localhost' IDENTIFIED BY 'password';
FLUSH PRIVILEGES;

安装mysql模块

在Node.js中连接MySQL，需要使用mysql模块。我们可以使用npm包管理器安装mysql模块。

npm install mysql

连接池的使用

首先，创建一个连接池对象，并配置连接池的相关参数，例如最大连接数max、最小连接数min、超时时间acquireTimeoutMs等。然后，使用连接池对象获取数据库连接。如果连接池中没有可用的连接，getConnection()方法将会阻塞，直到连接池中有可用的连接或等待超时。

以下代码演示了使用连接池执行查询操作的示例。

const mysql = require('mysql');
const pool = mysql.createPool({
    connectionLimit : 10,
    host     : 'localhost',
    user     : 'user',
    password : 'password',
    database : 'test'
});

pool.getConnection(function(err, connection) {
    if (err) throw err;

    connection.query('SELECT * FROM users', function (error, results, fields) {
        connection.release();
        if (error) throw error;
        console.log('The solution is: ', results);
    });
});

在上述代码中，我们使用getConnection()方法获取连接，执行一个简单的查询后，将连接释放回连接池中。

处理连接错误

连接池虽然可以优化数据库连接的使用，但在使用过程中仍有可能发生连接错误。当连接错误发生时，应该终止该连接，并重新获取一个新的连接，而不是捕获错误后继续使用可能已经失效的连接。以下代码演示了如何在连接错误发生时关闭连接并重新获取一个新的连接。

const mysql = require('mysql');
const pool = mysql.createPool({
    connectionLimit : 10,
    host     : 'localhost',
    user     : 'user',
    password : 'password',
    database : 'test'
});

pool.getConnection(function(err, connection) {
    if (err) throw err;

    connection.query('SELECT * FROM users', function (error, results, fields) {
        connection.release();
        if (error) {
            console.error(error);
            connection.destroy();
            pool.getConnection(function(err, connection) {
                if (err) throw err;
                console.log('New connection acquired');
            });
        } else {
            console.log('The solution is: ', results);
        }
    });
});

在上述代码中，当发生连接错误时，我们先输出错误信息，然后使用destroy()方法关闭连接，并重新获取一个新的连接。如果重新获取连接成功，将输出信息New connection acquired。