Node.js 后端连接 MySQL 数据库

MySQL 是一种流行的关系型数据库管理系统，与 Node.js 后端结合使用可以构建功能强大的 Web 应用程序。本文将介绍如何使用 Node.js 来连接 MySQL 数据库并进行基本的 CRUD 操作。

安装

首先，需要在本地计算机上安装 MySQL 服务。可以通过官方网站下载并安装。

然后，使用 Node.js 的 mysql2 模块来连接 MySQL 数据库。

在项目根目录下执行以下命令：

npm install mysql2

连接到数据库

使用以下代码连接到 MySQL 数据库：

const mysql = require('mysql2');

const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'my_database'
});

connection.connect(function(err) {
  if (err) throw err;
  console.log('Connected to MySQL database!');
});

这里，我们使用 mysql2 模块的 createConnection 函数来创建数据库连接。 createConnection 函数接受一个配置对象，其中包含数据库的连接信息。

在连接对象上调用 connect 方法来尝试连接数据库。如果连接失败，将抛出错误。否则，将输出一个成功信息字符串。

查询数据

使用以下代码从 MySQL 数据库查询数据：

connection.query('SELECT * FROM my_table', function (error, results, fields) {
  if (error) throw error;
  console.log(results);
});

这里，我们使用连接对象的 query 方法来执行 SQL 查询。 query 函数接受两个参数：SQL 查询字符串和回调函数。回调函数将在 SQL 查询完成时被调用，并且接收异常错误，查询结果和查询字段三个参数。

在回调函数中，我们可以打印查询结果或使用其进行其他操作。

插入数据

使用以下代码向 MySQL 数据库插入数据：

const user = { name: 'John', email: 'john@example.com' };
connection.query('INSERT INTO users SET ?', user, function (error, results, fields) {
  if (error) throw error;
  console.log('User added to database with ID:', results.insertId);
});

这里，我们使用连接对象的 query 方法来执行 SQL 插入语句。在 SQL 插入语句中，使用 ? 占位符来代替实际值，然后在查询函数的第二个参数中传入实际值对象。回调函数将在 SQL 插入操作完成时被调用，并且接收异常错误，插入结果和插入字段三个参数。

在回调函数中，我们可以打印插入结果或使用其进行其他操作。

更新数据

使用以下代码更新 MySQL 数据库中的数据：

connection.query(
  'UPDATE users SET email = ? WHERE id = ?',
  ['newemail@example.com', 1],
  function (error, results, fields) {
    if (error) throw error;
    console.log('User email updated to:', results.changedRows);
});

这里，我们使用连接对象的 query 方法来执行 SQL 更新语句。在 SQL 更新语句中，使用 ? 占位符来代替实际值，然后在查询函数的第二个参数中传入实际值数组。回调函数将在 SQL 更新操作完成时被调用，并且接收异常错误，更新结果和更新字段三个参数。

在回调函数中，我们可以打印更新结果或使用其进行其他操作。

删除数据

使用以下代码从 MySQL 数据库中删除数据：

connection.query(
  'DELETE FROM users WHERE id = ?',
  [1],
  function (error, results, fields) {
    if (error) throw error;
    console.log('Deleted rows:', results.affectedRows);
});

这里，我们使用连接对象的 query 方法来执行 SQL 删除语句。在 SQL 删除语句中，使用 ? 占位符来代替实际值，然后在查询函数的第二个参数中传入实际值数组。回调函数将在 SQL 删除操作完成时被调用，并且接收异常错误，删除结果和删除字段三个参数。

在回调函数中，我们可以打印删除结果或使用其进行其他操作。

关闭连接

使用以下代码关闭与 MySQL 数据库的连接：

connection.end(function(err) {
  if (err) throw err;
  console.log('Connection closed.');
});

这里，我们在连接对象上调用 end 方法来关闭连接。在回调函数中，我们可以打印关闭连接成功的信息。

结论

使用 Node.js 后端连接 MySQL 数据库是构建 Web 应用程序的关键步骤之一。通过本文介绍，您现在可以连接到 MySQL 数据库，查询，插入，更新和删除数据以及关闭数据库连接。

Happy coding!