当前位置：首页 > news >正文

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

news 来源：原创 2025/5/9 8:02:25

前言

前面我们已经介绍了第二阶段的第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的数据项进行删除