当前位置：首页 > article >正文

在项目中操作 MySQL

article 2025/2/22 11:51:23

在现代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));