使用nodejs连接mySQL写接口全过程(增删改查)

更新时间：2023年12月20日 10:02:25 作者：撒个辣酱

这篇文章主要给大家介绍了关于使用nodejs连接mySQL写接口(增删改查)的相关资料,MySQL是一种常用的关系型数据库,它与Node.js的结合可以提供强大的数据存储和检索功能,需要的朋友可以参考下

前言

提示：请先建好mySQL数据库，本案例所用node版本为16.20.0：

提示：以下是本篇文章正文内容，下面案例可供参考

一、navicat建立链接

文件-新建链接-MySQL

默认端口为3306，连接名自定，密码为安装MySQL设置的数据库密码

二、建数据库表

打开或新建一个数据库，建立一张新表，设计好字段后加入两条测试数据

此处建立表名为userList（后面会用到）

字段：name, password, money, userId, sex, company, job

三、新建nodejs项目，建议直接使用Hbuilder编辑器快速创建

提示：请一定要确认nodejs版本是否与npm版本有冲突

打开Hbuilder，文件-新建-项目，选择Express项目

四、新建的项目在vscode打开后，进入app.js

1、在项目内写入启动项目的代码

提示：启动代码需写在var app = express();代码之后，否则报错

本案例将服务启动在2323端口

app.listen(2323, () => console.log('服务已启动在2323端口'))

2、文件夹右键，在集成终端中打开，输入node app.js启动服务

启动成功后会在终端内显示你打印的字样，说明启动成功

此时可写一个简单的get接口来测试是否有问题

app.get('/', (req, res) => {
  res.json('helloWord')
})

写入此代码后，进入localhost:2323/或者127.0.0.1:2323/，则返回helloWord

此时证明服务器没问题了

五、建立MySQL链接

因Hbuilder建立的express项目并没有下载Mysql插件，所以需在终端自行下载

直接在终端运行 npm install mysql 即可

下载成功后在router文件夹下index.js下建立链接，在此处编写具体接口代码
代码示例：

const mysql = require('mysql');

// 链接数据库
const conn = mysql.createConnection({ 
  user:'root',          //用户名使用前面数据库建立链接里的用户名
  password:'******',	//密码
  port:3306,
  host:'localhost',		//主机（默认都是local host）
  database:'node'       //数据库名注意！！！不是你新建连接起的连接名
})
// 测试连接
conn.connect(err=>{
  console.log(err,'连接成功');
})

启动项目后如果返回null,链接成功，则链接数据库成功

六、简单查询列表

提示：此处开始用到sql语句，请在navicat运行成功后再进行编写

代码示例：

index.js

// 获取用户列表
router.get('/getList', (req, res, next) => {
  // sql语句查询列表所有数据  SELECT * FROM 你数据库的表名，我这里是userList
    let sql = "SELECT * FROM userlist";
  conn.query(sql, (err, r) => {
    res.json({code: 200, data: r, msg: '成功'})
  })
});

postman测试结果：

七、添加数据

代码示例：

index.js

// 在index.js同目录下创建新的interface.js文件，并在index.js最上面引入文件interface.js
var interface = require('./interface')

// 添加用户接口
router.post('/addUser', (req, res) => {
  interface.addUser(conn, req, res)
})

interface.js代码示例：此处设置了用户名和密码必须传递，否则失败

此处使用了随机生成id函数randomId

// 添加用户
const addUser = (conn, req, res) => {
    const params = req.body
    // console.log(params);
    const ret = {}
    if (params.name == '') {
        ret.code = 501
        ret.data = null
        ret.msg = '请传递用户名'
        res.json(ret)
        return
    } else if (params.password == '') {
        ret.code = 501
        ret.data = null
        ret.msg = '请设置用户密码'
        res.json(ret)
        return
    } else {
        conn.query(`INSERT INTO userlist(name,password,money,userid,sex,company,job)VALUES(
            '${params.name}','${params.password}','${params.money}','${randomId()}','${params.sex}','${params.company}','${params.job}')`,
            function (error, results, fields) {
            if (error) {
                ret.code = 500
                ret.data = null
                ret.msg = error.sqlMessage
                return
            }
            if (results.length === 0) {
                ret.code = 501
                ret.message = '请传递正确的参数'
            } else {
                ret.code = 200
                ret.data = null
                ret.msg = '添加成功'
            }
            res.json(ret)
        })
    }
}

const randomId = function uuid(){
    return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
        var r = Math.random() * 16 | 0,
            v = c == 'x' ? r : (r & 0x3 | 0x8);
        return v.toString(16);
    });		
}

//最后exports
exports.addUser = addUser

postman测试结果：

此时查看数据库表，会多出一条刚刚添加的数据

八、修改数据

index.js代码示例：

// 修改用户接口
router.post('/updateUser', (req, res) => {
  interface.updateUser(conn, req, res)
})

interface.js代码示例: 传递参数比添加多了一个userId

// 修改用户
const updateUser = (conn, req, res) => {
    const params = req.body
    // console.log(params);
    const ret = {}
    if (params.name == '') {
        ret.code = 501
        ret.data = null
        ret.msg = '请传递用户名'
        res.json(ret)
        return
    } else if (params.password == '') {
        ret.code = 501
        ret.data = null
        ret.msg = '请设置用户密码'
        res.json(ret)
        return
    } else if (params.userId == '') {
        ret.code = 501
        ret.data = null
        ret.msg = '请传递用户id'
        res.json(ret)
        return
    } else {
        conn.query(`UPDATE userlist SET 
        name="${params.name}",
        password="${params.password}",
        money="${params.money}",
        sex="${params.sex}",
        company="${params.company}",
        job="${params.job}" WHERE userId="${params.userId}";`,
            function (error, results, fields) {
                if (error) {
                    ret.code = 500
                    ret.data = null
                    ret.msg = error.sqlMessage
                    return
                }
                if (results.length === 0) {
                    ret.code = 501
                    ret.message = '请传递正确的参数'
                } else {
                    ret.code = 200
                    ret.data = null
                    ret.msg = '修改成功'
                }
                res.json(ret)
            })
    }
}

//最后exports
exports.updateUser = updateUser

postman测试结果:

修改成功后刷新数据库表，对应userId的数据会更改

九、删除数据

index.js代码示例：

// 删除用户接口
router.post('/deleteUser', (req, res) => {
  interface.deleteUser(conn, req, res)
})

interface.js代码示例: 参数仅传userId

// 删除用户
const deleteUser = (conn, req, res) => {
    const params = req.body
    // console.log(params);
    const ret = {}
    if (params.userId == '') {
        ret.code = 501
        ret.data = null
        ret.msg = '请传递用户id'
        res.json(ret)
        return
    } else { 
        conn.query(`DELETE FROM userlist WHERE userId="${params.userId}";`,
            function (error, results, fields) {
                // console.log(error);
                if (error) {
                    ret.code = 500
                    ret.data = null
                    ret.msg = error.sqlMessage
                    return
                }
                if (results.length === 0) {
                    ret.code = 501
                    ret.message = '请传递正确的参数'
                } else {
                    ret.code = 200
                    ret.data = null
                    ret.msg = '删除成功'
                }
                res.json(ret)
            })
    }
}

//最后exports
exports.deleteUser = deleteUser

postman测试结果：删除刚刚修改的那一条

成功后刷新数据库表，刚刚那条数据发现已删除

总结

本人nodejs仅还在学习阶段，希望能对学习nodejs的小伙伴有所帮助！

到此这篇关于使用nodejs连接mySQL写接口(增删改查)的文章就介绍到这了,更多相关nodejs连接mySQL写接口内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

node.js博客项目开发手记
本篇文章给大家总结了node.js博客项目开发的相关步骤以及知识点分享，有兴趣的朋友参考下。
2018-03-03
nodejs中的express-jwt的使用解读
这篇文章主要介绍了nodejs中的express-jwt的使用解读，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-04-04
nodejs入门教程一：概念与用法简介
这篇文章主要介绍了nodejs入门教程之概念与用法,结合实例形式分析了nodejs基本概念、功能、命令与相关使用技巧,需要的朋友可以参考下
2017-04-04
connect中间件session、cookie的使用方法分享
今天大象哥用了下connect的session和cookie，感觉还挺好用的，分享一下(里面坑挺多的，文档写的太模糊了，费了哥不少时间)。
2014-06-06
基于模板引擎Jade的应用(详解)
下面小编就为大家分享一篇基于模板引擎Jade的应用详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2017-12-12
WebSocket+node.js创建即时通信的Web聊天服务器
这篇文章主要为大家详细介绍了WebSocket+node.js创建即时通信的Web聊天服务器的相关资料，感兴趣的小伙伴们可以参考一下
2016-08-08
gulp安装以及打包合并的方法教程
这篇文章主要给大家介绍了关于gulp实现人一个打包合并的方法教程，并分享了gulp打包js/css时合并成一个文件时的顺序的解决方法，文中通过示例代码介绍的非常详细，需要的朋友可以参考借鉴，下面随着小编来一起学习学习吧。
2017-11-11
如何在Nodejs中使用模块fs文件系统
这篇文章主要介绍了如何在Nodejs中使用模块fs文件系统，对nodejs感兴趣的同学，可以参考下
2021-05-05
async/await优雅的错误处理方法总结
这篇文章主要给大家介绍了关于async/await优雅的错误处理方法的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-01-01
在Node.js中处理Promise中错误的示例代码
在现代JavaScript开发中,尤其在Node.js环境中,Promise已成为处理异步操作的重要方式,然而,Promise的错误处理却常常让开发者感到困惑,在这篇文章中,我们将深入探讨如何在Node.js中处理Promise中的错误,提供多个示例代码,以便于理解和实践,需要的朋友可以参考下
2024-09-09