【koa】05-koa+mysql实现数据库集成：连接和增删改查

前言

前面我们已经介绍了第二阶段的第1-4点内容，本篇介绍第5点内容：数据库集成（koa+mysql）

也是第二阶段内容的完结。

一、学习目标

在koa项目中正常连接数据库，对数据表进行增删改查的操作。

二、操作步骤

本篇文章会使用到：koa+sequelize+mysql+apipost（用于测试http方法）

注意：文章很多的操作步骤和“express框架的数据库集成”基本上是一样的，参考文章：

【express-generator】09-连接和使用数据库-CRUD 操作（第二阶段完结）-CSDN博客

所以文章中会简单跳过/省略一些简单的步骤。

1、安排依赖

在项目根目录下运行以下命令安装必要的依赖：

npm install koa mysql2 sequelize koa-router koa-bodyparser

2、配置数据库连接

注意：每个人的数据库连接连接信息不一样，对应修改自己的信息。

在state2/models/dbConnect.js中配置数据库连接信息：

// 该文件负责连接数据库
const { Sequelize } = require("sequelize");// 创建数据库连接
const sequelize = new Sequelize("mysite2", "root", "123456aa", {host: "localhost",dialect: 'mysql',logging: false
});const startDB=async()=> {try {await sequelize.authenticate();console.log('数据库已建立起连接.');} catch (error) {console.error('Unable to connect to the database:', error);}
}
startDB()// 向外暴露这个连接实例
module.exports = sequelize;

3、定义数据模型

在state2/models/userModel写入以下代码：

const { DataTypes } = require("sequelize");
const sequelize = require("./dbConnect");// 定义数据模型
module.exports = sequelize.define("koauser", {// 这张表拥有哪些字段name : {type : DataTypes.STRING,allowNull : true},age : {type : DataTypes.INTEGER,allowNull : true},
},{//与模型定义时的名称一致。 // 比如定义了上述定义了content模型，设置了这个字段，创建表的名字也是content。freezeTableName : true,  //用于记录数据的创建时间和更新时间。createdAt : false,  updatedAt : false
});

这里我们定义了一个名为“koauser”的数据表，有name和age字段，分别是string和integer数据类型。

4、初始化Sequelize和加载模型

在state2/demodels/db.js写入以下代码：

// 该文件负责对数据库进行一个初始化操作
const sequelize = require("./dbConnect"); // 数据库连接实例const userModel = require("./userModel"); // 数据模型
const initData=async function () {// 将数据模型和表进行同步await sequelize.sync({alter: true,})// 同步完成之后，有一些表是需要一些初始化数据// 查询这张表有没有内容，没有内容才初始化数据const userCount = await userModel.count();if (!userCount) {// 进入此 if，说明该表没有数据，我们进行一个初始化await userModel.create({name: "Tom",age:18})console.log("初始化内容数据表数据完毕...");}console.log("数据库数据已经准备完毕....");
}
initData()

5、创建Koa应用并集成Sequelize

在state2/demo5.js中写入以下代码：

const Koa = require('koa');
const Router = require('koa-router');
const bodyParser = require('koa-bodyparser');
// const models = require('./models');
const userModel = require('./models/userModel');
const app = new Koa();
const router = new Router();require('./models/db');
// 使用bodyParser中间件解析请求体
app.use(bodyParser());// 定义路由
router.get('/', async (ctx) => {ctx.body = 'Welcome to Koa with Sequelize!';
});// 使用路由中间件
app.use(router.routes()).use(router.allowedMethods());app.listen(3000, () => {console.log('Server is running at http://localhost:3000');
});

启动服务，看是否正常连接数据库和创建、初始化数据表。

在state2的目录下打开终端，执行node demo5.js

启动之前，数据库的表情况

启动之后，多了一个koauser的数据表，并且有一条数据。

6、增删改查（CRUD）操作

Create:增加

Read:查

Update：更新

Delete:删除

6.1、查找所有用户信息

在state2/demo5.js中新增代码：

// 查找所有用户
router.get('/users', async (ctx) => {const users = await userModel.findAll();ctx.body = users;
});

方法放在这个位置

测试：启动服务+apipost工具

新增get方法，点击发送则会得到以下结果

6.2、增加新的用户

//   创建用户
router.post('/user', async (ctx) => {const { name, age } = ctx.request.body;try {const user = await userModel.create({ name,age });ctx.body = user;} catch (error) {ctx.status = 400;ctx.body = { error: error.message };}
});

测试：启动服务+添加post方法

在数据表中刷新可以看到新增的数据项

6.3、查找单条用户数据

为了后续测试，先增加了几条数据

// 查找单个用户
router.get('/user/:id', async (ctx) => {const { id } = ctx.params;try {const user = await userModel.findByPk(id);if (user) {ctx.body = user;} else {ctx.status = 404;ctx.body = { error: 'User not found' };}} catch (error) {ctx.status = 400;ctx.body = { error: error.message };}
});

测试：启动服务+添加get方法

查找id为1的数据项

查找id为3的数据项

6.4、更新用户信息

  // 更新用户router.put('/user/:id', async (ctx) => {const { id } = ctx.params;const { name,age } = ctx.request.body;try {const user = await userModel.findByPk(id);if (user) {await user.update({ name,age });ctx.body = user;} else {ctx.status = 404;ctx.body = { error: 'User not found' };}} catch (error) {ctx.status = 400;ctx.body = { error: error.message };}});

测试：启动服务+测试put方法

我们尝试将id为1的数据项，对name进行修改成"Rura"(原本是Tom)

响应结果

刷新数据表，可以看见id为1的数据项的name已经被修改。

6.5、删除用户信息

  // 删除用户router.delete('/user/:id', async (ctx) => {const { id } = ctx.params;try {const user = await userModel.findByPk(id);if (user) {await user.destroy();ctx.status = 204;} else {ctx.status = 404;ctx.body = { error: 'User not found' };}} catch (error) {ctx.status = 500;ctx.body = { error: error.message };}});

测试：启动服务+测试delete方法

这里我们尝试将id为4的数据项进行删除