Springboot集成Mybatispuls操作mysql数据库-03

news2024/10/6 2:27:02

MyBatis-Plus（简称MP）是一个MyBatis的增强工具，在MyBatis的基础上只做增强而不做改变。它支持所有MyBatis原生的特性，因此引入MyBatis-Plus不会对现有的MyBatis构架产生任何影响。MyBatis-Plus旨在简化开发、提高效率，特别是简化了CRUD（增删改查）操作。

MyBatis-Plus的常见使用场景

  1. 数据权限控制：在查询数据时，自动添加当前用户可访问的数据范围的WHERE条件。
  2. 多租户支持：在查询数据时，自动添加租户ID的WHERE条件，以区分不同租户的数据。
  3. 动态表名：根据不同的请求参数，动态修改SQL语句中的表名，以实现数据分片或数据隔离等功能。
  4. 加密解密：对数据库中的敏感数据进行加密，查询数据时进行解密。
  5. 缓存优化：通过缓存某些查询结果来提高系统性能，可以将缓存对象作为拦截器的属性来管理。

MyBatis-Plus通过启动加载XML配置时注入单表SQL操作来简化开发工作，提高生产率。总的来说，MyBatis-Plus是一个强大的MyBatis增强工具，为开发者提供了更多的便利和灵活性。

Springboot集成Mybatisplus

涉及的模块

  • springboot-mybatisplus：mysql测试，端口号18086

但在此模块中我们会通过springbootTest和Controller两种方式来进行测试。

本示例依赖一个基础开发框架，这部分详细可参考：动手开发基于Springboot的基础开发框架-01

模块结构说明

在这里插入图片描述

  • 类文件说明

    • SystemLogController.java：controller，它会调用ISystemLogDao接口
    • ISystemLogDao.java：Dao接口
    • SystemLogQuery：ISystemLogDao接口参数
    • SystemLogDaoImpl.java：ISystemLogDao接口实现
    • SystemLogMapper.java：mybatis Mapper接口
    • SystemLogEntity.java：数据库实体类

  • 文件夹

    • resources/mybatis：mybatis配置文件，一般与SystemLogMapper.java一一对应

  • 测试类

    • SystemLogControllerTest：测试 LoadBalanceController.java URI接口功能
    • SystemLogDaoTest：测试 ISystemLogDao.java 接口实现功能

数据库脚本

数据库脚本

CREATE TABLE `jdemo`.`t_sys_record_demo`  (
  `uuid` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
  `biz_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '业务ID',
  `user_id` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '操作用户ID',
  `track_uid` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '链路ID',
  `code` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '操作代码',
  `custom_code` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '操作2级代码',
  `status` int NULL DEFAULT NULL COMMENT '记录状态:1可查询，0不可查询',
  `ctime` datetime NULL DEFAULT NULL,
  `utime` datetime NULL DEFAULT NULL,
  `cid` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
  `cname` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
  PRIMARY KEY (`uuid`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

java实体类

注意下列@TableName中的值要和数据库表名一致。

@Data
@EqualsAndHashCode(callSuper = true)
@Accessors(chain = true)
@TableName("t_sys_record_demo")
public class SystemLogEntity extends DBEntity {

    private String bizId;

    private String userId;

    private String trackUid;

    private String code;

    private String customCode;

    private Integer status;

    @TableField(value = "cid", fill = FieldFill.INSERT, insertStrategy = FieldStrategy.NEVER, updateStrategy = FieldStrategy.NEVER)
    private String cid;

    @TableField(value = "cname", fill = FieldFill.INSERT, insertStrategy = FieldStrategy.NEVER, updateStrategy = FieldStrategy.NEVER)
    private String cname;

}

模块配置

Maven 依赖

这里需要注意mybatisplus分2和3两个版本，3版本对应的springboot3，2对应的是springboot2，这两个mybatisplus版本并不兼容。

    <dependencies>
        <!--数据库相关-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-spring-boot3-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
        </dependency>
        <!--工具包-->
        <dependency>
            <groupId>com.korgs</groupId>
            <artifactId>framework-persistence</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>

framework-persistence是笔者开发的一个基础jar包，在最后的源码中可以找到。

Invalid value type for attribute ‘factoryBeanObjectType’: java.lang.String 这个错误是由于版本不对引起的， 因为mybatis2和3不相互兼容，这主要是jdk版本不同导致的，其它三方插件也有这个问题。

application.properties配置

spring.profiles.active = dev
spring.application.name=springbootMybatisplus
server.port=18086
#debug=true

management.endpoints.web.exposure.include = *
management.endpoint.health.show-details=always

##mybatis Server
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/jdemo?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=12345678
spring.datasource.druid.initial-size=5
spring.datasource.druid.min-idle=5
spring.datasource.druid.max-active=20
spring.datasource.druid.max-wait=60000
spring.datasource.druid.validation-query=SELECT 1 FROM DUAL
spring.datasource.druid.max-pool-prepared-statement-per-connection-size=5
spring.datasource.druid.test-while-idle=true
spring.datasource.druid.test-on-borrow=false
spring.datasource.druid.test-on-return=false
spring.datasource.druid.time-between-eviction-runs-millis=60000
spring.datasource.druid.min-evictable-idle-time-millis=100000
spring.datasource.druid.filters=stat
#
##mybatis plugs
mybatis-plus.mapper-locations=classpath:/mybatis/*Mapper.xml
mybatis-plus.configuration.map-underscore-to-camel-case=true
mybatis-plus.configuration.default-statement-timeout=20000
mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

注意上面配置中的mybatis-plus.configuration.log-impl和mybatis-plus.mapper-locations。前者用于日志打印，在发布应用时需要注释掉，后者用来指定Mapper.xml文件存放的classpath地址。

修改 SpringbootApplication启动类

配置@MapperScan注解，比如@MapperScan("com.korgs.dao")表示要查找的mybatis bean类。

@Slf4j
@SpringBootApplication(scanBasePackages = {"com.korgs",  "cn.hutool.extra.spring"})
@Configuration
@EnableConfigurationProperties
@ServletComponentScan
@RestController
@MapperScan("com.korgs.dao")
public class SpringbootMybatisplusApplication {

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

	@GetMapping("/helloworld")
	public BaseResponse helloWorld(){
		log.info(LogGenerator.trackLog()
				+ "msg="+ "I am busy to handle this request.");
		return BaseResponse.success("hello world");
	}
}

程序实现

定义ISystemLogDao接口

定义供上层类调用的数据库操作接口

在这里插入图片描述

接口定义
public interface ISystemLogDao extends IService<SystemLogEntity> {

    List<SystemLogEntity> listByCondition(SystemLogQuery query);

    IPage<SystemLogEntity> pageSystemLog(IPage<SystemLogEntity> iPage, String bizId, String code);
}
接口实现
@Repository
@Primary
public class SystemLogDaoImpl extends ServiceImpl<SystemLogMapper, SystemLogEntity> implements ISystemLogDao {

    @Override
    public List<SystemLogEntity> listByCondition(SystemLogQuery query) {
        LambdaQueryWrapper<SystemLogEntity> queryWrapper = Wrappers.lambdaQuery();
        if(StrUtil.isNotEmpty(query.getCode())){
            queryWrapper.eq(SystemLogEntity::getCode, query.getCode());
        }
        if(StrUtil.isNotEmpty(query.getBizId())){
            queryWrapper.eq(SystemLogEntity::getBizId, query.getBizId());
        }
        return list(queryWrapper);
    }

    @Override
    public IPage<SystemLogEntity> pageSystemLog(IPage<SystemLogEntity> iPage, String bizId, String code) {
        return this.getBaseMapper().pageSystemLog(iPage, bizId, code);
    }

}
接口参数
@Data
public class SystemLogQuery {

    private String bizId;

    private String code;
}

定义Mapper实现

一个Mapper实现类对应一个Mapper.xml，即使Mapper.xml为空实现也需要配置。

Mapper接口定义
public interface SystemLogMapper extends BaseMapper<SystemLogEntity> {

    IPage<SystemLogEntity> pageSystemLog(IPage<SystemLogEntity> iPage,
                                         @Param("bizId") String bizId,
                                         @Param("code") String code);
}
Mapper接口对应的Mapper.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.korgs.dao.SystemLogMapper">

    <select id="pageSystemLog" resultType="com.korgs.dao.SystemLogEntity">
        select
            t_sys_record_demo.*
        from
            t_sys_record_demo
        where 1=1
        <if test="bizId != null">
            and t_sys_record_demo.biz_id = #{bizId}
        </if>
        <if test="code != null">
            and upper(t_sys_record_demo.code) LIKE upper(CONCAT('%',#{code},'%'))
        </if>
    </select>
</mapper>

上述配置文件中：

  • mapper标签：配置为SystemLogMapper.java类的全路径
  • select标签中的id属性：配置为SystemLogMapper.java类中定义的接口名称
    • select标签中的resultType属性：定义为sql语句要返回的实体对象的全路径，此值也与SystemLogMapper.java中相应的接口返回参数相对应。

编写Controller Restful

@Slf4j
@RestController
@RequestMapping("/api/load")
public class SystemLogController {

    @Autowired
    private ISystemLogDao iSystemLogDao;

    @GetMapping("/v1/hello-content")
    public ListResponse<SystemLogEntity> loadHelloContent(String uuid){
        log.info("{} uuid ={}", LogGenerator.trackLog(), uuid);

        List<SystemLogEntity> list = iSystemLogDao.list();
        log.info("{} uuid={} size={}", LogGenerator.trackLog(), uuid, CollUtil.size(list));

        return ListResponse.success(list);
    }
}

使用SpringbootTest测试

测试Dao接口

@SpringBootTest
public class SystemLogDaoTest {
    private static final Logger logger = LoggerFactory.getLogger(SystemLogDaoTest.class);

    @Autowired
    private ISystemLogDao iSystemLogDao;

    /*注意此处要引用 import org.junit.jupiter.api.Test;*/

    /*全表搜索*/
    @Test
    public void iSystemLogDao() {
        List<SystemLogEntity> list = iSystemLogDao.list();
        logger.info(JSONUtil.toJsonStr(list));
    }

    /*增加操作*/
    @Test
    public void iSystemLogDaoInsert() {
        SystemLogEntity systemLogEntity = new SystemLogEntity();
        systemLogEntity.setUuid(UUIDUtil.uuid32());
        iSystemLogDao.save(systemLogEntity);
    }

    /*删除操作*/
    @Test
    public void iSystemLogDaoDelete() {
        iSystemLogDao.removeById("3006316502a24b6b8b5eac4d1a8f6e5a");
    }

    /*更新操作*/
    @Test
    public void iSystemLogDaoUpdate() {
        SystemLogEntity systemLogEntity = new SystemLogEntity();
        systemLogEntity.setUuid("a4dd3bcf2a134941a4a1fb9119028600");
        systemLogEntity.setCode("heart");
        iSystemLogDao.updateById(systemLogEntity);
    }

    /*分页查询*/
    @Test
    public  void iSystemLogDaoPage() {
        IPage<SystemLogEntity> iPage = new Page<SystemLogEntity>(1, 3);
        iPage = iSystemLogDao.pageSystemLog(iPage, "001", "lung");
        List<SystemLogEntity>  logEntityIPage = iPage.getRecords();
        logger.info(JSONUtil.toJsonStr(logEntityIPage));
    }

}

测试Controller服务

@SpringBootTest
@AutoConfigureMockMvc
public class SystemLogControllerTest {
    @Autowired
    protected MockMvc mockMvc;

    private HttpHeaders httpHeaders = new HttpHeaders();

    private static final ObjectMapper mapper = new ObjectMapper();

//    @Before
    public void setBasicAuth() throws Exception {
        // 设置basicAuth
        String basicAuthString = "Basic " + Base64.getEncoder().encodeToString("aaa:bbb".getBytes());
        httpHeaders.set("Authorization", basicAuthString);
    }

    @Test
    public void testController() throws Exception {
        MvcResult mvcResult = mockMvc.perform(get("/api/load//v1/hello-content")
                        .contentType(MediaType.APPLICATION_JSON_VALUE)
                        // 设定basicAuth到请求header中
                        .headers(httpHeaders)
                        .param("uuid", "12312312"))
                // 打印详细的请求以及返回内容
                .andDo(print())
                // 判断HttpStatus是200，如果不是表示失败
                .andExpect(status().isOk())
                // 返回结果给mvcResult
                .andReturn();
        // 获取mvcResult的body
        String resutlStr = mvcResult.getResponse().getContentAsString(Charset.defaultCharset());
        ListResponse response =  mapper.readValue(resutlStr, ListResponse.class);
        // 判断结果是否成功
        assertEquals("0", response.getStatus().toString());
    }

}

程序源码下载

Springboot集成Mybatispuls操作mysql数据库

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

yum常用命令与lrzsz的在线安装

yum常用命令与lrzsz的在线安装

yum命令 yum&#xff08; Yellow dog Updater, Modified&#xff09;是一个在 Fedora 和 RedHat 以及 SUSE 中的 Shell 前端软件包管理器。 基于 RPM 包管理&#xff0c;能够从指定的服务器自动下载 RPM 包并且安装&#xff0c;可以自动处理依赖性关系&#xff0c;并且一次安装…
阅读更多...
python数据分析所需要的语法基础

python数据分析所需要的语法基础

Python语言基础——语法基础 前言语法基础变量标识符数据类型输入与输出代码缩进与注释 总结 前言 对于学过C语言的人来说&#xff0c;python其实很简单。学过一种语言&#xff0c;学习另一种语言&#xff0c;很显然的能感觉到&#xff0c;语言大体上都是相通的。当然&#xf…
阅读更多...
nacos开启登录开关启动报错“Unable to start embedded Tomcat”

nacos开启登录开关启动报错“Unable to start embedded Tomcat”

nacos 版本&#xff1a;2.3.2 2.2.2版本之前的Nacos默认控制台&#xff0c;无论服务端是否开启鉴权&#xff0c;都会存在一个登录页&#xff1b;在之后的版本关闭了默认登录页面&#xff0c;无需登录直接进入控制台操作。在这里我们可以在官网可以看到相关介绍 而我现在所用的…
阅读更多...
代码随想录-算法训练营day31【贪心算法01：理论基础、分发饼干、摆动序列、最大子序和】

代码随想录-算法训练营day31【贪心算法01：理论基础、分发饼干、摆动序列、最大子序和】

代码随想录-035期-算法训练营【博客笔记汇总表】-CSDN博客 第八章 贪心算法 part01● 理论基础 ● 455.分发饼干 ● 376. 摆动序列 ● 53. 最大子序和 贪心算法其实就是没有什么规律可言&#xff0c;所以大家了解贪心算法 就了解它没有规律的本质就够了。 不用花心思去研究其…
阅读更多...
软件测试与管理-白盒测试-基本路径测试法

软件测试与管理-白盒测试-基本路径测试法

知识点&#xff1a; 1.原理 是在程序控制流图的基础上&#xff0c;通过分析控制构造的环路复杂性&#xff0c;导出基本可执行路径的集合&#xff0c;然后根据可执行路径进行测试用例设计的方法。此方法设计出的测试用例需保证被测程序的每个可执行语句至少执行一次。 2.步骤 &a…
阅读更多...
Netty 实现dubbo rpc

Netty 实现dubbo rpc

一、RPC 的基本介绍 RPC (Remote Procedure Call) 远程过程调用&#xff0c;是一个计算机通信协议。该协议允许运行于一台计算机的程序调用另一台计算机的子程序&#xff0c;而程序员无需额外的为这个交互编程。也就是说可以达到两个或者多个应用程序部署在不同的服务器上&…
阅读更多...
基于BP神经网络的QPSK解调算法matlab性能仿真

基于BP神经网络的QPSK解调算法matlab性能仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 5.算法完整程序工程 1.算法运行效果图预览 2.算法运行软件版本 matlab2022a 3.部分核心程序 ........................................................................ for ij 1:leng…
阅读更多...
神经网络中的归一化

神经网络中的归一化

我们今天介绍一下神经网络中的归一化方法~ 之前学到的机器学习中的归一化是将数据缩放到特定范围内&#xff0c;以消除不同特征之间的量纲和取值范围差异。通过将原始数据缩放到一个特定的范围内&#xff0c;比如[0,1]或者[-1,1]&#xff0c;来消除不同特征之间的量纲和取值范围…
阅读更多...
弹性云服务器给用户带来了哪些便利

弹性云服务器给用户带来了哪些便利

什么是弹性云服务器&#xff1f; 弹性云服务器&#xff08;ECS&#xff0c;Elastic Cloud Server&#xff09;简单地说&#xff0c;是指运行在云计算环境中的虚拟服务器。弹性云服务器可以说是虚拟专用服务器(VPS)&#xff0c;但VPS却不能说是云服务器。这是因为两者有着本质的…
阅读更多...
软件游戏丢失XINPUT1_4.dll文件的多种解决方法分享

软件游戏丢失XINPUT1_4.dll文件的多种解决方法分享

当玩家在尝试启动某款游戏时&#xff0c;遇到了系统提示“游戏找不到XINPUT1_4.dll”&#xff0c;这个错误通常发生在玩家尝试启动游戏时&#xff0c;游戏无法找到所需的XINPUT1_4.dll文件&#xff0c;呆滞无法正常启动运行。但是幸运的是&#xff0c;有一些简单的修复方法可以…
阅读更多...
【typescript测试 - Jest 配置与使用】

【typescript测试 - Jest 配置与使用】

安装 npm install --save-dev types/jestnpm install --save-dev ts-jest配置 tsconfig.json {"compilerOptions": {"types": ["jest"]} }jest.config.js module.exports {preset: ts-jest,testEnvironment: node, };使用 // add.js funct…
阅读更多...
数据分析——业务指标量化

数据分析——业务指标量化

业务指标量化 前言一、统计指标二、统计指标特点完整的统计指标统计指标的理解和使用方法 三、统计指标类型总量指标时期指标时点指标总量指标的作用 相对指标计划完成相对数指标结构相对数指标比例相对数指标比较相对数指标动态相对数指标 平均指标 四、数量指标和质量指标五、…
阅读更多...
【1小时掌握速通深度学习面试8】生成模型-中

【1小时掌握速通深度学习面试8】生成模型-中

目录 28.DBN与DBM 有什么区别? 29.VAE如何控制生成图像的类别? 30.如何修改VAE的损失函数&#xff0c;使得隐藏层的编码是相互解耦的? 31.自回归方法如何应用在生成模型上? 32.原始 VAE存在哪些问题? 有哪些改进方式? 33.如何将VAE与GAN 进行结合&#xff1f; 34.…
阅读更多...
Rust Postgres实例

Rust Postgres实例

Rust Postgres介绍 Rust Postgres是一个纯Rust实现的PostgreSQL客户端库&#xff0c;无需依赖任何外部二进制文件2。这意味着它可以轻松集成到你的Rust项目中&#xff0c;提供对PostgreSQL的支持。 特点 高性能&#xff1a;Rust Postgres提供了高性能的数据库交互功能&#…
阅读更多...
C++使用单链表实现一元多项式的加，乘操作

C++使用单链表实现一元多项式的加，乘操作

相邀再次喝酒 待 葡萄成熟透 但是命运入面 每个邂逅 一起走到了 某个路口 是敌与是友 各自也没有自由 位置变了 各有队友 首先&#xff0c;按照惯例&#xff0c;十分欢迎大家边听歌边观看本博客&#xff01;&#xff01; 最佳损友 - 陈奕迅 - 单曲 - 网易云音乐 (163.com) 一…
阅读更多...
ABAP 第二代增强-采购申请子屏幕增强

ABAP 第二代增强-采购申请子屏幕增强

文章目录 第二代增强-采购申请子屏幕增强需求实现过程创建项目运行效果客户屏幕的PBO全局变量获取数据更新数据运行效果查询底表修改数据 第二代增强-采购申请子屏幕增强 需求 实现过程 创建项目 运行效果 客户屏幕的PBO 全局变量 *&------------------------------------…
阅读更多...
python_5

python_5

# 制作一个注册登录模块 # 注册&#xff1a;将用户填入的账户和密码保存到一个文件(users.bin) # 登陆&#xff1a;将用户填入账户密码和users.bin中保存的账户密码进行比对,如果账户和密码完全相同 那么登录成功&#xff0c;否则登录失败 import hashlib import json import o…
阅读更多...
Petalinux的使用——定制Linux系统

Petalinux的使用——定制Linux系统

文章目录 配置petalinux运行环境petalinux设计流程 配置petalinux运行环境 Petalinux的安装在文章Ubuntu镜像源的更改及其Petalinux的安装中已经介绍&#xff0c;下面介绍petalinux运行环境的配置过程。 进入到petalinux的安装路径下&#xff0c;使用下面的命令对petalinux的运…
阅读更多...
第十三章 计算机网络

第十三章 计算机网络

这里写目录标题 1.网络设备2.协议簇2.1电子邮件(传输层)2.2地址解析(网际层)2.3DHCP(动态主动配置协议)2.4URL(统一资源定位器)2.5IP地址和子网掩码 1.网络设备 物理层&#xff1a;中继器&#xff0c;集线器(多路中继器) 数据链路层&#xff1a;网桥&#xff0c;交换机(多端口…
阅读更多...
【微磁学3D绘图工具探索】Excalibur

【微磁学3D绘图工具探索】Excalibur

文章目录 概要调查报告技术名词解释主要特点 技术和算法实现他能够画出怎样酷炫的图 小结 概要 微磁学中的磁学结构同时包括二维和三维&#xff0c;想要绘制得好看&#xff0c;结果清晰&#xff0c;那么就需要一些自己写的绘图代码之外的额外渲染功能&#xff0c;尤其是对于三…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023