Node.js对MySQL数据库的增删改查实战记录

在项目中操作数据库的三大步骤

1. 安装操作 MySQL 数据库的第三方模块（mysql）

2. 通过 mysql 模块连接到 MySQL 数据库

3. 通过 mysql 模块执行 SQL 语句

操作数据库的具体步骤

一：安装MySQL模块及express模块

MySQL模块是托管于npm上的第三方模块，我们可以运行下方命令安装MySQL第三方包，通过它来建立node.js项目与MySQL数据库的连接，进而操作数据库（以下代码在终端中运行）

//安装mysql第三方模块
npm i mysql
//安装express第三方模块
npm i express

二：通过express创建一个服务器

// 引入express
const express = require('express');
// 创建服务器
const app = express();
// 启动服务器
app.listen(80, () => {
   console.log('http://127.0.0.1');
})

三：配置MySQL模块

在使用 MySQL 模块操作 MySQL 数据库之前，必须先对 mysql模块进行必要的配置，主要的配置步骤如下：

// 1.引入mysql
const mysql = require('mysql');
// 2.建立与mysql数据库连接
var db = mysql.createPool({
   host: '127.0.0.1',   // 数据库的 ip 地址
   user: 'root',        // 登录数据库的账号
   password: '123456',  // 登录数据库的密码
   database: 'web67'    // 指定要操作哪个数据库
});

四：测试 mysql 模块能否正常工作

调用 db.query() 函数，指定要执行的 SQL 语句，通过回调函数拿到执行的结果

// 测试mysql模块是否能正常运行，查找所有数据并显示至页面
   db.query('select * from one', (err, data) => {
       if (err) return console.log(err.message);
       if (data.length === 0) return console.log('数据库无数据');
       console.log(data) //data是从数据库中查找到的数据
       })
   });

以上代码全部准备完毕后开始对MySQL数据库中的数据进行增删改查：

SELECT：查询one数据表中所有的数据:

案例代码：

// 获取数据库中的数据
app.get('/selectuser', (req, res) => {
   // 查看数据库连接是否成功
   db.query('select * from one', (err, data) => {
       //err不为空则表示错误
       if (err) return console.log(err.message);
       if (data.length === 0) return console.log('获取失败');
       res.send(data)
   })
});

INSERT INTO:向数据库中添加数据：

案例代码：

这里用到了post请求，需要通过req.body接收客户端请求的数据，并通过app.use(express.urlencoded({extended:false}))代码行将数据进行解析（见下方完整代码）

// 向数据库添加数据
app.post('/insertuser', (req, res) => {
   // 接收客户端请求的数据
   const body = req.body;
   // 构建sql语句
   const sql = 'insert into one set ?'
       // 将客户请求的数据插入到数据库中
   db.query(sql, body, (err, data) => {
       if (err) return console.log(err.message);
       if (data.affectedRows !== 1) return console.log('添加失败');
       res.send({
           status: 0,
           msg: '添加数据成功'
       })
   })
})

UPADTE:修改数据库中的数据：

案例代码：

// 修改数据库中数据
app.post('/updateuser', (req, res) => {
   //接收客户端请求的数据
   const body = req.body;
   //构建修改的sql语句
   const sql = 'update one set uname=? where id=?';
   db.query(sql, [body.uname, body.id], (err, data) => {
       if (err) return console.log(err.message);
       if (data.affectedRows !== 1) return console.log('修改失败');
       res.send({
           status: 0,
           msg: '修改数据成功'
       })
   })
})

DELETE:删除数据库中的数据：

案例代码：

// 删除数据库中的数据
app.get('/deleteuser/:id', (req, res) => {
   // 获取客户端提交的数据,req.params通过:冒号匹配动态参数
   const id = req.params.id;
   // 构建删除的sql语句，一般为了防止数据被永久性删除，我们会通过update将该条数据对应的
      状态码先修改为0
   const sql = 'update one set status=0 where id=?';
   // 执行sql
   db.query(sql, id, (err, data) => {
       if (err) return console.log(err.message);
       if (data.affectedRows !== 1) return console.log('删除失败');
       res.send({
           status: 0,
           msg: '删除成功'
       })
   })
})

到这里通过express中间件对MySQL数据库的增删改查就完成啦，【完整代码】如下：

// 通过express中间件实现对mysql数据库的增删改查
const express = require('express');
// 创建一个服务器
const app = express();
// 解析客户端请求的数据
app.use(express.urlencoded({ extended: false }));
// 引入mysql操作数据库
const mysql = require('mysql');
// 配置数据库
const db = mysql.createPool({
   host: '127.0.0.1', //数据库ip地址
   user: 'root', //数据库账号
   password: '123456', //数据库密码
   database: 'web67' //数据库名称
});

// 获取数据库中的数据
app.get('/selectuser', (req, res) => {
   // 查看数据库连接是否成功
   db.query('select * from one', (err, data) => {
       if (err) return console.log(err.message);
       if (data.length === 0) return console.log('获取失败');
       res.send(data)
   })
});

// 向数据库添加数据
app.post('/insertuser', (req, res) => {
   // 接收客户端请求的数据
   const body = req.body;
   // 构建sql语句
   const sql = 'insert into one set ?'
       // 将客户请求的数据插入到数据库中
   db.query(sql, body, (err, data) => {
       if (err) return console.log(err.message);
       if (data.affectedRows !== 1) return console.log('添加失败');
       res.send({
           status: 0,
           msg: '添加数据成功'
       })
   })
})

// 修改数据库中数据
app.post('/updateuser', (req, res) => {
   const body = req.body;
   const sql = 'update one set uname=? where id=?';
   db.query(sql, [body.uname, body.id], (err, data) => {
       if (err) return console.log(err.message);
       if (data.affectedRows !== 1) return console.log('修改失败');
       res.send({
           status: 0,
           msg: '修改数据成功'
       })
   })
})

// 删除数据库中的数据(指定id)
app.get('/deleteuser/:id', (req, res) => {
       const id = req.params.id; //id为动态参数，所以要通过req.params获取
       const sql = 'update one set status=0 where id=?'
       db.query(sql, id, (err, data) => {
           if (err) return console.log(err.message);
           if (data.affectedRows !== 1) return console.log('删除数据失败');
           res.send({
               status: 0,
               msg: '删除成功'
           })
       })
   })
   // 启动服务器
app.listen(80, () => {
   console.log('http://127.0.0.1');
})

来源：https://blog.csdn.net/SunFlower914/article/details/120708890