nodejs mysql 连接数据库连接池

在Node.js中使用MySQL时，为了提高性能和资源利用率，通常会使用连接池来管理数据库连接。如何通过连接池解决频繁创建和销毁数据库连接的问题，并提供详细的代码示例和多种实现思路。

开头：解决方案

在Node.js中，每次与MySQL数据库进行交互时都重新创建一个连接会导致性能下降和资源浪费。为了解决这个问题，可以使用mysql模块中的连接池功能。连接池会在内部维护一组数据库连接，并根据需要分配和释放这些连接，从而减少连接创建和销毁的开销。

接下来，我们将如何配置和使用MySQL连接池，并提供几种不同的实现思路。

1. 使用 `mysql` 模块创建连接池

以下是使用官方 mysql 模块（已停止维护，但仍然广泛使用）创建连接池的基本方法：

代码示例

javascript
// 引入 mysql 模块
const mysql = require('mysql');</p>

<p>// 创建连接池
const pool = mysql.createPool({
    host: 'localhost',         // 数据库地址
    user: 'root',             // 用户名
    password: 'password',     // 密码
    database: 'test_db',      // 数据库名称
    connectionLimit: 10       // 连接数
});</p>

<p>// 查询数据库
pool.getConnection((err, connection) => {
    if (err) throw err;</p>

<pre><code>console.log('Connected to the database!');

// 执行 SQL 查询
connection.query('SELECT * FROM users', (error, results, fields) => {
    if (error) throw error;

    console.log('Query results:', results);

    // 释放连接
    connection.release();
});

});

说明

createPool 方法用于创建一个连接池。
connectionLimit 参数定义了连接池中允许的连接数。
在查询完成后，必须调用 connection.release() 将连接返回到池中，以便其他请求可以复用。

2. 使用 `mysql2` 模块优化连接池

mysql2 是 mysql 模块的升级版，提供了更好的性能和更多的特性，例如支持 Promise 和流式查询。

代码示例

javascript
// 引入 mysql2/promise 模块
const mysql = require('mysql2/promise');</p>

<p>// 创建连接池
const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'test_db',
    waitForConnections: true,  // 如果没有空闲连接，则等待
    connectionLimit: 10,       // 连接数
    queueLimit: 0             // 等待队列长度限制（0 表示不限制）
});</p>

<p>// 使用 async/await 查询数据库
async function queryDatabase() {
    try {
        const [rows, fields] = await pool.execute('SELECT * FROM users');
        console.log('Query results:', rows);
    } catch (error) {
        console.error('Error executing query:', error);
    }
}</p>

<p>queryDatabase();

说明

mysql2/promise 提供了基于 Promise 的 API，使代码更加简洁和易于维护。
waitForConnections 参数控制当没有可用连接时是否等待。
queueLimit 参数限制等待队列的长度，避免过多请求堆积。

3. 使用 ORM 工具管理连接池

除了直接操作 MySQL 模块外，还可以使用 ORM（对象关系映射）工具来简化数据库操作。常见的 Node.js ORM 工具有 Sequelize 和 TypeORM。

使用 Sequelize 示例

javascript
// 引入 Sequelize 模块
const { Sequelize, DataTypes } = require('sequelize');</p>

<p>// 创建 Sequelize 实例并配置连接池
const sequelize = new Sequelize('test_db', 'root', 'password', {
    host: 'localhost',
    dialect: 'mysql',
    pool: {
        max: 10,              // 连接数
        min: 0,               // 最小连接数
        acquire: 30000,       // 获取连接的等待时间（毫秒）
        idle: 10000           // 连接保持空闲的时间（毫秒）
    }
});</p>

<p>// 定义模型
const User = sequelize.define('User', {
    name: {
        type: DataTypes.STRING,
        allowNull: false
    },
    email: {
        type: DataTypes.STRING,
        allowNull: false
    }
}, {
    timestamps: false
});</p>

<p>// 同步模型并查询数据
(async () => {
    try {
        await sequelize.authenticate();
        console.log('Connection has been established successfully.');</p>

<pre><code>    const users = await User.findAll();
    console.log('Users:', JSON.stringify(users, null, 2));
} catch (error) {
    console.error('Unable to connect to the database:', error);
}

})();

说明

Sequelize 自动管理连接池，开发者只需配置相关参数。
模型定义使得数据库表结构与代码逻辑更加清晰。

4. 其他注意事项

4.1 错误处理

在使用连接池时，务必处理可能发生的错误，例如连接超时或数据库不可用的情况。

javascript pool.on('error', (err) => { console.error('A connection pool error occurred:', err.stack); });

4.2 关闭连接池

在应用关闭时，确保正确关闭连接池以释放资源。

javascript pool.end((err) => { if (err) { return console.error('Error closing the connection pool:', err); } console.log('Connection pool closed.'); });