SpringBoot 整合 MybatisPlus 3.0

SpringBoot整合MybatisPlus 3.0

1. 添加pom依赖

   <!-- druid数据库连接池启动器 --> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.9</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> <version>5.1.46</version> </dependency> <!-- mybatis-plus启动器 --> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>3.0.1</version> </dependency>

2. application.properties配置

   spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spring.datasource.username=root spring.datasource.password=123 spring.datasource.url=jdbc:mysql://localhost:3306/mp_demo?useUnicode=true&characterEncoding=utf-8&useSSL=false

3. 编写实体类

   /** * @author wsyjlly * @create 2019.06.29 - 12:18 **/ @AllArgsConstructor @NoArgsConstructor @Accessors @Data @TableName(value = "message") public class Message implements Serializable { private Integer id; private Integer mid; private String content; @TableField(value = "column_200") private String column1; @TableField(value = "column_500") private String column2; @TableField(value = "column_5000") private String column3; }

4. 编写mapper接口继承BaseMapper接口的数据操作方法

   /** * @author wsyjlly * @create 2019.06.29 - 12:30 **/ @Mapper public interface MessageMapper extends BaseMapper<Message> {}

5. 编写Service

   /** * @author wsyjlly * @create 2019.06.29 - 12:33 **/ public interface MessageService { List<Message> getAllMessage(); List<Message> getMessageByMid(Integer mid); Integer fetchOne(Integer id,Integer mid); Integer updateMessageByModuleIdAndMessageId(Message message); Integer addMessage(Message message); Integer deleteMessage(Integer mid,Integer id); }

   /** * @author wsyjlly * @create 2019.06.29 - 13:29 **/ @Service public class MessageServiceImpl implements MessageService { @Autowired private MessageMapper messageMapper; private Logger logger = LoggerFactory.getLogger(getClass()); @Override public List<Message> getAllMessage() { return messageMapper.selectList(new QueryWrapper<Message>()); } @Override public List<Message> getMessageByMid(Integer mid) { return messageMapper.selectList(new QueryWrapper<Message>().eq("mid",mid)); } @Override public Integer fetchOne(Integer id,Integer mid){ return messageMapper.selectCount(new QueryWrapper<Message>().eq("id",id).eq("mid",mid)); } @Override public Integer updateMessageByModuleIdAndMessageId(Message message){ System.out.println(message); logger.debug(message.toString()); return messageMapper.updateById(message); } @Override public Integer addMessage(Message message){ System.out.println(message); logger.debug(message.toString()); return messageMapper.insert(message); } @Override public Integer deleteMessage(Integer mid,Integer id){ logger.debug(mid+"-"+id); return messageMapper.delete(new QueryWrapper<Message>().eq("id",id).eq("mid",mid)); } }

6. 编写Controller

   /** * @author wsyjlly * @create 2019.06.29 - 12:52 **/ @RestController public class MainController { @Autowired private MessageService messageService; @GetMapping("/messages") public ModelMap getMessages(){ ModelMap map = new ModelMap(); return map.addAttribute("messages",messageService.getAllMessage()); } @GetMapping("module1") public Object getMessageType1(){ return messageService.getMessageByMid(1); } @GetMapping("module2") public Object getMessageType2(){ return messageService.getMessageByMid(2); } @PostMapping("/message") public ModelMap addMessage(@RequestBody Message message){ ModelMap map = new ModelMap(); Integer result = messageService.addMessage(message); if (result==1){ map.addAttribute("result",true); map.addAttribute("tip","添加成功！"); }else{ map.addAttribute("result",false); map.addAttribute("tip","添加失败！"); } return map; } @DeleteMapping("/{mid}/{id}") public ModelMap deleteMessage(@PathVariable Integer mid,@PathVariable Integer id){ System.out.println(mid); System.out.println(id); ModelMap map = new ModelMap(); Integer result = messageService.deleteMessage(mid,id); if (result==1){ map.addAttribute("result",true).addAttribute("tip","删除成功！"); }else{ map.addAttribute("result",false).addAttribute("tip","删除失败！"); } return map; } @PatchMapping("/message") public ModelMap updateMessage(@RequestBody Message message){ Integer one = messageService.fetchOne(message.getId(), message.getMid()); ModelMap map = new ModelMap(); if (one==1){ Integer result = messageService.updateMessageByModuleIdAndMessageId(message); if (result==1){ map.addAttribute("result",true).addAttribute("tip","更新成功！"); }else{ map.addAttribute("result",false).addAttribute("tip","更新失败！"); } System.out.println(message); }else{ map.addAttribute("tip","查询异常！"); } return map; } }

7. 显示结果