文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

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

2024-04-02 19:55

关注

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

  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');
})

总结

到此这篇关于Node.js对MySQL数据库增删改查的文章就介绍到这了,更多相关Node.js对MySQL增删改查内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-数据库
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯