Node.js 数据库操作：MySQL 连接与使用教程

引言 / 什么是 Node.js 与 MySQL 交互

Node.js 作为流行的后端 JavaScript 运行时，凭借其非阻塞 I/O 特性，成为构建高性能 Web 应用的理想选择。而 MySQL 作为开源关系型数据库，因其稳定性、易用性和社区支持，被广泛应用于企业级项目中。掌握 Node.js 与 MySQL 的交互能力，是后端开发者必备的核心技能之一。

本文将以用户管理系统为例，系统讲解如何通过 Node.js 完成 MySQL 数据库的连接、查询、更新等操作。内容涵盖驱动安装、连接池配置、参数化查询防注入等关键知识点，帮助读者快速搭建起安全可靠的数据交互层。

准备工作

环境要求

• Node.js 版本 ≥ 16.x（推荐 LTS 版本）
• MySQL 数据库（本地或云服务，版本 ≥ 5.7）
• 代码编辑器（如 VS Code）

数据库准备

1. 创建测试数据库：

   CREATE DATABASE IF NOT EXISTS user_management DEFAULT CHARSET utf8mb4;
   

2. 创建用户表：

   CREATE TABLE users (
     id INT AUTO_INCREMENT PRIMARY KEY,
     username VARCHAR(50) NOT NULL UNIQUE,
     email VARCHAR(100) NOT NULL UNIQUE,
     created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
   );
   

基础操作 / 核心用法

步骤一：安装 MySQL 驱动

Node.js 通过 mysql2 包与 MySQL 交互（比传统 mysql 包性能更好）：

npm install mysql2

步骤二：建立数据库连接

创建 db.js 文件配置连接：

const mysql = require('mysql2/promise'); // 使用 promise 版本

const pool = mysql.createPool({
  host: 'localhost',
  user: 'root',
  password: 'yourpassword',
  database: 'user_management',
  waitForConnections: true,
  connectionLimit: 10, // 连接池大小
  queueLimit: 0
});

module.exports = pool;

提示：生产环境建议将配置信息存储在环境变量中，使用 dotenv 包管理。

步骤三：执行简单查询

创建 userController.js 实现基础 CRUD：

const pool = require('./db');

// 查询所有用户
async function getAllUsers() {
  const [rows] = await pool.query('SELECT * FROM users');
  return rows;
}

// 添加用户
async function addUser(username, email) {
  const [result] = await pool.query(
    'INSERT INTO users (username, email) VALUES (?, ?)',
    [username, email]
  );
  return result.insertId;
}

// 示例调用
(async () => {
  const newUserId = await addUser('john_doe', 'john@example.com');
  console.log('新增用户ID:', newUserId);
  
  const users = await getAllUsers();
  console.log('用户列表:', users);
})();

进阶技巧

参数化查询防止 SQL 注入

错误示范（存在注入风险）：

// 危险！直接拼接 SQL 字符串
const username = req.body.username; // 假设值为 "admin'; DROP TABLE users--"
pool.query(`SELECT * FROM users WHERE username = '${username}'`);

正确做法（使用占位符）：

async function getUserByUsername(username) {
  // 使用 ? 作为占位符
  const [rows] = await pool.query(
    'SELECT * FROM users WHERE username = ?',
    [username]
  );
  return rows[0];
}

连接池使用最佳实践

连接池参数配置建议：

性能优化示例：

// 重用连接池而非频繁创建
const pool = mysql.createPool({ /* 配置 */ });

// 在 HTTP 服务器中复用
const express = require('express');
const app = express();

app.get('/users', async (req, res) => {
  try {
    const users = await pool.query('SELECT * FROM users');
    res.json(users[0]);
  } catch (err) {
    res.status(500).json({ error: err.message });
  }
});

app.listen(3000);

事务处理示例

async function transferFunds(fromId, toId, amount) {
  const connection = await pool.getConnection();
  try {
    await connection.beginTransaction();
    
    // 扣减转出账户
    await connection.query(
      'UPDATE accounts SET balance = balance - ? WHERE id = ?',
      [amount, fromId]
    );
    
    // 增加转入账户
    await connection.query(
      'UPDATE accounts SET balance = balance + ? WHERE id = ?',
      [amount, toId]
    );
    
    await connection.commit();
    return true;
  } catch (err) {
    await connection.rollback();
    throw err;
  } finally {
    connection.release();
  }
}

常见问题

Q：连接数据库时报 ER_ACCESS_DENIED_ERROR 错误？

A：检查用户名/密码是否正确，确认用户是否有对应数据库的访问权限。可通过 MySQL 命令行测试：

mysql -u root -p -D user_management

Q：如何处理连接池泄漏？

A：确保每次 getConnection() 后都调用 release()，推荐使用 async/await 配合 try/finally 结构。

Q：参数化查询能否处理对象类型？

A：MySQL 驱动会自动处理基本类型转换，复杂对象需先序列化为 JSON 字符串：

const user = { name: 'Alice', age: 25 };
await pool.query(
  'INSERT INTO profiles SET data = ?',
  [JSON.stringify(user)]
);

小结

本文系统讲解了 Node.js 操作 MySQL 的完整流程：从驱动安装到连接池配置，从基础 CRUD 到事务处理，特别强调了参数化查询对安全性的重要性。实际开发中，建议结合 ORM 工具（如 Sequelize）进一步提升开发效率，但对于需要精细控制 SQL 的场景，直接使用 mysql2 仍是更灵活的选择。

建议读者通过以下方式巩固知识：

1. 在本地搭建完整的用户管理系统
2. 尝试添加分页查询、模糊搜索等功能
3. 研究连接池监控指标的实现方法

掌握这些技能后，你将能够独立开发需要数据库交互的 Node.js 应用模块，为构建全栈项目打下坚实基础。