文章目录
- 简介
- 特性
- 支持数据库
- 框架结构
- 入门案例
- 开发环境
- 准备数据
- 创建SpringBoot工程
- 初始化工程
- 引入SpringBoot父工程
- 添加依赖
- 安装Lombok插件
- 配置编码
- 配置application.yml文件
- 加入日志功能
- 编写实体类 User.java
- 创建mapper接口并扫描
- 简单的查询测试
- 增删改查
- BaseMapper
- BaseMapper中提供的CRUD方法
- 添加示例
- 删除示例
- 修改示例
- 查询示例
- BaseMapper.java源码
简介
MyBatis-Plus是MyBatis的增强工具,在MyBatis的基础上只做增强不做改变,为简化开发、提高效率而生。MyBatis-Plus提供了通用的mapper和service,可以在不编写任何SQL语句的情况下,快速地实现对单表的CRUD、批量、逻辑删除、分页等操作。
特性
- 无侵入:只做增强不做改变,引入它不会对现有工程产生影响,如丝般顺滑
- 损耗小:启动即会自动注入基本 CURD,性能基本无损耗,直接面向对象操作
- 强大的 CRUD 操作:内置通用 Mapper、通用 Service,仅仅通过少量配置即可实现单表大部分 CRUD 操作,更有强大的条件构造器,满足各类使用需求
- 支持 Lambda 形式调用:通过 Lambda 表达式,方便的编写各类查询条件,无需再担心字段写错
- 支持主键自动生成:支持多达 4 种主键策略(内含分布式唯一 ID 生成器 – Sequence),可自由配置,完美解决主键问题
- 支持 ActiveRecord 模式:支持 ActiveRecord 形式调用,实体类只需继承 Model 类即可进行强大的 CRUD 操作
- 支持自定义全局通用操作:支持全局通用方法注入( Write once, use anywhere )
- 内置代码生成器:采用代码或者 Maven 插件可快速生成 Mapper 、 Model 、 Service 、 Controller 层代码,支持模板引擎,更有超多自定义配置等您来使用
- 内置分页插件:基于 MyBatis 物理分页,开发者无需关心具体操作,配置好插件之后,写分页等同于普通 List 查询
- 分页插件支持多种数据库:支持 MySQL、MariaDB、Oracle、DB2、H2、HSQL、SQLite、Postgre、SQLServer 等多种数据库
- 内置性能分析插件:可输出 SQL 语句以及其执行时间,建议开发测试时启用该功能,能快速揪出慢查询
- 内置全局拦截插件:提供全表 delete 、 update 操作智能分析阻断,也可自定义拦截规则,预防误操作
支持数据库
任何能使用 MyBatis 进行 CRUD, 并且支持标准 SQL 的数据库,具体支持情况如下,如果不在下列表查看分页部分教程 PR 您的支持。
MySQL,Oracle,DB2,H2,HSQL,SQLite,PostgreSQL,SQLServer,Phoenix,Gauss ,ClickHouse,Sybase,OceanBase,Firebird,Cubrid,Goldilocks,csiidb
达梦数据库,虚谷数据库,人大金仓数据库,南大通用(华库)数据库,南大通用数据库,神通数据库,瀚高数据库
框架结构
官方文档:https://baomidou.com/pages/24112f/
入门案例
开发环境
- IDE:IDEA 2019.3.5
- JDK:JDK8+
- 构建工具:Maven 3.5.4
- MySQL:MySQL 8.0.24
- Navicat:Navicat Premium 15
- Spring Boot:2.6.7
- MyBatis-Plus:3.5.1
https://baomidou.com/pages/24112f/
准备数据
打开Navicat运行以下SQL脚本进行建库建表
CREATE DATABASE `mybatis_plus` /*!40100 DEFAULT CHARACTER SET utf8mb4 */; use `mybatis_plus`; CREATE TABLE `user` ( `id` bigint(20) NOT NULL COMMENT '主键ID', `name` varchar(30) DEFAULT NULL COMMENT '姓名', `age` int(11) DEFAULT NULL COMMENT '年龄', `email` varchar(50) DEFAULT NULL COMMENT '邮箱', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
插入几条测试数据
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');
https://baomidou.com/pages/24112f/
创建SpringBoot工程
初始化工程
使用 Spring Initializer
快速初始化一个 Spring Boot 工程
引入SpringBoot父工程
<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.7.1</version><relativePath/> </parent>
添加依赖
<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.1</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency></dependencies>
安装Lombok插件
配置编码
配置application.yml文件
#配置端口server:port: 80spring:#配置数据源datasource:#配置数据源类型type: com.zaxxer.hikari.HikariDataSource#配置连接数据库的信息driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/mybatis_plus" />-8&useSSL=falseusername: rootpassword: root#MyBatis-Plus相关配置mybatis-plus:configuration:#配置日志,加入日志功能,可以查看MyBatisPlus生成的SQL语句。log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
注意:
加入日志功能
详见application.yml文件。
编写实体类 User.java
(此处使用了 Lombok 简化代码)
package com.xxxx.mybatisplus.pojo;import lombok.Data;@Datapublic class User {private Long id;private String name;private Integer age;private String email;}
@Data:注解在类上,提供类所有属性的 Getting 和 Setting方法,此外还提供了equals、canEqual、hashCode、toString等方法。
创建mapper接口并扫描
编写 Mapper 包下的 UserMapper
接口
package com.xxxx.mybatisplus.mapper;import com.baomidou.mybatisplus.core.mapper.BaseMapper;import com.xxxx.mybatisplus.pojo.User;public interface UserMapper extends BaseMapper<User>{}
在 Spring Boot 启动类中添加 @MapperScan
注解,扫描 Mapper 文件夹
package com.xxxx.mybatisplus;import org.mybatis.spring.annotation.MapperScan;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication//扫描接口所在的包@MapperScan("com.xxxx.mybatisplus.mapper")public class MybatisplusApplication {public static void main(String[] args) {SpringApplication.run(MybatisplusApplication.class, args);}}
简单的查询测试
package com.xxxx.mybatisplus;import com.xxxx.mybatisplus.mapper.UserMapper;import com.xxxx.mybatisplus.pojo.User;import net.minidev.json.JSONUtil;import org.junit.jupiter.api.Test;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import java.util.List;@SpringBootTestpublic class MyBatisPlusTest {//@Autowired,会报红,要在mapper接口上加@Repository@ResourceUserMapper userMapper;@Testpublic void testSelectList() {//通过条件构造器查询一个list集合,若没有条件,则可以设置参数为nullList<User> list = userMapper.selectList(null);list.forEach(System.out::println);}}
控制台查询结果:
增删改查
BaseMapper
说明:
- 通用 CRUD 封装BaseMapper 接口,为
Mybatis-Plus
启动时自动解析实体表关系映射转换为Mybatis
内部对象注入容器 - 泛型
T
为任意实体对象 - 参数
Serializable
为任意类型主键Mybatis-Plus
不推荐使用复合主键约定每一张表都有自己的唯一id
主键 - 对象
Wrapper
为条件构造器
MyBatis-Plus中的基本CRUD在内置的BaseMapper中都已得到了实现,因此我们继承该接口以后可以直接使用。
BaseMapper中提供的CRUD方法
- 增加:Insert
// 插入一条记录int insert(T entity);
- 删除:Delete
// 根据 entity 条件,删除记录int delete(@Param(Constants.WRAPPER) Wrapper<T> wrapper);// 删除(根据ID 批量删除)int deleteBatchIds(@Param(Constants.COLLECTION) Collection<" />extends Serializable> idList);// 根据 ID 删除int deleteById(Serializable id);// 根据 columnMap 条件,删除记录int deleteByMap(@Param(Constants.COLUMN_MAP) Map<String, Object> columnMap);
- 修改:Update
// 根据 whereWrapper 条件,更新记录int update(@Param(Constants.ENTITY) T updateEntity, @Param(Constants.WRAPPER) Wrapper<T> whereWrapper);// 根据 ID 修改int updateById(@Param(Constants.ENTITY) T entity);
- 查询:Select
// 根据 ID 查询T selectById(Serializable id);// 根据 entity 条件,查询一条记录T selectOne(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);// 查询(根据ID 批量查询)List<T> selectBatchIds(@Param(Constants.COLLECTION) Collection<? extends Serializable> idList);// 根据 entity 条件,查询全部记录List<T> selectList(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);// 查询(根据 columnMap 条件)List<T> selectByMap(@Param(Constants.COLUMN_MAP) Map<String, Object> columnMap);// 根据 Wrapper 条件,查询全部记录List<Map<String, Object>> selectMaps(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);// 根据 Wrapper 条件,查询全部记录。注意: 只返回第一个字段的值List<Object> selectObjs(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);// 根据 entity 条件,查询全部记录(并翻页)IPage<T> selectPage(IPage<T> page, @Param(Constants.WRAPPER) Wrapper<T> queryWrapper);// 根据 Wrapper 条件,查询全部记录(并翻页)IPage<Map<String, Object>> selectMapsPage(IPage<T> page, @Param(Constants.WRAPPER) Wrapper<T> queryWrapper);// 根据 Wrapper 条件,查询总记录数Integer selectCount(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);
添加示例
@Test//实现新增用户信息public void testInsert(){User user = new User();user.setName("张三");user.setAge(23);user.setEmail("zahngsan@xxxx.com");int result = userMapper.insert(user);System.out.println("result:"+result);System.out.println("id:"+user.getId());}
注:在MyBatisPlus中,默认使用雪花算法生成id。
删除示例
deleteById
@Testpublic void testDelete(){//通过id删除用户信息int result = userMapper.deleteById(1548596044798009345L);System.out.println("result:"+result);}
deleteByMap
@Testpublic void testDelete(){Map<String,Object> map = new HashMap<>();map.put("name","张三");map.put("age",23);//根据map集合中设置的条件删除用户信息int result = userMapper.deleteByMap(map);System.out.println("result:"+result);}
deleteBatchIds
@Testpublic void testDelete(){List<Long> list = Arrays.asList(1L,2L,3L);//通过多个id批量删除int result = userMapper.deleteBatchIds(list);System.out.println("result:"+result);}
修改示例
updateById
@Testpublic void testUpdate(){User user = new User();user.setId(4L);user.setName("张三");user.setEmail("zahngsan@xxxx.com");int result = userMapper.updateById(user);System.out.println("result:"+result);}
查询示例
selectById
@Testpublic void testSelect(){//通过id查询用户信息//SELECT id,name,age,email FROM user WHERE id=" />User user = userMapper.selectById(1L);System.out.println(user);}
selectBatchIds
@Testpublic void testSelect(){List<Long> list = Arrays.asList(1L,2L,3L);//通过多个id查询多个用户信息//SELECT id,name,age,email FROM user WHERE id IN ( " />List<User> users = userMapper.selectBatchIds(list);}
selectByMap
@Testpublic void testSelect(){Map<String,Object> map = new HashMap<>();map.put("name","jack");map.put("age",20);//根据map集合中的条件查询List<User> users = userMapper.selectByMap(map);users.forEach(System.out::println);}
BaseMapper.java源码
/* * Copyright (c) 2011-2022, baomidou (jobob@qq.com). * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */package com.baomidou.mybatisplus.core.mapper;import com.baomidou.mybatisplus.core.conditions.Wrapper;import com.baomidou.mybatisplus.core.metadata.IPage;import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;import com.baomidou.mybatisplus.core.toolkit.Constants;import com.baomidou.mybatisplus.core.toolkit.ExceptionUtils;import org.apache.ibatis.annotations.Param;import java.io.Serializable;import java.util.Collection;import java.util.List;import java.util.Map;/* :`.:, :::,,. ::`:::::: ::``,:,` .:` `:: `::::::::.:``:';,`::::, .:::` `@++++++++: ``:::`@+++++++++++# :::, #++++++++++++++` ,:`::::::;'##++++++++++ .@#@;` ::::::::::::::::::::;#@####@, :::::::::::::::+#;::.@@######+@:::::::::::::.#@:; ,@@########':::::::::::: .#''':` ;##@@@+:##########@::::::::::: @#;.,:.#@@@######++++#####'::::::::: .##+,:#`@@@@@#####+++++'#####+::::::::` ,`::@#:``@@@@#####++++++'#####+#':::::::::::@. @@@@######+++++''#######+##';::::;':,`@@@@#####+++++'''#######++++++++++` #@@#####++++++''########++++++++' `#@######+++++''+########+++++++;`@@#####+++++''##########++++++, @@######+++++'##########+++++#`@@@@#####+++++############++++;;#@@@@@####++++##############+++, @@@@@@@@@@@###@###############++' @#@@@@@@@@@@@@###################+:`@#@@@@@@@@@@@@@@###################'`:@#@@@@@@@@@@@@@@@@@##################,,@@@@@@@@@@@@@@@@@@@@################; ,#@@@@@@@@@@@@@@@@@@@##############+`.#@@@@@@@@@@@@@@@@@@#############@,@@@@@@@@@@@@@@@@@@@###########@, :#@@@@@@@@@@@@@@@@##########@,`##@@@@@@@@@@@@@@@########+,`+@@@@@@@@@@@@@@@#####@:``:@@@@@@@@@@@@@@##@;. `,'@@@@##@@@+;,```...`` _ _ /_ _ _/_. ____/_/ / //_//_//_|/ /_\/_///_/_\Talk is cheap. Show me the code. _/ / *//** * Mapper 继承该接口后,无需编写 mapper.xml 文件,即可获得CRUD功能 * 这个 Mapper 支持 id 泛型
* * @author hubin * @since 2016-01-23 */public interface BaseMapper<T> extends Mapper<T> {/** * 插入一条记录 * * @param entity 实体对象 */int insert(T entity);/** * 根据 ID 删除 * * @param id 主键ID */int deleteById(Serializable id);/** * 根据实体(ID)删除 * * @param entity 实体对象 * @since 3.4.4 */int deleteById(T entity);/** * 根据 columnMap 条件,删除记录 * * @param columnMap 表字段 map 对象 */int deleteByMap(@Param(Constants.COLUMN_MAP) Map<String, Object> columnMap);/** * 根据 entity 条件,删除记录 * * @param queryWrapper 实体对象封装操作类(可以为 null,里面的 entity 用于生成 where 语句) */int delete(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);/** * 删除(根据ID或实体 批量删除) * * @param idList 主键ID列表或实体列表(不能为 null 以及 empty) */int deleteBatchIds(@Param(Constants.COLLECTION) Collection<" />> idList);/** * 根据 ID 修改 * * @param entity 实体对象 */int updateById(@Param(Constants.ENTITY) T entity);/** * 根据 whereEntity 条件,更新记录 * * @param entity实体对象 (set 条件值,可以为 null) * @param updateWrapper 实体对象封装操作类(可以为 null,里面的 entity 用于生成 where 语句) */int update(@Param(Constants.ENTITY) T entity, @Param(Constants.WRAPPER) Wrapper<T> updateWrapper);/** * 根据 ID 查询 * * @param id 主键ID */T selectById(Serializable id);/** * 查询(根据ID 批量查询) * * @param idList 主键ID列表(不能为 null 以及 empty) */List<T> selectBatchIds(@Param(Constants.COLLECTION) Collection<? extends Serializable> idList);/** * 查询(根据 columnMap 条件) * * @param columnMap 表字段 map 对象 */List<T> selectByMap(@Param(Constants.COLUMN_MAP) Map<String, Object> columnMap);/** * 根据 entity 条件,查询一条记录 * 查询一条记录,例如 qw.last("limit 1") 限制取一条记录, 注意:多条数据会报异常
* * @param queryWrapper 实体对象封装操作类(可以为 null) */default T selectOne(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper) {List<T> ts = this.selectList(queryWrapper);if (CollectionUtils.isNotEmpty(ts)) {if (ts.size() != 1) {throw ExceptionUtils.mpe("One record is expected, but the query result is multiple records");}return ts.get(0);}return null;}/** * 根据 Wrapper 条件,判断是否存在记录 * * @param queryWrapper 实体对象封装操作类 * @return */default boolean exists(Wrapper<T> queryWrapper) {Long count = this.selectCount(queryWrapper);return null != count && count > 0;}/** * 根据 Wrapper 条件,查询总记录数 * * @param queryWrapper 实体对象封装操作类(可以为 null) */Long selectCount(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);/** * 根据 entity 条件,查询全部记录 * * @param queryWrapper 实体对象封装操作类(可以为 null) */List<T> selectList(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);/** * 根据 Wrapper 条件,查询全部记录 * * @param queryWrapper 实体对象封装操作类(可以为 null) */List<Map<String, Object>> selectMaps(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);/** * 根据 Wrapper 条件,查询全部记录 * 注意: 只返回第一个字段的值
* * @param queryWrapper 实体对象封装操作类(可以为 null) */List<Object> selectObjs(@Param(Constants.WRAPPER) Wrapper<T> queryWrapper);/** * 根据 entity 条件,查询全部记录(并翻页) * * @param page 分页查询条件(可以为 RowBounds.DEFAULT) * @param queryWrapper 实体对象封装操作类(可以为 null) */<P extends IPage<T>> P selectPage(P page, @Param(Constants.WRAPPER) Wrapper<T> queryWrapper);/** * 根据 Wrapper 条件,查询全部记录(并翻页) * * @param page 分页查询条件 * @param queryWrapper 实体对象封装操作类 */<P extends IPage<Map<String, Object>>> P selectMapsPage(P page, @Param(Constants.WRAPPER) Wrapper<T> queryWrapper);}