一、条件构造器和常用接口
1、wapper介绍
Wrapper : 条件构造抽象类,最顶端父类
AbstractWrapper : 用于查询条件封装,生成 sql 的 where 条件
QueryWrapper : 查询条件封装
UpdateWrapper : Update 条件封装
AbstractLambdaWrapper : 使用Lambda 语法
LambdaQueryWrapper :用于Lambda语法使用的查询Wrapper
LambdaUpdateWrapper : Lambda 更新封装Wrapper
2、 QueryWrapper
①等于(eq)、不等于(ne)、大于(gt)、大于等于(ge)、小于(lt)、小于等于(le)
queryWrapper.eq("column_name", value);//等于
queryWrapper.ne("column_name", value);//不等于
queryWrapper.gt("column_name", value);//大于
queryWrapper.ge("column_name", value);//大于等于
queryWrapper.lt("column_name", value);//小于
queryWrapper.le("column_name", value);//小于等于
②between:查询字段值在指定范围内的记录,包含边界值
queryWrapper.between("column_name", value1,value2);
③模糊查询(like、notLike、likeLeft、likeRight)
使用通配符 % 进行模糊匹配。
queryWrapper.like("column_name", value);
queryWrapper.notLike("column_name", value);
queryWrapper.likeLeft("column_name", value);
queryWrapper.likeRight("column_name", value);
④在集合中(in)、不在集合中(notIn),子查询(inSql、notInSql)
queryWrapper.in("column_name", Collection<?> values);
queryWrapper.notIn("column_name", Collection<?> values);
queryWrapper.InSql("column_name", sql);
queryWrapper.notInSql("column_name", sql);
⑤空(isNull)、非空(isNotNull)
queryWrapper.isNull("column_name");
queryWrapper.isNotNull("column_name");
⑥排序(orderByAsc、orderByDesc)
queryWrapper.orderByAsc("column_name");
queryWrapper.orderByDesc("column_name");
⑦分组(groupBy)、HAVING 子句(having)
queryWrapper.groupBy("column_name");
queryWrapper.having("sql_having_condition");
⑧连接查询(or、and)
queryWrapper.eq("column1", value1).or().eq("column2", value2);
queryWrapper.eq("column1", value1).and().eq("column2", value2);
⑨嵌套查询(nested)
queryWrapper.nested(wrapper -> { wrapper.eq("column1", value1).or().eq("column2", value2);
});
⑩存在(exists)、不存在(notExists)
queryWrapper.exists("sql_exists_condition");
queryWrapper.notExists("sql_not_exists_condition");
自定义 SQL 片段(apply)
queryWrapper.apply("your_custom_sql_condition");
选择特定的列(select)
queryWrapper.select("column1", "column2");
例1:组装查询条件
@Test
public void test01(){//查询用户名包含a,年龄在20到30之间,并且邮箱不为null的用户信息//SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE is_deleted=0 AND (username LIKE ? AND age BETWEEN ? AND ? AND email IS NOT NULL)QueryWrapper<User> queryWrapper = new QueryWrapper<>();queryWrapper.like("name", "a").between("age", 20, 30).isNotNull("email");List<User> list = userMapper.selectList(queryWrapper);list.forEach(System.out::println);
}
例2:组装排序条件
@Test
public void test02(){//按年龄降序查询用户,如果年龄相同则按id升序排列//SELECT id,name,age,email,is_deleted FROM user WHERE is_deleted=0 ORDER BY age DESC,id ASCQueryWrapper<User> queryWrapper = new QueryWrapper<>();queryWrapper.orderByDesc("age").orderByAsc("id");List<User> users = userMapper.selectList(queryWrapper);users.forEach(System.out::println);
}
例3:组装删除条件
@Test
public void test03(){//删除email为空的用户//DELETE FROM t_user WHERE (email IS NULL)QueryWrapper<User> queryWrapper = new QueryWrapper<>();queryWrapper.isNull("email");//条件构造器也可以构建删除语句的条件int result = userMapper.delete(queryWrapper);System.out.println("受影响的行数:" + result);
}
例4:条件的优先级:更新
@Test
public void test04() {QueryWrapper<User> queryWrapper = new QueryWrapper<>();//将(年龄大于20并且用户名中包含有a)或邮箱为null的用户信息修改//UPDATE user SET age=?, email=? WHERE (name LIKE ? AND age > ? OR email IS NULL)queryWrapper.like("name", "a").gt("age", 20).or().isNull("email");User user = new User();user.setAge(18);user.setEmail("user@atguigu.com");int result = userMapper.update(user, queryWrapper);System.out.println("受影响的行数:" + result);
}
@Test
public void test14() {QueryWrapper<User> queryWrapper = new QueryWrapper<>();//将用户名中包含有a并且(年龄大于20或邮箱为null)的用户信息修改//UPDATE user SET age=?, email=? WHERE (name LIKE ? AND (age > ? OR email IS NULL))//lambda表达式内的逻辑优先运算queryWrapper.like("name", "a").and(i -> i.gt("age", 20).or().isNull("email"));User user = new User();user.setAge(18);user.setEmail("user@atguigu.com");int result = userMapper.update(user, queryWrapper);System.out.println("受影响的行数:" + result);
}
例5:组装select子句
@Test
public void test05() {//查询用户信息的username和age字段//SELECT name,age FROM user WHERE is_deleted=0QueryWrapper<User> queryWrapper = new QueryWrapper<>();queryWrapper.select("name", "age");//selectMaps()返回Map集合列表,通常配合select()使用,避免User对象中没有被查询到的列值为nullList<Map<String, Object>> maps = userMapper.selectMaps(queryWrapper);maps.forEach(System.out::println);
}
例6:实现子查询
@Test
public void test06() {//查询id小于等于3的用户信息//SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE (id IN (select id from t_user where id <= 3))QueryWrapper<User> queryWrapper = new QueryWrapper<>();queryWrapper.inSql("id", "select id from user where id <= 3");List<User> list = userMapper.selectList(queryWrapper);list.forEach(System.out::println);
}
3、 UpdateWrapper
设置字段值(set)
用于指定需要更新的字段和对应的值。
updateWrapper.set("column_name", value);
更新
@Test
public void test07() {//将(年龄大于20或邮箱为null)并且用户名中包含有a的用户信息修改//组装set子句以及修改条件UpdateWrapper<User> updateWrapper = new UpdateWrapper<>();//lambda表达式内的逻辑优先运算updateWrapper.set("age", 18).set("email", "user@atguigu.com").like("name", "a").and(i -> i.gt("age", 20).or().isNull("email"));//这里必须要创建User对象,否则无法应用自动填充。如果没有自动填充,可以设置为null//UPDATE user SET name=?, age=?,email=? WHERE (name LIKE ? AND (age > ? OR email IS NULL))//User user = new User();//user.setName("张三");//UPDATE t_user SET age=?,email=? WHERE (username LIKE ? AND (age > ? OR email IS NULL))int result = userMapper.update(null, updateWrapper);System.out.println(result);
}
4、condition
在开发的过程中,组装条件是常见的功能,而这些条件数据来源于用户输入,是可选的,因此我们在组装这些条件时,必须先判断用户是否选择了这些条件,若选择则需要组装该条件,若没有选择则一定不能组装,以免影响SQL执行的结果
思路一:直接判断
@Test
public void test08() {//定义查询条件,有可能为null(用户未输入或未选择)String username = null;Integer ageBegin = 10;Integer ageEnd = 24;QueryWrapper<User> queryWrapper = new QueryWrapper<>();//StringUtils.isNotBlank()判断某字符串是否不为空且长度不为0且不由空白符(whitespace) 构成if(StringUtils.isNotBlank(username)){queryWrapper.like("username","a");}if(ageBegin != null){queryWrapper.ge("age", ageBegin);}if(ageEnd != null){queryWrapper.le("age", ageEnd);}//SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE (age >= ? AND age <= ?)List<User> users = userMapper.selectList(queryWrapper);users.forEach(System.out::println);
}
思路二:使用带condition参数的重载方法构建查询条件
@Test
public void test08UseCondition() {//定义查询条件,有可能为null(用户未输入或未选择)String username = null;Integer ageBegin = 10;Integer ageEnd = 24;QueryWrapper<User> queryWrapper = new QueryWrapper<>();//StringUtils.isNotBlank()判断某字符串是否不为空且长度不为0且不由空白符(whitespace) 构成queryWrapper.like(StringUtils.isNotBlank(username), "username", "a").ge(ageBegin != null, "age", ageBegin).le(ageEnd != null, "age", ageEnd);//SELECT id,username AS name,age,email,is_deleted FROM t_user WHERE (age >= ? AND age <= ?)List<User> users = userMapper.selectList(queryWrapper);users.forEach(System.out::println);
}
5、 LambdaQueryWrapper
用于构建Lambda查询和更新操作
@Test
public void test09() {//定义查询条件,有可能为null(用户未输入)String username = "a";Integer ageBegin = 10;Integer ageEnd = 24;LambdaQueryWrapper<User> queryWrapper = new LambdaQueryWrapper<>();//避免使用字符串表示字段,防止运行时错误queryWrapper.like(StringUtils.isNotBlank(username), User::getName, username) .ge(ageBegin != null, User::getAge, ageBegin).le(ageEnd != null, User::getAge, ageEnd);List<User> users = userMapper.selectList(queryWrapper);users.forEach(System.out::println);
}
6、 LambdaUpdateWrapper
@Test
public void test10() {//组装set子句LambdaUpdateWrapper<User> updateWrapper = new LambdaUpdateWrapper<>(); updateWrapper.set(User::getAge, 18).set(User::getEmail, "user@atguigu.com").like(User::getName, "a").and(i -> i.lt(User::getAge, 24).or().isNull(User::getEmail)); //lambda 表达式内的逻辑优先运算User user = new User();int result = userMapper.update(user, updateWrapper);System.out.println("受影响的行数:" + result);
}
注意事项
- 使用 LambdaUpdateWrapper 时,要确保实体类中的字段都有对应的 getter 方法,因为 Lambda 表达式是通过这些 getter 方法来引用字段的。
- 与 LambdaQueryWrapper 一样,尽量避免在 LambdaUpdateWrapper 中直接拼接 SQL 片段,以防止 SQL 注入攻击。
- 更新操作可能会影响到数据库中的数据完整性和业务逻辑,因此在使用 LambdaUpdateWrapper 进行更新操作时,务必谨慎并充分测试。
二、插件
1、分页插件
MyBatis Plus自带分页插件,只要简单的配置即可实现分页功能
①添加配置类
@SpringBootApplication
@MapperScan("com.qcby.mybatisplus.mapper")
public class MybatisPlusApplication {public static void main(String[] args) {SpringApplication.run(MybatisPlusApplication.class, args);}@Beanpublic MybatisPlusInterceptor mybatisPlusInterceptor() {MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();interceptor.addInnerInterceptor(newPaginationInnerInterceptor(DbType.MYSQL));return interceptor;}}
②测试
@Test
public void testPage(){//设置分页参数Page<User> page = new Page<>(1, 5);userMapper.selectPage(page, null);//获取分页数据List<User> list = page.getRecords();list.forEach(System.out::println);System.out.println("当前页:"+page.getCurrent());System.out.println("每页显示的条数:"+page.getSize());System.out.println("总记录数:"+page.getTotal());System.out.println("总页数:"+page.getPages());System.out.println("是否有上一页:"+page.hasPrevious());System.out.println("是否有下一页:"+page.hasNext());
}
2、xml自定义分页
①UserMapper中定义接口方法
@Repository //用于标识数据访问对象
public interface UserMapper extends BaseMapper<User> {/*** 根据年龄查询用户列表,分页显示* @param page 分页对象 ,xml中可以从里面进行取值 ,传递参数 Page 即自动分页 ,必须放在第一位* @param age 年龄* @return */Page<User> selectPageVo(@Param("page") Page<User> page, @Param("age") Integer age);
}
②UserMapper.xml中编写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.qcby.mybatisplus.mapper.UserMapper"><!--IPage<User> selectPageVo(Page<User> page, Integer age);--><select id="selectPageVo" resultType="com.qcby.mybatisplus.model.User">SELECT id,name,age,email FROM user WHERE age > #{age}</select>
</mapper>
③测试
@Test
public void testSelectPageVo(){//设置分页参数Page<User> page = new Page<>(1, 5);userMapper.selectPageVo(page, 20);//获取分页数据List<User> list = page.getRecords();list.forEach(System.out::println);System.out.println("当前页:"+page.getCurrent());System.out.println("每页显示的条数:"+page.getSize());System.out.println("总记录数:"+page.getTotal());System.out.println("总页数:"+page.getPages());System.out.println("是否有上一页:"+page.hasPrevious());System.out.println("是否有下一页:"+page.hasNext());
}
三、通用枚举
表中的有些字段值是固定的,例如性别(男或女),此时我们可以使用MyBatis-Plus的通用枚举 来实现
1、数据库user表添加字段sex,int类型,1代表男,2代表女,并且在User类中添加sex属性
private SexEnum sex;
2、创建通用枚举类型
package com.qcby.mybatisplus.enums;
import com.baomidou.mybatisplus.annotation.EnumValue;
import lombok.Getter;@Getter
public enum SexEnum {MALE(1, "男"),FEMALE(2, "女");@EnumValue //存储到数据库的字段类型private Integer sex;private String sexName;SexEnum(Integer sex, String sexName) {this.sex = sex;this.sexName = sexName;}
}
3、配置扫描通用枚举
# 配置MyBatis日志
mybatis-plus:configuration:log-impl: org.apache.ibatis.logging.stdout.StdOutImpl# 配置扫描通用枚举type-enums-package: com.qcby.mybatisplus.enums
4、测试
@Test
public void testSexEnum(){User user = new User();user.setName("Enum");user.setAge(20);//设置性别信息为枚举项,会将@EnumValue注解所标识的属性值存储到数据库user.setSex(SexEnum.MALE);//INSERT INTO user ( name, age, sex ) VALUES ( ?, ?, ? ) //Parameters: Enum(String), 20(Integer), 1(Integer)userMapper.insert(user);
}
四、代码生成器
1、引入依赖
<dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-generator</artifactId><version>3.5.1</version>
</dependency>
<dependency><groupId>org.freemarker</groupId><artifactId>freemarker</artifactId><version>2.3.31</version>
</dependency>
2、快速生成
public class FastAutoGeneratorTest {public static void main(String[] args) {FastAutoGenerator.create("jdbc:mysql://127.0.0.1:3306/mybatis_plus? characterEncoding=utf-8&userSSL=false", "root", "123456").globalConfig(builder -> {builder.author("atguigu") // 设置作者//.enableSwagger() // 开启 swagger 模式.fileOverride() // 覆盖已生成文件.outputDir("D://mybatis_plus"); // 指定输出目录}).packageConfig(builder -> {builder.parent("com.qcby") // 设置父包名.moduleName("mybatisplus") // 设置父包模块名.pathInfo(Collections.singletonMap(OutputFile.mapperXml, "D://mybatis_plus"));// 设置mapperXml生成路径}).strategyConfig(builder -> {builder.addInclude("t_user") // 设置需要生成的表名.addTablePrefix("t_", "c_"); // 设置过滤表前缀}).templateEngine(new FreemarkerTemplateEngine()) // 使用Freemarker 引擎模板,默认的是Velocity引擎模板.execute();}
}
五、多数据源
适用于多种场景:纯粹多库、 读写分离、 一主多从、 混合模式等
目前我们就来模拟一个纯粹多库的一个场景,其他场景类似
场景说明:
我们创建两个库,分别为: mybatis_plus(以前的库不动)与mybatis_plus_1 (新建),将mybatis_plus库的product表移动到mybatis_plus_1库,这样每个库一张表,通过一个测试用例 分别获取用户数据与商品数据,如果获取到说明多库模拟成功
1、创建数据库及表
同时删除mybatis_plus中的product表
CREATE DATABASE `mybatis_plus_1` /*!40100 DEFAULT CHARACTER SET utf8mb4 */; use `mybatis_plus_1`;
CREATE TABLE product
(
id BIGINT(20) NOT NULL COMMENT '主键ID',
name VARCHAR(30) NULL DEFAULT NULL COMMENT '商品名称 ',
price INT(11) DEFAULT 0 COMMENT '价格 ',
version INT(11) DEFAULT 0 COMMENT '乐观锁版本号 ',
PRIMARY KEY (id));INSERT INTO product (id, NAME, price) VALUES (1, '外星人笔记本 ', 100);
2、引入依赖
<dependency><groupId>com.baomidou</groupId><artifactId>dynamic-datasource-spring-boot-starter</artifactId><version>3.5.0</version>
</dependency>
3、配置多数据源
说明:注释掉之前的数据库连接,添加新配置
spring:# 配置数据源信息datasource:dynamic:# 设置默认的数据源或者数据源组 ,默认值即为masterprimary: master# 严格匹配数据源 ,默认false.true未匹配到指定数据源时抛异常 ,false使用默认数据源strict: falsedatasource:master:url: jdbc:mysql://localhost:3306/mybatis_plus?characterEncoding=utf-8&useSSL=falsedriver-class-name: com.mysql.cj.jdbc.Driverusername: rootpassword: 123456slave_1:url: jdbc:mysql://localhost:3306/mybatis_plus_1?characterEncoding=utf-8&useSSL=falsedriver-class-name: com.mysql.cj.jdbc.Driverusername: rootpassword: 123456
4、创建用户service
public interface UserService extends IService<User> {
}
@DS("master") //指定所操作的数据源
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
}
5、创建商品service
public interface ProductService extends IService<Product> {
}
@DS("slave_1") //指定操作的数据源
@Service
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {
}
6、测试
@Autowired
private UserService userService;
@Autowired
private ProductService productService;@Test
public void testDynamicDataSource(){System.out.println(userService.getById(1L));System.out.println(productService.getById(1L));
}