SpringBoot+SpringMVC+MybatisPlus框架整合实现分页插件查询

时间 2019-11-10

标签 springboot+springmvc+mybatisplus springboot springmvc mybatisplus 框架整合实现分页插件查询栏目 Spring 繁體版

原文原文链接

一、首先介绍一下，mybatisPlus

根据官方文档的介绍，MybatisPlus（简称mp）是对mybatis的加强而不作改变，只为ti提升效率简化开发，具体参见http://mp.baomidou.com/#/?id=%e7%ae%80%e4%bb%8b前端

2.项目结构

3.框架搭建

打开Eclipse->File->New->springboot->spring starter project 选择Type为mavenjava

4.建立成功以后，配置pom.xml文件和application.yml文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>2.2.0.M1</version>
 <relativePath/> 
 </parent>

 <groupId>com.example</groupId>
 <artifactId>Springboot-mybatisPlus</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <name>Springboot-mybatisPlus</name>
 <description>Demo project for Spring Boot</description>mysql

<properties>
 <java.version>1.8</java.version>
 </properties>web

<dependencies>

 <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>

<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>spring

<dependency>
 <groupId>mysql</groupId>
 <artifactId>mysql-connector-java</artifactId>
 <scope>runtime</scope>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>sql

<!--mybatis Plus-->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.1.0</version>
</dependency>

<!-- MP 代码生成器 -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-generator</artifactId>
    <version>3.1.0</version>
</dependency>

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.0.29</version>
</dependency>

<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.16.16</version>
</dependency>数据库

apache

<dependency>
<groupId>org.apache.velocity</groupId>
<artifactId>velocity-engine-core</artifactId>
<version>2.0</version>
</dependency>

</dependencies>浏览器

<build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>缓存

<repositories>
 <repository>
 <id>spring-snapshots</id>
 <name>Spring Snapshots</name>
 <url>https://repo.spring.io/snapshot</url>
 <snapshots>
 <enabled>true</enabled>
 </snapshots>
 </repository>
 <repository>
 <id>spring-milestones</id>
 <name>Spring Milestones</name>
 <url>https://repo.spring.io/milestone</url>
 </repository>
 </repositories>
 <pluginRepositories>
 <pluginRepository>
 <id>spring-snapshots</id>
 <name>Spring Snapshots</name>
 <url>https://repo.spring.io/snapshot</url>
 <snapshots>
 <enabled>true</enabled>
 </snapshots>
 </pluginRepository>
 <pluginRepository>
 <id>spring-milestones</id>
 <name>Spring Milestones</name>
 <url>https://repo.spring.io/milestone</url>
 </pluginRepository>
 </pluginRepositories>

</project>
5.application.yml

# 该配置的名称是固定的，不能够改变，不然将不能自动加载到数据源中
spring:
datasource:
# 使用druid数据源
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:9306/wise_secretgarden?useUnicode=true&characterEncoding=utf-8
username: admin
password: admin
validation-query: "SELECT 'X' FROM DUAL"
max-wait: 10000 #最大创建链接等待时间。若是超过此时间将接到异常。设为-1表示无限制
max-idle: 10 #最大空闲数，数据库链接的最大空闲时间。超过空闲时间，数据库链接将被释放。设为0表示无限制
min-idle: 5 ##最小空闲链接:链接池中允许保持空闲状态的最小链接数量,低于这个数量将建立新的链接
max_active: 50 ##链接池的最大数据库链接数。设为0表示无限制
initial-size: 5 #初始化链接:链接池启动时建立的初始化链接数量
test-on-borrow: false
test-while-idle: true
remove_abandoned: true #超过removeAbandonedTimeout时间后，是否进行没用链接（废弃）的回收（默认为false，调整为true)
remove_abandoned_timeout: 180 #超过期间限制，回收没有用(废弃)的链接（默认为 300秒，调整为180）
time-between-eviction-runs-millis: 18800
pool-prepared-statements: true
max-pool-prepared-statement-per-connection-size: 20
connection-properties: config.decrypt=true;druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
filters: stat,wall,log4j2

mybatis-plus:
mapper-locations: classpath:/mapper/*.xml
#实体扫描，多个package用逗号或者分号分隔
typeAliasesPackage: com.example.demo.model

6.mybatis-plus配置-MybatisPlusConfig.java

package com.example.demo.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import com.baomidou.mybatisplus.plugins.PaginationInterceptor;

@Configuration

public class MybatisPlusConfig {
 /**
 * mybatis-plus分页插件 
 */
 @Bean
 public PaginationInterceptor paginationInterceptor() {
 return new PaginationInterceptor();
 }

}
7.使用mybatis-plus的代码生成插件

package com.example.demo.util;

import java.util.HashMap;
import java.util.Map;

import com.baomidou.mybatisplus.generator.AutoGenerator;
import com.baomidou.mybatisplus.generator.InjectionConfig;
import com.baomidou.mybatisplus.generator.config.DataSourceConfig;
import com.baomidou.mybatisplus.generator.config.GlobalConfig;
import com.baomidou.mybatisplus.generator.config.PackageConfig;
import com.baomidou.mybatisplus.generator.config.StrategyConfig;
import com.baomidou.mybatisplus.generator.config.converts.MySqlTypeConvert;
import com.baomidou.mybatisplus.generator.config.rules.DbColumnType;
import com.baomidou.mybatisplus.generator.config.rules.DbType;
import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class MpGenerator {

 public static void main(String[] args) {
 AutoGenerator mpg = new AutoGenerator();
 // 全局配置
 GlobalConfig gc = new GlobalConfig();
 gc.setOutputDir("D:/source");
 gc.setFileOverride(true);
 gc.setActiveRecord(true);
 gc.setEnableCache(false);// XML 二级缓存
 gc.setBaseResultMap(true);// XML ResultMap
 gc.setBaseColumnList(false);// XML columList
 gc.setAuthor("the_sardine");
 mpg.setGlobalConfig(gc);

 // 数据源配置
 DataSourceConfig dsc = new DataSourceConfig();
 dsc.setDbType(DbType.MYSQL);
 dsc.setTypeConvert(new MySqlTypeConvert() {
 // 自定义数据库表字段类型转换【可选】
 @Override
 public DbColumnType processTypeConvert(String fieldType) {
 log.info("转换类型：" + fieldType);
 // 注意！！processTypeConvert 存在默认类型转换，若是不是你要的效果请自定义返回、非以下直接返回。
 return super.processTypeConvert(fieldType);
 }
 });
 dsc.setDriverName("com.mysql.jdbc.Driver");
 dsc.setUsername("admin");
 dsc.setPassword("admin");
 dsc.setUrl("jdbc:mysql://127.0.0.1:9306/wise_secretgarden?useUnicode=true&characterEncoding=utf-8");
 mpg.setDataSource(dsc);

 // 策略配置
 StrategyConfig strategy = new StrategyConfig();
 strategy.setNaming(NamingStrategy.underline_to_camel);// 表名生成策略
 strategy.setExclude("coach");
 mpg.setStrategy(strategy);

 // 包配置
 PackageConfig pc = new PackageConfig();
 pc.setParent(null);
 pc.setEntity("com.example.demo.model");
 pc.setMapper("com.example.demo.mapper");
 pc.setService("com.example.demo.service");
 pc.setServiceImpl("com.example.demo.service.impl");
 pc.setController("com.example.demo.controller");
 mpg.setPackageInfo(pc);

 // 注入自定义配置，能够在 VM 中使用 cfg.abc 【可无】
 InjectionConfig cfg = new InjectionConfig() {
 @Override
 public void initMap() {
 Map<String, Object> map = new HashMap<>();
 map.put("abc", this.getConfig().getGlobalConfig().getAuthor() + "-mp");
 this.setMap(map);
 }
 };
 mpg.setCfg(cfg);

 mpg.execute();

 // 打印注入设置【可无】

 log.error("error", mpg.getCfg().getMap().get("abc"));
 }
}

执行代码后会生成以下结构：

将相应模块代码稍微修改下，放入项目就能够了

8.代码示例

Coach.java

package com.example.demo.model;

import java.util.Date;
import com.baomidou.mybatisplus.activerecord.Model;
import java.io.Serializable;

/**
* 
* 教练表
* 
*
* @author the_sardine
* @since 2019-04-08
*/
public class Coach extends Model<Coach> {

private static final long serialVersionUID = 1L;

private String id;
private String lang;
private Integer state;
private String name;
private String url;
private String levelText;
private String levelCode;
private String coachCode;
private String context;
private String sex;
private String birth;
private String teachAge;
private String skiAge;
private String idNumber;
private String phoneNumber;
private String email;
private Integer enableSingleSki;
private Integer enableDoubleSki;
private String peopleNum;
private String introduction;
private String money;
private String training;
private String trainingTime;
private String area;
private Date createTime;
private String createUserId;
private Date lastModifyTime;
private String lastModifyUserId;

public String getId() {
return id;
}

public void setId(String id) {
this.id = id;
}

public String getLang() {
return lang;
}

public void setLang(String lang) {
this.lang = lang;
}

public Integer getState() {
return state;
}

public void setState(Integer state) {
this.state = state;
}

public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

public String getUrl() {
return url;
}

public void setUrl(String url) {
this.url = url;
}

public String getLevelText() {
return levelText;
}

public void setLevelText(String levelText) {
this.levelText = levelText;
}

public String getLevelCode() {
return levelCode;
}

public void setLevelCode(String levelCode) {
this.levelCode = levelCode;
}

public String getCoachCode() {
return coachCode;
}

public void setCoachCode(String coachCode) {
this.coachCode = coachCode;
}

public String getContext() {
return context;
}

public void setContext(String context) {
this.context = context;
}

public String getSex() {
return sex;
}

public void setSex(String sex) {
this.sex = sex;
}

public String getBirth() {
return birth;
}

public void setBirth(String birth) {
this.birth = birth;
}

public String getTeachAge() {
return teachAge;
}

public void setTeachAge(String teachAge) {
this.teachAge = teachAge;
}

public String getSkiAge() {
return skiAge;
}

public void setSkiAge(String skiAge) {
this.skiAge = skiAge;
}

public String getIdNumber() {
return idNumber;
}

public void setIdNumber(String idNumber) {
this.idNumber = idNumber;
}

public String getPhoneNumber() {
return phoneNumber;
}

public void setPhoneNumber(String phoneNumber) {
this.phoneNumber = phoneNumber;
}

public String getEmail() {
return email;
}

public void setEmail(String email) {
this.email = email;
}

public Integer getEnableSingleSki() {
return enableSingleSki;
}

public void setEnableSingleSki(Integer enableSingleSki) {
this.enableSingleSki = enableSingleSki;
}

public Integer getEnableDoubleSki() {
return enableDoubleSki;
}

public void setEnableDoubleSki(Integer enableDoubleSki) {
this.enableDoubleSki = enableDoubleSki;
}

public String getPeopleNum() {
return peopleNum;
}

public void setPeopleNum(String peopleNum) {
this.peopleNum = peopleNum;
}

public String getIntroduction() {
return introduction;
}

public void setIntroduction(String introduction) {
this.introduction = introduction;
}

public String getMoney() {
return money;
}

public void setMoney(String money) {
this.money = money;
}

public String getTraining() {
return training;
}

public void setTraining(String training) {
this.training = training;
}

public String getTrainingTime() {
return trainingTime;
}

public void setTrainingTime(String trainingTime) {
this.trainingTime = trainingTime;
}

public String getArea() {
return area;
}

public void setArea(String area) {
this.area = area;
}

public Date getCreateTime() {
return createTime;
}

public void setCreateTime(Date createTime) {
this.createTime = createTime;
}

public String getCreateUserId() {
return createUserId;
}

public void setCreateUserId(String createUserId) {
this.createUserId = createUserId;
}

public Date getLastModifyTime() {
return lastModifyTime;
}

public void setLastModifyTime(Date lastModifyTime) {
this.lastModifyTime = lastModifyTime;
}

public String getLastModifyUserId() {
return lastModifyUserId;
}

public void setLastModifyUserId(String lastModifyUserId) {
this.lastModifyUserId = lastModifyUserId;
}

@Override
protected Serializable pkVal() {
return this.id;
}

@Override
public String toString() {
return "Coach{" +
", id=" + id +
", lang=" + lang +
", state=" + state +
", name=" + name +
", url=" + url +
", levelText=" + levelText +
", levelCode=" + levelCode +
", coachCode=" + coachCode +
", context=" + context +
", sex=" + sex +
", birth=" + birth +
", teachAge=" + teachAge +
", skiAge=" + skiAge +
", idNumber=" + idNumber +
", phoneNumber=" + phoneNumber +
", email=" + email +
", enableSingleSki=" + enableSingleSki +
", enableDoubleSki=" + enableDoubleSki +
", peopleNum=" + peopleNum +
", introduction=" + introduction +
", money=" + money +
", training=" + training +
", trainingTime=" + trainingTime +
", area=" + area +
", createTime=" + createTime +
", createUserId=" + createUserId +
", lastModifyTime=" + lastModifyTime +
", lastModifyUserId=" + lastModifyUserId +
"}";
}
}

CoachMapper.java

package com.example.demo.mapper;

import com.baomidou.mybatisplus.mapper.BaseMapper;
import com.example.demo.model.Coach;

/**
* 
* 教练表 Mapper 接口
* 
*
* @author the_sardine
* @since 2019-04-08
*/
public interface CoachMapper extends BaseMapper<Coach> {

}

打开你会发现mapper里面是空的，那是由于mybatis-plus已经帮咱们把一些经常使用的通用的增删改查的代码，还有对分页查询的处理全都封装在BaseMapper里了，简化了咱们的开发代码量。

package com.baomidou.mybatisplus.mapper;

import java.io.Serializable;
import java.util.Collection;
import java.util.List;
import java.util.Map;

import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.session.RowBounds;

/**
* 
* Mapper 继承该接口后，无需编写 mapper.xml 文件，便可得到CRUD功能
* 
* 
* 这个 Mapper 支持 id 泛型
* 
*
* @author hubin
* @Date 2016-01-23
*/
public interface BaseMapper<T> {

/**
* 
* 插入一条记录
* 
*
* @param entity 实体对象
* @return int
*/
Integer insert(T entity);

/**
* 
* 插入一条记录
* 
*
* @param entity 实体对象
* @return int
*/
Integer insertAllColumn(T entity);

/**
* 
* 根据 ID 删除
* 
*
* @param id 主键ID
* @return int
*/
Integer deleteById(Serializable id);

/**
* 
* 根据 columnMap 条件，删除记录
* 
*
* @param columnMap 表字段 map 对象
* @return int
*/
Integer deleteByMap(@Param("cm") Map<String, Object> columnMap);

/**
* 
* 根据 entity 条件，删除记录
* 
*
* @param wrapper 实体对象封装操做类（能够为 null）
* @return int
*/
Integer delete(@Param("ew") Wrapper<T> wrapper);

/**
* 
* 删除（根据ID 批量删除）
* 
*
* @param idList 主键ID列表
* @return int
*/
Integer deleteBatchIds(@Param("coll") Collection<? extends Serializable> idList);

/**
* 
* 根据 ID 修改
* 
*
* @param entity 实体对象
* @return int
*/
Integer updateById(@Param("et") T entity);

/**
* 
* 根据 ID 修改
* 
*
* @param entity 实体对象
* @return int
*/
Integer updateAllColumnById(@Param("et") T entity);

/**
* 
* 根据 whereEntity 条件，更新记录
* 
*
* @param entity 实体对象
* @param wrapper 实体对象封装操做类（能够为 null）
* @return
*/
Integer update(@Param("et") T entity, @Param("ew") Wrapper<T> wrapper);

/**
* 
* 根据 ID 查询
* 
*
* @param id 主键ID
* @return T
*/
T selectById(Serializable id);

/**
* 
* 查询（根据ID 批量查询）
* 
*
* @param idList 主键ID列表
* @return List<T>
*/
List<T> selectBatchIds(@Param("coll") Collection<? extends Serializable> idList);

/**
* 
* 查询（根据 columnMap 条件）
* 
*
* @param columnMap 表字段 map 对象
* @return List<T>
*/
List<T> selectByMap(@Param("cm") Map<String, Object> columnMap);

/**
* 
* 根据 entity 条件，查询一条记录
* 
*
* @param entity 实体对象
* @return T
*/
T selectOne(@Param("ew") T entity);

/**
* 
* 根据 Wrapper 条件，查询总记录数
* 
*
* @param wrapper 实体对象
* @return int
*/
Integer selectCount(@Param("ew") Wrapper<T> wrapper);

/**
* 
* 根据 entity 条件，查询所有记录
* 
*
* @param wrapper 实体对象封装操做类（能够为 null）
* @return List<T>
*/
List<T> selectList(@Param("ew") Wrapper<T> wrapper);

/**
* 
* 根据 Wrapper 条件，查询所有记录
* 
*
* @param wrapper 实体对象封装操做类（能够为 null）
* @return List<T>
*/
List<Map<String, Object>> selectMaps(@Param("ew") Wrapper<T> wrapper);

/**
* 
* 根据 Wrapper 条件，查询所有记录
* 注意：只返回第一个字段的值
* 
*
* @param wrapper 实体对象封装操做类（能够为 null）
* @return List<Object>
*/
List<Object> selectObjs(@Param("ew") Wrapper<T> wrapper);

/**
* 
* 根据 entity 条件，查询所有记录（并翻页）
* 
*
* @param rowBounds 分页查询条件（能够为 RowBounds.DEFAULT）
* @param wrapper 实体对象封装操做类（能够为 null）
* @return List<T>
*/
List<T> selectPage(RowBounds rowBounds, @Param("ew") Wrapper<T> wrapper);

/**
* 
* 根据 Wrapper 条件，查询所有记录（并翻页）
* 
*
* @param rowBounds 分页查询条件（能够为 RowBounds.DEFAULT）
* @param wrapper 实体对象封装操做类
* @return List<Map<String, Object>>
*/
List<Map<String, Object>> selectMapsPage(RowBounds rowBounds, @Param("ew") Wrapper<T> wrapper);

}
ICoachService.java

package com.example.demo.service;

import com.example.demo.model.Coach;
import com.baomidou.mybatisplus.service.IService;

/**
* 
* 教练表服务类
* 
*
* @author the_sardine
* @since 2019-04-08
*/
public interface ICoachService extends IService<Coach> {

}

package com.baomidou.mybatisplus.service;

import java.io.Serializable;
import java.util.Collection;
import java.util.List;
import java.util.Map;

import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.plugins.Page;

/**
* 
* 顶级 Service
* 
*
* @author hubin
* @Date 2016-04-20
*/
public interface IService<T> {

/**
* 
* 插入一条记录（选择字段，策略插入）
* 
*
* @param entity 实体对象
* @return boolean
*/
boolean insert(T entity);

/**
* 
* 插入一条记录（所有字段）
* 
*
* @param entity 实体对象
* @return boolean
*/
boolean insertAllColumn(T entity);

/**
* 
* 插入（批量），该方法不适合 Oracle
* 
*
* @param entityList 实体对象列表
* @return boolean
*/
boolean insertBatch(List<T> entityList);

/**
* 
* 插入（批量）
* 
*
* @param entityList 实体对象列表
* @param batchSize 插入批次数量
* @return boolean
*/
boolean insertBatch(List<T> entityList, int batchSize);

/**
* 
* 批量修改插入
* 
*
* @param entityList 实体对象列表
* @return boolean
*/
boolean insertOrUpdateBatch(List<T> entityList);

/**
* 
* 批量修改插入
* 
*
* @param entityList 实体对象列表
* @param batchSize
* @return boolean
*/
boolean insertOrUpdateBatch(List<T> entityList, int batchSize);

/**
* 
* 批量修改或插入所有字段
* 
*
* @param entityList 实体对象列表
* @return boolean
*/
boolean insertOrUpdateAllColumnBatch(List<T> entityList);

/**
* 批量修改或插入所有字段
*
* @param entityList 实体对象列表
* @param batchSize
* @return boolean
*/
boolean insertOrUpdateAllColumnBatch(List<T> entityList, int batchSize);

/**
* 
* 根据 ID 删除
* 
*
* @param id 主键ID
* @return boolean
*/
boolean deleteById(Serializable id);

/**
* 
* 根据 columnMap 条件，删除记录
* 
*
* @param columnMap 表字段 map 对象
* @return boolean
*/
boolean deleteByMap(Map<String, Object> columnMap);

/**
* 
* 根据 entity 条件，删除记录
* 
*
* @param wrapper 实体包装类 {@link Wrapper}
* @return boolean
*/
boolean delete(Wrapper<T> wrapper);

/**
* 
* 删除（根据ID 批量删除）
* 
*
* @param idList 主键ID列表
* @return boolean
*/
boolean deleteBatchIds(Collection<? extends Serializable> idList);

/**
* 
* 根据 ID 选择修改
* 
*
* @param entity 实体对象
* @return boolean
*/
boolean updateById(T entity);

/**
* 
* 根据 ID 修改所有字段
* 
*
* @param entity 实体对象
* @return boolean
*/
boolean updateAllColumnById(T entity);

/**
* 
* 根据 whereEntity 条件，更新记录
* 
*
* @param entity 实体对象
* @param wrapper 实体包装类 {@link Wrapper}
* @return boolean
*/
boolean update(T entity, Wrapper<T> wrapper);

/**
* 
* 根据ID 批量更新
* 
*
* @param entityList 实体对象列表
* @return boolean
*/
boolean updateBatchById(List<T> entityList);

/**
* 
* 根据ID 批量更新
* 
*
* @param entityList 实体对象列表
* @param batchSize 更新批次数量
* @return boolean
*/
boolean updateBatchById(List<T> entityList, int batchSize);

/**
* 
* 根据ID 批量更新所有字段
* 
*
* @param entityList 实体对象列表
* @return boolean
*/
boolean updateAllColumnBatchById(List<T> entityList);

/**
* 
* 根据ID 批量更新所有字段
* 
*
* @param entityList 实体对象列表
* @param batchSize 更新批次数量
* @return boolean
*/
boolean updateAllColumnBatchById(List<T> entityList, int batchSize);

/**
* 
* TableId 注解存在更新记录，否插入一条记录
* 
*
* @param entity 实体对象
* @return boolean
*/
boolean insertOrUpdate(T entity);

/**
* 插入或修改一条记录的所有字段
*
* @param entity 实体对象
* @return boolean
*/
boolean insertOrUpdateAllColumn(T entity);

/**
* 
* 根据 ID 查询
* 
*
* @param id 主键ID
* @return T
*/
T selectById(Serializable id);

/**
* 
* 查询（根据ID 批量查询）
* 
*
* @param idList 主键ID列表
* @return List<T>
*/
List<T> selectBatchIds(Collection<? extends Serializable> idList);

/**
* 
* 查询（根据 columnMap 条件）
* 
*
* @param columnMap 表字段 map 对象
* @return List<T>
*/
List<T> selectByMap(Map<String, Object> columnMap);

/**
* 
* 根据 Wrapper，查询一条记录
* 
*
* @param wrapper 实体对象
* @return T
*/
T selectOne(Wrapper<T> wrapper);

/**
* 
* 根据 Wrapper，查询一条记录
* 
*
* @param wrapper {@link Wrapper}
* @return Map<String,Object>
*/
Map<String, Object> selectMap(Wrapper<T> wrapper);

/**
* 
* 根据 Wrapper，查询一条记录
* 
*
* @param wrapper {@link Wrapper}
* @return Object
*/
Object selectObj(Wrapper<T> wrapper);

/**
* 
* 根据 Wrapper 条件，查询总记录数
* 
*
* @param wrapper 实体对象
* @return int
*/
int selectCount(Wrapper<T> wrapper);

/**
* 
* 查询列表
* 
*
* @param wrapper 实体包装类 {@link Wrapper}
* @return
*/
List<T> selectList(Wrapper<T> wrapper);

/**
* 
* 翻页查询
* 
*
* @param page 翻页对象
* @return
*/
Page<T> selectPage(Page<T> page);

/**
* 
* 查询列表
* 
*
* @param wrapper {@link Wrapper}
* @return
*/
List<Map<String, Object>> selectMaps(Wrapper<T> wrapper);

/**
* 
* 根据 Wrapper 条件，查询所有记录
* 
*
* @param wrapper 实体对象封装操做类（能够为 null）
* @return List<Object>
*/
List<Object> selectObjs(Wrapper<T> wrapper);

/**
* 
* 翻页查询
* 
*
* @param page 翻页对象
* @param wrapper {@link Wrapper}
* @return
*/
@SuppressWarnings("rawtypes")
Page<Map<String, Object>> selectMapsPage(Page page, Wrapper<T> wrapper);

/**
* 
* 翻页查询
* 
*
* @param page 翻页对象
* @param wrapper 实体包装类 {@link Wrapper}
* @return
*/
Page<T> selectPage(Page<T> page, Wrapper<T> wrapper);

}
CoachServiceImpl.java

package com.example.demo.service.impl;

import com.example.demo.model.Coach;
import com.example.demo.mapper.CoachMapper;
import com.example.demo.service.ICoachService;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;

/**
* 
* 教练表服务实现类
* 
*
* @author the_sardine
* @since 2019-04-08
*/
@Service
public class CoachServiceImpl extends ServiceImpl<CoachMapper, Coach> implements ICoachService {

}
mybatisplus封装方法在Servicelmpl中

package com.baomidou.mybatisplus.service.impl;

import java.io.Serializable;
import java.util.Collection;
import java.util.List;
import java.util.Map;

import org.apache.ibatis.binding.MapperMethod;
import org.apache.ibatis.session.SqlSession;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

import com.baomidou.mybatisplus.entity.TableInfo;
import com.baomidou.mybatisplus.enums.SqlMethod;
import com.baomidou.mybatisplus.exceptions.MybatisPlusException;
import com.baomidou.mybatisplus.mapper.BaseMapper;
import com.baomidou.mybatisplus.mapper.Condition;
import com.baomidou.mybatisplus.mapper.SqlHelper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.baomidou.mybatisplus.service.IService;
import com.baomidou.mybatisplus.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.toolkit.MapUtils;
import com.baomidou.mybatisplus.toolkit.ReflectionKit;
import com.baomidou.mybatisplus.toolkit.StringUtils;
import com.baomidou.mybatisplus.toolkit.TableInfoHelper;

/**
* 
* IService 实现类（泛型：M 是 mapper 对象，T 是实体， PK 是主键泛型）
* 
*
* @author hubin
* @Date 2016-04-20
*/
public class ServiceImpl<M extends BaseMapper<T>, T> implements IService<T> {

@Autowired
protected M baseMapper;

/**
* 
* 判断数据库操做是否成功
* 
* 
* 注意！！该方法为 Integer 判断，不可传入 int 基本类型
* 
*
* @param result 数据库操做返回影响条数
* @return boolean
*/
protected static boolean retBool(Integer result) {
return SqlHelper.retBool(result);
}

@SuppressWarnings("unchecked")
protected Class<T> currentModelClass() {
return ReflectionKit.getSuperClassGenricType(getClass(), 1);
}

/**
* 
* 批量操做 SqlSession
* 
*/
protected SqlSession sqlSessionBatch() {
return SqlHelper.sqlSessionBatch(currentModelClass());
}

/**
* 获取SqlStatement
*
* @param sqlMethod
* @return
*/
protected String sqlStatement(SqlMethod sqlMethod) {
return SqlHelper.table(currentModelClass()).getSqlStatement(sqlMethod.getMethod());
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean insert(T entity) {
return retBool(baseMapper.insert(entity));
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean insertAllColumn(T entity) {
return retBool(baseMapper.insertAllColumn(entity));
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean insertBatch(List<T> entityList) {
return insertBatch(entityList, 30);
}

/**
* 批量插入
*
* @param entityList
* @param batchSize
* @return
*/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean insertBatch(List<T> entityList, int batchSize) {
if (CollectionUtils.isEmpty(entityList)) {
throw new IllegalArgumentException("Error: entityList must not be empty");
}
try (SqlSession batchSqlSession = sqlSessionBatch()) {
int size = entityList.size();
String sqlStatement = sqlStatement(SqlMethod.INSERT_ONE);
for (int i = 0; i < size; i++) {
batchSqlSession.insert(sqlStatement, entityList.get(i));
if (i >= 1 && i % batchSize == 0) {
batchSqlSession.flushStatements();
}
}
batchSqlSession.flushStatements();
} catch (Throwable e) {
throw new MybatisPlusException("Error: Cannot execute insertBatch Method. Cause", e);
}
return true;
}

/**
* 
* TableId 注解存在更新记录，否插入一条记录
* 
*
* @param entity 实体对象
* @return boolean
*/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean insertOrUpdate(T entity) {
if (null != entity) {
Class<?> cls = entity.getClass();
TableInfo tableInfo = TableInfoHelper.getTableInfo(cls);
if (null != tableInfo && StringUtils.isNotEmpty(tableInfo.getKeyProperty())) {
Object idVal = ReflectionKit.getMethodValue(cls, entity, tableInfo.getKeyProperty());
if (StringUtils.checkValNull(idVal)) {
return insert(entity);
} else {
/*
* 更新成功直接返回，失败执行插入逻辑
*/
return updateById(entity) || insert(entity);
}
} else {
throw new MybatisPlusException("Error: Can not execute. Could not find @TableId.");
}
}
return false;
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean insertOrUpdateAllColumn(T entity) {
if (null != entity) {
Class<?> cls = entity.getClass();
TableInfo tableInfo = TableInfoHelper.getTableInfo(cls);
if (null != tableInfo && StringUtils.isNotEmpty(tableInfo.getKeyProperty())) {
Object idVal = ReflectionKit.getMethodValue(cls, entity, tableInfo.getKeyProperty());
if (StringUtils.checkValNull(idVal)) {
return insertAllColumn(entity);
} else {
/*
* 更新成功直接返回，失败执行插入逻辑
*/
return updateAllColumnById(entity) || insertAllColumn(entity);
}
} else {
throw new MybatisPlusException("Error: Can not execute. Could not find @TableId.");
}
}
return false;
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean insertOrUpdateBatch(List<T> entityList) {
return insertOrUpdateBatch(entityList, 30);
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean insertOrUpdateBatch(List<T> entityList, int batchSize) {
return insertOrUpdateBatch(entityList, batchSize, true);
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean insertOrUpdateAllColumnBatch(List<T> entityList) {
return insertOrUpdateBatch(entityList, 30, false);
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean insertOrUpdateAllColumnBatch(List<T> entityList, int batchSize) {
return insertOrUpdateBatch(entityList, batchSize, false);
}

/**
* 批量插入修改
*
* @param entityList 实体对象列表
* @param batchSize 批量刷新个数
* @param selective 是否滤掉空字段
* @return boolean
*/
private boolean insertOrUpdateBatch(List<T> entityList, int batchSize, boolean selective) {
if (CollectionUtils.isEmpty(entityList)) {
throw new IllegalArgumentException("Error: entityList must not be empty");
}
try (SqlSession batchSqlSession = sqlSessionBatch()) {
int size = entityList.size();
for (int i = 0; i < size; i++) {
if (selective) {
insertOrUpdate(entityList.get(i));
} else {
insertOrUpdateAllColumn(entityList.get(i));
}
if (i >= 1 && i % batchSize == 0) {
batchSqlSession.flushStatements();
}
}
batchSqlSession.flushStatements();
} catch (Throwable e) {
throw new MybatisPlusException("Error: Cannot execute insertOrUpdateBatch Method. Cause", e);
}
return true;
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean deleteById(Serializable id) {
return SqlHelper.delBool(baseMapper.deleteById(id));
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean deleteByMap(Map<String, Object> columnMap) {
if (MapUtils.isEmpty(columnMap)) {
throw new MybatisPlusException("deleteByMap columnMap is empty.");
}
return SqlHelper.delBool(baseMapper.deleteByMap(columnMap));
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean delete(Wrapper<T> wrapper) {
return SqlHelper.delBool(baseMapper.delete(wrapper));
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean deleteBatchIds(Collection<? extends Serializable> idList) {
return SqlHelper.delBool(baseMapper.deleteBatchIds(idList));
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateById(T entity) {
return retBool(baseMapper.updateById(entity));
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateAllColumnById(T entity) {
return retBool(baseMapper.updateAllColumnById(entity));
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean update(T entity, Wrapper<T> wrapper) {
return retBool(baseMapper.update(entity, wrapper));
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateBatchById(List<T> entityList) {
return updateBatchById(entityList, 30);
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateBatchById(List<T> entityList, int batchSize) {
return updateBatchById(entityList, batchSize, true);
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateAllColumnBatchById(List<T> entityList) {
return updateAllColumnBatchById(entityList, 30);
}

@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateAllColumnBatchById(List<T> entityList, int batchSize) {
return updateBatchById(entityList, batchSize, false);
}

/**
* 根据主键ID进行批量修改
*
* @param entityList 实体对象列表
* @param batchSize 批量刷新个数
* @param selective 是否滤掉空字段
* @return boolean
*/
private boolean updateBatchById(List<T> entityList, int batchSize, boolean selective) {
if (CollectionUtils.isEmpty(entityList)) {
throw new IllegalArgumentException("Error: entityList must not be empty");
}
try (SqlSession batchSqlSession = sqlSessionBatch()) {
int size = entityList.size();
SqlMethod sqlMethod = selective ? SqlMethod.UPDATE_BY_ID : SqlMethod.UPDATE_ALL_COLUMN_BY_ID;
String sqlStatement = sqlStatement(sqlMethod);
for (int i = 0; i < size; i++) {
MapperMethod.ParamMap<T> param = new MapperMethod.ParamMap<>();
param.put("et", entityList.get(i));
batchSqlSession.update(sqlStatement, param);
if (i >= 1 && i % batchSize == 0) {
batchSqlSession.flushStatements();
}
}
batchSqlSession.flushStatements();
} catch (Throwable e) {
throw new MybatisPlusException("Error: Cannot execute updateBatchById Method. Cause", e);
}
return true;
}

@Override
public T selectById(Serializable id) {
return baseMapper.selectById(id);
}

@Override
public List<T> selectBatchIds(Collection<? extends Serializable> idList) {
return baseMapper.selectBatchIds(idList);
}

@Override
public List<T> selectByMap(Map<String, Object> columnMap) {
return baseMapper.selectByMap(columnMap);
}

@Override
public T selectOne(Wrapper<T> wrapper) {
return SqlHelper.getObject(baseMapper.selectList(wrapper));
}

@Override
public Map<String, Object> selectMap(Wrapper<T> wrapper) {
return SqlHelper.getObject(baseMapper.selectMaps(wrapper));
}

@Override
public Object selectObj(Wrapper<T> wrapper) {
return SqlHelper.getObject(baseMapper.selectObjs(wrapper));
}

@Override
public int selectCount(Wrapper<T> wrapper) {
return SqlHelper.retCount(baseMapper.selectCount(wrapper));
}

@Override
public List<T> selectList(Wrapper<T> wrapper) {
return baseMapper.selectList(wrapper);
}

@Override
public Page<T> selectPage(Page<T> page) {
return selectPage(page, Condition.EMPTY);
}

@Override
public List<Map<String, Object>> selectMaps(Wrapper<T> wrapper) {
return baseMapper.selectMaps(wrapper);
}

@Override
public List<Object> selectObjs(Wrapper<T> wrapper) {
return baseMapper.selectObjs(wrapper);
}

@Override
public Page<Map<String, Object>> selectMapsPage(Page page, Wrapper<T> wrapper) {
wrapper = (Wrapper<T>) SqlHelper.fillWrapper(page, wrapper);
page.setRecords(baseMapper.selectMapsPage(page, wrapper));
return page;
}

@Override
public Page<T> selectPage(Page<T> page, Wrapper<T> wrapper) {
wrapper = (Wrapper<T>) SqlHelper.fillWrapper(page, wrapper);
page.setRecords(baseMapper.selectPage(page, wrapper));
return page;
}
}

CoachController.java

package com.example.demo.controller;

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

import com.baomidou.mybatisplus.plugins.Page;
import com.example.demo.model.Coach;
import com.example.demo.service.ICoachService;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;

/**
* 
* 教练表前端控制器
* 
*
* @author the_sardine
* @since 2019-04-08
*/
@RestController
@RequestMapping("/coach")
public class CoachController {

 @Autowired
 private ICoachService iCoachService;

 @GetMapping("/select")//等同于@RequestMapping(value = "/list",method = RequestMethod.GET)
 public List<Coach> select(){
 return iCoachService.selectList(null);

 }

 @RequestMapping("/list")
 public Page<Coach> list(){
 System.out.println("fff");
 Page<Coach>selectPage=iCoachService.selectPage(new Page<>(0,10),null);
 System.out.println("ccc");
 System.out.println(selectPage);
 System.out.println(selectPage.getTotal());
 System.out.println(selectPage.getSize());
 System.out.println(selectPage.toString());
 return selectPage;
 }


 @GetMapping("/selects")
 public String selects(){
 return "hello world";

 }

}
经过mybatisplus生成的CoachMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.demo.mapper.CoachMapper">

<resultMap id="BaseResultMap" type="com.example.demo.model.Coach">
<id column="id" property="id" />
<result column="lang" property="lang" />
<result column="state" property="state" />
<result column="name" property="name" />
<result column="url" property="url" />
<result column="levelText" property="levelText" />
<result column="levelCode" property="levelCode" />
<result column="coachCode" property="coachCode" />
<result column="context" property="context" />
<result column="sex" property="sex" />
<result column="birth" property="birth" />
<result column="teachAge" property="teachAge" />
<result column="skiAge" property="skiAge" />
<result column="idNumber" property="idNumber" />
<result column="phoneNumber" property="phoneNumber" />
<result column="email" property="email" />
<result column="enableSingleSki" property="enableSingleSki" />
<result column="enableDoubleSki" property="enableDoubleSki" />
<result column="peopleNum" property="peopleNum" />
<result column="introduction" property="introduction" />
<result column="money" property="money" />
<result column="training" property="training" />
<result column="trainingTime" property="trainingTime" />
<result column="area" property="area" />
<result column="createTime" property="createTime" />
<result column="createUserId" property="createUserId" />
<result column="lastModifyTime" property="lastModifyTime" />
<result column="lastModifyUserId" property="lastModifyUserId" />
</resultMap>

</mapper>

入口启动类

package com.example.demo;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@MapperScan("com.example.demo.mapper")
public class SpringbootMybatisPlusApplication {

   public static void main(String[] args) {
       SpringApplication.run(SpringbootMybatisPlusApplication.class, args);
   }

}
运行

在浏览器中输入url地址

控制台打印分页信息

SpringBoot+SpringMVC+MybatisPlus框架整合实现分页插件查询

一、首先介绍一下，mybatisPlus

2.项目结构

3.框架搭建

4.建立成功以后，配置pom.xml文件和application.yml文件

</project> 5.application.yml

6.mybatis-plus配置-MybatisPlusConfig.java

} 7.使用mybatis-plus的代码生成插件

</project>
5.application.yml

}
7.使用mybatis-plus的代码生成插件