• SpringBoot项目整合MybatisPlus持久层框架+Druid数据库连接池

    前言

    之前搭建SpringBoot项目工程，所使用的持久层框架不是Mybatis就是JPA，还没试过整合MybatisPlus框架并使用，原来也如此简单。在此简单记录一下在SpringBoot项目中，整合MybatisPlus持久层框架、Druid数据库连接池的过程。

    一、导入依赖

    （1）pom.xml

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.  
    7.     <groupId>org.examplegroupId>
    8.     <artifactId>帅龍之龍artifactId>
    9.     <version>1.0-SNAPSHOTversion>
    10.  
    11.     
    12.     <parent>
    13.         <groupId>org.springframework.bootgroupId>
    14.         <artifactId>spring-boot-starter-parentartifactId>
    15.          <version>2.5.3version>
    16.         
    17.         <relativePath/> 
    18.     parent>
    19.  
    20.     
    21.     <properties>
    22.         <java.version>1.8java.version>
    23.         
    24.     properties>
    25.  
    26.     <dependencies>
    27.         
    28.         <dependency>
    29.             <groupId>org.springframework.bootgroupId>
    30.             <artifactId>spring-boot-starter-webartifactId>
    31.         dependency>
    32.  
    33.         
    34.         <dependency>
    35.             <groupId>org.mybatis.spring.bootgroupId>
    36.             <artifactId>mybatis-spring-boot-starterartifactId>
    37.             <version>2.1.1version>
    38.         dependency>
    39.  
    40.         
    41.         <dependency>
    42.             <groupId>com.baomidougroupId>
    43.             <artifactId>mybatis-plus-boot-starterartifactId>
    44.             <version>3.5.2version>
    45.         dependency>
    46.  
    47.         
    48.         <dependency>
    49.             <groupId>com.alibabagroupId>
    50.             <artifactId>druid-spring-boot-starterartifactId>
    51.             <version>1.2.15version>
    52.         dependency>
    53.  
    54.         
    55.         <dependency>
    56.             <groupId>mysqlgroupId>
    57.             <artifactId>mysql-connector-javaartifactId>
    58.             <scope>runtimescope>
    59.         dependency>
    60.  
    61.         
    62.         <dependency>
    63.             <groupId>org.springframework.bootgroupId>
    64.             <artifactId>spring-boot-starter-thymeleafartifactId>
    65.         dependency>
    66.  
    67.         
    68.         <dependency>
    69.             <groupId>org.projectlombokgroupId>
    70.             <artifactId>lombokartifactId>
    71.         dependency>
    72.  
    73.         
    74.         <dependency>
    75.             <groupId>eu.bitwalkergroupId>
    76.             <artifactId>UserAgentUtilsartifactId>
    77.             <version>1.20version>
    78.         dependency>
    79.     dependencies>
    80.  
    81.     <build>
    82.         <plugins>
    83.             <plugin>
    84.                 <groupId>org.springframework.bootgroupId>
    85.                 <artifactId>spring-boot-maven-pluginartifactId>
    86.             plugin>
    87.         plugins>
    88.     build>
    89. project>

    二、项目配置

    （1）application.yml

    1. server:
    2.   port: 8090
    3.  
    4. spring:
    5.   datasource:
    6.     #---- ^ MySQL 数据库配置 ----#
    7.     driver-class-name: com.mysql.cj.jdbc.Driver
    8.     url: jdbc:mysql://127.0.0.1:3306/帅龍之龍?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
    9.     username: 
    10.     password: 
    11.     type: com.alibaba.druid.pool.DruidDataSource
    12.     #---- / MySQL 数据库配置 ----#
    13.  
    14.     #---- ^ Druid 数据库连接池配置 ----#
    15.     druid:
    16.       # 初始化连接池数量
    17.       initial-size: 5
    18.       # 最小连接池数量
    19.       min-idle: 5
    20.       # 最大连接池数量
    21.       max-active: 30
    22.       # 配置获取连接等待超时的时间，单位毫秒
    23.       max-wait: 60000
    24.       # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
    25.       time-between-eviction-runs-millis: 60000
    26.       # 配置一个连接在池中最小生存的时间，单位是毫秒
    27.       min-evictable-idle-time-millis: 300000
    28.       # 验证数据库连接的有效性，若返回结果不为空，则说明连接可用
    29.       validation-query: select 1
    30.       # 在检查闲置连接时同时检查连接可用性
    31.       test-while-idle: true
    32.       # 申请连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能
    33.       test-on-borrow: false
    34.       # 归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能
    35.       test-on-return: false
    36.       # 是否缓存preparedStatement，也就是PSCache，PSCache对支持游标的数据库性能提升巨大，比如说Oracle，而在MySQL下建议关闭
    37.       pool-prepared-statements: true
    38.       # 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
    39.       max-pool-prepared-statement-per-connection-size: 20
    40.       filters: stat,wall
    41.       # 合并多个DruidDataSource的监控数据
    42.       #useGlobalDataSourceStat: true
    43.       # 通过connectProperties属性来打开mergeSql功能；慢SQL记录
    44.       connect-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
    45.       # 采集web-jdbc关联监控的数据
    46.       web-stat-filter:
    47.         enabled: true
    48.         url-pattern: "/*"
    49.         exclusions: "*.txt,*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*"
    50.       # 监控配置
    51.       stat-view-servlet:
    52.         enabled: true
    53.         url-pattern: "/druid/*"
    54.         reset-enable: false
    55.         login-username: root
    56.         login-password: 123456
    57.         allow:
    58.         deny:
    59.     #---- / Druid ^ 数据库连接池配置 ----#
    60.  
    61.   #---- ^ 文件上传大小限制 ----#
    62.   servlet:
    63.     multipart:
    64.       max-file-size: 30MB
    65.       max-request-size: 30MB
    66.   #---- / 文件上传大小限制 ----#
    67.  
    68.   #---- ^ thymeleaf 前端模板配置 ----#
    69.   thymeleaf:
    70.     mode: HTML
    71.     encoding: UTF-8
    72.     cache: false
    73.     prefix: classpath:/templates/
    74.     suffix: .html
    75.   #---- / thymeleaf 前端模板配置 ----#
    76.  
    77. #---- ^ mybatis-plus 配置 ----#
    78. mybatis-plus:
    79.   mapper-locations: mapper/*.xml
    80.   configuration:
    81.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    82.     map-underscore-to-camel-case: true
    83.   type-aliases-package: org.example.pojo.entity
    84. #---- / mybatis-plus 配置 ----#

    三、控制层

    （1）/src/org/example/controller/RecordController.java

    1. package org.example.controller;
    2.  
    3. import org.example.service.impl.RecordServiceImpl;
    4. import org.springframework.beans.factory.annotation.Autowired;
    5. import org.springframework.stereotype.Controller;
    6. import org.springframework.web.bind.annotation.*;
    7.  
    8. import javax.servlet.http.HttpServletRequest;
    9.  
    10. @Controller
    11. @RequestMapping(value = "api")
    12. public class RecordController {
    13.  
    14.     @Autowired
    15.     private RecordServiceImpl recordService;
    16.  
    17.     /**
    18.      * 保存用户访问记录
    19.      */
    20.     @GetMapping(value = "saveUserAccessRecord")
    21.     @ResponseBody
    22.     @CrossOrigin
    23.     public  T saveUserAccessRecord (HttpServletRequest request) {
    24.         return recordService.saveUserAccessRecord(request);
    25.     }
    26.  
    27.     /**
    28.      * 删除用户访问记录
    29.      */
    30.     @GetMapping(value = "deleteUserAccessRecord")
    31.     @ResponseBody
    32.     @CrossOrigin
    33.     public  T deleteUserAccessRecord (@RequestParam("recordId") Integer recordId) {
    34.         return recordService.deleteUserAccessRecord(recordId);
    35.     }
    36.  
    37.     /**
    38.      * 修改用户访问记录
    39.      */
    40.     @GetMapping(value = "modifyUserAccessRecord")
    41.     @ResponseBody
    42.     @CrossOrigin
    43.     public  T modifyUserAccessRecord () {
    44.         return recordService.modifyUserAccessRecord();
    45.     }
    46.  
    47.     /**
    48.      * 查询用户访问记录
    49.      */
    50.     @GetMapping(value = "queryUserAccessRecord")
    51.     @ResponseBody
    52.     @CrossOrigin
    53.     public  T queryUserAccessRecord () {
    54.         return recordService.queryUserAccessRecord();
    55.     }
    56. }

    四、接口层

    （1）/src/org/example/service/IRecordService.java

    1. package org.example.service;
    2.  
    3. import javax.servlet.http.HttpServletRequest;
    4.  
    5. public interface IRecordService {
    6.      T saveUserAccessRecord(HttpServletRequest request);
    7.  
    8.      T deleteUserAccessRecord(Integer recordId);
    9.  
    10.      T modifyUserAccessRecord();
    11.  
    12.      T queryUserAccessRecord();
    13. }

    五、实现层

    （1）/src/org/example/service/impl/RecordServiceImpl.java

    1. package org.example.service.impl;
    2.  
    3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
    4. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
    5. import eu.bitwalker.useragentutils.UserAgent;
    6. import org.example.mapper.RecordMapper;
    7. import org.example.pojo.entity.Record;
    8. import org.example.service.IRecordService;
    9. import org.slf4j.Logger;
    10. import org.slf4j.LoggerFactory;
    11. import org.springframework.beans.factory.annotation.Autowired;
    12. import org.springframework.stereotype.Service;
    13.  
    14. import javax.servlet.http.HttpServletRequest;
    15. import java.util.HashMap;
    16.  
    17. @Service
    18. public class RecordServiceImpl implements IRecordService {
    19.  
    20.     private static final Logger log = LoggerFactory.getLogger(RecordServiceImpl.class);
    21.  
    22.     @Autowired
    23.     public RecordMapper recordMapper;
    24.  
    25.     @Override
    26.     public  T saveUserAccessRecord(HttpServletRequest request) {
    27.         HashMap responseObj = new HashMap<>();
    28.  
    29.         try {
    30.             String agent = request.getHeader("User-Agent");
    31.             UserAgent userAgent = UserAgent.parseUserAgentString(agent);
    32.  
    33.             // 获取发起请求的IP地址
    34.             String ip = request.getHeader("x-forwarded-for");
    35.             if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
    36.                 ip = request.getHeader("Proxy-Client-IP");
    37.             }
    38.             if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
    39.                 ip = request.getHeader("WL-Proxy-Client-IP");
    40.             }
    41.             if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
    42.                 ip = request.getRemoteAddr();
    43.             }
    44.  
    45.             Record record = new Record();
    46.             record.setIp(ip);
    47.             record.setBrowser(userAgent.getBrowser().getName());
    48.             record.setOs(userAgent.getOperatingSystem().getName());
    49.             record.setDeviceType(userAgent.getOperatingSystem().getDeviceType().getName());
    50.             recordMapper.insert(record);
    51.  
    52.             responseObj.put("code", 200);
    53.             responseObj.put("success", true);
    54.             responseObj.put("data", record);
    55.             responseObj.put("msg", "保存成功");
    56.         } catch (Exception e) {
    57.             responseObj.put("code", 500);
    58.             responseObj.put("success", false);
    59.             responseObj.put("msg", e.getMessage());
    60.         }
    61.  
    62.         return (T) responseObj;
    63.     }
    64.  
    65.     @Override
    66.     public  T deleteUserAccessRecord(Integer recordId) {
    67.         try {
    68.             recordMapper.deleteById(recordId);
    69.             return (T) "success";
    70.         } catch (Exception e) {
    71.             return (T) "fail";
    72.         }
    73.     }
    74.  
    75.     @Override
    76.     public  T modifyUserAccessRecord() {
    77.         try {
    78.             Record record = new Record();
    79.             record.setId(1L);
    80.             record.setIp("localhost");
    81.             record.setBrowser("帅龍之龍");
    82.             record.setOs("Windows 11");
    83.             record.setDeviceType("Android");
    84.             recordMapper.updateById(record);
    85.             return (T) "success";
    86.         } catch (Exception e) {
    87.             return (T) "fail";
    88.         }
    89.     }
    90.  
    91.     @Override
    92.     public  T queryUserAccessRecord() {
    93.         // 根据ID查询
    94.         // Long recordId = (long) 1;
    95.         // return (T) recordMapper.selectById(recordId);
    96.  
    97.         // 使用 QueryWrapper 构造器查询全部用户
    98.         // QueryWrapper queryWrapper = new QueryWrapper<>();
    99.         // queryWrapper.eq("ip", "0:0:0:0:0:0:0:1");
    100.         // return (T) recordMapper.selectList(queryWrapper);
    101.  
    102.         // 使用 LambdaQueryWrapper 构造器查询全部用户
    103.         LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>();
    104.         lambdaQueryWrapper.eq(Record::getIp, "127.0.0.1");
    105.         return (T) recordMapper.selectList(lambdaQueryWrapper);
    106.     }
    107. }

    六、对象实体

    （1）/src/org/example/pojo/entity/Record.java

    1. package org.example.pojo.entity;
    2.  
    3. import com.baomidou.mybatisplus.annotation.IdType;
    4. import com.baomidou.mybatisplus.annotation.TableField;
    5. import com.baomidou.mybatisplus.annotation.TableId;
    6. import lombok.Data;
    7. import lombok.ToString;
    8.  
    9. import java.sql.Timestamp;
    10.  
    11. @Data
    12. @ToString
    13. public class Record {
    14.     // 指定主键名、主键生产策略
    15.     @TableId(value = "id", type = IdType.AUTO)
    16.     private Long id;
    17.  
    18.     private String ip;
    19.  
    20.     private String os;
    21.  
    22.     private String browser;
    23.  
    24.     // 指定列名，若一致则可以不用指定，若不一致则需要指定
    25.     @TableField("device_type")
    26.     private String deviceType;
    27.  
    28.     // 指定列名，若一致则可以不用指定，若不一致则需要指定
    29.     @TableField("create_time")
    30.     private Timestamp createTime;
    31. }

    七、持久层

    （1）/src/org/example/mapper/RecordMapper.java

    1. package org.example.mapper;
    2.  
    3. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
    4. import org.example.pojo.entity.*;
    5. import org.springframework.stereotype.Repository;
    6.  
    7. @Repository
    8. public interface RecordMapper extends BaseMapper {
    9. }

    八、启动器

    （1）App.java

    1. package org.example;
    2.  
    3. import org.mybatis.spring.annotation.MapperScan;
    4. import org.springframework.boot.SpringApplication;
    5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6. import org.springframework.transaction.annotation.EnableTransactionManagement;
    7. import org.springframework.web.servlet.config.annotation.EnableWebMvc;
    8.  
    9. @MapperScan("org.example.*")
    10. @EnableWebMvc
    11. @EnableTransactionManagement
    12. @SpringBootApplication
    13. public class App {
    14.     public static void main(String[] args) {
    15.         SpringApplication.run(App.class, args);
    16.     }
    17. }

    九、数据表

    1. --
    2. -- 表的结构 `record`
    3. --
    4.  
    5. CREATE TABLE IF NOT EXISTS `record` (
    6.   `id` bigint(20) NOT NULL AUTO_INCREMENT,
    7.   `ip` varchar(30) DEFAULT NULL,
    8.   `os` varchar(30) DEFAULT NULL,
    9.   `browser` varchar(30) DEFAULT NULL,
    10.   `device_type` varchar(30) DEFAULT NULL,
    11.   `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    12.   PRIMARY KEY (`id`)
    13. ) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=8 ;
    14.  
    15. --
    16. -- 转存表中的数据 `record`
    17. --
    18.  
    19. INSERT INTO `record` (`id`, `ip`, `os`, `browser`, `device_type`, `create_time`) VALUES
    20. (1, 'localhost', 'Windows 11', '帅龍之龍', 'Android', '2021-11-13 17:33:24'),
    21. (2, '0:0:0:0:0:0:0:1', 'WINDOWS_10', 'CHROME', 'Computer', '2021-11-13 17:43:54'),
    22. (3, '0:0:0:0:0:0:0:1', 'WINDOWS_10', 'CHROME', 'Computer', '2021-11-13 17:48:28'),
    23. (4, '127.0.0.1', 'WINDOWS_10', 'CHROME', 'Computer', '2021-11-13 17:49:38'),
    24. (5, '127.0.0.1', 'WINDOWS_10', 'CHROME', 'Computer', '2021-11-13 17:54:42'),
    25. (6, '192.168.0.101', 'Windows 10', 'Chrome 9', 'Computer', '2023-10-09 14:18:32'),
    26. (7, '192.168.0.101', 'Windows 10', 'Chrome 9', 'Computer', '2023-10-09 14:19:29');

    十、运行效果

    （1）德鲁伊登录页面

    （2）查询示例

  • 相关阅读:
    命令行参数
    旅游景区IP网络广播系统方案-旅游风景区景点IP网络广播建设指南
    SAP ABAP debug的七种方法及错误消息定位
    c语言实现面向对象编程（const * ，* const）
    Reids实战——分布式锁优化（Lua脚本）
    spark性能优化调优指导性文件
    【JavaWeb】JSP基本语法、指令、九大内置对象、四大作用域
    【数据分析入门】Seaborn[散点图、条形图、计数图、热力图、箱型图、小提琴图]
    数据⼀致性模型有哪些？
    uniapp——uicloud云服务（增删改查）
  • 原文地址：https://blog.csdn.net/Cai181191/article/details/133686732