mybatis-plus 系统化实战:从基础 crud 到高级查询与性能优化
一、引言
在 java 持久层开发领域,mybatis 凭借其轻量、灵活、sql 可控性强的特点,成为企业级项目的主流选择。但原生 mybatis 存在大量重复编码工作——例如基础 crud 接口的编写、复杂查询条件的拼接、分页逻辑的重复实现等,这些冗余操作不仅降低开发效率,还可能因人为疏忽引入潜在 bug。
mybatis-plus(简称 mp)作为 mybatis 的增强工具,遵循“只做增强,不做改变”的核心理念,在完全兼容 mybatis 原有功能的基础上,内置了大量实用特性,彻底解决了原生 mybatis 的痛点。其核心优势包括:无侵入式增强、内置基础 crud 接口无需手动编写 sql、强大的条件构造器简化查询逻辑、完善的分页插件与批量操作支持、灵活的关联查询方案等。
在企业开发中,mybatis-plus 能够显著提升持久层开发效率(减少 60% 以上的重复编码),同时保证 sql 的灵活性与性能可控性,广泛应用于中大型 spring boot 项目中,是 java 开发者必备的实战技能之一。本文将从环境搭建到性能优化,系统化讲解 mybatis-plus 的实战用法,助力开发者快速上手并灵活运用。
二、环境搭建:spring boot + mybatis-plus 快速集成
mybatis-plus 与 spring boot 的集成非常简洁,只需完成 maven 依赖引入和基础配置,即可快速启用所有核心功能。以下是完整的搭建步骤(基于 spring boot 2.7.x,jdk 8+)。
2.1 引入 maven 依赖
在 pom.xml 中引入 mybatis-plus 核心依赖、数据库驱动(以 mysql 8.0 为例)、 lombok(简化实体类编写),无需额外引入 mybatis 依赖(mp 已内置)。
<!-- spring boot 父依赖 -->
<parent>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-parent</artifactid>
<version>2.7.15</version>
<relativepath/>
</parent>
<dependencies>
<!-- spring boot web 依赖(非必需,用于演示接口调用) -->
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-web</artifactid>
</dependency>
<!-- mybatis-plus 核心依赖 -->
<dependency>
<groupid>com.baomidou</groupid>
<artifactid>mybatis-plus-boot-starter</artifactid>
<version>3.5.3.1</version>
</dependency>
<!-- mysql 驱动 -->
<dependency>
<groupid>mysql</groupid>
<artifactid>mysql-connector-java</artifactid>
<scope>runtime</scope>
</dependency>
<!-- lombok 简化实体类 -->
<dependency>
<groupid>org.projectlombok</groupid>
<artifactid>lombok</artifactid>
<optional>true</optional>
</dependency>
<!-- 测试依赖 -->
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-test</artifactid>
<scope>test</scope>
</dependency>
</dependencies>2.2 核心配置(application.yml)
在 resources 目录下创建 application.yml 文件,配置数据库连接信息、mybatis-plus 基础参数(如 mapper 映射文件路径、实体类别名包、sql 日志打印等),配置后即可自动加载。
spring:
# 数据库配置
datasource:
driver-class-name: com.mysql.cj.jdbc.driver
url: jdbc:mysql://localhost:3306/mp_demo?useunicode=true&characterencoding=utf-8&servertimezone=gmt%2b8&usessl=false
username: root # 替换为你的数据库用户名
password: 123456 # 替换为你的数据库密码
# mybatis-plus 配置
mybatis-plus:
# mapper 映射文件路径(若无需自定义 sql,可省略)
mapper-locations: classpath:mapper/**/*.xml
# 实体类别名包(简化 xml 中实体类引用)
type-aliases-package: com.example.mpdemo.entity
# 全局配置
global-config:
db-config:
# 主键生成策略(auto=自增,none=手动输入,assign_id=雪花算法等)
id-type: auto
# 逻辑删除字段配置(可选,用于软删除)
logic-delete-field: isdeleted
logic-delete-value: 1 # 已删除
logic-not-delete-value: 0 # 未删除
# 日志配置(打印执行的 sql,便于调试)
configuration:
log-impl: org.apache.ibatis.logging.stdout.stdoutimpl2.3 启动类配置
在 spring boot 启动类上添加 @mapperscan 注解,指定 mapper 接口所在的包路径,确保 mybatis-plus 能够扫描到 mapper 接口并生成代理对象。
package com.example.mpdemo;
import org.mybatis.spring.annotation.mapperscan;
import org.springframework.boot.springapplication;
import org.springframework.boot.autoconfigure.springbootapplication;
// 扫描 mapper 接口所在包
@mapperscan("com.example.mpdemo.mapper")
@springbootapplication
public class mpdemoapplication {
public static void main(string[] args) {
springapplication.run(mpdemoapplication.class, args);
}
}三、基础 crud 实战:基于 iservice 与 basemapper
mybatis-plus 提供了两个核心接口用于实现基础 crud 操作:basemapper(面向 mapper 层)和 iservice(面向 service 层,封装了 basemapper 的方法,提供更便捷的调用)。推荐在开发中使用 iservice + serviceimpl 的组合,简化 service 层代码编写。
以下将以 user 实体类为例,演示完整的基础 crud 实战(包含实体类、mapper 接口、service 接口/实现类、调用示例),所有代码可直接复制运行。
3.1 准备数据库表
创建 user 表(对应 user 实体类),sql 语句如下(适配 mysql 8.0,包含逻辑删除字段):
create table `user` ( `id` int(11) not null auto_increment comment '主键id', `username` varchar(50) not null comment '用户名', `password` varchar(100) not null comment '密码(实际开发中需加密)', `age` int(3) default null comment '年龄', `email` varchar(100) default null comment '邮箱', `is_deleted` tinyint(1) default 0 comment '逻辑删除(0=未删除,1=已删除)', `create_time` datetime default current_timestamp comment '创建时间', `update_time` datetime default current_timestamp on update current_timestamp comment '更新时间', primary key (`id`) ) engine=innodb default charset=utf8mb4 comment='用户表';
3.2 编写实体类 user
使用 lombok 的 @data 注解简化 getter/setter 方法,通过 mybatis-plus 的注解指定表名、字段映射、备注等信息。
package com.example.mpdemo.entity;
import com.baomidou.mybatisplus.annotation.*;
import lombok.data;
import java.util.date;
@data
@tablename("user") // 指定对应数据库表名(若实体类名与表名一致,可省略)
public class user {
// 主键,自增(对应全局配置的 id-type: auto)
@tableid(type = idtype.auto)
private integer id;
// 用户名(非空字段)
@tablefield("username") // 若实体类字段与表字段一致,可省略
private string username;
// 密码
private string password;
// 年龄
private integer age;
// 邮箱
private string email;
// 逻辑删除字段(与全局配置一致,可省略注解)
@tablelogic
private integer isdeleted;
// 创建时间(自动填充)
@tablefield(fill = fieldfill.insert)
private date createtime;
// 更新时间(自动填充)
@tablefield(fill = fieldfill.insert_update)
private date updatetime;
}3.3 自动填充配置(可选)
上述实体类中,createtime 和 updatetime 字段使用了 @tablefield(fill = …) 注解,用于实现“插入时自动填充创建时间、更新时自动填充更新时间”,无需手动设置。需创建填充处理器:
package com.example.mpdemo.config;
import com.baomidou.mybatisplus.core.handlers.metaobjecthandler;
import org.apache.ibatis.reflection.metaobject;
import org.springframework.stereotype.component;
import java.util.date;
@component
public class mymetaobjecthandler implements metaobjecthandler {
// 插入时填充
@override
public void insertfill(metaobject metaobject) {
// 填充 createtime 和 updatetime
strictinsertfill(metaobject, "createtime", date.class, new date());
strictinsertfill(metaobject, "updatetime", date.class, new date());
}
// 更新时填充
@override
public void updatefill(metaobject metaobject) {
// 只填充 updatetime
strictupdatefill(metaobject, "updatetime", date.class, new date());
}
}3.4 编写 mapper 接口
usermapper 继承 basemapper,basemapper 已内置了 selectbyid、insert、updatebyid、deletebyid 等基础 crud 方法,无需手动编写任何方法。
package com.example.mpdemo.mapper;
import com.baomidou.mybatisplus.core.mapper.basemapper;
import com.example.mpdemo.entity.user;
import org.springframework.stereotype.repository;
// @repository 用于标识 mapper 接口,避免 ide 报错(可选)
@repository
public interface usermapper extends basemapper<user> {
// 无需编写任何方法,basemapper 已提供所有基础 crud 操作
}3.5 编写 service 接口与实现类
iservice 是 mybatis-plus 提供的 service 层接口,封装了 basemapper 的方法,还提供了批量操作、条件查询等便捷方法。userservice 继承 iservice,userserviceimpl 继承 serviceimpl(实现 iservice)并注入 usermapper。
3.5.1 service 接口
package com.example.mpdemo.service;
import com.baomidou.mybatisplus.extension.service.iservice;
import com.example.mpdemo.entity.user;
// 继承 iservice,指定实体类类型
public interface userservice extends iservice<user> {
// 可添加自定义 service 方法(基础 crud 无需添加)
}3.5.2 service 实现类
package com.example.mpdemo.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.serviceimpl;
import com.example.mpdemo.entity.user;
import com.example.mpdemo.mapper.usermapper;
import com.example.mpdemo.service.userservice;
import org.springframework.stereotype.service;
// 继承 serviceimpl,注入 mapper 接口,实现 service 接口
@service
public class userserviceimpl extends serviceimpl<usermapper, user> implements userservice {
// 基础 crud 方法无需实现,serviceimpl 已全部封装
}3.6 基础 crud 调用示例(测试类)
通过 spring boot 测试类,演示 iservice 中常用的基础 crud 方法,运行测试方法即可验证效果。
package com.example.mpdemo;
import com.example.mpdemo.entity.user;
import com.example.mpdemo.service.userservice;
import org.junit.jupiter.api.test;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.boot.test.context.springboottest;
import java.util.list;
@springboottest
public class userservicetest {
// 注入 userservice
@autowired
private userservice userservice;
// 1. 新增用户(insert)
@test
public void testinsert() {
user user = new user();
user.setusername("zhangsan");
user.setpassword("123456");
user.setage(20);
user.setemail("zhangsan@example.com");
// 调用 iservice 的 save 方法(底层调用 basemapper 的 insert)
boolean success = userservice.save(user);
system.out.println("新增结果:" + success + ",新增用户id:" + user.getid());
}
// 2. 根据id查询用户(selectbyid)
@test
public void testselectbyid() {
user user = userservice.getbyid(1); // 查询id为1的用户
system.out.println("查询到的用户:" + user);
}
// 3. 查询所有用户(selectlist)
@test
public void testselectall() {
list<user> userlist = userservice.list(); // 查询所有未删除的用户(自动过滤逻辑删除)
userlist.foreach(system.out::println);
}
// 4. 根据id更新用户(updatebyid)
@test
public void testupdatebyid() {
user user = new user();
user.setid(1); // 必须设置主键id
user.setage(22); // 更新年龄为22
user.setemail("zhangsan22@example.com"); // 更新邮箱
boolean success = userservice.updatebyid(user);
system.out.println("更新结果:" + success);
}
// 5. 根据id删除用户(逻辑删除,deletebyid)
@test
public void testdeletebyid() {
boolean success = userservice.removebyid(1); // 逻辑删除id为1的用户
system.out.println("删除结果:" + success);
}
// 6. 批量新增(savebatch)
@test
public void testsavebatch() {
list<user> userlist = list.of(
new user(null, "lisi", "123456", 25, "lisi@example.com", 0, null, null),
new user(null, "wangwu", "123456", 28, "wangwu@example.com", 0, null, null)
);
// 批量新增,底层会分批次执行sql(默认批次大小1000)
boolean success = userservice.savebatch(userlist);
system.out.println("批量新增结果:" + success);
}
}四、高级查询技巧:提升查询灵活性与效率
基础 crud 仅能满足简单的业务需求,在实际开发中,往往需要复杂的查询条件(如多字段模糊查询、范围查询)、分页查询、关联查询等。mybatis-plus 提供了完善的高级查询特性,以下讲解最常用、最实用的技巧。
4.1 条件构造器:querywrapper / lambdaquerywrapper
条件构造器是 mybatis-plus 高级查询的核心,用于动态拼接 sql 查询条件(无需手动拼接 sql 字符串,避免 sql 注入风险)。常用的构造器有两个:
- querywrapper:通过字符串指定字段名,灵活性高,但字段名容易写错(无编译期检查);
- lambdaquerywrapper:通过 lambda 表达式获取字段名,有编译期检查,避免字段名写错,推荐使用。
以下通过示例演示两种构造器的常用用法(基于 userservice):
package com.example.mpdemo;
import com.baomidou.mybatisplus.core.conditions.query.lambdaquerywrapper;
import com.baomidou.mybatisplus.core.conditions.query.querywrapper;
import com.example.mpdemo.entity.user;
import com.example.mpdemo.service.userservice;
import org.junit.jupiter.api.test;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.boot.test.context.springboottest;
import java.util.list;
@springboottest
public class querywrappertest {
@autowired
private userservice userservice;
// 1. querywrapper 示例:多条件查询(年龄大于20,邮箱包含example,用户名不为null)
@test
public void testquerywrapper() {
querywrapper<user> querywrapper = new querywrapper<>();
// 年龄 > 20
querywrapper.gt("age", 20);
// 邮箱 like %example%
querywrapper.like("email", "example");
// 用户名 is not null
querywrapper.isnotnull("username");
// 排序:按年龄降序,按id升序
querywrapper.orderbydesc("age").orderbyasc("id");
list<user> userlist = userservice.list(querywrapper);
userlist.foreach(system.out::println);
}
// 2. lambdaquerywrapper 示例(推荐):同样的条件,避免字段名写错
@test
public void testlambdaquerywrapper() {
lambdaquerywrapper<user> lambdaquerywrapper = new lambdaquerywrapper<>();
// 年龄 > 20(lambda表达式获取字段,编译期检查)
lambdaquerywrapper.gt(user::getage, 20);
// 邮箱 like %example%
lambdaquerywrapper.like(user::getemail, "example");
// 用户名 is not null
lambdaquerywrapper.isnotnull(user::getusername);
// 排序:按年龄降序,按id升序
lambdaquerywrapper.orderbydesc(user::getage).orderbyasc(user::getid);
list<user> userlist = userservice.list(lambdaquerywrapper);
userlist.foreach(system.out::println);
}
// 3. 条件构造器常用方法补充
@test
public void testlambdaquerywrapperadvanced() {
lambdaquerywrapper<user> wrapper = new lambdaquerywrapper<>();
// 1. 范围查询:年龄在20-30之间(包含20和30)
wrapper.between(user::getage, 20, 30);
// 2. 等值查询:用户名 = zhangsan
wrapper.eq(user::getusername, "zhangsan");
// 3. 非等值查询:密码 != 123456
wrapper.ne(user::getpassword, "123456");
// 4. 模糊查询:用户名以zhang开头(like 'zhang%')
wrapper.likeleft(user::getusername, "zhang");
// 5. 模糊查询:用户名以san结尾(like '%san')
wrapper.likeright(user::getusername, "san");
// 6. 空值查询:邮箱 is null
wrapper.isnull(user::getemail);
// 7. 非空查询:邮箱 is not null
wrapper.isnotnull(user::getemail);
// 8. 逻辑或:年龄 < 20 或 年龄 > 30
wrapper.or().lt(user::getage, 20).or().gt(user::getage, 30);
// 9. 逻辑与(默认,可省略):年龄 > 20 且 邮箱不为空
wrapper.and(i -> i.gt(user::getage, 20).isnotnull(user::getemail));
// 10. 只查询指定字段(避免查询无用字段,提升性能)
wrapper.select(user::getid, user::getusername, user::getage);
list<user> userlist = userservice.list(wrapper);
userlist.foreach(system.out::println);
}
}4.2 分页插件配置与调用示例
mybatis-plus 内置了分页插件(paginationinnerinterceptor),支持 mysql、oracle、sql server 等多种数据库,配置简单,调用便捷,无需手动编写分页 sql(如 limit 语句)。
4.2.1 分页插件配置
创建 mybatis-plus 配置类,注入分页插件,指定数据库类型(避免分页语法兼容问题)。
package com.example.mpdemo.config;
import com.baomidou.mybatisplus.annotation.dbtype;
import com.baomidou.mybatisplus.extension.plugins.mybatisplusinterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.paginationinnerinterceptor;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;
@configuration
public class mybatisplusconfig {
// 配置分页插件
@bean
public mybatisplusinterceptor mybatisplusinterceptor() {
mybatisplusinterceptor interceptor = new mybatisplusinterceptor();
// 添加分页插件,指定数据库类型为 mysql
interceptor.addinnerinterceptor(new paginationinnerinterceptor(dbtype.mysql));
return interceptor;
}
}4.2.2 分页查询调用示例
使用 page 类封装分页参数(当前页码、每页条数),结合条件构造器,调用 iservice 的 page 方法即可实现分页查询,返回结果包含分页信息(总条数、总页数、当前页数据等)。
package com.example.mpdemo;
import com.baomidou.mybatisplus.core.metadata.ipage;
import com.baomidou.mybatisplus.core.toolkit.wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.page;
import com.example.mpdemo.entity.user;
import com.example.mpdemo.service.userservice;
import org.junit.jupiter.api.test;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.boot.test.context.springboottest;
@springboottest
public class pagetest {
@autowired
private userservice userservice;
// 1. 基础分页查询(无条件)
@test
public void testpagebasic() {
// 分页参数:当前页(从1开始)、每页条数
page<user> page = new page<>(1, 2);
// 调用 page 方法,返回分页结果
ipage<user> useripage = userservice.page(page);
// 分页信息解析
system.out.println("总条数:" + useripage.gettotal());
system.out.println("总页数:" + useripage.getpages());
system.out.println("当前页码:" + useripage.getcurrent());
system.out.println("每页条数:" + useripage.getsize());
system.out.println("当前页数据:");
useripage.getrecords().foreach(system.out::println);
}
// 2. 带条件的分页查询(结合 lambdaquerywrapper)
@test
public void testpagewithcondition() {
// 分页参数:第2页,每页3条
page<user> page = new page<>(2, 3);
// 条件:年龄 > 20,按年龄降序
lambdaquerywrapper<user> wrapper = wrappers.lambdaquery(user.class)
.gt(user::getage, 20)
.orderbydesc(user::getage);
// 带条件分页查询
ipage<user> useripage = userservice.page(page, wrapper);
// 输出分页结果
system.out.println("总条数:" + useripage.gettotal());
system.out.println("总页数:" + useripage.getpages());
useripage.getrecords().foreach(system.out::println);
}
// 3. 分页查询指定字段(避免查询无用字段)
@test
public void testpageselectfield() {
page<user> page = new page<>(1, 2);
lambdaquerywrapper<user> wrapper = wrappers.lambdaquery(user.class)
.gt(user::getage, 20)
.select(user::getid, user::getusername, user::getage); // 只查询3个字段
ipage<user> useripage = userservice.page(page, wrapper);
useripage.getrecords().foreach(system.out::println);
}
}4.3 关联查询:注解与手动 sql 最佳实践
mybatis-plus 本身不直接提供像 mybatis-plus join 那样的强关联查询封装,但可以通过 mybatis 的原生注解(@one、@many)或手动编写 xml sql 实现关联查询(一对一、一对多),以下是企业开发中最常用的两种方式。
示例场景:新增 order 实体类(订单表),user 与 order 是一对多关系(一个用户可以有多个订单),演示一对多关联查询。
4.3.1 准备关联表与实体类
(1)订单表 sql
create table `order` ( `id` int(11) not null auto_increment comment '订单id', `order_no` varchar(50) not null comment '订单编号', `user_id` int(11) not null comment '关联用户id(外键)', `total_amount` decimal(10,2) not null comment '订单总金额', `create_time` datetime default current_timestamp comment '创建时间', primary key (`id`), key `idx_user_id` (`user_id`) comment '用户id索引,提升关联查询效率' ) engine=innodb default charset=utf8mb4 comment='订单表';
(2)order 实体类
package com.example.mpdemo.entity;
import com.baomidou.mybatisplus.annotation.idtype;
import com.baomidou.mybatisplus.annotation.tableid;
import com.baomidou.mybatisplus.annotation.tablename;
import lombok.data;
import java.math.bigdecimal;
import java.util.date;
@data
@tablename("`order`") // 订单表名是关键字order,需用反引号包裹
public class order {
@tableid(type = idtype.auto)
private integer id;
private string orderno;
// 关联用户id(外键)
private integer userid;
private bigdecimal totalamount;
private date createtime;
}(3)修改 user 实体类(添加订单列表属性)
package com.example.mpdemo.entity;
import com.baomidou.mybatisplus.annotation.*;
import lombok.data;
import java.util.date;
import java.util.list;
@data
@tablename("user")
public class user {
// 原有字段不变,新增以下属性
// 一对多关联:一个用户有多个订单(非数据库字段,需用@tablefield(exist = false)标识)
@tablefield(exist = false)
private list<order> orderlist;
}4.3.2 方式一:通过 @one / @many 注解实现关联查询
通过 mybatis 的 @many 注解(一对多),在 usermapper 中编写关联查询方法,无需编写 xml 文件,适合简单的关联场景。
package com.example.mpdemo.mapper;
import com.baomidou.mybatisplus.core.mapper.basemapper;
import com.example.mpdemo.entity.order;
import com.example.mpdemo.entity.user;
import org.apache.ibatis.annotations.one;
import org.apache.ibatis.annotations.result;
import org.apache.ibatis.annotations.results;
import org.apache.ibatis.annotations.select;
import org.springframework.stereotype.repository;
import java.util.list;
@repository
public interface usermapper extends basemapper<user> {
// 一对多关联查询:查询用户及其所有订单
@select("select * from user where id = #{userid}")
@results({
// 映射用户自身字段(id、username等)
@result(column = "id", property = "id"),
@result(column = "username", property = "username"),
@result(column = "age", property = "age"),
@result(column = "email", property = "email"),
// 关联查询订单:通过user的id关联order的user_id
@result(
column = "id", // 关联字段(user的id)
property = "orderlist", // 映射到user的orderlist属性
// 一对多关联,使用@many注解
many = @many(select = "com.example.mpdemo.mapper.ordermapper.selectbyuserid")
)
})
user selectuserwithorders(integer userid);
// 批量查询用户及其订单(可选)
@select("select * from user where id in (#{ids})")
@results({
@result(column = "id", property = "id"),
@result(column = "username", property = "username"),
@result(
column = "id",
property = "orderlist",
many = @many(select = "com.example.mpdemo.mapper.ordermapper.selectbyuserid")
)
})
list<user> selectuserswithorders(list<integer> ids);
}
// 新增 ordermapper 接口
package com.example.mpdemo.mapper;
import com.baomidou.mybatisplus.core.mapper.basemapper;
import com.example.mpdemo.entity.order;
import org.apache.ibatis.annotations.select;
import org.springframework.stereotype.repository;
import java.util.list;
@repository
public interface ordermapper extends basemapper<order> {
// 根据用户id查询订单(供usermapper的@many注解调用)
@select("select * from `order` where user_id = #{userid}")
list<order> selectbyuserid(integer userid);
}4.3.3 方式二:手动编写 xml sql 实现关联查询(推荐)
对于复杂的关联查询(如多表关联、多条件过滤),推荐使用 xml 编写 sql,灵活性更高,便于维护。以下演示通过 xml 实现用户与订单的一对多关联查询。
(1)修改 usermapper 接口,添加关联查询方法
package com.example.mpdemo.mapper;
import com.baomidou.mybatisplus.core.mapper.basemapper;
import com.example.mpdemo.entity.user;
import org.springframework.stereotype.repository;
import java.util.list;
@repository
public interface usermapper extends basemapper<user> {
// 新增:通过xml实现用户与订单的关联查询
list<user> selectuserwithordersbyxml(integer userid);
}(2)编写 xml 映射文件
在 resources/mapper 目录下创建 usermapper.xml 文件(与 application.yml 中 mapper-locations 配置一致),编写关联查询 sql。
<?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.example.mpdemo.mapper.usermapper"><!-- 一对多关联查询:查询用户及其所有订单 -->
<select id="selectuserwithordersbyxml" resultmap="userwithordersmap">
select
u.id as user_id,
u.username,
u.age,
u.email,
o.id as order_id,
o.order_no,
o.total_amount,
o.create_time as order_create_time
from
user u
left join
`order` o on u.id = o.user_id
where
u.id = #{userid}
and u.is_deleted = 0
</select><!-- 结果集映射:关联用户和订单 -->
<resultmap id="userwithordersmap" type="com.example.mpdemo.entity.user">
<!-- 用户自身字段映射 -->
<id column="user_id" property="id"/>
<result column="username" property="username"/>
<result column="age" property="age"/>
<result column="email" property="email"/>
<!-- 一对多关联:映射订单列表 -->
<collection property="orderlist" oftype="com.example.mpdemo.entity.order">
<id column="order_id" property="id"/>
<result column="order_no" property="orderno"/>
<result column="user_id" property="userid"/>
<result column="total_amount" property="totalamount"/>
<result column="order_create_time" property="createtime"/>
</collection>
</resultmap>
</mapper>(3)关联查询调用示例
package com.example.mpdemo;
import com.example.mpdemo.entity.user;
import com.example.mpdemo.mapper.usermapper;
import org.junit.jupiter.api.test;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.boot.test.context.springboottest;
@springboottest
public class relationquerytest {
@autowired
private usermapper usermapper;
// 测试注解方式关联查询
@test
public void testselectuserwithorders() {
user user = usermapper.selectuserwithorders(1);
system.out.println("用户信息:" + user.getusername() + "," + user.getemail());
system.out.println("用户订单:");
user.getorderlist().foreach(order -> system.out.println(order.getorderno() + "," + order.gettotalamount()));
}
// 测试xml方式关联查询
@test
public void testselectuserwithordersbyxml() {
user user = usermapper.selectuserwithordersbyxml(1);
system.out.println("用户信息:" + user.getusername() + "," + user.getemail());
system.out.println("用户订单:");
user.getorderlist().foreach(order -> system.out.println(order.getorderno() + "," + order.gettotalamount()));
}
}五、性能优化策略:提升系统响应速度与稳定性
mybatis-plus 的高效性不仅体现在开发效率上,通过合理的配置与优化,还能显著提升系统的运行性能。以下讲解企业开发中最常用的 3 种性能优化策略,涵盖缓存、批量操作、sql 日志分析。
5.1 二级缓存配置:减少数据库查询压力
mybatis 提供了两级缓存:一级缓存(sqlsession 级缓存,默认开启)和二级缓存(mapper 级缓存,默认关闭)。mybatis-plus 完全兼容 mybatis 的缓存机制,开启二级缓存后,多个 sqlsession 可以共享 mapper 层的缓存数据,减少重复查询数据库的次数,提升查询性能。
5.1.1 二级缓存开启步骤
(1)全局开启二级缓存(application.yml)
mybatis-plus:
configuration:
log-impl: org.apache.ibatis.logging.stdout.stdoutimpl
cache-enabled: true # 全局开启二级缓存(默认false)(2)在 mapper 接口上添加 @cachenamespace 注解
二级缓存是 mapper 级别的,需在具体的 mapper 接口上添加注解,标识该 mapper 开启二级缓存。
package com.example.mpdemo.mapper;
import com.baomidou.mybatisplus.core.mapper.basemapper;
import com.example.mpdemo.entity.user;
import org.apache.ibatis.annotations.cachenamespace;
import org.springframework.stereotype.repository;
// 开启二级缓存,eviction=缓存回收策略,flushinterval=缓存刷新间隔(毫秒)
@cachenamespace(eviction = org.apache.ibatis.cache.decorators.lrucache.class, flushinterval = 60000)
@repository
public interface usermapper extends basemapper<user> {
// 接口方法不变
}5.1.2 二级缓存注意事项
- 缓存的数据必须是可序列化的(实体类需实现 serializable 接口),否则会报错;
- 二级缓存适用于查询频繁、修改较少的数据(如字典表、配置表),避免缓存雪崩;
- 当 mapper 中的增删改方法被调用时,该 mapper 的二级缓存会自动清空,保证数据一致性;
- 对于关联查询的缓存,需在关联的 mapper 接口上也开启二级缓存,避免缓存失效。
5.2 批量操作:savebatch、updatebatchbyid 的注意事项
mybatis-plus 提供了批量新增(savebatch)、批量更新(updatebatchbyid)等批量操作方法,相比循环调用单条操作,批量操作能减少数据库连接次数,提升操作效率。但在使用时需注意以下细节,避免出现性能问题或数据异常。
5.2.1 批量操作核心注意事项
- 批次大小控制:savebatch、updatebatchbyid 方法默认批次大小为 1000(即每 1000 条数据执行一次批量 sql)。若批量操作的数据量过大(如 10 万条),无需修改默认批次大小(过大的批次会导致 sql 语句过长,占用数据库连接资源);若数据量较小(如几百条),可手动指定批次大小(如 batchsize = 500)。
// 手动指定批次大小为500 userservice.savebatch(userlist, 500); userservice.updatebatchbyid(userlist, 500);- 数据库连接配置优化:批量操作需要占用数据库连接较长时间,需在 application.yml 中优化数据库连接池配置(以 hikaricp 为例,spring boot 默认连接池):
spring: datasource: driver-class-name: com.mysql.cj.jdbc.driver url: jdbc:mysql://localhost:3306/mp_demo?useunicode=true&characterencoding=utf-8&servertimezone=gmt%2b8&usessl=false username: root password: 123456 hikari: maximum-pool-size: 20 # 最大连接数,根据服务器性能调整 minimum-idle: 5 # 最小空闲连接 connection-timeout: 30000 # 连接超时时间(毫秒) idle-timeout: 600000 # 空闲连接超时时间(毫秒)- 避免嵌套批量操作:不要在批量操作中嵌套另一个批量操作(如批量新增用户时,嵌套批量新增订单),会导致数据库连接耗尽,建议分步骤执行,或使用事务控制。
- 事务控制:批量操作建议添加事务注解(@transactional),确保批量操作要么全部成功,要么全部失败,避免数据不一致。
@service
public class userserviceimpl extends serviceimpl<usermapper, user> implements userservice {
@override
@transactional(rollbackfor = exception.class)
public boolean batchsaveuser(list userlist) {
// 批量新增,添加事务控制
return savebatch(userlist, 500);
}
}5.3 sql 日志分析与慢查询排查建议
在实际开发中,sql 性能是影响系统响应速度的关键因素。mybatis-plus 支持打印执行的 sql 日志,通过分析日志可以排查慢查询、冗余查询等问题,优化 sql 性能。
5.3.1 sql 日志配置(application.yml)
已在环境搭建部分配置了日志打印(log-impl: org.apache.ibatis.logging.stdout.stdoutimpl),会在控制台打印执行的 sql 语句、参数、执行时间等信息,示例如下:
==> preparing: select id,username,age from user where (age > ?) limit ?,? ==> parameters: 20(integer), 0(long), 2(long) <== total: 2
5.3.2 慢查询排查与优化建议
- 识别慢查询:通过 sql 日志中的执行时间,判断是否为慢查询(一般认为执行时间超过 500ms 的 sql 为慢查询)。例如:若某条查询 sql 执行时间达到 2000ms,需重点优化。
- 慢查询优化方法:
- 添加索引:对查询条件中频繁使用的字段(如 where、join on 后的字段)添加索引,减少数据库扫描行数;
- 避免全表扫描:避免使用 select * 查询所有字段,只查询需要的字段;避免使用 or、not in 等关键字(可替换为 in、exists);
- 优化关联查询:减少关联表的数量,对关联字段添加索引;避免在关联查询中使用子查询,可替换为 join;
- 分页查询优化:确保分页查询的排序字段有索引,避免分页时出现全表排序;
- 批量操作优化:如前所述,使用 mybatis-plus 的批量方法,减少数据库连接次数。
- 日志进阶配置:对于生产环境,不建议将日志打印到控制台(影响性能),可配置将 sql 日志输出到文件,并只打印慢查询日志(通过 logback/log4j2 配置),示例(logback):
到此这篇关于mybatis-plus从基础crud到高级查询与性能优化实战指南的文章就介绍到这了,更多相关mybatisplus crud查询内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网!
发表评论