AI 助理
备案控制台
开发者社区 数据库 文章 正文

express学会CRUD

2024-01-04 119
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，高可用系列 2核4GB
RDS MySQL Serverless 高可用系列，价值2615元额度，1个月
简介： express学会CRUD

使用express 搭建项目

1==> express 项目名 -e
2==> 然后按照提示就可以了
cd 项目名
3==>进入项目 下载依赖
cnpm i 
4==>启动项目
nodemon app.js
5==> 添加监听端口
在app.js 中 在（module.exports = app;前添加）就是在第40行 添加如下，监听端口
app.listen(666, () => {
    console.log('后端服务器启动成功，地址是: http://127.0.0.1:666')
})

下载mysql模块并连接数据库

应为我们要实现crud。所以我们需要与数据库相连接。
因为我们要下载mysql模块连接数据库。
第1步：下载模块 cnpm install mysql
第2步  创建connectmysql.js文件,连接mysql。connectmysql.js文件代码如下
const mysql=require("mysql");
const connection=mysql.createConnection({
    host:"localhost",  //默认链接的是本地
    user:"root",       //用户名
    password:"root",  //密码
    database:"xuexishopsystem"  //链接的是哪个数据库
})
// 下面是测试数据库是否链接成功
connection.query('select 1', (err, data) => {
    if (err) {
        console.log('报错了',err)
    } else {
        console.log('ok',data)
    }
})
// 因为别人要用connection ,所以我要将它暴露出去哦
module.exports=connection;
第3步 执行 node connectmysql.js 看看是否链接成功

实现后端路由

在routes文件夹中新增一个文件。accounts.js文件
这个文件是实现对账号的增加删除更改查询的。
accounts.js 文件代码如下：
var express = require('express');
var router = express.Router();
// 引入连接数据库的模块
const connection=require("./connectmysql.js")
/* GET users listing. */
router.get('/', function(req, res, next) {
  res.send('respond with a resource');
});
module.exports = router;

在app.js中去使用路由

var accountsRouter = require('./routes/accounts'); //引入路由
// /accounts 是路由的前缀
app.use('/accounts', accountsRouter);  //使用路由

cors 处理跨域

安装 cnpm install cors
const cors = require('cors')
//在调用路由之前解决跨域
app.use(cors())
app.use('/', indexRouter);
app.use('/users', usersRouter);
app.use('/accounts', accountsRouter);

前端访问

前端输入： http://127.0.0.1:666/accounts get请求就可以输出respond with a resource

数据库的设计

数据库名称 smsm
表名 account
建表名的SQL命令
create table account (
    id int primary key auto_increment,
    username varchar(30),
    password varchar(30),
    usergroup varchar(30),
    ctime timestamp default current_timestamp
)

在cmd中去连接数据库

mysql -hlocalhost -uroot -proot  [连接数据库]

显示数据库列表

show databases;

创建一个数据库

create database xuexishopsystem;

使用创建的数据库

use xuexishopsystem;

查询某个数据库下的表

show tables;

创建一个表

create table account (
    id int primary key auto_increment,
    username varchar(30),
    password varchar(30),
    usergroup varchar(30),
    ctime timestamp default current_timestamp
);
直接进行复制就可以了,注意别忘记写错分号

Navicat Premium 软件中查看我们创建的数据库和表

在 Navicat Premium 中，我们在左侧的菜单那区域，右击；然后刷新。
就可以看见我们刚刚创建的数据库和表名

你在控制台插入sql语句，需要设置字符集编码

set  names gbk;

app.js的全部代码

var createError = require('http-errors');
var express = require('express');
var path = require('path');
var cookieParser = require('cookie-parser');
var logger = require('morgan');
var indexRouter = require('./routes/index');
var usersRouter = require('./routes/users');
var accountsRouter = require('./routes/accounts');
const cors = require('cors')
var app = express();
// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');
app.use(logger('dev'));
app.use(express.json());
app.use(express.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));
app.use(cors())
app.use('/', indexRouter);
app.use('/users', usersRouter);
app.use('/accounts', accountsRouter);
// catch 404 and forward to error handler
app.use(function(req, res, next) {
  next(createError(404));
});
// error handler
app.use(function(err, req, res, next) {
  // set locals, only providing error in development
  res.locals.message = err.message;
  res.locals.error = req.app.get('env') === 'development' ? err : {};
  // render the error page
  res.status(err.status || 500);
  res.render('error');
});
app.listen(666, () => {
  console.log('后端服务器启动成功，地址是: http://127.0.0.1:666')
})
module.exports = app;

connectmysql.js

var createError = require('http-errors');
var express = require('express');
var path = require('path');
var cookieParser = require('cookie-parser');
var logger = require('morgan');
var indexRouter = require('./routes/index');
var usersRouter = require('./routes/users');
var accountsRouter = require('./routes/accounts');
const cors = require('cors')
var app = express();
// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');
app.use(logger('dev'));
app.use(express.json());
app.use(express.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));
app.use(cors())
app.use('/', indexRouter);
app.use('/users', usersRouter);
app.use('/accounts', accountsRouter);
// catch 404 and forward to error handler
app.use(function(req, res, next) {
  next(createError(404));
});
// error handler
app.use(function(err, req, res, next) {
  // set locals, only providing error in development
  res.locals.message = err.message;
  res.locals.error = req.app.get('env') === 'development' ? err : {};
  // render the error page
  res.status(err.status || 500);
  res.render('error');
});
app.listen(666, () => {
  console.log('后端服务器启动成功，地址是: http://127.0.0.1:666')
})
module.exports = app;

accounts.js

var express = require('express');
var router = express.Router();
// 引入连接数据库的模块
const connection=require("./connectmysql.js")
/* GET users listing. */
router.get('/', function(req, res, next) {
  res.send('respond with a resource');
});
// 添加
router.post('/add', function (req, res) {
  console.log('req.body', req.body)
  let { username, password, usergroup } = req.body || {}
  //怎么知道自己写的这一条sql语句对不对，可以在控制台打印出来。然后执行一下就知道自己的sql语句写对了没有。【非常重要的调试技巧】
  // 1.这里是写语句
  console.log(`insert into account(username, password, usergroup) values('${username}','${password}','${usergroup}')`);
  // 2.执行sql语句
  const sqlStr = `insert into account(username, password, usergroup) values('${username}','${password}','${usergroup}')`;
  connection.query(sqlStr, (err,data) => {
    if (err) {
      res.send({
        code: 1,
        msg:'插入失败，呜呜'
      });
      throw err 
    } else {
      console.log(data)
      if (data.affectedRows>0) {
        res.send({
          code: 0,
          msg:'添加成功'
        });
      } else {
        res.send({
          code: 1,
          msg:'添加数据异常'
        });
      }
    }
  })
});
// 查询
router.post('/lookfor', function (req, res) {
  // 1.这里是写语句
  const sqlStr = 'select * from account';
    // 2.执行sql语句
  connection.query(sqlStr, (err, data) => {
    if (err) {
      res.send({
        code: 1,
        msg:'查询失败'
      });
      throw err 
    } else {
      console.log('查询',data)
        res.send({
          code: 0,
          msg: '查询成功',
          data
        });
      }
  })
});
// 删除
router.get('/del', function (req, res) {
  let { id } = req.query
   // 1.这里是写语句
  const sqlStr = `delete from account where id= ${id}`
    // 2.执行sql语句
  connection.query(sqlStr, (err, data) => {
    if (err) {
      res.send({
        code: 1,
        msg:'删除失败'
      });
      throw err 
    } else {
      //这个判断是否删除成功，因为有可能没有这个id的
      if (data.affectedRows>0) {
        console.log('删除',data)
        res.send({
          code: 0,
          msg:'删除成功'
        });
      } else {
        res.send({
          code: 1,
          msg:'删除失败'
        });
      }
    }
  })
});
// 修改
router.post('/edit', function (req, res) {
  let { username,usergroup,id,password } = req.body
   // 1.这里是写语句 左侧是数据库的字段，右侧是传递过来的值 
  // 这里需要注意一下逗号 不要忘记写
  const sqlStr = `update  account set username= '${username}',  password= '${password}', usergroup= '${usergroup}' where id= ${id}`
  // 2.执行sql语句
  connection.query(sqlStr, (err, data) => {
    if (err) {
      res.send({
        code: 1,
        msg:'修改失败'
      });
      throw err 
    } else {
      //这个判断是否删除成功，因为有可能没有这个id的
      if (data.affectedRows>0) {
        console.log('修改',data)
        res.send({
          code: 0,
          msg:'修改成功'
        });
      } else {
        res.send({
          code: 1,
          msg:'修改失败'
        });
      }
    }
  })
});
module.exports = router;

现在存在的问题

1. 如何高效去处判断前端是否把必须传递的参数传递过来了。
现在写的代码中，都没有去判断参数的正确性，直接进行执行了SQL语句，这样是不正确的。
2.返回体应该进行统一的封装，而不是在请求的时候像现在这样去写重复代码。
3.我现在在执行 select * from account 这样的SQL语句其实性能值非常低的，怎么去优化。

遇见问题，这是你成长的机会，如果你能够解决，这就是收获。

文章标签：
云数据库 RDS MySQL 版
数据库
前端开发
SQL
关系型数据库
MySQL
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
晚来南风晚相识
目录
相关文章
懒懒学c
|
C语言
分支和循环语句
分支和循环语句
懒懒学c
87 1
root8042965
|
Java 数据库连接 程序员
从头到尾手把手教你搭建阅读Mybatis源码的环境(程序员必备技能)
从头到尾手把手教你搭建阅读Mybatis源码的环境(程序员必备技能)
root8042965
329 0
文如秋雨
|
存储 iOS开发
SwiftUI极简教程17:Gestures手势的使用
SwiftUI极简教程17:Gestures手势的使用
文如秋雨
1208 0
SwiftUI极简教程17:Gestures手势的使用
阿里云开发者
|
5月前
|
人工智能 开发者
文章和 PPT 配图有救了！SVG 绘图专家智能体大揭秘
本文分享如何使用 DeepSeek-V3-0324 和 Claude 3.5 或 3.7 绘制出高质量的图片，可以作为文章配图也可以为 PPT 配图，效率成倍增长。文章还介绍了原型图绘制、图片重绘修改和彩色报纸风的进阶案例。希望本文提供的技巧对大家有帮助，大家也可以修改提示词定制自己喜欢的风格。
阿里云开发者
341 13
蓝易云
|
7月前
|
监控 前端开发 Java
SpringBoot集成Tomcat、DispatcherServlet
通过这些配置，您可以充分利用 Spring Boot 内置的功能，快速构建和优化您的 Web 应用。
蓝易云
452 21
游客jjw5lou74ja6k
|
Web App开发 前端开发 API
老板的灵魂提问: 别人家的视频能自动播放为什么你开发的无法自动播放？为什么网页上的音视频无法自动播放了？
老板的灵魂提问: 别人家的视频能自动播放为什么你开发的无法自动播放？为什么网页上的音视频无法自动播放了？
游客jjw5lou74ja6k
243 0
vohelon
|
安全 网络安全 数据安全/隐私保护
https的原理
https的原理
vohelon
676 2
jcLee95
|
JavaScript 前端开发 Android开发
Flutter笔记：关于WebView插件的用法（下）
Flutter笔记：关于WebView插件的用法（下）
jcLee95
876 5
开发V|TG_ch3nguang
|
安全
链游系统开发DAPP项目逻辑讲解方案
链游系统开发具有以下优势： 　　1.Decentralization:Chain game systems are based on blockchain technology and do not rely on centralized servers,providing a more fair and transparent gaming environment. 　　2.Data security:Through the decentralized characteristics and encryption algorithms of blockchain,the chai
开发V|TG_ch3nguang
107 0
八音盒coding
|
小程序 JavaScript Java
基于微信小程序的垃圾分类小程序的设计与实现(源码+lw+部署文档+讲解等)
基于微信小程序的垃圾分类小程序的设计与实现(源码+lw+部署文档+讲解等)
八音盒coding
195 0

热门文章

最新文章

  • 1
    超简单：mac导出微信聊天记录（附上粉丝群全部聊天记录）
  • 2
    用 Windows Media Center 免费看大片 (一)
  • 3
    数据库必知词汇：即席查询(Ad Hoc)
  • 4
    阿里云推出商标交易平台「商标优选」 商标即买即用
  • 5
    CentOS7使用阿里源安装最新版Docker
  • 6
    Android匿名共享内存（Ashmem）原理
  • 7
    PPC与PC无线连接（Wi-Fi）
  • 8
    Target host or target server ***** is not in operation mode
  • 9
    Tomcat7.0源码分析——请求原理分析（下）
  • 10
    时光老人之2014
  • 1
    《2D横版平台跳跃游戏中角色二段跳失效与碰撞体穿透的耦合性Bug解析》
    36
  • 2
    《Unity3D VR游戏手柄振动与物理碰撞同步失效问题深度解析》
    33
  • 3
    【Azure环境】使用ARM Template部署Policy模板时候报错不支持filed函数: The template function 'field' is not valid.
    28
  • 4
    【含储能及sop的多时段配网优化模型】基于柔性开断点(Soft Open Point)的主动配电网电压与无功功率协调控制方法研究（Matlab代码实现）
    29
  • 5
    【孤岛划分】分布式能源接入弹性配电网模型研究【IEEE33节点】（Matlab代码实现）
    39
  • 6
    阿里云云栖大会2025年9月24日开启，免费申请大会门票，速度领取~
    169
  • 7
    使用阿里云服务器安装Z-Blog博客网站流程，新手一键部署教程
    36
  • 8
    Java 基础练习题及其实现思路，包括输入、条件判断、循环、数组、随机数等常见知识点
    60
  • 9
    Java 数组学习笔记
    39

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    蛋白质语言模型 ProGen：在实验室合成由 AI 预测的蛋白质