• 技术文章 >web前端 >js教程

    如何使用Nodejs连接Mysql,实现基本的增删改查操作

    青灯夜游青灯夜游2021-06-16 18:02:48转载833
    本篇文章给大家介绍一下如何使用Nodejs连接Mysql,实现基本的增删改查(CRUD)操作。有一定的参考价值,有需要的朋友可以参考一下,希望对大家有所帮助。

    【推荐学习:《nodejs 教程》】

    接下来示例代码的主要技术点包括

    0、前置需求

    1、node连接数据库

    2、 连接mysql数据库,实现表格显示功能

    2.png

    3.png

      const koaNunjucks = require('koa-nunjucks-2');
      const path = require('path');
    
       // 注入 nunjucks 模板引擎
       app.use(koaNunjucks({
          ext: 'html', // html文件的后缀名
          path: path.join(__dirname, 'views'), // 视图文件放在哪个文件夹下
          nunjucksConfig: {
            trimBlocks: true // 自动去除 block/tag 后面的换行符
          }
        }));
        //在 /userAll这个路由中我们不直接返回数据了,我们返回table.html页面
      router.get("/userAll", async ctx => {
      const userAll = await resDb("SELECT * FROM user")
      await ctx.render("table",{userAll})
      })

    3、 添加数据到mysql数据库中

    7.png

    8.png

    9.png

    4、 通过id更新数据

    5、通过id删除单条数据

    6、 完整代码

            const Koa = require("koa")
            const Router = require("koa-router")
            const mysql = require("mysql")
            const koaNunjucks = require('koa-nunjucks-2');
            const path = require('path');
    
            const app = new Koa();
            const router = new Router();
    
            // mysqljs 连接 mysql数据库
            let connection = mysql.createConnection({
                host: '127.0.0.1', // mysql所在的主机,本地的话就是 127.0.0.1 或者 localhost, 如果数据库在服务器上,就写服务器的ip
                user: 'root', // mysql的用户名 默认root
                password: 'mysql密码', // mysql的密码
                database: 'db1' // 你要连接那个数据库
            })
    
            // 连接 mysql
            connection.connect(err=>{
                // err代表失败
                if(err) {
                    console.log("数据库初始化失败");
                }else {
                    console.log("数据库初始化成功");
                }
            })
    
            // 因为 mysqljs不支持 Promise方式CRUD数据
            // 所以我们做一个简单的封装
            function resDb(sql, params) {
                return new Promise((resolve,reject) => {
                    let sqlParamsList = [sql]
                    if(params) {
                        sqlParamsList.push(params)
                    }
                    connection.query(...sqlParamsList, (err,res) => {
                        if(err) {
                            reject(err)
                        }else {
                            resolve(res)
                        }
                    })
                })
            }
    
             // 注入 nunjucks 模板引擎
             app.use(koaNunjucks({
                ext: 'html', // html文件的后缀名
                path: path.join(__dirname, 'views'), // 视图文件放在哪个文件夹下
                nunjucksConfig: {
                  trimBlocks: true // 自动去除 block/tag 后面的换行符
                }
              }));
    
            //请求 /userAll 的时候返回数据
            router.get("/userAll", async ctx => {
                const userAll = await resDb("SELECT * FROM user")
                await ctx.render("table",{userAll})
            })
    
            //请求 /addUser 接受前端传过来的数据,并且把数据持久化到数据库中
            router.get("/addUser", async ctx => {
                const { name, age } = ctx.query
                // 判断 name 和 age是否有值,都有值时,数据存入数据库,刷新表格页面
                // 否则直接返回到表格页面
                if(name && age) {
                await resDb("INSERT INTO user values(null,?,?)",[name, age])
                }
                //重定向路由,到 userAll
                ctx.redirect("/userAll")
            })
    
            //请求 /updateUser 接受前端传过来的数据,并且把数据持久化到数据库中
            router.get("/updateUser", async ctx => {
                const { id, name, age } = ctx.query
                // 判断 id, name 和 age是否有值,都有值时,更新数据库中的数据,刷新表格页面
                // 否则直接返回到表格页面
                if(id, name && age) {
                await resDb("UPDATE user SET name=?, age=? WHERE id=?",[name, age, id])
                }
                //重定向路由,到 userAll
                ctx.redirect("/userAll")
            })
    
            //请求/delete/:id  接受前端传过来的数据,并且把对应的id的数据删掉
            router.get("/delete/:id", async ctx => {
                const { id } = ctx.params
                // 判断 id否有值,有值时,根据id删除数据库中的数据,刷新表格页面
                // 否则直接返回到表格页面
                if(id) {
                await resDb("DELETE FROM user WHERE id=?",[id])
                }
                //重定向路由,到 userAll
                ctx.redirect("/userAll")
            })
    
            //测试代码
            router.get("/hello", ctx => {
                ctx.body = "hello"
            })
    
    
            app
            .use(router.routes())
            .use(router.allowedMethods())
            .listen(3333,()=>{
                console.log("server running port:" + 3333);
            })

    7、写在最后

    更多编程相关知识,请访问:编程视频!!

    以上就是如何使用Nodejs连接Mysql,实现基本的增删改查操作的详细内容,更多请关注php中文网其它相关文章!

    声明:本文转载于:掘金社区,如有侵犯,请联系admin@php.cn删除
    专题推荐:Nodejs Mysql 增删改查
    上一篇:浅谈Angular中的$injector对象 下一篇:Dom节点 vs 元素,两者有什么区别?
    第16期线上培训班

    相关文章推荐

    • 详解nodejs在控制台打印高亮代码的方法• 详解Nodejs Buffer模块的常用API• Nodejs中使用string_decoder模块将buffer转成string• vscode中如何断点调试nodejs• nodejs设置NODE_ENV时发生错误怎么解决?• 详解Nodejs中的阻塞和非阻塞

    全部评论我要评论

  • 取消发布评论发送
  • 1/1

    PHP中文网