第三章 CRUD的实现
前言
这章的主要内容是连接数据库、引入mybatis-plus,实现CRDU。
一、数据库配置
在service-upms-api项目的resources的文件夹下面创建一个application.yml的文件,具体配置如下:
spring:
datasource:
# 连接池
type: com.alibaba.druid.pool.DruidDataSource
druid:
# 数据库驱动
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: root
url: jdbc:mysql://base-mysql:3306/test?characterEncoding=utf8
这里为了解析yml文件,我们需要引入一个依赖,不引入会解析报错
<dependency>
<groupId>org.yaml</groupId>
<artifactId>snakeyaml</artifactId>
<version>1.33</version>
</dependency>
数据库连接池用的是阿里的druid,最新版本是1.2.14,由于我们是SpringBoot项目,所以引入druid-spring-boot-starter即可
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.14</version>
</dependency>
二、MyBatis-Plus配置
同样也是在application.yml里面,如下:
# mybaits-plus配置
mybatis-plus:
# MyBatis Mapper所对应的XML文件位置
mapper-locations: classpath:/mapper/*Mapper.xml
global-config:
# 关闭MP的LOGO
banner: false
MyBatis-Plus官网地址
第二章中规划了base-data模块是用来跟数据库打交道的,所以我们在这个模块来完成MyBatis-Plus的配置
引入依赖
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.2</version>
</dependency>
新建一个MybatisPlusConfig的文件,主要用来配置MapperScan和拦截器(分页、权限、多租户、乐观锁等都是通过这个来实现)
package com.ailot.cloud.base.data.mybatis;
import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.DataPermissionInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import lombok.extern.slf4j.Slf4j;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Slf4j
@Configuration
@MapperScan("com.ailot.**.mapper")
public class MybatisPlusConfig {
/**
* 分页、数据权限拦截
*
* @return PaginationInterceptor
*/
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor() {
log.info("初始化mybatis拦截器");
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
//分页拦截
interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
return interceptor;
}
}
做完这些后,在resources文件夹下面新建一个META-INF\spring.factories(spring.factories不知道怎么用的自行百度),用来自动装配我们指定的配置
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.ailot.cloud.base.data.mybatis.MybatisPlusConfig
然后,在service-upms-api这个项目中引入base-data这个包,配置好程序入口;
编译->运行,出现以下界面就表示我们成功了!
三、实现CRUD
Mapper CRUD 接口MyBatis-Plus已经帮我们实现好了,我们只需要去继承他封装的BaseMapper即可;
Service CRUD 接口MyBatis-Plus也帮我们实现好了,同样我们只需要去继承他封装的IService即可。
新建一个test的数据库,新建一个sys_user的表
CREATE TABLE `test`.`sys_user` (
`id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
`username` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
`password` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
`update_time` datetime NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP,
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;
新建实体类
package com.ailot.cloud.upms.common.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import java.time.LocalDateTime;
@Data
public class SysUser {
@TableId(type = IdType.ASSIGN_ID)
private String id;
private String username;
private String password;
private LocalDateTime createTime;
private LocalDateTime updateTime;
}
新建Mapper
package com.ailot.cloud.upms.api.mapper;
import com.ailot.cloud.upms.common.entity.SysUser;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
public interface SysUserMapper extends BaseMapper<SysUser> {
}
新建Service
package com.ailot.cloud.upms.api.service;
import com.ailot.cloud.upms.common.entity.SysUser;
import com.baomidou.mybatisplus.extension.service.IService;
public interface SysUserService extends IService<SysUser> {
}
新建ServiceImpl
package com.ailot.cloud.upms.api.service.impl;
import com.ailot.cloud.upms.api.mapper.SysUserMapper;
import com.ailot.cloud.upms.api.service.SysUserService;
import com.ailot.cloud.upms.common.entity.SysUser;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@Service
public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> implements SysUserService {
}
新建Controller
package com.ailot.cloud.upms.api.controller;
import com.ailot.cloud.upms.api.service.SysUserService;
import com.ailot.cloud.upms.common.entity.SysUser;
import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.*;
import javax.security.auth.login.CredentialNotFoundException;
@RestController
@RequestMapping("/user")
@AllArgsConstructor
public class SysUserController {
private final SysUserService sysUserService;
@PostMapping
public Boolean addUser(@RequestBody SysUser sysUser) {
return sysUserService.save(sysUser);
}
}
编译->运行,看到以下界面就表示成功了!
测试下接口
控制台输出结果:
当前版本tag:1.0.1
代码仓库
四、 体验地址
后台数据库只给了部分权限,报错属于正常!
想学的老铁给点点关注吧!!!
我是阿咕噜,一个从互联网慢慢上岸的程序员,如果喜欢我的文章,记得帮忙点个赞哟,谢谢!