后端实战教程: 如何使用 Node.js 开发 RESTful API 接口（Node.js + Express + Sequelize + MySQL）

mkdir nodejs-express-sequelize-mysql-kalacloudcd nodejs-express-sequelize-mysql-kalacloud

npm initname: (nodejs-express-sequelize-mysql)version: (1.0.0)description: Node.js Rest Apis with Express, Sequelize , MySQL.entry point: (index.js) server.jstest command:git repository:keywords: nodejs, express, sequelize, mysql, rest, apiauthor: kalacloudlicense: (ISC)Is this ok? (yes) yes

{  "name": "nodejs-mysql-kalacloud-com",  "version": "1.0.0",  "description": "Node.js Rest Apis with Express, Sequelize , MySQL.",  "main": "server.js",  "scripts": {    "test": "echo \"Error: no test specified\" && exit 1"  },  "keywords": [    "nodejs",    "express",    "sequelize",    "mysql",    "rest",    "api"  ],  "author": "kalacloud",  "license": "ISC"}

npm install express sequelize mysql2 body-parser cors --save

const express = require("express");const bodyParser = require("body-parser");const cors = require("cors");
const app = express();
var corsOptions = {  origin: "*"};
app.use(cors(corsOptions));
// content-type：application/jsonapp.use(bodyParser.json());
// content-type：application/x-www-form-urlencodedapp.use(bodyParser.urlencoded({ extended: true }));
// 简单路由app.get("/", (req, res) => {  res.json({ message: "欢迎访问卡拉云后端服务器" });});
// 设置监听端口const PORT = process.env.PORT || 8080;app.listen(PORT, () => {  console.log(`服务器运行端口： ${PORT}.`);});

module.exports = {  HOST: "192.168.1.5",  USER: "kalacloud",  PASSWORD: "YOUR_PASSWORD",  DB: "demo",  port:3306,  dialect: "mysql",  pool: {    max: 5,    min: 0,    acquire: 30000,    idle: 10000  }};

const dbConfig = require("../config/db.config.js");
const Sequelize = require("sequelize");const sequelize = new Sequelize(dbConfig.DB, dbConfig.USER, dbConfig.PASSWORD, {  host: dbConfig.HOST,  dialect: dbConfig.dialect,  operatorsAliases: false,
  pool: {    max: dbConfig.pool.max,    min: dbConfig.pool.min,    acquire: dbConfig.pool.acquire,    idle: dbConfig.pool.idle  }});
const db = {};
db.Sequelize = Sequelize;db.sequelize = sequelize;
db.todos = require("./todo.model.js")(sequelize, Sequelize);
module.exports = db;

const express = require("express");const bodyParser = require("body-parser");const cors = require("cors");
const app = express();
var corsOptions = {  origin: "http://localhost:8081"};
app.use(cors(corsOptions));
// content-type：application/jsonapp.use(bodyParser.json());
// content-type：application/x-www-form-urlencodedapp.use(bodyParser.urlencoded({ extended: true }));
// 简单路由app.get("/", (req, res) => {  res.json({ message: "欢迎访问卡拉云后端服务器" });});
// 设置监听端口const PORT = process.env.PORT || 8080;app.listen(PORT, () => {  console.log(`服务器运行端口： ${PORT}.`);});
const db = require("./app/models");db.sequelize.sync();

module.exports = (sequelize, Sequelize) => {  const Todo = sequelize.define("todo", {    title: {      type: Sequelize.STRING    },    description: {      type: Sequelize.STRING    },    status: {      type: Sequelize.BOOLEAN    }  });
  return Todo;};

const db = require("../models");const Todo = db.todos;const Op = db.Sequelize.Op;
// 创建并保存一条清单exports.create = (req, res) => {  // Validate request  if (!req.body.title) {    res.status(400).send({      message: "内容不能为空"    });    return;  }
  // 创建一条清单  const todo = {    title: req.body.title,    description: req.body.description,    stauts: req.body.stauts ? req.body.stauts : false  };
  // 将清单保存到数据库  Todo.create(todo)    .then(data => {      res.send(data);    })    .catch(err => {      res.status(500).send({        message:          err.message || "创建清单是发生错误。"      });    });};
// 从数据库中搜索.exports.findAll = (req, res) => {  const title = req.query.title;  var condition = title ? { title: { [Op.like]: `%${title}%` } } : null;
  Todo.findAll({ where: condition })    .then(data => {      res.send(data);    })    .catch(err => {      res.status(500).send({        message:          err.message || "搜索时，发生错误。"      });    });};
// 按照条目 ID 搜索exports.findOne = (req, res) => {  const id = req.params.id;
  Todo.findByPk(id)    .then(data => {      if (data) {        res.send(data);      } else {        res.status(404).send({          message: `没有找到 ${id} 的清单`        });      }    })    .catch(err => {      res.status(500).send({        message:  `查询第 ${id} 条清单时出错`      });    });};
// 更新指定 ID 清单exports.update = (req, res) => {  const id = req.params.id;
  Todo.update(req.body, {    where: { id: id }  })    .then(num => {      if (num == 1) {        res.send({          message: "更新成功"        });      } else {        res.send({          message: `第 ${id} 条更新失败。`        });      }    })    .catch(err => {      res.status(500).send({        message: `更新第 ${id} 条清单时出错`      });    });};
// Delete a Todo with the specified id in the requestexports.delete = (req, res) => {  const id = req.params.id;
  Todo.destroy({    where: { id: id }  })    .then(num => {      if (num == 1) {        res.send({          message: "删除成功"        });      } else {        res.send({          message: `删除第${id}条清单失败。`        });      }    })    .catch(err => {      res.status(500).send({        message: "不能删除清单：" + id      });    });};
// 删除数据库中所有清单exports.deleteAll = (req, res) => {  Todo.destroy({    where: {},    truncate: false  })    .then(nums => {      res.send({ message: `删除${nums}条清单 ` });    })    .catch(err => {      res.status(500).send({        message:          err.message || "删除所有清单时出错"      });    });};
// 检查所有清单状态exports.findAllstauts = (req, res) => {  Todo.findAll({ where: { stauts: true } })    .then(data => {      res.send(data);    })    .catch(err => {      res.status(500).send({        message:          err.message || "搜索清单时出错"      });    });};