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

NodeJs实现对本地 mysql 数据库的增删改查

news 来源：原创 2024/7/7 22:12:55

写在前面

今天我们接着写nodejs对数据库的操作，今天实现简单的增删改查，读之前请先移步到这里NodeJs 连接本地 mySql 数据库获取数据,避免后续一些代码出险阅读断层。

安装 nodemon

npm install nodemon

因为 nodejs 的服务是本地启动，避免后续频繁启动服务，安装 nodemon 可以帮助我们实现热重载不安装也可以，手动重启就可以了。

整体文件结构如图

在这里插入图片描述

实现基础服务

/*** @author 是悟能了* @aim 实现基础服务* @fileName baseServer.js*/const express = require('express');
const bodyParser = require('body-parser');
const serve = express();
const port = 8000;// TODO: 解析获取到的 json 数据
serve.use(bodyParser.urlencoded({extended: false
}));serve.use(bodyParser.json());serve.listen(port, () => {console.log(`serve is running...port = ${port}`);
});module.exports = serve;

测试启动

nodemon baseBaseServer.js

在这里插入图片描述

实现基础数据库连接

/*** @author 是悟能了* @aim 链接 mysql 数据库* @fileName baseLinkData.js*/const mysql = require('mysql');
// TODO: 创建数据库链接
const db = mysql.createConnection({host: "localhost",user: "root",password: "**********", //自己的数据库链接密码database: "sys",
});db.connect((err) => {if (err) {console.error('Error connecting to MySQL database:', err);return;}console.log('Connected to MySQL database success');
});module.exports = db;

测试连接数据库

nodemon baseLinkDateBase.js

在这里插入图片描述

实现基础回调信息

// TODO: 回调信息
module.exports = (status, code, message, data = [] || {}) => {return JSON.stringify({status,code,message,data})
}

实现静态数据库表的管理

// 表明配置
const TABLES = {USERINFOS: 'userinfos'
}module.exports = TABLES;

实现 CURD 功能

接口测试连通性

/*** @author 是悟能了* @aim 实现基础的 CURD*/const serve = require('./baseServer.js'); // 引入基础服务
const db = require('./baseLinkDateBase.js'); // 引入数据库链接
const TABLES = require('./TABLES.js'); // 引入 database - table
const errContent = require('./status.js'); // 引入回调信息// TODO: 测试接口连通性
serve.get("/", (req, res) => {// res.status(403);res.send(errContent(200, 1001, '接口连通性成功'));
});

启动服务

nodemon handleDataBase.js

在这里插入图片描述

查询所有数据

// TODO: 查询所有数据
serve.get("/api/v1/optionList", (req, res) => {const sql = `SELECT * FROM ${TABLES.USERINFOS}`;console.log(`当前执行SQL - ${sql}`);db.query(sql, (err, result) => {if (err) {res.status(500).send(errContent(500, 1009, '数据库访问失败'));} else {res.status(200).send(errContent(200, 1001, '查询成功', result));}})
});

在这里插入图片描述

新增一条数据

// TODO: 增加一条数据
serve.post("/api/v1/optionList", (req, res) => {const params = req.body;const sql = `INSERT INTO ${TABLES.USERINFOS}(name,age,gender) VALUES(?,?,?)`;const value = [params.name, params.age, params.gender];console.log(`当前执行SQL - ${sql} - ${params.name}`);db.query(sql, value, (err, result) => {if (err) {res.status(500).send(errContent(500, 1009, '新增失败'));} else {res.status(200).send(errContent(200, 1001, '新增成功'));}})
});

在这里插入图片描述

更新一条数据

// TODO: 更新一条数据
serve.put("/api/v1/optionList", (req, res) => {const params = req.body;const sql = `UPDATE ${TABLES.USERINFOS} SET gender = ? WHERE name = ?`;const value = ['women', params.name]console.log(`当前执行SQL - ${sql} - ${params.name}`);db.query(sql, value, (err, result) => {if (err) {res.status(500).send(errContent(500, 1009, '更新失败'));} else {res.status(200).send(errContent(200, 1001, '更新成功'));}})
});

在这里插入图片描述

删除一条数据

// TODO: 删除一条数据
serve.delete("/api/v1/optionList", (req, res) => {const params = req.body;const sql = `DELETE FROM ${TABLES.USERINFOS} WHERE name = ?`;const value = [params.name];console.log(`当前执行SQL - ${sql} - ${params.name}`);db.query(sql, value, (err, result) => {if (err) {res.status(500).send(errContent(500, 1009, '删除失败'));} else {res.status(200).send(errContent(200, 1001, '删除成功'));}})
});

在这里插入图片描述

根据条件查询

// TODO: 根据条件查询
serve.get("/api/v1/optionList/:name", (req, res) => {const params = req.params;console.log(`当前参数 - ${JSON.stringify(params)}`);const sql = `SELECT * FROM ${TABLES.USERINFOS} WHERE name = ?`;const value = [params.name];console.log(`当前执行SQL - ${sql}`);db.query(sql, value, (err, result) => {if (err) {res.status(500).send(errContent(500, 1009, '查询失败'));} else {res.status(200).send(errContent(200, 1001, '查询成功', result));}})
})