Node.js如何连接MySQL:从基础到实践
Node.js连接MySQL的核心方法是使用mysql2或mysql第三方库,通过创建连接配置、建立连接池并执行SQL查询来实现数据库操作,下面将详细展开这一过程,帮助开发者快速掌握Node.js与MySQL的集成。

安装必要的库
在Node.js项目中安装mysql2库(推荐使用,性能更好且支持Promise),通过npm命令安装:
npm install mysql2
建立数据库连接
使用mysql2创建连接时,需配置主机、用户、密码和数据库名等参数,示例代码如下:
const mysql = require('mysql2');
const connection = mysql.createConnection({
host: 'localhost',
user: 'root',
password: 'yourpassword',
database: 'testdb'
});
connection.connect((err) => {
if (err) throw err;
console.log('MySQL连接成功!');
});
使用连接池提升性能
对于高并发应用,连接池是更高效的选择,它可以复用连接,减少资源开销:
const pool = mysql.createPool({
host: 'localhost',
user: 'root',
password: 'yourpassword',
database: 'testdb',
waitForConnections: true,
connectionLimit: 10
});
pool.query('SELECT * FROM users', (err, results) => {
if (err) throw err;
console.log(results);
});
执行SQL查询
通过query()方法执行增删改查操作。注意防范SQL注入,建议使用参数化查询:
const sql = 'INSERT INTO users (name, email) VALUES (?, ?)';
pool.execute(sql, ['张三', 'zhangsan@example.com'], (err, result) => {
if (err) throw err;
console.log('数据插入成功');
});
使用Promise异步处理
mysql2支持Promise API,可结合async/await简化异步代码:
const promisePool = pool.promise();
async function getUsers() {
const [rows] = await promisePool.query('SELECT * FROM users');
return rows;
}
错误处理与连接关闭
务必添加错误监听,并在应用结束时关闭连接,避免资源泄漏:
connection.on('error', (err) => {
console.error('数据库错误:', err);
});
process.on('exit', () => {
connection.end();
});
Node.js通过mysql2库可高效连接MySQL,关键步骤包括配置连接参数、使用连接池优化、执行参数化查询以及妥善处理错误,结合Promise API,能进一步提升代码可读性和维护性,为后端开发提供稳定可靠的数据支持。
未经允许不得转载! 作者:HTML前端知识网,转载或复制请以超链接形式并注明出处HTML前端知识网。
原文地址:https://www.html4.cn/6413.html发布于:2026-07-23





