前端开发 Spring Boot 入门指南：实现数据库增删改查（上）

今日话题

基于 Spring Boot 实现增删改查，并且使用mysql数据库来实现

作者：云层上的光

时间：2024年6月21日 16时36分14秒

主线任务

一、项目创建

1、点击 “新建项目”，创建项目用来演示 Spring Boot 实现增删改查

2、填写项目配置：详细版见：

3、选择 3.1.1 项目版本作为演示，详细见 支线任务一：

1. Lombok
2. Spring Web
3. MyBatis Framework
4. MySQL Driver

mysql 相关依赖选择

4、使用 Maven 下载依赖，（详细版见：www.yuque.com/chuxin-cs/s…）

5、如果遇到依赖安装报错，详细版见：支线任务二：

二、实现 controller 增删改查方法

1、新建 controller 软件包、并且新建 UserController 文件类

2、编写“增删改查”方法

3、代码如下：

package com.chuxin.demotodolist.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/user")
public class UserController {
    // 增加
    @PostMapping("/add")
    private String add() {
        return "add";
    }
    // 删除
    @PostMapping("/delete")
    public String delete() {
        return "delete";
    }
    // 修改
    @PostMapping("/edit")
    public String edit() {
        return "edit";
    }
    // 查看
    @GetMapping("/getList")
    public String getList() {
        return "getList";
    }
}

三、实现 entity 实体类

1、新建 entity 软件包

2、新建 User 实体类

3、User 首字母大写，然后选择“类”回车创建

4、在 demo-crud 中介绍了 生成 Getter 和 Setter 这里采用 Lombok

四、Mysql 数据库设计

1、打开自己喜欢的数据库图形化工具，当前使用的是 Navicat Premium，下载教程见：

2、连接本地数据库

3、选择 Mysql 进行连接

4、填写 Mysql 连接信息

5、点击“连接测试”提示“连接成功”

6、点击 “确认”，进行本地 Mysql 进行连接

7、双击打开连接的本地数据库

8、由于之前 go 在进行数据库操作时创建过，先删除 spring-boot-demo

9、点击右键删除 “spring-boot-demo”

10、创建数据库

11、填写数据库信息，点击确认进行创建~

提示：（想了想这里按照项目名称来创建 ，此处创建 demo-todo-list，关于上面 spring-boot-demo 的删除操作多此一举了）

字符集：utf8mb4 -- UTF-8 Unicode

排序规则：utf8mb4_general_ci

12、双击打开创建的 demo-todo-list 数据库

13、新建表

14、完成数据库设计（设计层面，先一切从简）

15、sys_user 表sql：

CREATE TABLE `sys_user` (
  `id` int NOT NULL AUTO_INCREMENT COMMENT '用户id',
  `name` varchar(255) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '用户名',
  `password` varchar(255) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '密码',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

16、保存表，并且表名设计为 sys_user

17、此时 sys_user 表就创建完成了

五、Service 实现业务

1、新建 service 软件包

2、新建 UserService 选择“接口”进行创建

3、新建 impl 软件包

4、impl 包中新建 UserServiceImpl 类文件

5、此时文件路径如下：

6、编写 service/UserSerive 接口

代码如下：

package com.chuxin.demotodolist.service;

public interface UserService {
    // 增加
    String add();
    // 删除
    String delete();
    // 修改
    String edit();
    // 查看
    String getList();
}

7、实现 service.impl.UserServiceImpl 业务代码

六、Mapper 层操作 mybatis

1、新建 mapper 软件包

2、新建 UserMapper 接口

3、实现 UserMapper 增删改查

代码如下：

package com.chuxin.demotodolist.mapper;

import com.chuxin.demotodolist.entity.User;
import org.apache.ibatis.annotations.*;

import java.util.List;

@Mapper
public interface UserMapper {
    // 增
    @Insert("insert into sys_user (name,password) values (#{name},#{password})")
    Integer add(User user);
    // 删
    @Delete("delete from sys_user where id=#{id}")
    Integer delete(Integer id);
    // 改   后期我才发现这里没有增加修改的条件 不过为了研究就先这样了
    @Update("update sys_user set name=#{name},password=#{password}")
    Integer edit(User user);
    // 查
    @Select("select * from sys_user")
    List<User> getList();
}

4、改造 service/UserSerive 接口文件

5、代码如下：

package com.chuxin.demotodolist.service;

import com.chuxin.demotodolist.entity.User;

import java.util.List;

public interface UserService {

    // 增加
    Integer add(User user);

    // 删除
    Integer delete(Integer id);

    // 修改
    Integer edit(User user);

    // 查看
    List<User> getList();
}

6、改造 impl 包中新建 UserServiceImpl 类文件

7、代码如下：

package com.chuxin.demotodolist.service.impl;

import com.chuxin.demotodolist.entity.User;
import com.chuxin.demotodolist.mapper.UserMapper;
import com.chuxin.demotodolist.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;

@Service
public class UserServiceImpl implements UserService {
    @Autowired
    private UserMapper userMapper;
    // 增加
    @Override
    public Integer add(User user) {
        return userMapper.add(user);
    }
    // 删除
    @Override
    public Integer delete(Integer id) {
        return userMapper.delete(id);
    }
    // 修改
    @Override
    public Integer edit(User user) {
        return userMapper.edit(user);
    }
    // 查看
    @Override
    public List<User> getList() {
        return userMapper.getList();
    }
}

8、改造 controller 下 UserController 文件类

代码如下：

package com.chuxin.demotodolist.controller;

import com.chuxin.demotodolist.entity.User;
import com.chuxin.demotodolist.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;
    // 增加
    @PostMapping("/add")
    private Integer add(@RequestBody User user) {
        return userService.add(user);
    }
    // 删除
    @PostMapping("/delete")
    public Integer delete(@RequestBody Integer id) {
        return userService.delete(id);
    }
    // 修改
    @PostMapping("/edit")
    public Integer edit(@RequestBody User user) {
        return userService.edit(user);
    }
    // 查看
    @GetMapping("/getList")
    public List<User> getList() {
        return userService.getList();
    }
}

七、项目启动~

1、启动项目

2、提示 Lombok 相关操作，点击 “启动注解处理”

3、终端启动报错

4、将 application.properties 修改为 application.yaml 文件

5、application.yaml 修改完成~

6、为什么要修改为 yaml 文件，主要出于两个方面的原因：

当然两个文件用那个都是可以的，我觉得没有必要纠结，习惯那个用那个

• yaml 用的人比较多
• yaml 更加清晰，更好维护

7、解决办法，application.yaml 文件修改如下：

代码如下：

# spring config 配置
spring:
  # 当前项目名称
  application:
    name: demo-todo-list
  
  # 数据库相关操作
  datasource:
    # 数据库连接使用 jdbc
    driver-class-name: com.mysql.cj.jdbc.Driver
    # 连接地址
    url: jdbc:mysql://localhost:3306/demo-todo-list?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai
    # 用户名
    username: root
    # 密码
    password: 123456

8、再次启动，运行成功

八、接口测试

接口测试使用的 Apifox ，可以在线使用 Web 省去安装桌面端步骤

1、增加

1.1、点击发送，调用新增用户接口 http://localhost:8080/user/add

1.2、查看数据库，用户新增成功，但是插入数据失败

1.3、启动调试模式

1.4、清除打印日志

1.5、添加断点

1.6、再次点击发送

1.7、断点中 name 和 password 存在值

1.8、查看数据库，新增成功，（问题是代码没改动，不知道为什么又好了）

1.9、为了后续流程，取消断点调试模式

1.10、重新运行项目

2、查询

1、点击发送，调用查询用户接口 http://localhost:8080/user/getList

2、数据查询成功

3、删除

1、点击发送，调用删除用户接口 http://localhost:8080/user/delete

2、删除失败，接口 400 了

3、调用接口前删除日志，方便查看日志信息，此时终端已经报错

4、报错信息如下：

错误信息如下：

Resolved [org.springframework.http.converter.HttpMessageNotReadableException: 
JSON parse error: 
Cannot deserialize value of type `java.lang.Integer` from Object value
(token `JsonToken.START_OBJECT`)]

5、找到问题所在，这是因为：

使用@RequestBody 接收的是个对象，而我们在接口传参时用的格式是：

{ id: 4 }

所以这里 id 是一个对象{id: 4} 调用userService.delete(id) 希望传入的是整数类型

我们现在传递的是 {id:1} 所以就报错

6、改造如下：

代码如下：

package com.chuxin.demotodolist.controller;

import com.chuxin.demotodolist.entity.User;
import com.chuxin.demotodolist.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;

     // 删除
    @PostMapping("/delete")
    public Integer delete(@RequestBody User user) {
        return userService.delete(user.getId());
    }
    
}

7、重启项目，并且启动成功之后清除日志

8、调用接口删除，返回1 说明数据库成功 这里的1代表在数据库中影响1行

9、数据库查看，删除成功

4、修改

1、在“删除”接口报错时看到了这里的sql 语句错误，没有给定修改条件，先尝试不删除试试报出的错误是什么样的

2、重启项目，清除日志

3、点击发送，调用修改用户接口 http://localhost:8080/user/edit

4、返回整数3，这说明数据影响了3行，不会不给条件的话 给所有的数据进行更新吧？而且程序并没有报错

5、查看 数据库，数据全部同步更新了~

6、改造 UserMapper 接口文件，增加条件，然后重启项目

7、重新调用接口，修改id=1 的name为 chuxin

8、查看数据库，修改成功

代码仓库

github.com/chuxin-cs/s…

往期内容

点击链接查看：www.yuque.com/chuxin-cs/i…