MyBatis-Plus实现数据库curd操作
Posted 我永远信仰
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了MyBatis-Plus实现数据库curd操作相关的知识，希望对你有一定的参考价值。
文章目录
MyBatis-Plus
MyBatis-Plus实现数据库curd操作
-
mp是什么
- MyBatis-Plus(简称MP)是一个MyBatis 的增强工具，在MyBatis,的基础上只做增强不做改变，为简化开发、提高效率而生。
- 润物无声,
- 只做增强不做改变，引入它不会对现有工程产生影响，如丝般顺滑。v
效率至上, - 只需简单配置，即可快速进行CRUD操作，从而节省大量时间。v
- 丰富功能
- 热加载、代码生成、分页、性能分析等功能一应俱全。·
-
mp实现添加修改删除查询
-
mp自动填充乐观锁
-
mp逻辑删除
-
mp分页查询
2.1、mp入门
CREATE TABLE `user` (
`id` bigint NOT NULL COMMENT '主键ID',
`name` varchar(30) DEFAULT NULL COMMENT '姓名',
`age` int DEFAULT NULL COMMENT '年龄',
`email` varchar(50) DEFAULT NULL COMMENT '邮箱',
PRIMARY KEY (`id`)
)
INSERT INTO `user`(`id`,`name`,`age`,`email`) VALUES
(1,'Jone',18,'test1@baomidou.com'),
(2,'Jack',20,'test2@baomidou.com'),
(3,'Tom',28,'test3@baomidou.com'),
(4,'Sandy',21,'test4@baomidou.com'),
(5,'Billie',24,'test5@baomidou.com');
sprinboot版本 2. 2.1
引入相关依赖
<!--mp-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.2</version>
</dependency>
<!--mysql-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!--lombok-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
下载好lombok插件
配置数据库信息
创建实体类User
创建对应的Mapper
继承BaseMapper,里面封装了常用的增删查改方法
在启动类上增加扫描该mapper的路径。因为是该接口动态生成的，默认扫描不到、
@Autowired 对类成员变量、方法及构造函数进行标注，完成自动装配的工作。
通过 @Autowired的使用来消除 set ，get方法
@Repository、@Service、@Controller 和 @Component 将类标识为Bean
@Repository(“名称”)：dao层
@Service(“名称”)：service层
@Controller(“名称”)：web层
#mybatis日志 开启
mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
MP主键策略
- ASSIGN_ID默认生成19位 （根据符号位，时间戳、、、等等生成，百度）
- auto：自动增长
默认开启ASSIGN_ID
#全局设置主键生成策略
mybatis-plus.global-config.db-config.id-type=auto
2.2、curd
查找
void findAll()
List<User> users = userMapper.selectList(null);
users.forEach(System.out::println);
增加
void addUser()
User user = new User(12L, "黎明", 23, "592923@qq.com");
int insert = userMapper.insert(user); //影响行数
System.out.println(insert);
修改
public void upData()
User user = new User();
user.setId(12L);
user.setName("hhha");
int i = userMapper.updateById(user);
System.out.println("影响行数"+i);
2.3、自动填充
字段赋值的时候需要set
增加两个字段，对应的实体类也增加
@TableField(fill = FieldFill.INSERT)
private Data createTime;
@TableField(fill = FieldFill.INSERT_UPDATE)
private Data updateTime;
点进去看该注解的FieldFill类
需要建一个类开启自动填充的处理器。
不要忘记添加注解将它交给Spring管理
@Component
public class MyMetaObjectHandler implements MetaObjectHandler
//实现两个方法，自动填充增加、修改，设置填充策略
3、乐观锁
3.1、场景
主要适用场景:当要更新一条记录的时候，希望这条记录没有被别人更新，也就是说实现线程安全的数据更新
解决丢失更新的问题。（可重复读，解决了不可重复读，隔离性第三级别，Mysql默认）
乐观锁实现方式:
取出记录时，获取当前versione更新时，带上这个versionv
执行更新时，set version = newexsion where version = oldVersion
如果version不对，就更新失败
提交后修改版本号，另一个提交时，会先检查版本号和获取时是否一样，不一样提交失败，一样提交成功。
MP实现乐观锁。
1.显然，需要在表中加上字段version，实体类也是
添加注解@Version即可 （乐观锁注解）
3.配置乐观锁插件，Spring Boot创建一个配置类
添加配置注解，添加扫描，创建一个乐观锁插件
@Bean
public OptimisticLockerInterceptor optimisticLockerInterceptor()
return new OptimisticLockerInterceptor();
测试 失败案例
@Test
void lock()
User user = userMapper.selectById(1L); //注意该值需要从数据库中取出
user.setName("ZhangSan");
User user2 = userMapper.selectById(1L);
user2.setName("LiSi");
//user2执行插队
userMapper.updateById(user2);
userMapper.updateById(user);
4、MP查询
4.1、多个ID批量查询
selectBatchIds()：Batch 批量
@Test
public void select1()
List<User> users = userMapper.selectBatchIds(Arrays.asList(1, 2, 3));
for (User user : users)
System.out.println(user);
4.2、简单条件查询（Map）
public void select2()
Map<String, Object> columnMap = new HashMap<>();
columnMap.put("name", "Jack");// name =Jack
columnMap.put("age", "20");
List<User> users = userMapper.selectByMap(columnMap);
System.out.println(users);
4.3、分页查询
public void selectPage()
Page<User> page = new Page<>(1,3);
Page<User> userPage = userMapper.selectPage(page,null);
long pages = userPage.getPages();//总页数
long current = userPage.getCurrent();//当前页
List<User> records = userPage.getRecords();//数据集合
long total = userPage.getTotal();
boolean hasNext = userPage.hasNext();//是否还有下一页
boolean previous = userPage.hasPrevious();//上一页
System.out.println(pages);
System.out.println(current);
System.out.println(records);
System.out.println(total);
5、MP删除
-
简单删除，根据id删除。逻辑同上
-
批量删除
-
和批量查询一样
-
简单条件删除，和上面一样，使用map
5.1、物理删除和逻辑删除
物理删除∶真实删除，将对应数据从数据库中删除，之后查询不到此条被删除数据（易懂）
**逻辑删除︰**假删除，将对应数据中代表是否被删除字段状态修改为"被删除状态”，之后在数据库中仍旧能看到此条数据记录;
逻辑删除
逻辑删除实现的逻辑：
在表添加字段，作为逻辑删除标志，每次删除时候,修改标志位
0没有删除
1删除
1.表添加字段，实体类添加属性，这是标志
2.增加注解@TableLogic ：表逻辑
执行删除会将该字段的值设为1.
当该字段的值为1时，MP查不到该数据，但是该数据仍在数据库中存在
添加逻辑删除的组件
//逻辑删除组件
@Bean
public ISqlInjector sqlInjector()
return new LogicSqlInjector();
//逻辑删除组件
@Bean
public ISqlInjector sqlInjector()
return new LogicSqlInjector();
# 配置逻辑删除
mybatis-plus.global-config.db-config.logic-delete-value=1
mybatis-plus.global-config.db-config.logic-not-delete-value=0
官网版本有更新说明，版本不同配置不同。
注意：在数据库中该字段需要设置默认值，否则为null ，查不到0，不能将其改为1
增加了逻辑删除后，相当于在添加了AND deleted=0 的条件，虽然概述就仍在数据库，但是使用普通查询查不到。
6、条件构造器和常用接口（wrapper）
Wapper的使用
public void testWrapper1()
/**
* ge ：大于等于
* gt: 大于
* le ： <=
* lt ： <
*/
QueryWrapper<User> wrapper = new QueryWrapper<>();
QueryWrapper<User> queryWrapper = wrapper.ge("age", 18);
List<User> users = userMapper.selectList(queryWrapper);
users.forEach(System.out::println);
SELECT id,name,age,email,create_time,update_time,version,deleted FROM user WHERE deleted=0 AND (age >= ?)
ge:大于等于
gt: 大于
le ： <=
lt ： <
eq ：=
ne ：!=
between: 闭区间
notBetween: 闭区间
**用的多：**模糊查询
like 包含 %张%
notLike 不包含
likeLeft 张%
likeRight 张%
排序
orderBy、orderByDesc、orderByAsc. （参数）
<el-table
:data="list"
style="width: 100%"
row-key="id"
border
lazy
:load="getChildrens"
:tree-props="children: 'children', hasChildren: 'hasChildren'">
<el-table-column label="名称" width="230" align="left">
<template slot-scope="scope">
<span> scope.row.name </span>
</template>
</el-table-column>
<el-table-column label="编码" width="220">
<template slot-scope="row">
row.dictCode
</template>
</el-table-column>
<el-table-column label="值" width="230" align="left">
<template slot-scope="scope">
<span> scope.row.value </span>
</template>
</el-table-column>
<el-table-column label="创建时间" align="center">
<template slot-scope="scope">
<span> scope.row.createTime </span>
</template>
</el-table-column>
</el-table>
7、性能分析插件
对应新版的执行SQL分析打印插件
作用：输出打印 SQL 及执行时长，不要再生产环境下使用，因为会影响效率
基于旧版
导入插件：
/**
* sql执行效率插件
*/
@Bean
@Profile("dev","test") //在这两个环境下开启
public PerformanceInterceptor performanceInterceptor()
PerformanceInterceptor performanceInterceptor = new PerformanceInterceptor();
performanceInterceptor.setMaxTime(1);// ms 设置sql执行的最大时间，如果时间超过了则不执行。如果报错需要调大
return performanceInterceptor;
# 设置开发环境
spring.profiles.active=dev
使用该插件，可以帮助我们优化性能，把执行耗时长的sql揪出来优化
8、代码自动生成器
MyBatis-Plus 从 3.0.3 之后移除了代码生成器与模板引擎的默认依赖，需要手动添加相关依赖：
添加 代码生成器 依赖
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-generator</artifactId>
<version>3.0.5</version>
</dependency>
添加模板依赖：MyBatis-Plus 支持 Velocity（默认）、Freemarker、Beetl，用户可以选择自己熟悉的模板引擎，如果都不满足您的要求，可以采用自定义模板引擎。
<dependency>
<groupId>org.apache.velocity</groupId>
<artifactId>velocity-engine-core</artifactId>
<version>2.3</version>
</dependency>
<dependency>
<groupId>org.freemarker</groupId>
<artifactId>freemarker</artifactId>
<version>2.3.31</version>
</dependency>
package com.yong;
import com.baomidou.mybatisplus.core.exceptions.MybatisPlusException;
import com.baomidou.mybatisplus.core.toolkit.StringPool;
import com.baomidou.mybatisplus.generator.AutoGenerator;
import com.baomidou.mybatisplus.generator.InjectionConfig;
import com.baomidou.mybatisplus.generator.config.*;
import com.baomidou.mybatisplus.generator.config.po.TableInfo;
import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;
import static org.junit.platform.commons.util.StringUtils.isNotBlank;
/**
* @Author cyh
* @Date 2021/12/25 23:20
*/
public class CodeGenerator
/**
* <p>
* 读取控制台内容
* </p>
*/
public static String scanner(String tip)
Scanner scanner = new Scanner(System.in);
StringBuilder help = new StringBuilder();
help.append("请输入" + tip + "：");
System.out.println(help.toString());
if (scanner.hasNext())
String ipt = scanner.next();
if (isNotBlank(ipt))
return ipt;
throw new MybatisPlusException("请输入正确的" + tip + "！");
public static void main(String[] args)
// 代码生成器
AutoGenerator mpg = new AutoGenerator();
// 全局配置
GlobalConfig gc = new GlobalConfig();
String projectPath = System.getProperty("user.dir");
gc.setOutputDir(projectPath + "/src/main/java");
gc.setAuthor("cyh");
gc.setOpen(false);
// gc.setSwagger2(true); 实体属性 Swagger2 注解
mpg.setGlobalConfig(gc);
// 数据源配置
DataSourceConfig dsc = new DataSourceConfig();
dsc.setUrl("jdbc:mysql://localhost:3306/mybatis?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=Asia/Shanghai");
// dsc.setSchemaName("public");
dsc.setDriverName("com.mysql.jdbc.Driver");
dsc.setUsername("root");
dsc.setPassword("123456");
mpg.setDataSource(dsc);
// 包配置
PackageConfig pc = new PackageConfig();
pc.setModuleName(scanner("模块")); //主要是这里
pc.setParent("com.yong");
mpg.setPackageInfo(pc);
// 自定义配置
InjectionConfig cfg = new InjectionConfig()
@Override
public void initMap()
// to do nothing
;
// 如果模板引擎是 freemarker
String templatePath = "/templates/mapper.xml.ftl";
// 如果模板引擎是 velocity
// String templatePath = "/templates/mapper.xml.vm";
// 自定义输出配置
List<FileOutConfig> focList = new ArrayList<>();
// 自定义配置会被优先输出
focList.add(new FileOutConfig(templatePath)
@Override
public String outputFile(TableInfo tableInfo)
// 自定义输出文件名 ， 如果你 Entity 设置了前后缀、此处注意 xml 的名称会跟着发生变化！！
return projectPath + "/src/main/resources/mapper/" + pc.getModuleName()
+ "/" + tableInfo.getEntityName() + "Mapper" + StringPool.DOT_XML;
);
/*
cfg.setFileCreate(new IFileCreate()
@Override
public boolean isCreate(ConfigBuilder configBuilder, FileType fileType, String filePath)
// 判断自定义文件夹是否需要创建
checkDir("调用默认方法创建的目录，自定义目录用");
if (fileType == FileType.MAPPER)
// 已经生成 mapper 文件判断存在，不想重新生成返回 false
return !new File(filePath).exists();
// 允许生成模板文件
return true;
);
*/
cfg.setFileOutConfigList(focList);
mpg.setCfg(cfg);
// 配置模板
TemplateConfig templateConfig = new Mybatis-Plus
还在写CURD？试试这款基于mybatis-plus的springboot代码生成器
mybatis-plus自controller开始一键生成CURD代码