Spring Boot整合Mybatis-Plus和PageHelper分页插件
1 导入依赖
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.0.5</version>
</dependency>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>5.2.0</version>
</dependency>
2 application.yml文件配置数据连接池和PageHelper
server:
port: 8002
spring:
datasource:
url: jdbc:mysql://localhost:3306/j12emp?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
username: root
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
pagehelper:
helper-dialect: mysql
reasonable: true
support-methods-arguments: true
pageSizeZero: true
params=count: countSql
3 实体类Emp
package com.yy.pojo;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("emp")
public class Emp {
@TableId(value = "eid", type = IdType.AUTO)
private Integer eid;
private String ename;
private Double salary;
private Date bir;
}
4 消息类Message（整理返回前端数据）
package com.yy.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.HashMap;
import java.util.Map;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Message {
private int code;
private String ms;
private Map<String,Object> map=new HashMap<>();
public static Message success(){
Message mes=new Message();
mes.setCode(101);
mes.setMs("处理成功");
return mes;
}
public static Message fail(){
Message mes=new Message();
mes.setCode(102);
mes.setMs("处理失败");
return mes;
}
public Message add(String key,Object val){
this.getMap().put(key,val);
return this;
}
}
5 Dao层继承extends BaseMapper接口，mybatis-plus整合实现了基本的CRUD
package com.yy.dao;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yy.pojo.Emp;
public interface EmpDao extends BaseMapper<Emp> {
}
6 启动类添加@MapperScan(“mapper类包的路径”)，使用@MapperScan注解扫描dao层，dao接口不用再添加@Mapper注解
package com.yy;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@MapperScan("com.yy.dao")
public class EmpApplication {
public static void main(String[] args) {
SpringApplication.run(EmpApplication.class, args);
}
}
7 Service层代码
package com.yy.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.yy.dao.EmpDao;
import com.yy.pojo.Emp;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class EmpService {
@Autowired
EmpDao empDao;
public PageInfo<Emp> list(Integer pageIndex, Integer pageSize, String search){
PageHelper.startPage(pageIndex, pageSize);
QueryWrapper<Emp> queryWrapper = new QueryWrapper<>();
queryWrapper.like(search != null, "ename", search);
List<Emp> list = empDao.selectList(queryWrapper);
PageInfo<Emp> pageInfo = new PageInfo<>(list);
System.out.println(pageInfo);
return pageInfo;
}
public Integer add(Emp emp) {
return empDao.insert(emp);
}
public Integer del(Integer eId) {
return empDao.deleteById(eId);
}
public Integer update(Emp emp) {
return empDao.updateById(emp);
}
}
8 Controller层代码
package com.yy.controller;
import com.github.pagehelper.PageInfo;
import com.yy.pojo.Emp;
import com.yy.pojo.Message;
import com.yy.service.EmpService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@Controller
@ResponseBody
@RequestMapping("/emp")
public class EmpController {
@Autowired
EmpService empService;
@GetMapping("/")
public Message list(@RequestParam(defaultValue = "1") Integer pageIndex,
@RequestParam(defaultValue = "3") Integer pageSize,
String search) {
PageInfo<Emp> empPageInfo = empService.list(pageIndex, pageSize, search);
return Message.success().add("empPageInfo", empPageInfo);
}
@PostMapping("/")
public Message add(@RequestBody Emp emp) {
Integer integer = empService.add(emp);
if (integer>0){
return Message.success().add("emp", emp);
}else {
return Message.fail();
}
}
@PutMapping("/")
public Message update(@RequestBody Emp emp) {
if (empService.update(emp) > 0) {
return Message.success().add("emp", emp);
}
return Message.fail().add("emp", emp);
}
@DeleteMapping("/")
public Message del(Integer eId) {
if (empService.del(eId) > 0) {
return Message.success();
}
return Message.fail();
}
}
9 Postman测试
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
