nodejs 项目中如何对 mysql 增删改查

一、NODEJS项目中操作MYSQL的基本流程

在Node.js项目中操作MySQL数据库，通常涉及建立数据库连接、执行SQL语句、处理查询结果、关闭连接。Node.js使用mysql模块来简化与MySQL交互的过程。

首先，要建立与MySQL数据库的连接，可以使用mysql.createConnection()方法创建一个连接对象。接下来，在此连接上调用.query()方法执行SQL语句。针对增删改查（CRUD）操作，使用对应的SQL语句：INSERT增加数据、DELETE删除数据、UPDATE更新数据、SELECT查询数据。查询结果经处理后，需要关闭数据库连接以释放资源。

二、建立数据库连接

连接MySQL数据库

在Node.js中操作MySQL之前，确保已经安装了mysql模块。若未安装，使用npm install mysql命令进行安装。创建连接时，需要指定数据库服务器的地址、端口、用户名、密码及连接的数据库名。

const mysql = require('mysql');

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

打开与关闭连接

成功创建连接对象后，通过调用connection.connect()方法来建立连接。在数据库操作完成后，要调用connection.end()方法关闭连接，避免占用数据库资源。

connection.connect((err) => {

  if (err) throw err;
  console.log('Connected!');
});
// ... 增删改查的操作
connection.end((err) => {
  if (err) throw err;
  console.log('Disconnected!');
});

三、执行SQL语句

查询数据（SELECT）

使用SELECT语句来从数据库中查询数据。可以提取全表数据或根据特定条件进行筛选。

const sql = 'SELECT * FROM users WHERE age >= ?';

connection.query(sql, [18], (err, results, fields) => {
  if (err) throw err;
  console.log(results);
});

在此例中，通过占位符?代替实际参数值，connection.query()方法第二个参数为数组，包含替换占位符的值。

插入数据（INSERT）

使用INSERT INTO语句将新记录添加到数据库表中。

const post  = {username: 'testuser', age: 30};

const sql = 'INSERT INTO users SET ?';
connection.query(sql, post, (err, results, fields) => {
  if (err) throw err;
  console.log('Inserted Row ID:', results.insertId);
});

在这里，post对象中的属性名应与数据库表字段对应。

四、数据的增删改操作

删除数据（DELETE）

使用DELETE FROM语句根据条件从数据库中删除记录。

const sql = 'DELETE FROM users WHERE id = ?';

connection.query(sql, [5], (err, results, fields) => {
  if (err) throw err;
  console.log('Deleted Rows:', results.affectedRows);
});

这段代码删除id等于5的用户记录。

更新数据（UPDATE）

使用UPDATE语句对数据库中现有的记录进行修改。

const sql = 'UPDATE users SET age = ? WHERE id = ?';

connection.query(sql, [40, 5], (err, results, fields) => {
  if (err) throw err;
  console.log('Updated Rows:', results.changedRows);
});

该命令将id为5的用户的年龄更新为40岁。

五、错误处理与优化

错误处理

在进行数据库操作时，应添加错误处理逻辑。通常使用回调函数的err参数来捕捉错误。

连接池

在处理高并发情况时，使用连接池是一个更好的选择。连接池可以有效管理数据库连接，提升性能。

const pool = mysql.createPool({

  connectionLimit : 10,
  host            : 'localhost',
  user            : 'your_username',
  password        : 'your_password',
  database        : 'my_database'
});
pool.query('SELECT 1 + 1 AS solution', (err, results, fields) => {
  if (err) throw err;
  console.log('The solution is: ', results[0].solution);
});

六、SQL注入防范

在Node.js项目中使用mysql模块操作MySQL数据库时，务必注意防止SQL注入攻击。使用参数化查询是防范SQL注入的有效方法。如前面示例所示，在query()方法中使用问号?作为参数的占位符，可避免将用户输入直接拼接到SQL语句中。

七、事务处理

在对数据库进行增删改操作时，可以使用事务来确保数据的一致性。当在一个事务中执行多个操作时，要么全部成功，要么全部失败。

connection.beginTransaction((err) => {

  if (err) throw err;
  connection.query('INSERT INTO log SET data=?', logEntry, (err, result) => {
    if (err) {
      return connection.rollback(() => {
        throw err;
      });
    }
    const logId = result.insertId;
    connection.query('UPDATE users SET last_log_id = ? WHERE id = ?', [logId, userId], (err, result) => {
      if (err) {
        return connection.rollback(() => {
          throw err;
        });
      }
      connection.commit((err) => {
        if (err) {
          return connection.rollback(() => {
            throw err;
          });
        }
        console.log('Transaction Complete.');
      });
    });
  });
});

在此示例中，首先开启一个事务，接着插入一条日志记录，然后更新用户的最后日志ID。如果这些操作中任何一个失败，事务将回滚，撤销所有操作。

通过以上步骤，您可以在Node.js项目中实现对MySQL数据库的增删改查操作。每一步都需注重代码质量和安全性，确保数据的有效性与一致性。

相关问答FAQs：

1. 如何在 Node.js 项目中连接 MySQL 数据库？

在 Node.js 项目中，你可以使用 mysql 模块来连接 MySQL 数据库。首先，需要安装 mysql 模块，可在命令行中运行 npm install mysql 来安装。然后，在代码中引入 mysql 模块并创建数据库连接，使用正确的主机、用户名、密码和数据库名称等参数。接下来就可以通过该连接对象执行各种数据库操作，如增删改查等。

2. 如何在 Node.js 项目中进行 MySQL 数据的增删改查操作？

在 Node.js 中执行 MySQL 数据的增删改查操作，可以使用 SQL 语句执行相应的操作。例如，执行插入操作可以使用 INSERT INTO 语句，执行更新操作可以使用 UPDATE 语句，执行删除操作可以使用 DELETE FROM 语句，执行查询操作可以使用 SELECT 语句。在具体的代码中，你可以使用连接对象的 query 方法来执行这些 SQL 语句，并通过回调函数获取结果或处理错误。

3. Node.js 项目中如何处理 MySQL 数据操作的异步回调？

在 Node.js 中，由于大部分数据库操作是异步的，因此在执行 MySQL 数据操作时需要注意处理异步回调。一种常见的处理方式是使用 Promise，将数据库操作封装成 Promise 对象，并使用 async/awAIt 或 then/catch 来处理异步操作。另一种方式是使用回调函数，在执行数据库操作时传递一个回调函数给查询方法，在回调函数中处理操作结果或错误。无论是哪种方式，都要保证在进行下一步操作之前，先等待数据库操作完成并获取结果。

最后建议，企业在引入信息化系统初期，切记要合理有效地运用好工具，这样一来不仅可以让公司业务高效地运行，还能最大程度保证团队目标的达成。同时还能大幅缩短系统开发和部署的时间成本。特别是有特定需求功能需要定制化的企业，可以采用我们公司自研的企业级低代码平台：织信Informat。 织信平台基于数据模型优先的设计理念，提供大量标准化的组件，内置AI助手、组件设计器、自动化（图形化编程）、脚本、工作流引擎（BPMN2.0）、自定义API、表单设计器、权限、仪表盘等功能，能帮助企业构建高度复杂核心的数字化系统。如ERP、MES、CRM、PLM、SCM、WMS、项目管理、流程管理等多个应用场景，全面助力企业落地国产化/信息化/数字化转型战略目标。