10

30

springboot创建mymes

发表于 2020-10-30 • 被 1,464 人看爆

mymes项目搭建基本骨架

本文主要讲解mymes整合SpringBoot+MyBatis搭建基本骨架，以工业MES为基础实现基本的的CRUD操作及通过PageHelper实现分页查询。

1.mysql数据库环境的搭建

下载并安装mysql5.7,下载地址：https://dev.mysql.com/downloads/installer/
创建数据库脚本mymes

项目框架介绍

SpringBoot

Spring Boot提供了一种新的编程范式，能在最小的阻力下开发Spring应用程序。有了它，你可以更加敏捷地开发Spring应用程序，专注于应用程序的功能，不用在Spring的配置上多花功夫，甚至完全不用配置。实际上，Spring Boot的一项重要工作就是让Spring不再成为你成功路上的绊脚石。

Druid

Druid是一个高效的数据查询系统，主要解决的是对于大量的基于时序的数据进行聚合查询。数据可以实时摄入，进入到Druid后立即可查，同时数据是几乎是不可变。通常是基于时序的事实事件，事实发生后进入Druid，外部系统就可以对该事实进行查询。

Mybatis generator

MyBatis的代码生成器，可以根据数据库生成model、mapper.xml、mapper接口和Example，通常情况下的单表查询不用再手写mapper。

搭建项目

IDEA下载2020.1链接：https://pan.baidu.com/s/1ht1HdpcCYFB_txQ8Xm1MLA 关注公众号:回复IDEA获取提取码

使用IDEA初始化一个SpringBoot项目

创建springboot

添加项目依赖

在pom.xml中添加要使用的依赖

<!--MyBatis分页插件-->
       <dependency>
           <groupId>com.github.pagehelper</groupId>
           <artifactId>pagehelper-spring-boot-starter</artifactId>
           <version>1.2.10</version>
       </dependency>
       <!--集成druid连接池-->
       <dependency>
           <groupId>com.alibaba</groupId>
           <artifactId>druid-spring-boot-starter</artifactId>
           <version>1.1.10</version>
       </dependency>
       <!-- MyBatis 生成器 -->
       <dependency>
           <groupId>org.mybatis.generator</groupId>
           <artifactId>mybatis-generator-core</artifactId>
           <version>1.3.7</version>
       </dependency>
       <!--Mysql数据库驱动-->
       <dependency>
           <groupId>mysql</groupId>
           <artifactId>mysql-connector-java</artifactId>
           <version>5.1.10</version>
       </dependency>
       <!--Hutool Java工具包-->
       <dependency>
           <groupId>cn.hutool</groupId>
           <artifactId>hutool-all</artifactId>
           <version>4.5.7</version>
       </dependency>
       <!--MyBatis Plus 依赖-->
       <dependency>
           <groupId>com.baomidou</groupId>
           <artifactId>mybatis-plus-boot-starter</artifactId>
           <version>3.3.2</version>
       </dependency>
       <!--MyBatis Plus 代码生成器-->
       <dependency>
           <groupId>com.baomidou</groupId>
           <artifactId>mybatis-plus-generator</artifactId>
           <version>3.3.2</version>
       </dependency>

MySql数据驱动的注意事项:

下载的是5.7的mysql则mysql-connector-java版本下载5.1.X的，配置使用com.mysql.jdbc.Driver
下载的是8.X的mysql则mysql-connector-java版本下载8.0，配置使用 com.mysql.cj.jdbc.Driver

修改SpringBoot配置文件

创建application.yml中添加数据源配置和MyBatis的mapper.xml的路径配置

server: port: 9999 spring: datasource: url: jdbc:mysql://localhost:3306/mymes?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai username: root password: root

mybatis: mapper-locations: - classpath:mapper/.xml - classpath:com/**/mapper/*.xml

创建common文件夹存放通用类,例如通用返回类

import cn.hutool.core.convert.Convert;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import java.util.List;
/**

  分页数据封装类

 

 */

public class CommonPage<T> {

    private Integer pageNum;

    private Integer pageSize;

    private Integer totalPage;

    private Long total;

    private List<T> list;
    /**

      将MyBatis Plus 分页结果转化为通用结果

     /

    public static <T> CommonPage<T> restPage(Page<T> pageResult) {

        CommonPage<T> result = new CommonPage<>();

        result.setPageNum(Convert.toInt(pageResult.getCurrent()));

        result.setPageSize(Convert.toInt(pageResult.getSize()));

        result.setTotal(pageResult.getTotal());

        result.setTotalPage(Convert.toInt(pageResult.getTotal()/pageResult.getSize()+1));

        result.setList(pageResult.getRecords());

        return result;

    }
    public Integer getPageNum() {

        return pageNum;

    }
    public void setPageNum(Integer pageNum) {

        this.pageNum = pageNum;

    }
    public Integer getPageSize() {

        return pageSize;

    }
    public void setPageSize(Integer pageSize) {

        this.pageSize = pageSize;

    }
    public Integer getTotalPage() {

        return totalPage;

    }
    public void setTotalPage(Integer totalPage) {

        this.totalPage = totalPage;

    }
    public List<T> getList() {

        return list;

    }
    public void setList(List<T> list) {

        this.list = list;

    }
    public Long getTotal() {

        return total;

    }
    public void setTotal(Long total) {

        this.total = total;

    }

}

/**
 * 通用返回对象
 *
 */
public class CommonResult<T> {
    private long code;
    private String message;
    private T data;

    protected CommonResult() {
    }

    protected CommonResult(long code, String message, T data) {
        this.code = code;
        this.message = message;
        this.data = data;
    }

    /**
     * 成功返回结果
     *
     * @param data 获取的数据
     */
    public static <T> CommonResult<T> success(T data) {
        return new CommonResult<T>(ResultCode.SUCCESS.getCode(), ResultCode.SUCCESS.getMessage(), data);
    }

    /**
     * 成功返回结果
     *
     * @param data 获取的数据
     * @param  message 提示信息
     */
    public static <T> CommonResult<T> success(T data, String message) {
        return new CommonResult<T>(ResultCode.SUCCESS.getCode(), message, data);
    }

    /**
     * 失败返回结果
     * @param errorCode 错误码
     */
    public static <T> CommonResult<T> failed(IErrorCode errorCode) {
        return new CommonResult<T>(errorCode.getCode(), errorCode.getMessage(), null);
    }

    /**
     * 失败返回结果
     * @param errorCode 错误码
     * @param message 错误信息
     */
    public static <T> CommonResult<T> failed(IErrorCode errorCode,String message) {
        return new CommonResult<T>(errorCode.getCode(), message, null);
    }

    /**
     * 失败返回结果
     * @param message 提示信息
     */
    public static <T> CommonResult<T> failed(String message) {
        return new CommonResult<T>(ResultCode.FAILED.getCode(), message, null);
    }

    /**
     * 失败返回结果
     */
    public static <T> CommonResult<T> failed() {
        return failed(ResultCode.FAILED);
    }

    /**
     * 参数验证失败返回结果
     */
    public static <T> CommonResult<T> validateFailed() {
        return failed(ResultCode.VALIDATE_FAILED);
    }

    /**
     * 参数验证失败返回结果
     * @param message 提示信息
     */
    public static <T> CommonResult<T> validateFailed(String message) {
        return new CommonResult<T>(ResultCode.VALIDATE_FAILED.getCode(), message, null);
    }

    /**
     * 未登录返回结果
     */
    public static <T> CommonResult<T> unauthorized(T data) {
        return new CommonResult<T>(ResultCode.UNAUTHORIZED.getCode(), ResultCode.UNAUTHORIZED.getMessage(), data);
    }

    /**
     * 未授权返回结果
     */
    public static <T> CommonResult<T> forbidden(T data) {
        return new CommonResult<T>(ResultCode.FORBIDDEN.getCode(), ResultCode.FORBIDDEN.getMessage(), data);
    }

    public long getCode() {
        return code;
    }

    public void setCode(long code) {
        this.code = code;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    public T getData() {
        return data;
    }

    public void setData(T data) {
        this.data = data;
    }
}

/**
 * 封装API的错误码
 * 
 */
public interface IErrorCode {
    long getCode();

    String getMessage();
}

/**
 * 枚举了一些常用API操作码
 * 
 */
public enum ResultCode implements IErrorCode {
    SUCCESS(200, "操作成功"),
    FAILED(500, "操作失败"),
    VALIDATE_FAILED(404, "参数检验失败"),
    UNAUTHORIZED(401, "暂未登录或token已经过期"),
    FORBIDDEN(403, "没有相关权限");
    private long code;
    private String message;

    private ResultCode(long code, String message) {
        this.code = code;
        this.message = message;
    }

    public long getCode() {
        return code;
    }

    public String getMessage() {
        return message;
    }
}

公众号