Ailot

Appearance

第三章 CRUD 的实现 ​

前言 ​

这章的主要内容是连接数据库、引入 mybatis-plus，实现 CRDU。

一、数据库配置 ​

在 service-upms-api 项目的 resources 的文件夹下面创建一个 application.yml 的文件，具体配置如下：

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 文件，我们需要引入一个依赖，不引入会解析报错

xml
<dependency>
    <groupId>org.yaml</groupId>
    <artifactId>snakeyaml</artifactId>
    <version>1.33</version>
</dependency>

数据库连接池用的是阿里的druid，最新版本是 1.2.14，由于我们是 SpringBoot 项目，所以引入 druid-spring-boot-starter 即可

xml
			<dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.2.14</version>
            </dependency>

二、MyBatis-Plus 配置 ​

同样也是在 application.yml 里面，如下：

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 的配置 引入依赖

xml
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.5.2</version>
</dependency>

新建一个 MybatisPlusConfig 的文件，主要用来配置 MapperScan 和拦截器（分页、权限、多租户、乐观锁等都是通过这个来实现）

java
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 不知道怎么用的自行百度），用来自动装配我们指定的配置

yml
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 的表

sql
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;

新建实体类

java
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

java
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

java
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

java
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

java
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 代码仓库

四、 体验地址 ​

后台数据库只给了部分权限，报错属于正常！

想学的老铁给点点关注吧！！！

我是阿咕噜，一个从互联网慢慢上岸的程序员，如果喜欢我的文章，记得帮忙点个赞哟，谢谢！

Copyright © 2019-present Ailot