Node.js 作为一种基于 Chrome V8 引擎的 JavaScript 运行时，凭借其高效、轻量级的特点被广泛应用于后端开发，在实际项目中，与 MySQL 数据库进行交互是常见需求，本文将详细介绍 Node.js 连接 MySQL 数据库的完整流程，包括环境准备、驱动选择、连接配置及基本操作示例。
环境准备与依赖安装
在开始之前，需确保系统已安装 Node.js 和 MySQL 数据库，Node.js 官网提供安装包，MySQL 可从官网下载或使用包管理器安装，通过 npm（Node.js 包管理器）安装 MySQL 驱动，推荐使用 mysql2 包，它是 mysql 的升级版，性能更优且支持 Promise，在项目目录下执行命令：npm install mysql2，安装完成后,即可在代码中引入该模块进行数据库连接。
数据库连接配置
连接 MySQL 数据库需要配置连接参数，包括主机名（host）、用户名（user）、密码（password）、数据库名（database）及端口号（port）等，这些参数可以直接写在代码中，但更推荐通过环境变量管理，以提高安全性,以下为基本连接示例代码：
const mysql = require('mysql2/promise');
// 创建连接池
const pool = mysql.createPool({
host: 'localhost',
user: 'root',
password: 'your_password',
database: 'test_db',
waitForConnections: true,
connectionLimit: 10,
queueLimit: 0
});
// 测试连接
pool.getConnection()
.then(conn => {
console.log('MySQL 连接成功');
conn.release();
})
.catch(err => {
console.error('连接失败:', err);
});
上述代码使用 createPool 创建连接池，相比单连接模式，连接池能有效管理数据库连接，提高应用性能。connectionLimit 参数可设置最大连接数,避免资源耗尽。
执行 SQL 查询
连接成功后，可通过连接池执行 SQL 语句。mysql2 支持 Promise 和回调两种方式，推荐使用 Promise 以简化异步代码,以下为查询和插入数据的示例：
// 查询数据
async function queryData() {
try {
const [rows] = await pool.execute('SELECT * FROM users WHERE age > ?', [18]);
console.log('查询结果:', rows);
} catch (err) {
console.error('查询失败:', err);
}
}
// 插入数据
async function insertData(name, age) {
try {
const [result] = await pool.execute(
'INSERT INTO users (name, age) VALUES (?, ?)',
[name, age]
);
console.log('插入成功，ID:', result.insertId);
} catch (err) {
console.error('插入失败:', err);
}
}
// 调用函数
queryData();
insertData('张三', 20);
代码中使用了参数化查询（ 占位符），可有效防止 SQL 注入攻击,这是数据库操作中必须注意的安全问题。
关闭连接
在应用关闭时，需正确释放数据库连接资源，通过调用 pool.end() 方法可关闭所有连接,确保程序优雅退出：
process.on('exit', async () => {
await pool.end();
console.log('数据库连接已关闭');
});
错误处理与最佳实践
数据库操作中，错误处理至关重要，建议使用 try-catch 捕获异常，并根据错误类型进行日志记录或用户提示，应避免在代码中硬编码敏感信息（如密码），推荐使用 .env 文件结合 dotenv 模块管理配置，对于高频操作，可适当调整连接池参数,优化性能。
相关问答 FAQs
Node.js 连接 MySQL 时出现 "ER_ACCESS_DENIED_ERROR" 错误怎么办？
该错误通常是由于用户名或密码错误、权限不足导致的，请检查 MySQL 中配置的用户权限，确保用户拥有访问目标数据库的权限,并确认连接参数中的用户名和密码正确无误。
如何优化 Node.js 与 MySQL 的连接性能？
可通过以下方式优化：使用连接池管理连接；避免频繁创建和销毁连接；合理设置 connectionLimit 参数；对复杂查询使用索引；启用 MySQL 的查询缓存（根据场景选择），对于高并发场景,可考虑使用读写分离或分库分表策略。