在项目中操作 MySQL

在现代Web开发中，Node.js因其非阻塞I/O模型和高效的性能成为了构建后端服务的热门选择之一。与此同时，MySQL作为最流行的关系型数据库管理系统之一，凭借其稳定性、可靠性和易用性，在数据存储方面扮演着重要角色。本文将详细介绍如何在一个Node.js项目中有效地操作MySQL数据库。

准备工作

安装Node.js和MySQL

确保你的开发环境中已经安装了Node.js。你可以通过运行 node -v 和 npm -v 来检查是否已正确安装Node.js及其包管理器npm。

接下来，你需要一个MySQL数据库实例。可以通过本地安装MySQL服务器或者使用云服务商提供的MySQL服务。

初始化项目

首先，创建一个新的Node.js项目目录，并初始化npm项目：

mkdir node-mysql-demo
cd node-mysql-demo
npm init -y

这会生成一个 package.json 文件，记录项目的依赖信息等。

安装必要的依赖

为了连接和操作MySQL数据库，我们将使用 mysql2 包。它是一个功能强大的MySQL客户端库，支持Promise API，便于异步编程。

npm install mysql2

连接到MySQL数据库

在项目根目录下创建一个名为 db.js 的文件，用于设置与MySQL数据库的连接配置：

const mysql = require('mysql2');// 创建数据库连接池
const pool = mysql.createPool({host: 'localhost', // 数据库地址user: 'root',      // 用户名password: '',      // 密码database: 'test_db'// 数据库名称
});module.exports = pool.promise(); // 返回一个支持Promise的连接池

这样做的好处是可以通过连接池来复用数据库连接，提高性能。

执行基本的CRUD操作

现在我们可以开始编写一些代码来执行基本的增删改查（CRUD）操作。

查询数据

创建一个 query.js 文件，演示如何从数据库中查询数据：

const db = require('./db');async function getProducts() {const [rows, fields] = await db.query('SELECT * FROM products WHERE status = ?',['active']);console.log(rows);
}getProducts();

这里我们使用了预处理语句，以防止SQL注入攻击。

插入数据

同样地，插入新记录也很简单：

async function addProduct(name, price) {const [result] = await db.execute('INSERT INTO products (name, price) VALUES (?, ?)',[name, price]);console.log(result.insertId); // 输出新插入记录的ID
}addProduct('New Product', 9.99);

更新数据

更新现有记录如下所示：

async function updateProduct(id, newName) {const [result] = await db.execute('UPDATE products SET name = ? WHERE id = ?',[newName, id]);console.log(`Changed rows: ${result.affectedRows}`);
}updateProduct(1, 'Updated Product Name');

删除数据

最后，删除记录可以这样做：

async function deleteProduct(id) {const [result] = await db.execute('DELETE FROM products WHERE id = ?',[id]);console.log(`Deleted rows: ${result.affectedRows}`);
}deleteProduct(1);

错误处理

在实际应用中，良好的错误处理机制是非常重要的。下面是如何改进上述函数以包含基本的错误处理逻辑：

async function safeOperation(operationFn) {try {await operationFn();console.log('Operation succeeded');} catch (error) {console.error('Error occurred:', error);}
}safeOperation(() => addProduct('Another Product', 19.99));