如何使用Node.js连接MySQL数据库

在现代的Web开发中，Node.js因其高效、轻量和非阻塞IO的特点，被广泛应用于后端开发中。而MySQL则是世界上最流行的开源关系型数据库管理系统之一。将Node.js与MySQL集成，可以让你构建强大的、基于数据库的Web应用程序。本篇博客将详细介绍如何在Node.js项目中连接MySQL数据库，并通过实际代码示例展示具体实现步骤。

一、准备工作

1. 安装Node.js 首先，确保你已经在系统上安装了Node.js和npm（Node Packaged Modules）。你可以通过以下命令检查是否已经安装：

shell
node -v
npm -v

如果未安装，请前往Node.js官方网站（[Node.js官网](https://nodejs.org)）下载并安装适合你操作系统的版本。

2. 创建Node.js项目
在你的工作目录中，通过终端命令行创建一个新的Node.js项目：

```shell
mkdir nodejs-mysql-example
cd nodejs-mysql-example
npm init -y

上述命令会创建一个新的项目文件夹并生成

package.json

文件，这个文件是Node.js项目的配置文件。

1. 安装必要的依赖 我们需要安装MySQL驱动程序（mysql或mysql2）来帮助Node.js与MySQL数据库进行通信。在这个例子中，我们使用mysql2库：

npminstall mysql2

二、连接MySQL数据库

下一步是创建一个JavaScript文件，并编写代码以实现Node.js与MySQL的连接。我们将此文件命名为

index.js

。

1. 导入MySQL2库 在文件index.js中，首先导入mysql2库：

const mysql =require('mysql2');

1. 创建连接 接下来，设置数据库连接参数并创建数据库连接：

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

请确保在这个对象中填入你实际的数据库主机、用户、密码和数据库名称。

1. 连接到数据库 使用connect方法连接到数据库，并处理连接结果：

connection.connect((err)=>{if(err){
    console.error('Error connecting to the database:', err.message);return;}
  console.log('Connected to the MySQL database.');});

当成功连接到数据库时，会在控制台打印

Connected to the MySQL database.

，否则会打印错误信息。

三、执行SQL查询

成功连接到MySQL数据库后，接下来是执行SQL查询，如插入、查询、更新和删除操作。

1. 执行简单查询 下面展示如何执行一个简单的SQL查询来查询数据：

const query ='SELECT * FROM your_table';
connection.query(query,(err, results, fields)=>{if(err){
    console.error('Error executing query:', err.message);return;}
  console.log('Query results:', results);});

1. 插入数据 插入数据的示例如下：

const insertQuery ='INSERT INTO your_table (column1, column2) VALUES (?, ?)';const insertValues =['value1','value2'];
connection.query(insertQuery, insertValues,(err, results, fields)=>{if(err){
    console.error('Error inserting data:', err.message);return;}
  console.log('Data inserted successfully:', results.insertId);});

在这里，我们使用占位符

?

来防止SQL注入攻击，将实际值通过数组传递给查询函数。

1. 更新数据 更新数据的查询如下：

const updateQuery ='UPDATE your_table SET column1 = ? WHERE column2 = ?';const updateValues =['new_value','condition_value'];
connection.query(updateQuery, updateValues,(err, results, fields)=>{if(err){
    console.error('Error updating data:', err.message);return;}
  console.log('Data updated successfully:', results.affectedRows);});

1. 删除数据 删除数据的查询如下：

const deleteQuery ='DELETE FROM your_table WHERE column1 = ?';const deleteValue =['value1'];
connection.query(deleteQuery, deleteValue,(err, results, fields)=>{if(err){
    console.error('Error deleting data:', err.message);return;}
  console.log('Data deleted successfully:', results.affectedRows);});

以上代码展示了如何执行基本的CRUD（创建、读取、更新、删除）操作。

四、关闭数据库连接

在完成所有数据库操作后，记得关闭连接以释放资源：

connection.end((err)=>{if(err){
    console.error('Error closing the connection:', err.message);return;}
  console.log('Database connection closed.');});

五、完整代码示例

最后，将上述所有代码整合到一起，形成一个完整的示例：

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

connection.connect((err)=>{if(err){ 
    console.error('Error connecting to the database:', err.message);return;}
  console.log('Connected to the MySQL database.');// Query exampleconst query ='SELECT * FROM your_table';
  connection.query(query,(err, results, fields)=>{if(err){
      console.error('Error executing query:', err.message);return;}
    console.log('Query results:', results);// Insert exampleconst insertQuery ='INSERT INTO your_table (column1, column2) VALUES (?, ?)';const insertValues =['value1','value2'];
    connection.query(insertQuery, insertValues,(err, results, fields)=>{if(err){
        console.error('Error inserting data:', err.message);return;}
      console.log('Data inserted successfully:', results.insertId);// Update exampleconst updateQuery ='UPDATE your_table SET column1 = ? WHERE column2 = ?';const updateValues =['new_value','condition_value'];
      connection.query(updateQuery, updateValues,(err, results, fields)=>{if(err){
          console.error('Error updating data:', err.message);return;}
        console.log('Data updated successfully:', results.affectedRows);// Delete exampleconst deleteQuery ='DELETE FROM your_table WHERE column1 = ?';const deleteValue =['value1'];
        connection.query(deleteQuery, deleteValue,(err, results, fields)=>{if(err){
            console.error('Error deleting data:', err.message);return;}
          console.log('Data deleted successfully:', results.affectedRows);// Close the connection
          connection.end((err)=>{if(err){
              console.error('Error closing the connection:', err.message);return;}
            console.log('Database connection closed.');});});});});});});

结语

通过本篇博客，你应该掌握了如何使用Node.js连接MySQL数据库，以及如何进行基本的CRUD操作。希望这些示例代码能帮助你在工作或学习中更好地使用Node.js和MySQL构建高性能的Web应用。

最后问候亲爱的朋友们，并邀请你们阅读我的全新著作