Node.js如何连接MySQL:从基础到实践

Node.js连接MySQL的核心方法是使用mysqlmysql2这类第三方模块,通过创建连接配置、建立连接池并执行SQL查询来实现数据库操作,以下将详细说明连接步骤、代码示例及最佳实践。

nodejs如何连mysql,Nodejs高效连接MySQL数据库

确保已安装Node.js和MySQL环境,并通过npm安装mysql模块(或更高效的mysql2):

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连接成功!');
});

使用连接池提升性能 在高并发场景中,连接池(Connection Pool) 能有效管理连接资源,避免频繁创建和销毁连接:

const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  password: 'yourpassword',
  database: 'testdb',
  waitForConnections: true,
  connectionLimit: 10,
  queueLimit: 0
});
pool.query('SELECT * FROM users', (err, results) => {
  if (err) throw err;
  console.log(results);
});

执行SQL查询与异步处理 推荐使用Promise封装或async/await语法简化异步操作(mysql2支持原生Promise):

async function getUser() {
  const [rows] = await pool.promise().query('SELECT * FROM users WHERE id = ?', [1]);
  console.log(rows);
}
getUser();

错误处理与安全注意事项

  • 始终验证用户输入,使用参数化查询防止SQL注入。
  • 通过try-catch捕获异常,并监听连接错误事件:
    connection.on('error', (err) => {
    console.error('数据库错误:', err);
    });

实际应用建议

  • 对于大型项目,可结合ORM工具如Sequelize简化操作。
  • 将连接配置存储在环境变量中(如使用dotenv模块),避免硬编码敏感信息。
  • 定期监控连接状态,设置合理的超时和重连机制。

Node.js通过轻量级模块即可高效连接MySQL,关键在于合理使用连接池、异步查询和安全防护,掌握这些基础后,可进一步探索事务管理、流式处理等高级功能,以构建稳健的数据库应用。

未经允许不得转载! 作者:HTML前端知识网,转载或复制请以超链接形式并注明出处HTML前端知识网

原文地址:https://www.html4.cn/8289.html发布于:2026-08-01