【SpringBoot】7 数据库（MySQL&MyBatis）

MySQL

前提：当地有安装 MySQL 。
毗连

使用工具 Navicat Premium ，或者 IDEA 自带的 DB 工具，或者其他能毗连 MySQL 数据库的工具都可以。

1）创建 MySQL Data Source

2）根据当地设置毗连上 MySQL，点击【Test Connection】，表现毗连乐成，再点击【OK】按钮即可乐成毗连上 DB。

版本

此时已经是乐成毗连上 MySQL，在 console 窗口输入命令检察当地 MySQL 的版本。

1. SELECT VERSION();

复制代码

依赖

前往公共 Maven 检察，发现 MySQL 没有8.0.34的版本，所以用降个版本用 v8.0.33。
仓库地点：https://mvnrepository.com/artifact/com.mysql/mysql-connector-j

   pom.xml

1. <dependency>
2.     <groupId>com.mysql</groupId>
3.     <artifactId>mysql-connector-j</artifactId>
4.     <version>8.0.33</version>
5. </dependency>

复制代码

  application.yml

1. spring:
2.   application:
3.     name: system
4.   thymeleaf:
5.     prefix: classpath:/templates/ #前缀，默认为classpath:/templates/
6.     suffix: .html #后缀，默认为.html
7.   datasource:
8.     driver-class-name: com.mysql.cj.jdbc.Driver
9.     url: jdbc:mysql://localhost:3306/system?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
10.     username: root
11.     password: root

复制代码

com.mysql.jdbc.Driver 和 com.mysql.cj.jdbc.Driver 的区别及设定 serverTimezone 的方法：https://www.jb51.net/program/298475don.htm
建库建表

新建库 system，新建表 t_user。

1. #建库,库名: system
2. CREATE DATABASE `system` CHARACTER SET 'utf8mb4';
4. #进入 system 数据库
5. use `system`;
7. #建表,表名: t_user
8. CREATE TABLE `system`.`t_user`  (
9.   `id` int NOT NULL AUTO_INCREMENT,
10.   `name` varchar(255) NOT NULL,
11.   `age` tinyint NULL,
12.   `gender` varchar(2) NULL COMMENT '性别',
13.   `deleted` tinyint(1) NOT NULL COMMENT '已经删除：0否，1是',
14.   `create_time` timestamp NOT NULL,
15.   `update_time` timestamp NULL,
16.   PRIMARY KEY (`id`)
17. );

复制代码

MyBatis

官网

MyBatis 3：https://mybatis.org/mybatis-3/
MyBatis-Plus（推荐）：https://baomidou.com/
依赖

   pom.xml

1. <dependency>
2.     <groupId>com.baomidou</groupId>
3.     <artifactId>mybatis-plus-boot-starter</artifactId>
4.     <version>3.5.7</version>
5. </dependency>

复制代码

设置

1）启动类添加 @MapperScan 注解
   SystemApplication.java

1. @SpringBootApplication
2. @MapperScan("com.lm.system.mapper")
3. public class SystemApplication extends SpringBootServletInitializer {}

复制代码

插件（可选）

图标不同是因为装了插件，这个装不装都可以，装了可以在 Mapper 接口和 Mapper.xml 两个间跳转等功能。

实当代码

实体类

实体类 User 实用于背景程序操作，数据库操作。
   User.java

1. package com.lm.system.common;
3. import com.baomidou.mybatisplus.annotation.IdType;
4. import com.baomidou.mybatisplus.annotation.TableId;
5. import lombok.AllArgsConstructor;
6. import lombok.Data;
7. import lombok.NoArgsConstructor;
9. import java.util.Date;
11. /**
12. * @Author: DuHaoLin
13. * @Date: 2024/7/26
14. */
15. @Data
16. @NoArgsConstructor
17. @AllArgsConstructor
18. public class User {
20.     @TableId(value = "id", type = IdType.INPUT)
21.     private Integer id; //自增长
22.     private String name;
23.     private Integer age;
24.     private String gender; //性别
25.     private Integer deleted; //是否已经删除：0否，1是
26.     private Date createTime;
27.     private Date updateTime;
29. }

复制代码

UserDTO 实用于数据传输。
   UserDTO.java

1. package com.lm.system.common.dto;
3. import io.swagger.annotations.ApiModel;
4. import lombok.AllArgsConstructor;
5. import lombok.Data;
6. import lombok.NoArgsConstructor;
8. /**
9. * @Author: DuHaoLin
10. * @Date: 2024/7/27
11. */
12. @Data
13. @NoArgsConstructor
14. @AllArgsConstructor
15. @ApiModel("用户实体类")
16. public class UserDTO {
18.     private Integer id;
19.     private String name;
20.     private Integer age;
21.     private String gender;
22.     private String createTime;
23.     private String updateTime;
25. }

复制代码

Mapper / Dao 层

在 system 目录下，新建 mapper 目录，在 mapper 目录下新建 UserMapper 接口。
   UserMapper.java（这是个接口）

1. package com.lm.system.mapper;
3. import com.lm.system.common.User;
4. import org.apache.ibatis.annotations.Param;
6. import java.util.List;
8. /**
9. * @Author: DuHaoLin
10. * @Date: 2024/7/27
11. */
12. public interface UserMapper {
14.     int insertUser(@Param("user") User user); //写入单个用户信息
16.     int updateUser(@Param("user") User user); //修改单个用户信息
18.     User queryUserById(int id); //按ID查询用户信息
20.     List<User> queryAllUser(); //查询所有用户信息
22.     int deleteUser(int id); //按ID删除用户
24. }

复制代码

在 resource 目录下，新建 com 目录，在 com 目录下新建 lm 目录，在 lm 目录下新建 system 目录，在 system 目录下新建 UserMapper.xml 文件。
注：保持 resource 下的 mapper 目录的层级，和 src 中的 mapper 目录的层级一样。
   UserMapper.xml

1. <?xml version="1.0" encoding="UTF-8"?>
2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3. <mapper namespace="com.lm.system.mapper.UserMapper">
5.     <!--  返回结果集  -->
6.     <resultMap id="users" type="com.lm.system.common.User">
7.         <id property="id" column="id" jdbcType="INTEGER" />
8.         <result property="name" column="name" jdbcType="VARCHAR" />
9.         <result property="age" column="age" jdbcType="INTEGER" />
10.         <result property="gender" column="gender" jdbcType="VARCHAR" />
11.         <result property="deleted" column="deleted" jdbcType="INTEGER" />
12.         <result property="createTime" column="create_time" jdbcType="DATE" />
13.         <result property="updateTime" column="update_time" jdbcType="DATE" />
14.     </resultMap>
16.     <resultMap id="userDTO" type="com.lm.system.common.dto.UserDTO">
17.         <result property="name" column="name" jdbcType="VARCHAR" />
18.         <result property="age" column="age" jdbcType="INTEGER" />
19.         <result property="gender" column="gender" jdbcType="VARCHAR" />
20.     </resultMap>
22.     <sql id="baseColumn">
23.         id, `name`, age, gender, deleted, create_time, update_time
24.     </sql>
26.     <insert id="insertUser" parameterType="com.lm.system.common.User"
27.             keyColumn="id" keyProperty="id" useGeneratedKeys="true">
28.         INSERT INTO t_user (name, age, gender, deleted, create_time, update_time)
29.         VALUES (#{user.name}, #{user.age}, #{user.gender}, 0, NOW(), NOW())
30.     </insert>
32.     <update id="updateUser" parameterType="com.lm.system.common.User">
33.         UPDATE t_user SET
34.             <if test="user.name != '' and user.name != null"> name=#{user.name}, </if>
35.             <if test="user.age != null"> age=#{user.age}, </if>
36.             <if test="user.gender != '' and user.gender != null"> gender=#{user.gender}, </if>
37.             update_time=NOW()
38.         WHERE id = #{user.id}
39.     </update>
41.     <select id="queryUserById" parameterType="int" resultType="com.lm.system.common.User">
42.         SELECT <include refid="baseColumn"></include>
43.         FROM t_user
44.         WHERE id = #{id} AND deleted = 0
45.     </select>
47.     <select id="queryAllUser" resultMap="userDTO">
48.         SELECT <include refid="baseColumn"></include>
49.         FROM t_user
50.         WHERE deleted = 0
51.     </select>
53.     <update id="deleteUser" parameterType="int">
54.         UPDATE t_user SET deleted = 1
55.         WHERE id = #{id}
56.     </update>
58. </mapper>

复制代码

Service 层

在 system 目录下，新建 service 目录，在 service 目录下新建 UserService 接口。
   UserService.java（这是一个接口）

1. package com.lm.system.service;
3. import com.lm.system.common.User;
5. import java.util.List;
7. /**
8. * @Author: DuHaoLin
9. * @Date: 2024/7/27
10. */
11. public interface UserService {
13.     int insertUser(User user); //写入单个用户信息
15.     int updateUser(User user); //修改单个用户信息
17.     User queryUserById(int id); //按ID查询用户信息
19.     List<User> queryAllUser(); //查询所有用户信息
21.     int deleteUser(int id); //按ID删除用户
23. }

复制代码

在 service 目录下新建 impl 目录，在 impl 目录下新建 UserServiceImpl 类。
   UserServiceImpl.java

1. package com.lm.system.service;
3. import com.lm.system.common.User;
4. import com.lm.system.common.dto.UserDTO;
6. import java.util.List;
8. /**
9. * @Author: DuHaoLin
10. * @Date: 2024/7/27
11. */
12. public interface UserService {
14.     int insertUser(User user); //写入单个用户信息
16.     int updateUser(User user); //修改单个用户信息
18.     User queryUserById(int id); //按ID查询用户信息
20.     List<User> queryAllUser(); //查询所有用户信息
22.     int deleteUser(int id); //按ID删除用户
24. }

复制代码

Exception

在 system 目录下，新建 exception 目录，exception 目录下新建 DatabaseException 类。
   DataBaseException.java

1. package com.lm.system.exception;
3. /**
4. * @Author: DuHaoLin
5. * @Date: 2024/7/27
6. */
7. public class DataBaseException extends RuntimeException {
8.     public DataBaseException() {
9.         super();
10.     }
12.     public DataBaseException(String message) {
13.         super(message);
14.     }
16.     public DataBaseException(String message, Throwable cause) {
17.         super(message, cause);
18.     }
19. }

复制代码

  GlobalExceptionHandler.java
添加一个捕获 DatabaseException 的方法。

1. @ExceptionHandler({DataBaseException.class})
2. public String handleDataBaseException(Exception e, HttpServletRequest request) {
3.     log.error("500-数据库操作失败,{},{}", e.getMessage(), request.getServletPath());
4.     return ResultBody
5.             .build(HttpStatus.INTERNAL_SERVER_ERROR)
6.             .setMsg(e.getMessage())
7.             .getReturn();
8. }

复制代码

Util

在 system 目录下，新建 ResultUtil 类。
   ResultUtil.java

1. package com.lm.system.util;
3. import com.lm.system.common.ResultBody;
4. import org.springframework.http.HttpStatus;
6. /**
7. * @Author: DuHaoLin
8. * @Date: 2024/7/27
9. */
10. public class ResultUtil{
12.     /**
13.      * 根据操作记录数判断是否操作成功，返回对应的结果
14.      * @param i 本次操作的数据库操作记录数
15.      */
16.     private static String getResult(int i, String successMsg, String failMsg) {
17.         boolean b = i == 0;
18.         return ResultBody
19.                 .build(b ? HttpStatus.INTERNAL_SERVER_ERROR : HttpStatus.OK)
20.                 .setMsg(b ? failMsg : successMsg)
21.                 .getReturn();
22.     }
24.     public static String getAddResult(int i) {
25.         return getResult(i, "添加成功", "添加失败");
26.     }
28.     public static String getUpdateResult(int i) {
29.         return getResult(i, "修改成功", "修改失败");
30.     }
32.     public static String getDeleteResult(int i) {
33.         return getResult(i, "删除成功", "删除失败");
34.     }
36. }

复制代码

Controller 层

   UserController.java

1. package com.lm.system.controller;
3. import com.lm.system.common.ResultBody;
4. import com.lm.system.common.User;
5. import com.lm.system.common.dto.UserDTO;
6. import com.lm.system.service.UserService;
7. import com.lm.system.util.ResultUtil;
8. import io.swagger.annotations.Api;
9. import io.swagger.annotations.ApiOperation;
10. import org.springframework.beans.BeanUtils;
11. import org.springframework.http.HttpStatus;
12. import org.springframework.web.bind.annotation.*;
14. import javax.annotation.Resource;
15. import java.util.List;
18. /**
19. * @Author: DuHaoLin
20. * @Date: 2024/7/26
21. */
22. @RestController
23. @Api(tags = "用户接口")
24. @RequestMapping("user")
25. public class UserController {
27.     @Resource
28.     private UserService userService;
31.     @PostMapping("addUser")
32.     @ApiOperation("添加用户")
33.     public String addUser(@RequestBody UserDTO dto) {
34.         User user = new User();
35.         BeanUtils.copyProperties(dto, user);
36.         int i = userService.insertUser(user);
37.         return ResultUtil.getAddResult(i);
38.     }
40.     @PutMapping("updateUser")
41.     @ApiOperation("修改用户")
42.     public String updateUser(@RequestBody User user) {
43.         int i = userService.updateUser(user);
44.         return ResultUtil.getUpdateResult(i);
45.     }
47.     @GetMapping("userById/{id}")
48.     @ApiOperation("按用户ID获取用户信息")
49.     public String queryUserById(@PathVariable int id) {
50.         User user = userService.queryUserById(id);
51.         return ResultBody
52.                 .build(user == null ? HttpStatus.NO_CONTENT : HttpStatus.OK)
53.                 .setData(user)
54.                 .setCount(user == null ? 0 : 1)
55.                 .getReturn();
56.     }
58.     @GetMapping("users")
59.     @ApiOperation("获取所有用户信息")
60.     public String users() {
61.         List<User> users = userService.queryAllUser();
62.         return ResultBody
63.                 .build(HttpStatus.OK)
64.                 .setData(users)
65.                 .setCount(users.size())
66.                 .getReturn();
67.     }
69.     @DeleteMapping("deleteUser/{id}")
70.     @ApiOperation("按用户ID删除用户信息")
71.     public String deleteUser(@PathVariable int id) {
72.         int i = userService.deleteUser(id);
73.         return ResultUtil.getDeleteResult(i);
74.     }
76. }

复制代码

  UserPageController.java

1. package com.lm.system.controller;
3. import com.lm.system.common.User;
4. import com.lm.system.service.UserService;
5. import io.swagger.annotations.Api;
6. import org.springframework.stereotype.Controller;
7. import org.springframework.ui.Model;
8. import org.springframework.web.bind.annotation.GetMapping;
10. import javax.annotation.Resource;
11. import java.util.List;
13. /**
14. * @Author: DuHaoLin
15. * @Date: 2024/7/26
16. */
17. @Controller
18. @Api(tags = "用户页面")
19. public class UserPageController {
21.     @Resource
22.     private UserService userService;
24.     @GetMapping("userPage")
25.     public String user(Model model) {
26.         List<User> users = userService.queryAllUser();
27.         model.addAttribute("users", users);
28.         return "user";
29.     }
31. }

复制代码

效果图

接口文档

添加用户接口

注：Post 方法要用 Swagger 或 Postman 软件进行访问，不能使用浏览器直接进行访问。

查询全部效户接口

删除用户接口

修改用户接口

用户页面

项目目录布局

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。