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

前言

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

一、导入依赖

(1)pom.xml

<?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><groupId>org.example</groupId><artifactId>帅龍之龍</artifactId><version>1.0-SNAPSHOT</version><!-- SpringBoot应用的父级依赖:提供了SpringBoot统一的依赖管理和插件管理 --><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.5.3</version><!-- <version>3.0.1</version> --><relativePath/> <!-- lookup parent from repository --></parent><!-- JDK版本 --><properties><java.version>1.8</java.version><!-- <java.version>17</java.version> --></properties><dependencies><!-- Web启动器 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- MyBatis 持久层框架 --><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.1.1</version></dependency><!-- MyBatisPlus 增强框架 --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.2</version></dependency><!-- Druid 数据库连接池 --><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.2.15</version></dependency><!-- MySQL 驱动 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><!-- Thymeleaf --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-thymeleaf</artifactId></dependency><!-- Lombok --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><!-- UserAgent --><dependency><groupId>eu.bitwalker</groupId><artifactId>UserAgentUtils</artifactId><version>1.20</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>
</project>

二、项目配置

(1)application.yml

server:port: 8090spring:datasource:#---- ^ MySQL 数据库配置 ----#driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://127.0.0.1:3306/帅龍之龍?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTCusername: password: type: com.alibaba.druid.pool.DruidDataSource#---- / MySQL 数据库配置 ----##---- ^ Druid 数据库连接池配置 ----#druid:# 初始化连接池数量initial-size: 5# 最小连接池数量min-idle: 5# 最大连接池数量max-active: 30# 配置获取连接等待超时的时间,单位毫秒max-wait: 60000# 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒time-between-eviction-runs-millis: 60000# 配置一个连接在池中最小生存的时间,单位是毫秒min-evictable-idle-time-millis: 300000# 验证数据库连接的有效性,若返回结果不为空,则说明连接可用validation-query: select 1# 在检查闲置连接时同时检查连接可用性test-while-idle: true# 申请连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能test-on-borrow: false# 归还连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能test-on-return: false# 是否缓存preparedStatement,也就是PSCache,PSCache对支持游标的数据库性能提升巨大,比如说Oracle,而在MySQL下建议关闭pool-prepared-statements: true# 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙max-pool-prepared-statement-per-connection-size: 20filters: stat,wall# 合并多个DruidDataSource的监控数据#useGlobalDataSourceStat: true# 通过connectProperties属性来打开mergeSql功能;慢SQL记录connect-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000# 采集web-jdbc关联监控的数据web-stat-filter:enabled: trueurl-pattern: "/*"exclusions: "*.txt,*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*"# 监控配置stat-view-servlet:enabled: trueurl-pattern: "/druid/*"reset-enable: falselogin-username: rootlogin-password: 123456allow:deny:#---- / Druid ^ 数据库连接池配置 ----##---- ^ 文件上传大小限制 ----#servlet:multipart:max-file-size: 30MBmax-request-size: 30MB#---- / 文件上传大小限制 ----##---- ^ thymeleaf 前端模板配置 ----#thymeleaf:mode: HTMLencoding: UTF-8cache: falseprefix: classpath:/templates/suffix: .html#---- / thymeleaf 前端模板配置 ----##---- ^ mybatis-plus 配置 ----#
mybatis-plus:mapper-locations: mapper/*.xmlconfiguration:log-impl: org.apache.ibatis.logging.stdout.StdOutImplmap-underscore-to-camel-case: truetype-aliases-package: org.example.pojo.entity
#---- / mybatis-plus 配置 ----#

三、控制层

(1)/src/org/example/controller/RecordController.java

package org.example.controller;import org.example.service.impl.RecordServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;import javax.servlet.http.HttpServletRequest;@Controller
@RequestMapping(value = "api")
public class RecordController {@Autowiredprivate RecordServiceImpl recordService;/*** 保存用户访问记录*/@GetMapping(value = "saveUserAccessRecord")@ResponseBody@CrossOriginpublic <T> T saveUserAccessRecord (HttpServletRequest request) {return recordService.saveUserAccessRecord(request);}/*** 删除用户访问记录*/@GetMapping(value = "deleteUserAccessRecord")@ResponseBody@CrossOriginpublic <T> T deleteUserAccessRecord (@RequestParam("recordId") Integer recordId) {return recordService.deleteUserAccessRecord(recordId);}/*** 修改用户访问记录*/@GetMapping(value = "modifyUserAccessRecord")@ResponseBody@CrossOriginpublic <T> T modifyUserAccessRecord () {return recordService.modifyUserAccessRecord();}/*** 查询用户访问记录*/@GetMapping(value = "queryUserAccessRecord")@ResponseBody@CrossOriginpublic <T> T queryUserAccessRecord () {return recordService.queryUserAccessRecord();}
}

四、接口层

(1)/src/org/example/service/IRecordService.java

package org.example.service;import javax.servlet.http.HttpServletRequest;public interface IRecordService {<T> T saveUserAccessRecord(HttpServletRequest request);<T> T deleteUserAccessRecord(Integer recordId);<T> T modifyUserAccessRecord();<T> T queryUserAccessRecord();
}

五、实现层

(1)/src/org/example/service/impl/RecordServiceImpl.java

package org.example.service.impl;import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import eu.bitwalker.useragentutils.UserAgent;
import org.example.mapper.RecordMapper;
import org.example.pojo.entity.Record;
import org.example.service.IRecordService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;@Service
public class RecordServiceImpl implements IRecordService {private static final Logger log = LoggerFactory.getLogger(RecordServiceImpl.class);@Autowiredpublic RecordMapper recordMapper;@Overridepublic <T> T saveUserAccessRecord(HttpServletRequest request) {HashMap<String, Object> responseObj = new HashMap<>();try {String agent = request.getHeader("User-Agent");UserAgent userAgent = UserAgent.parseUserAgentString(agent);// 获取发起请求的IP地址String ip = request.getHeader("x-forwarded-for");if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {ip = request.getHeader("Proxy-Client-IP");}if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {ip = request.getHeader("WL-Proxy-Client-IP");}if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {ip = request.getRemoteAddr();}Record record = new Record();record.setIp(ip);record.setBrowser(userAgent.getBrowser().getName());record.setOs(userAgent.getOperatingSystem().getName());record.setDeviceType(userAgent.getOperatingSystem().getDeviceType().getName());recordMapper.insert(record);responseObj.put("code", 200);responseObj.put("success", true);responseObj.put("data", record);responseObj.put("msg", "保存成功");} catch (Exception e) {responseObj.put("code", 500);responseObj.put("success", false);responseObj.put("msg", e.getMessage());}return (T) responseObj;}@Overridepublic <T> T deleteUserAccessRecord(Integer recordId) {try {recordMapper.deleteById(recordId);return (T) "success";} catch (Exception e) {return (T) "fail";}}@Overridepublic <T> T modifyUserAccessRecord() {try {Record record = new Record();record.setId(1L);record.setIp("localhost");record.setBrowser("帅龍之龍");record.setOs("Windows 11");record.setDeviceType("Android");recordMapper.updateById(record);return (T) "success";} catch (Exception e) {return (T) "fail";}}@Overridepublic <T> T queryUserAccessRecord() {// 根据ID查询// Long recordId = (long) 1;// return (T) recordMapper.selectById(recordId);// 使用 QueryWrapper 构造器查询全部用户// QueryWrapper<Record> queryWrapper = new QueryWrapper<>();// queryWrapper.eq("ip", "0:0:0:0:0:0:0:1");// return (T) recordMapper.selectList(queryWrapper);// 使用 LambdaQueryWrapper 构造器查询全部用户LambdaQueryWrapper<Record> lambdaQueryWrapper = new LambdaQueryWrapper<>();lambdaQueryWrapper.eq(Record::getIp, "127.0.0.1");return (T) recordMapper.selectList(lambdaQueryWrapper);}
}

六、对象实体

(1)/src/org/example/pojo/entity/Record.java

package org.example.pojo.entity;import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import lombok.ToString;import java.sql.Timestamp;@Data
@ToString
public class Record {// 指定主键名、主键生产策略@TableId(value = "id", type = IdType.AUTO)private Long id;private String ip;private String os;private String browser;// 指定列名,若一致则可以不用指定,若不一致则需要指定@TableField("device_type")private String deviceType;// 指定列名,若一致则可以不用指定,若不一致则需要指定@TableField("create_time")private Timestamp createTime;
}

七、持久层

(1)/src/org/example/mapper/RecordMapper.java

package org.example.mapper;import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.example.pojo.entity.*;
import org.springframework.stereotype.Repository;@Repository
public interface RecordMapper extends BaseMapper<Record> {
}

八、启动器

(1)App.java

package org.example;import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.web.servlet.config.annotation.EnableWebMvc;@MapperScan("org.example.*")
@EnableWebMvc
@EnableTransactionManagement
@SpringBootApplication
public class App {public static void main(String[] args) {SpringApplication.run(App.class, args);}
}

九、数据表

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

十、运行效果

(1)德鲁伊登录页面

(2)查询示例

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/100408.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Eclipse iceoryx(千字自传)

1 在固定时间内实现无任何限制的数据传输 在汽车automotive、机器人robotics和游戏gaming等领域,必须在系统的不同部分之间传输大量数据。使用Linux等操作系统时,必须使用进程间通信(IPC)机制传输数据。Eclipse iceoryx是一种中间件,它使用零拷贝Zero-Copy、共享内存Share…

RPA机器人的使用条件是什么,可以使用在私域运营中吗?

随着科技的发展&#xff0c;许多新型技术为我们的生活和工作带来了极大的便利。其中&#xff0c;RPA机器人作为一种自动化工具&#xff0c;正逐渐被广泛应用于各个领域。本文将探讨RPA机器人的使用条件&#xff0c;并分析是否可以在私域运营中使用。 首先&#xff0c;了解RPA机…

JAVA--一次性输入一行数

1 使用循环逐个输入&#xff08;类C&#xff09; 首先需要创建一个用于输入的Scanner对象&#xff0c;然后使用循环来连续读取输入。当需要输入的数目未知或数目不确定时&#xff0c;这是一个常见的做法。 import java.util.Scanner;public class Main {public static void m…

【OSPF宣告——network命令与多区域配置实验案例】

个人名片&#xff1a; &#x1f43c;作者简介&#xff1a;一名大二在校生&#xff0c;喜欢编程&#x1f38b; &#x1f43b;‍❄️个人主页&#x1f947;&#xff1a;小新爱学习. &#x1f43c;个人WeChat&#xff1a;hmmwx53 &#x1f54a;️系列专栏&#xff1a;&#x1f5bc…

NanoPC-T4 RK3399:移植Kernel和rootfs

一:获取源码 Rockchip SDK: git clone https://github.com/rockchip-linux/kernel.git 主线源码: GitHub - torvalds/linux: Linux kernel source tree The Linux Kernel Archives 二:编译 1、修改Makefile ARCH := arm64 CROSS_COMPILE := /home/zhaotj/tools…

win10电脑插入耳机,右边耳机声音比左边小很多

最近使用笔记本看视频&#xff0c;发现插入耳机&#xff08;插入式和头戴式&#xff09;后&#xff0c;右边耳机声音比左边耳机声音小很多很多&#xff0c;几乎是一边很清晰&#xff0c;另一边什么都听不到。 将耳机插到别人电脑上测试耳机正常&#xff0c;那就是电脑的问题。试…

自然语言处理(NLP)的开发框架

自然语言处理&#xff08;NLP&#xff09;领域有许多开源的框架和库&#xff0c;用于处理文本数据和构建NLP应用程序。以下是一些常见的NLP开源框架及其特点&#xff0c;希望对大家有所帮助。北京木奇移动技术有限公司&#xff0c;专业的软件外包开发公司&#xff0c;欢迎交流合…

Outlook屏蔽Jira AI提醒

前言&#xff1a;最近不知道为什么jira上的ai小助手抽风&#xff0c;一周发个几千封邮件…导致我现在都不想在邮箱里面跟找垃圾一样找消息了。实在忍无可忍&#xff0c;决定屏蔽AI小助手&#xff0c;方法很简单&#xff0c;follow me~~ 第一步&#xff1a;双击打开电脑版Outloo…

springboot家乡特色推荐系统springboot28

大家好✌&#xff01;我是CZ淡陌。一名专注以理论为基础实战为主的技术博主&#xff0c;将再这里为大家分享优质的实战项目&#xff0c;本人在Java毕业设计领域有多年的经验&#xff0c;陆续会更新更多优质的Java实战项目&#xff0c;希望你能有所收获&#xff0c;少走一些弯路…

leetCode 1143.最长公共子序列 动态规划 + 滚动数组

1143. 最长公共子序列 - 力扣&#xff08;LeetCode&#xff09; 给定两个字符串 text1 和 text2&#xff0c;返回这两个字符串的最长 公共子序列 的长度。如果不存在 公共子序列 &#xff0c;返回 0 。 一个字符串的 子序列 是指这样一个新的字符串&#xff1a;它是由原字符串…

接口(interface)

接口&#xff08;interface&#xff09; 概述 接口就是规范&#xff0c;定义一组规则&#xff0c;体现了现实世界中“如果你是/要…则必须能…”的思想。继承是一个“是不是”的is-a关系&#xff0c;而接口实现则是“能不能”的has-a关系 1.接口的理解&#xff1a;接口的本质…

Oracle Database Express Edition (XE)配置与部署

获取下载安装包 https://www.oracle.com/cn/database/technologies/xe-downloads.htmlhttps://yum.oracle.com/repo/OracleLinux/OL7/latest/x86_64/index.html安装.rpm安装包 cd /usr/local/src wget https://download.oracle.com/otn-pub/otn_software/db-express/oracle-d…

Linux下kibana的安装与配置

1. 环境配置 确保Linux服务器上已安装Java 8或更高版本。可以通过运行 java -version 来验证Java的版本。 下载Kibana 7.17.11的压缩文件&#xff0c;可以从Kibana 7.17.11下载 上传服务器&#xff0c;并解压Kibana压缩文件。 2. Kibana配置 编辑Kibana的配置文件 config/k…

Golang Gocron开源定时框架

GoCron 是一个开源的 Go 语言定时任务框架&#xff0c;它允许你在 Go 代码中轻松地创建和管理定时任务。你可以使用 GoCron 来执行周期性任务、定时任务等&#xff0c;它提供了简单的 API 和丰富的功能&#xff0c;以帮助你管理定时任务。 要开始使用 GoCron&#xff0c;你需要…

Idea下面git的使用:变基、合并、优选、还原提交、重置、回滚、补丁

多分支和分支切换 变基和合并 变基是把本项目的所有提交都列出来按顺序一个个提交到目标分支上去 而合并是把两个分支合并起来&#xff0c;但是旧的分支还是可以启动其他分支&#xff0c;在旧的分支上继续开发 master: A -- B -- C -- M/ feature: D -- Emaster: A -…

Vue脚手架开发流程

一、项目运行时会先执行 public / index.html 文件 <!DOCTYPE html> <html lang""><head><meta charset"utf-8"><meta http-equiv"X-UA-Compatible" content"IEedge"><meta name"viewport&quo…

java学习--day25(反射)

文章目录 今天的内容1.反射1.1获取Class对象1.2获取Constructor对象1.3获取Method对象1.4获取Field对象 今天的内容 1.反射【重点】 1.反射 反射很重要&#xff0c;咱们以后进行封装的时候都有必要书写反射&#xff0c;让咱们的代码具有更强普适性 Java反射是在动态的获取类&am…

粘性文本整页滚动效果

效果展示 CSS 知识点 background 相关属性综合运用position 属性的 sticky 值运用scroll-behavior 属性运用scroll-snap-type 属性运用scroll-snap-align 属性运用 整体页面效果实现 <div class"container"><!-- 第一屏 --><div class"sec&qu…

一致性哈希算法

普通取模算法 假设我们有三台缓存服务器&#xff0c;用于缓存图片&#xff0c;我们为这三台缓存服务器编号为 0号、1号、2号&#xff0c;现在有3万张图片需要缓存&#xff0c;我们希望这些图片被均匀的缓存到这3台服务器上&#xff0c;以便它们能够分摊缓存的压力。也就是说&a…

JAVA编程题-求矩阵螺旋值

螺旋类 package entity; /*** 打印数组螺旋值类*/ public class Spiral { // 数组行private int row; // 数组列private int col; // 行列数private int size; // 当前行索引private int rowIndex; // 当前列索引private int colIndex; // 行开始索引private int rowStart; //…