需求分析
  1. 查询API（状态、页码、行数）
  2. 新增API（任务名称、截止日期、内容）
  3. 修改：首先通过查询API（ID）获得修改行数据，修改API提交最终修改（任务名称、截止日期、内容、ID）
  4. 删除API（ID）

  5. 更新状态API（ID、状态【待办、完成】）

    api设计

  6. 初始化项目：

    1. mkdir nodejs-express-vue-backEnd
    2. cd nodejs-express-vue-backEnd
    3. git init
    4. npm init -y
    5. // 创建.gitignore文件，添加忽略配置:node_modules、.lh
    6. npm i express sequelize sequelize-cli mysql2 body-parser -S
    7. npm i nodemon -D
    8. mkdir src
    9. //在src文件夹下创建app.js文件
  • express web服务框架
  • sequelize ORM对象管理模型，用来处理代码与数据库的通信
  • sequelize-cli 使用sequelize的脚手架工具
  • mysql2 mysql数据库驱动，连接数据库
  • body-parser 处理body形式的传参，JSON（例如:post请求） ```javascript const express = require(‘express’); const bodyParser = require(‘body-parser’); const app = express();

/**

  • 应用级别中间件
  • 处理参数 */ app.use(express.json());

app.use(express.urlencoded());

app.use(bodyParser.urlencoded({ extended: true }));

/**

  • API
    */ app.get(‘/list’, (req, res, next) => { // throw new Error(‘异常测试’); // next(new Error(‘异常测试’)); res.json({ list: [] }); });

app.post(‘/create’, (req, res, next) => { let { name, date, content, id } = req.body; res.json({ todo: {}, name, date, content, id, message: “创建成功” }); });

app.post(‘/edit’, (req, res, next) => { let { name, date, content, id } = req.body; res.json({ todo: {}, name, date, content, id, message: “创建成功” }); });

app.post(‘/action’, (req, res, next) => { let { status, id } = req.body; res.json({ status, id, message: “执行成功” }); });

app.post(‘/delete’, (req, res, next) => { let { id } = req.body; res.json({ id, message: “删除成功” });

});

/** 应用级中间件 1.所有错误Error:status=500 2.所有业务异常：status=1003 3.404错误 **/ app.use(‘*’, (req, res, next) => {//404服务器不认为是ERR所以此处使用通配符去处理404异常 res.json({ message: ‘请求资源不存在’ }); }); app.use((err, req, res, next) => { if (err) { res.statusCode = 500; res.json({ message: err.message }); } });

/**

  • 监听服务器的端口 **/ app.listen(8080, () => { console.log(‘服务器启动成功！’) }); ```
    ORM模型创建
  1. 创建数据库

20220324150229003.png

  1. 使用‘sequelize-cli’初始化项目的数据库配置信息npx sequelize init（建议新建一个文件夹，不建议在根目录下执行）

  2. 生成模型文件models、migrations.

    npx sequelize model:generate —name Business —attributes name:String,date:Date,content:String

  3. 持久化 模型对应的【数据库表】

npx sequelize db:migrate

API具体实现
  1. const express = require('express');
  2. const bodyParser = require('body-parser');
  3. const app = express();
  4. const models = require('../db/models');
  6. /********************************************
  7.  *  应用级别中间件
  8.  * 处理参数
  9. *********************************************/
  10. app.use(express.json());
  12. app.use(express.urlencoded());
  14. app.use(bodyParser.urlencoded({ extended: true }));
  19. /********************************************
  20.  * API  
  21. *********************************************/
  23. app.get('/list',async (req, res, next) => {
  24.     //    throw new Error('异常测试');
  25.     //    next(new Error('异常测试'));
  26.     //offset代表从第几条记录“之后“开始查询,limit表明查询多少条结果
  27.     try {
  28.         let { status, page } = req.query;
  29.         let limit = 10;//每页10条
  30.         let offset = (page - 1) * limit;//开始从那个位置读取数据库
  31.         let where = {};
  32.         if (status != -1) {
  33.             where.status = status;
  34.         }
  35.         let obj =await models.Business.findAndCountAll({
  36.             where,
  37.             offset,
  38.             limit
  39.         });
  40.         res.json({
  41.             obj
  42.         });
  43.     } catch (error) {
  44.         next(error);
  45.     }
  47. });
  49. app.post('/create', async (req, res, next) => {
  50.     try {
  51.         let { name, date, content } = req.body;
  52.         /** 数据持久化到数据库 */
  53.         let obj = await models.Business.create({
  54.             name, date, content
  55.         });
  56.         res.json({
  57.             obj,
  58.             message: "创建成功"
  59.         });
  60.     } catch (error) {
  61.         next(error);
  62.     }
  63. });
  65. app.post('/edit', async (req, res, next) => {
  66.     try {
  67.         let { name, date, content, id } = req.body;
  68.         /** 数据持久化到数据库 */
  69.         let obj = await models.Business.findOne({
  70.             where: {
  71.                 id
  72.             }
  73.         });
  74.         if (obj) {//防止多人处理
  75.             obj = await obj.update({
  76.                 name,
  77.                 date,
  78.                 content
  79.             });
  80.             res.json({
  81.                 obj,
  82.                 message: "修改成功"
  83.             });
  84.         }
  85.     } catch (error) {
  86.         next(error);
  87.     }
  88. });
  90. app.post('/action', async (req, res, next) => {
  91.     try {
  92.         let { status, id } = req.body;
  93.         let obj = await models.Business.findOne({
  94.             where: {
  95.                 id
  96.             }
  97.         });
  98.         if (obj && status != obj.status) {
  99.             obj = obj.update({
  100.                 status
  101.             });
  102.             res.json({
  103.                 obj,
  104.                 message: "执行成功"
  105.             });
  106.         } else {
  107.             next(new Error('状态与数据库一致，或者行明细不存在'));
  108.         }
  109.     } catch (error) {
  110.         next(error);
  111.     }
  112. });
  114. app.post('/delete', (req, res, next) => {
  115.     let { id } = req.body;
  116.     res.json({
  117.         id,
  118.         message: "删除成功"
  119.     });
  121. });
  123. /**********************************************
  124. 应用级中间件
  125. 1.所有错误Error:status=500
  126. 2.所有业务异常：status=1003
  127. 3.404错误
  128. ************************************************/
  129. app.use('*', (req, res, next) => {//404服务器不认为是ERR所以此处使用通配符去处理404异常
  130.     res.json({
  131.         message: '请求资源不存在'
  132.     });
  133. });
  134. app.use((err, req, res, next) => {
  135.     if (err) {
  136.         res.statusCode = 500;
  137.         res.json({
  138.             message: err.message
  139.         });
  140.     }
  141. });
  146. /**********************************************
  147.  * 监听服务器的端口
  148.  **********************************************/
  149. app.listen(8080, () => {
  150.     console.log('服务器启动成功！')
  151. });

前端效果演示(略)

运维和发布

pm2是一个工具。
npm i pm2 -g
pm2 init //初始化项目启动或者是运维的脚本
pm2 start ecosystem.config.js //启动服务
pm2 list //查看启动的服务
pm2 restart id/name//重启指定的服务 例如: pm2 restart 0
pm2 log//查看服务器运行日志