node.js对数据库mysql的连接与操作（增、删、改、查、五种SQL语法）

在现代的Web开发中，Node.js由于其高效的异步处理能力，常被用作后端开发语言。而MySQL作为一种流行的关系数据库管理系统，与Node.js的结合使用非常普遍。本文将详细介绍如何使用Node.js连接MySQL数据库，并进行增、删、改、查的基本操作。

一、环境准备

在开始之前，请确保已安装Node.js和MySQL。你还需要使用npm安装mysql模块。可以通过以下命令安装：

npm install mysql

二、连接MySQL数据库

首先，我们需要创建一个连接对象来连接MySQL数据库。以下是一个简单的示例：

const mysql = require('mysql');

// 创建连接对象
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'your_password',
  database: 'your_database'
});

// 连接数据库
connection.connect((err) => {
  if (err) {
    console.error('数据库连接失败:', err.stack);
    return;
  }
  console.log('数据库连接成功，ID:', connection.threadId);
});

在这个示例中，我们创建了一个连接对象，同时指定了数据库地址、用户名、密码和数据库名称。然后通过connect方法连接数据库。

三、增、删、改、查操作示例

1. 插入数据（增）

我们可以使用INSERT语句向数据库中添加新记录。

const insertSql = 'INSERT INTO users (name, age) VALUES (?, ?)';
connection.query(insertSql, ['张三', 25], (err, results) => {
  if (err) {
    console.error('插入失败:', err);
    return;
  }
  console.log('插入成功，ID:', results.insertId);
});

2. 查询数据（查）

使用SELECT语句查询数据库中的数据。

const selectSql = 'SELECT * FROM users';
connection.query(selectSql, (err, results) => {
  if (err) {
    console.error('查询失败:', err);
    return;
  }
  console.log('查询结果:', results);
});

3. 更新数据（改）

使用UPDATE语句修改数据库中的记录。

const updateSql = 'UPDATE users SET age = ? WHERE name = ?';
connection.query(updateSql, [30, '张三'], (err, results) => {
  if (err) {
    console.error('更新失败:', err);
    return;
  }
  console.log('更新成功，受影响的行数:', results.affectedRows);
});

4. 删除数据（删）

使用DELETE语句从数据库中删除记录。

const deleteSql = 'DELETE FROM users WHERE name = ?';
connection.query(deleteSql, ['张三'], (err, results) => {
  if (err) {
    console.error('删除失败:', err);
    return;
  }
  console.log('删除成功，受影响的行数:', results.affectedRows);
});

四、关闭数据库连接

完成所有操作后，记得关闭数据库连接：

connection.end((err) => {
  if (err) {
    return console.log('关闭连接失败:', err.message);
  }
  console.log('数据库连接已关闭。');
});

总结

通过以上的示例代码，我们展示了如何使用Node.js连接MySQL数据库，并分别进行了增、删、改、查四种基本操作。Node.js与MySQL的组合能够有效支持我们构建高效的Web应用。在实际开发中，建议对数据库操作进行错误处理，并考虑使用连接池来优化数据库连接的性能。