Spring boot 4 搞懂MyBatis-Plus的用法

Spring boot 4 搞懂MyBatis-Plus的用法

MyBatis-Plus 是一个 MyBatis 的增强工具,在 MyBatis 的基础上只做增强不做改变,为简化开发、提高效率而生

官方地址:
git源码
文档

Spring boot 4如何集成

增加依赖

Add MyBatis-Plus dependency

<mybatisplus.version>3.5.15</mybatisplus.version><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-spring-boot4-starter</artifactId><version>${mybatisplus.version}</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-jsqlparser</artifactId><version>${mybatisplus.version}</version></dependency>

配置

@ConfigurationpublicclassMybatisPlusConfig{@BeanpublicMybatisPlusInterceptormybatisPlusInterceptor(){MybatisPlusInterceptor mybatisPlusInterceptor =newMybatisPlusInterceptor();// 数据权限 mybatisPlusInterceptor.addInnerInterceptor(newDataFilterInterceptor());// 分页插件 mybatisPlusInterceptor.addInnerInterceptor(newPaginationInnerInterceptor());// 乐观锁 mybatisPlusInterceptor.addInnerInterceptor(newOptimisticLockerInnerInterceptor());// 防止全表更新与删除 mybatisPlusInterceptor.addInnerInterceptor(newBlockAttackInnerInterceptor());return mybatisPlusInterceptor;}}

基础特性

  1. “零SQL” CRUD
    • 核心点:业务模块的Mapper 接口继承 BaseMapper<T>,即可拥有 insertselectByIdupdateByIddeleteBatchIds 等 17 个常用方法。
    • Service CRUD:除了 Mapper 层,MP 还提供了 IServiceServiceImpl,封装了更多的业务逻辑方法(如 saveBatch 批量插入)。
    • 提供SqlHelper工具类实现批量写入或更新操作
  2. 条件构造器(Wrapper)
    • 三板斧QueryWrapper(用于查询,支持lambda避免字段名写错)、UpdateWrapper(用于更新,支持链式设置 set 值)。
    • Lambda 表达式:推荐使用 LambdaQueryWrapper,利用方法引用(如 User::getName)来指定字段,编译期检查,防止 SQL 拼写错误。
  3. 常用注解
    • @TableName:指定表名(如果类名与表名不一致)。
    • @TableId:指定主键策略(如 IdType.AUTO 自增,IdType.ASSIGN_ID 雪花算法)。
    • @TableField:填充字段(如创建时间、更新时间自动填充 FieldFill.INSERT_UPDATE),或者逻辑删除字段 @TableLogic

增强功能

  1. 自动填充
    • 自动填充:实现 MetaObjectHandler 接口,重写 insertFillupdateFill 方法,统一处理 create_timeupdate_time 等字段。
  • 逻辑删除:配置后,delete 语句会自动转化为 UPDATE 语句(设置删除标记),查询时自动追加 WHERE deleted = 0 条件。 【在实体类中,对应数据库表的逻辑删除字段上添加 @TableLogic 注解】
    • 插入:逻辑删除字段的值不受限制。
    • 查找:自动添加条件,过滤掉标记为已删除的记录。
    • 更新:防止更新已删除的记录。
    • 删除:将删除操作转换为更新操作,标记记录为已删除
  • 自定义ID生成器
    • IdentifierGenerator主要用于生成数据库表的主键ID
    • KeyGenerator是MyBatis框架中的一个接口,用于在执行SQL语句时生成键值,通常用于生成自增主键或者在执行INSERT语句后获取新生成的ID
    • MyBatis-Plus 内置支持多种数据库的主键生成策略,如:
      • H2KeyGenerator
      • OracleKeyGenerator
      • PostgreKeyGenerator
  • 多数据源支持:详细使用参见https://github.com/baomidou/dynamic-datasource
    • Spring Boot 1.5.x ~ 2.x.x 使用 dynamic-datasource-spring-boot-starter,支持 JDK 8 及以上版本
    • Spring Boot 3.x.x 使用 dynamic-datasource-spring-boot3-starter要求 JDK 17 及以上
    • Spring Boot 4.x.x 使用 dynamic-datasource-spring-boot4-starter要求 JDK 17 及以上

插件机制

常用插件

  1. 分页插件(PaginationInnerInterceptor)
    • 原理:MP 的分页不是内存分页,而是物理分页。它通过 MyBatis 的拦截器(Interceptor)机制,在 SQL 执行前重写 SQL(如加上 LIMIT)。
    • 使用:配置 MybatisPlusInterceptor,注入 PaginationInnerInterceptor。代码中使用 Page<T> 对象接收结果。
  2. 乐观锁插件OptimisticLockerInnerInterceptor
    1. 读取记录时,获取当前的版本号(version)。
    2. 在更新记录时,将这个版本号一同传递。
    3. 执行更新操作时,设置 version = newVersion 的条件为 version = oldVersion
    4. 如果版本号不匹配,则更新失败。
  3. 多租户插件TenantLineInnerInterceptor
    1. 是 MyBatis-Plus 提供的一个插件,用于实现多租户的数据隔离。通过这个插件,可以确保每个租户只能访问自己的数据,从而实现数据的安全隔离
    2. 默认插入 SQL 是需要判断租户条件,因此需要配合自动填充字段功能填充租户字段,否则租户字段不会自动保存到数据库
  4. 非法SQL拦截插件IllegalSQLInnerInterceptor
    • 用于拦截和检查非法SQL语句。该插件旨在帮助开发者在SQL执行前发现并解决潜在的安全问题,如全表更新、删除操作,以及对索引的检查等
  5. 防全表更新与删除插件BlockAttackInnerInterceptor
    1. 专门用于防止恶意的全表更新和删除操作。该插件通过拦截 updatedelete 语句,确保这些操作不会无意中影响到整个数据表,从而保护数据的完整性和安全性

执行流程

MyBatis-Plus(MP)插件的执行流程,本质上是基于 MyBatis 的插件(Plugin)机制实现的。MP 利用这一机制,在 MyBatis 的核心执行流程中“插入”自己的逻辑,从而实现分页、性能分析、SQL 注入防护等功能。

MybatisPlusInterceptor 是“包工头”,它实现了 MyBatis 的接口并拦下所有活;而 List<InnerInterceptor>是“工人”,实现具体的功能

组件层级类/接口名称职责实现关系
顶层门面MybatisPlusInterceptor实现 MyBatis 原生 Interceptor,作为唯一入口,管理插件列表。实现
org.apache.ibatis.
plugin.Interceptor
插件容器List<InnerInterceptor>存储具体的增强逻辑(如分页、乐观锁),由顶层门面调用。内部持有
具体逻辑PaginationInnerInterceptor
实现具体的业务逻辑(如重写 SQL、计算耗时)。实现
InnerInterceptor

如何自定义SQL

通过如下注解,可以实现自定义SQL

  • @Select: 查询
  • @Insert: 插入
  • @Update: 更新
  • @Delete: 删除
@MapperpublicinterfaceUserMapperextendsBaseMapper<User>{// 简单查询@Select("SELECT * FROM user WHERE email = #{email}")UserselectByEmail(@Param("email")String email);// 复杂一点的条件查询@Select("SELECT * FROM user WHERE status = #{status} AND age > #{minAge}")List<User>selectByStatusAndAge(@Param("status")Integer status,@Param("minAge")Integer minAge);}

mybatis知识

# {}${} 的区别

  • #{}:是预编译处理(PreparedStatement)。MyBatis 会将它替换为 ?,能有效防止 SQL 注入
  • ${}:是字符串替换。直接将变量拼接到 SQL 中,存在注入风险,通常用于传入数据库表名或排序字段(ORDER BY

MyBatis 的一级缓存和二级缓存

  • 一级缓存: 作用域为 SqlSession。在同一个会话中,相同的查询不再查数据库。默认开启。
  • 二级缓存: 作用域为 Namespace(多个会话间共享)。需要手动开启,且实体类必须实现序列化接口。
  • 失效场景: 任何的 INSERT, UPDATE, DELETE 操作都会刷新缓存

实体类属性名和表中字段名不一致怎么办?

  1. 在 SQL 语句中使用别名(AS)。
  2. 使用 ResultMap 进行映射(最常用)。
  3. 开启驼峰命名自动转换配置(mapUnderscoreToCamelCase

Mybatis的缓存机制

一级缓存建议保持默认(开启),而二级缓存通常不建议开启(默认也是关闭的),尤其是在复杂的业务或分布式系统中

一级缓存

一级缓存的实现参见:BaseExecutorPerpetualCache

  • 一级缓存的生命周期由 Executor(执行器)管理。在 BaseExecutor(所有执行器的基类)中,定义了本地缓存对象
  • SqlSession 每次创建都会生成一个新的 Executor,所以一级缓存是线程隔离的【参见DefaultSqlSessionFactory】

二级缓存

二级缓存的实现参见:CachingExecutorSynchronizedCache
当开启二级缓存后,MyBatis 会使用 CachingExecutor 包装原来的 Executor

装饰器模式: 二级缓存的实现非常优雅,PerpetualCache 是基础,通过 SynchronizedCache(同步)、LoggingCache(日志)、ScheduledCache(定时)、SerializedCache(序列化)、LruCache(回收策略)等装饰器层层包装,组合出最终需要的功能

特性一级缓存 (Local)二级缓存 (Global)
作用范围单个 SqlSession 内同一个 Mapper 命名空间内
数据共享独享,不跨会话共享,跨 SqlSession
默认状态开启关闭 (需手动配置)
生命周期伴随 SqlSession 的创建与关闭伴随 SqlSessionFactory 的生命周期
清空时机增删改操作、close()、commit()对应 Mapper 的增删改操作、commit()

是否开启

缓存类型建议配置理由适用场景
一级缓存开启 (默认)安全、自动管理、提升单次会话性能所有场景(无需干预)
二级缓存关闭 (默认)避免脏读、避免分布式不一致复杂业务、分布式系统
二级缓存开启 (需评估)需处理好序列化和跨表失效问题单机应用、数据字典、纯读场景

一句话建议: 用好一级缓存,忘掉二级缓存,用 Redis 来做全局缓存

加载流程

MapperImpl方法调用过程

  1. 代理拦截(MybatisMapperProxy)
    • MybatisMapperProxy 是在 Spring 容器进行依赖注入(@Autowired)时,由 MapperProxyFactory 调用 getObject 方法实例化的
  2. 命令执行(MapperMethod):
    • MybatisMapperProxy 会拿到一个 MapperMethod 实例。
    • 调用 mapperMethod.execute(sqlSession, args)
    • 此时,控制权从 “代理层” 转移到了 “命令层”
  3. SQL 执行(SqlSession/Executor):
    • MapperMethod 内部会根据 SQL 类型,调用 sqlSession.selectOne()insert() 等方法。
    • 最终由 Executor 去 JDBC 层面执行 SQL
publicclassMapperRegistry{privatefinalConfiguration config;privatefinalMap<Class<?>,MapperProxyFactory<?>> knownMappers =newConcurrentHashMap();publicMapperRegistry(Configuration config){this.config = config;}public<T>TgetMapper(Class<T> type,SqlSession sqlSession){MapperProxyFactory<T> mapperProxyFactory =(MapperProxyFactory)this.knownMappers.get(type);if(mapperProxyFactory ==null){thrownewBindingException("Type "+ type +" is not known to the MapperRegistry.");}else{try{return(T)mapperProxyFactory.newInstance(sqlSession);}catch(Exception e){thrownewBindingException("Error getting mapper instance. Cause: "+ e, e);}}}

Spring boot启动时初始化过程

  1. SqlSessionFactoryp初始化
    • MybatisAutoConfiguration -> MybatisSqlSessionFactoryBean ->SqlSessionFactory
  2. Mapper 注册与扫描
    • AutoConfiguredMapperScannerRegistrar->AutoConfiguredMapperScannerRegistrar->MapperScannerConfigurer ->ClassPathMapperScanner ->ClassPathBeanDefinitionScanner->MapperFactoryBean
  3. MybatisMapperProxy 实例化
    1. 获取 Mapper Bean
      • 当 Spring 容器尝试填充 @Autowired private UserMapper userMapper; 时。
      • 容器发现这是一个 FactoryBean,于是调用 MapperFactoryBean.getObject()
    2. 获取 SqlSession
      • MapperFactoryBean.getObject() 内部会调用 this.getSqlSession().getMapper(this.mapperInterface);
    3. 最终实例化 (核心点)
      • sqlSession.getMapper() 会委托给 (T)this.getConfiguration().getMapper(type, this);
      • Configuration 持有一个 this.mapperRegistry.getMapper(type, sqlSession)(注册中心)。
      • MapperRegistry 里存着 Class -> MapperProxyFactory 的映射
publicclassMapperRegistry{privatefinalConfiguration config;privatefinalMap<Class<?>,MapperProxyFactory<?>> knownMappers =newConcurrentHashMap();publicMapperRegistry(Configuration config){this.config = config;}public<T>TgetMapper(Class<T> type,SqlSession sqlSession){MapperProxyFactory<T> mapperProxyFactory =(MapperProxyFactory)this.knownMappers.get(type);if(mapperProxyFactory ==null){thrownewBindingException("Type "+ type +" is not known to the MapperRegistry.");}else{try{return(T)mapperProxyFactory.newInstance(sqlSession);}catch(Exception e){thrownewBindingException("Error getting mapper instance. Cause: "+ e, e);}}}
在这里插入图片描述

Read more

Chatbox AI|多模型多模态交互+MCP,一个工具打造你的全能私人助手

Chatbox AI|多模型多模态交互+MCP,一个工具打造你的全能私人助手

ChatBoxAI集成GPT-4、Claude等顶尖模型,支持Windows/macOS/Linux多平台,具备隐私加密、文件智能解析(PDF/代码/图片)及开发者友好特性。其应用覆盖自媒体创作、代码实时预览、AI绘图(封面/表情包)及联网搜索,通过MCP协议扩展能力。未来将深化多模态交互,整合边缘计算与AR技术,构建教育、医疗等行业解决方案,推动“增强智能”革命。作为打破数据孤岛的工具,ChatBoxAI不仅是效率助手,更象征人机协作新范式——普通人可调度AI集群资源,开发者快速构建微服务,开启智能普惠时代。 Chatbox AI|多模型多模态交互+MCP,一个工具打造你的全能私人助手 * 1. 前言 * 2. ChatboxAI介绍 * 2.1 什么是ChatboxAI? * 2.2 ChatboxAI的优势 * 2.3 安装使用 * 3.

By Ne0inhk
【探索java之路】简单聊聊网络通讯核心协议

【探索java之路】简单聊聊网络通讯核心协议

目录 引言 一、传输层协议详解 TCP(传输控制协议) UDP(用户数据报协议) TCP vs UDP 对比分析 二、应用层协议详解 HTTP(超文本传输协议) HTTPS(安全超文本传输协议) 三、协议间的协同工作 端到端通信流程实例 常见通信模式 引言 网络通信的核心协议,不仅是后端开发的必备技能,也是前端优化、架构设计乃至安全防护的基础。OSI七层模型与TCP/IP四层模型是理解网络通信的理论框架。在实际应用中,TCP/IP模型更为广泛使用,包括应用层、传输层、网络层和链路层。本文重点讨论应用层协议HTTP/HTTPS和传输层协议TCP/UDP。 一、传输层协议详解 TCP(传输控制协议) TCP是互联网中最重要、应用最广泛的传输层协议之一,以其可靠性和有序性著称。 核心特性: * 面向连接:通信前必须建立连接,通信结束后释放连接 * 可靠传输:

By Ne0inhk

7.高并发内存池大页内存申请释放以及使用定长内存池脱离new

在高并发内存池的设计中,“大页内存管理” 和 “元数据开销优化” 是两个核心痛点:原生malloc/free在大内存分配时频繁触发系统调用,而new/delete管理内存池元对象(如ThreadCache、span)会引入额外性能损耗。本文基于 TCMalloc 思想,拆解高并发内存池中大页内存的申请 / 释放逻辑,以及如何通过定长内存池(ObjectPool) 彻底脱离new/delete,实现元数据的零开销管理 一、背景:为什么要单独处理大页内存? 在高并发内存池的三级缓存架构(ThreadCache→CentralCache→PageCache)中,我们将内存分为 “小对象(≤256KB)” 和 “大对象(>256KB)”: * 小对象:走三级缓存,利用线程私有、桶锁、批量分配降低竞争 * 大对象:若仍走缓存,会导致 “缓存污染”(大内存占满缓存,小对象无空间可用),且大内存分配频率低,缓存收益有限

By Ne0inhk
JAVA 集合框架进阶:List 与 Set 的深度解析与实战

JAVA 集合框架进阶:List 与 Set 的深度解析与实战

JAVA 集合框架进阶:List 与 Set 的深度解析与实战 1.1 本章学习目标与重点 💡 掌握 List 和 Set 接口的核心特性,理解不同实现类的底层原理与适用场景。 💡 熟练运用集合的常用方法,解决数据存储、查找、去重等实际开发问题。 💡 理解集合的线程安全问题,掌握线程安全集合的使用方式。 ⚠️ 本章重点是 不同集合的底层数据结构 和 性能对比,这是面试和开发中的核心考点。 1.2 List 接口:有序可重复的集合 1.2.1 List 接口的核心特性 💡 List 是有序集合,元素的存储顺序和插入顺序一致,支持通过索引访问元素。 List 允许存储重复元素,也可以存储 null 值。 List 接口的常用实现类有 ArrayList、LinkedList 和

By Ne0inhk