Node.js 如何使用 MySQL

在现代的Web开发中，Node.js与MySQL的结合使用非常普遍。MySQL作为一种强大的关系型数据库，能够高效地存储和管理数据，而Node.js则凭借其非阻塞I/O和事件驱动的特性，为构建高性能的应用程序提供了有力支持。下面我们就来探讨一下Node.js如何使用MySQL。

需要安装 mysql 模块。在项目目录下打开终端，运行 npm install mysql 命令，即可将其安装到项目中。

安装完成后，在Node.js文件中引入该模块：

const mysql = require('mysql');

接下来，要创建一个数据库连接。可以通过以下代码来配置连接信息：

const connection = mysql.createConnection({
  host: 'localhost',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database'
});

配置好连接后，使用 connection.connect() 方法来建立与MySQL数据库的连接：

connection.connect((err) => {
  if (err) {
    console.error('数据库连接错误: ', err.stack);
    return;
  }
  console.log('已连接到数据库，连接ID为: ', connection.threadId);
});

连接成功后，就可以执行SQL语句了。例如，执行一个简单的查询语句：

const sql = 'SELECT * FROM your_table';
connection.query(sql, (err, results, fields) => {
  if (err) throw err;
  console.log('查询结果: ', results);
});

这里的 connection.query() 方法用于执行SQL语句。第一个参数是SQL语句，第二个参数是回调函数，回调函数的三个参数分别是错误对象 err、查询结果 results 和字段信息 fields。

如果需要执行插入、更新或删除操作，同样使用 connection.query() 方法，只是SQL语句不同。例如插入操作：

const insertSql = 'INSERT INTO your_table (column1, column2) VALUES (?,?)';
const values = ['value1', 'value2'];
connection.query(insertSql, values, (err, result) => {
  if (err) throw err;
  console.log('插入成功，插入ID为: ', result.insertId);
});

这里通过 ? 占位符来传递实际的值，这样可以有效防止SQL注入攻击。

最后，在使用完数据库连接后，要记得关闭连接：

connection.end((err) => {
  if (err) {
    console.error('关闭连接错误: ', err.message);
    return;
  }
  console.log('数据库连接已关闭');
});

通过以上步骤，我们就可以在Node.js项目中顺利使用MySQL数据库，实现数据的存储、查询和管理等功能，为构建功能丰富的Web应用打下坚实基础。