【README】

本文代碼參見： https://github.com/TomJourney/mybatis-plus-test

本文集成了springboot與mybatis-plus；

本文主要內容如下（總結自B站黑馬程序員）：

• MybatisPlus常見注解；
• MybatisPlus常見配置；
• 條件構造器；
• 自定義sql；
• IService接口；

---

【1】MyBatis-plus常見注解

【注解官方使用文檔】https://baomidou.com/reference/annotation/

1）MybatisPlus通過掃描實體類，并基于反射獲取po類信息作為數據庫表信息；默認規則如下：

• 類名駝峰轉下劃線作為表名；
• 名為id的字段作為主鍵；
• 變量名駝峰轉下劃線作為表的字段名；

補充：若po類的字段與數據庫表字段不滿足上述默認規則，則需要使用注解來做自定義（這就是注解的作用，非常重要） ；

2）注解（修飾po）：

• @TableName： 設置表名；
• @TableId：指定表中的主鍵字段；
• @TableField：指定表中的普通字段；

@Data
@TableName("user_tbl")
public class UserPO {@TableId("idXXX")private Long id;@TableField("nameXXX")private String name;private String mobilePhone;private String addr;
}

---

【2】MyBatis-Plus常見配置

mybatis-plus常見配置官方文檔：https://baomidou.com/reference/

【2.1】MyBatis-Plus配置示例

# 更多配置可以參考：  https://baomidou.com/reference/
# 別名掃描包
mybatis-plus.type-aliases-package=com.tom.study.mybatisplustest.infrastructure.dao# mapper.xml路徑
mybatis-plus.mapper-locations=classpath*:com.tom.study.mybatisplustest.infrastructure.dao/**/*.xml# 配置
# 是否開啟下劃線和駝峰的映射
mybatis-plus.configuration.map-underscore-to-camel-case=true
# 是否開啟二級緩存
mybatis-plus.configuration.cache-enabled=false# 全局配置
# 更新策略： 只更新非空字段 
mybatis-plus.global-config.db-config.update-strategy=not_null

---

【3】MyBatisPlus核心內容

【3.1】條件構造器

1）MybatisPlus支持各種復雜的where條件，Wrapper類就是構建條件的包裝器，該類定義了多種方法用于抽象sql條件（where子句）；

---

【3.1.1】業務場景1-帶多字段條件的查詢-使用QueryWrapper

【業務場景】查詢id大于100且名字包含6的用戶

sql語句偽代碼： select * from table where id > 100 and name like %6%；【說明：本sql僅供參考，生產環境不要使用】

【構建查詢語句，封裝到QueryWrapper】qryByCondition01()

@Service
public class UserAppService {@AutowiredUserMapper userMapper;public List<UserPO> qryByCondition01() {QueryWrapper<UserPO> userPOQueryWrapper = new QueryWrapper<UserPO>().select("id", "name", "addr").like("name", "6").ge("id", 100);// 查詢return userMapper.selectList(userPOQueryWrapper);}
}

【sql執行日志】

==>  Preparing: SELECT id,name,addr FROM user_tbl WHERE (name LIKE ? AND id >= ?)
==> Parameters: %6%(String), 100(Integer)
<==    Columns: id, name, addr
<==        Row: 106, tr106, 成都市天府大道106號
<==        Row: 116, tr116, 成都市天府大道116號
<==      Total: 2

---

【3.1.2】業務場景2-帶條件的更新-使用QueryWrapper

【業務場景】根據name等于user2的用戶的地址addr，手機號碼mobilePhone；

sql語句偽代碼： update table set addr=‘XXX’, mobile_phone=‘XXX’ where name=‘user2’；【說明：本sql僅供參考，生產環境不要使用】

【構建更新的where子句，封裝到QueryWrapper】updateByCondition02()

public void updateByCondition2() {QueryWrapper<UserPO> updateWrapper = new QueryWrapper<UserPO>().eq("name", "user2");UserPO userPO = new UserPO();userPO.setAddr("成都天府四街401號");userPO.setMobilePhone("110");userMapper.update(userPO, updateWrapper);
}

【sql執行日志】

JDBC Connection [com.mysql.cj.jdbc.ConnectionImpl@774e182c] will not be managed by Spring
==>  Preparing: UPDATE user_tbl SET mobile_phone=?, addr=? WHERE (name = ?)
==> Parameters: 110(String), 成都天府四街401號(String), user2(String)
<==    Updates: 1

---

【3.1.3】業務場景3-帶條件對字段做計算-使用UpdateWrapper

【業務場景】更新id為4,5,6的用戶的余額，都加500元（消費券）；

sql語句偽代碼： update table set balance = balance + 500 where id in (4,5,6)；【說明：本sql僅供參考，生產環境不要使用】

【構建更新的where子句，封裝到UpdateWrapper】updateByCondition03()

public void updateByCondition3() {UpdateWrapper<UserPO> updateWrapper = new UpdateWrapper<UserPO>().setSql("balance = balance + 500").in("id", Arrays.asList(4, 5, 6));userMapper.update(null, updateWrapper);}

【sql執行日志】

JDBC Connection [com.mysql.cj.jdbc.ConnectionImpl@7d18e48f] will not be managed by Spring
==>  Preparing: UPDATE user_tbl SET balance = balance + 500 WHERE (id IN (?,?,?))
==> Parameters: 4(Integer), 5(Integer), 6(Integer)
<==    Updates: 3

---

【3.1.4】lambda語法的QueryWrapper-使用LambdaQueryWrapper

public List<UserPO> qryByLambdaCondition04() {LambdaQueryWrapper<UserPO> userPOQueryWrapper = new LambdaQueryWrapper<UserPO>().select(UserPO::getId, UserPO::getName, UserPO::getAddr).like(UserPO::getName, "6").ge(UserPO::getId, 100);// 查詢return userMapper.selectList(userPOQueryWrapper);
}

【sql日志】

==>  Preparing: SELECT id,name,addr FROM user_tbl WHERE (name LIKE ? AND id >= ?)
==> Parameters: %6%(String), 100(Integer)
<==    Columns: id, name, addr
<==        Row: 106, tr106, 成都市天府大道106號
<==        Row: 116, tr116, 成都市天府大道116號
<==      Total: 2

---

【4】自定義sql（MyBatisPlus的優缺點）

1）應用場景：使用mybatisPlus的Wrapper構建復雜的where條件，然后自定義sql語句中剩下的部分；

2）MyBatisPlus的優缺點：

• 優點：能夠容易定義where子句的查詢條件；
• 缺點：不容易定義where關鍵字之前的sql，如聚合函數count(),avg()等 （如sql= select user_state, count(1) from table where id in (1,2,3) group by user_state)；

【4.1】MyBatisPlus使用自定義sql的場景

【業務場景】更新id為4,5,6的用戶的余額，都加500元。

【第1步】構建更新條件-使用LambdaQueryWrapper

public void updateBalanceByDiySql() {LambdaQueryWrapper<UserPO> userPOQueryWrapper = new LambdaQueryWrapper<UserPO>().in(UserPO::getId, List.of(4, 5, 6));// 更新userMapper.updateBalance(userPOQueryWrapper, new BigDecimal("500"));}

【第2步】mapper方法中使用@Param注解聲明wrapper實例名稱為ew（而且必須為ew）

public interface UserMapper extends BaseMapper<UserPO> {void updateBalance(@Param("ew")LambdaQueryWrapper<UserPO> wrapper, @Param("balance")BigDecimal balance);
}

補充：也可以使用常量Constants.WRAPPER獲取ew值；

【第3步】自定義sql，使用Wrapper條件

【UserMapper.xml】 UserMapper.xml與UserMapper.java 在同一個package下；

<?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.tom.study.mybatisplustest.infrastructure.dao.user.mapper.UserMapper"><update id="updateBalance">update user_tbl set balance = balance + #{balance} ${ew.customSqlSegment}</update>
</mapper>

【sql日志】

==>  Preparing: update user_tbl set balance = balance + ? WHERE (id IN (?,?,?))
==> Parameters: 500(BigDecimal), 4(Integer), 5(Integer), 6(Integer)
<==    Updates: 3

---

【5】MyBatisPlus提供的Service接口（IService）

1）MyBatisPlus提供的IService接口：自定義多個增刪改查方法api；

• ServiceImpl 實現了 IService，業務邏輯可以不用實現IService，而繼承ServiceImpl ；因為實現IService，需要重寫其所有方法，非常麻煩；

【5.1】繼承ServiceImpl 類

【5.1.1】使用ServiceImpl接口更新用戶余額

public interface UserMapper extends BaseMapper<UserPO> {void updateBalance(@Param("ew") LambdaQueryWrapper<UserPO> wrapper, @Param("balance") BigDecimal balance);
}// 繼承MybatisPlus的ServiceImpl，ServiceImpl實現了MybatisPlus的IService接口
@Service
public class MyBatisPlusUserService extends ServiceImpl<UserMapper, UserPO> {}// 單元測試
@SpringBootTest
public class MyBatisPlusUserServiceTest {@Autowiredprivate MyBatisPlusUserService userService;@Testvoid testSaveUser() {UserPO userPO = new UserPO();userPO.setId(123001L);userPO.setName("張三001");userPO.setMobilePhone("19912340001");userPO.setAddr("成都天府五街001號");userService.save(userPO);}}

【代碼說明】

• UserMapper 僅繼承BaseMapper，無需寫其他代碼；
• MyBatisPlusUserService 繼承ServiceImpl，無需寫其他代碼；
• 單元測試：調用MyBatisPlusUserService.save()方法，實際上調用的是ServiceImpl.save()方法；

【sql運行日志】

==>  Preparing: INSERT INTO user_tbl ( id, name, mobile_phone, addr ) VALUES ( ?, ?, ?, ? )
==> Parameters: 123001(Long), 張三001(String), 19912340001(String), 成都天府五街001號(String)
<==    Updates: 1

【補充】MyBatisPlus-ServiceImpl代碼結構；

// 業務service
@Service
public class MyBatisPlusUserService extends ServiceImpl<UserMapper, UserPO> {
}// MyBatisPlus的ServiceImpl定義，繼承CrudRepository,并實現IService
public class ServiceImpl<M extends BaseMapper<T>, T> extends CrudRepository<M, T> implements IService<T> {public ServiceImpl() {}
}// MybatisPlus-IService定義，繼承 IRepository 
public interface IService<T> extends IRepository<T> {@Transactional(rollbackFor = {Exception.class})default boolean saveBatch(Collection<T> entityList) {return this.saveBatch(entityList, 1000);}@Transactional(rollbackFor = {Exception.class})default boolean saveOrUpdateBatch(Collection<T> entityList) {return this.saveOrUpdateBatch(entityList, 1000);}@Transactional(rollbackFor = {Exception.class})default boolean removeBatchByIds(Collection<?> list) {return this.removeByIds(list);}@Transactional(rollbackFor = {Exception.class})default boolean updateBatchById(Collection<T> entityList) {return this.updateBatchById(entityList, 1000);}
}// IRepository 定義：
public interface IRepository<T> {int DEFAULT_BATCH_SIZE = 1000;default boolean save(T entity) {return SqlHelper.retBool(this.getBaseMapper().insert(entity));}boolean saveBatch(Collection<T> entityList, int batchSize);boolean saveOrUpdateBatch(Collection<T> entityList, int batchSize);// 增刪改查api... 
}

---

【5.1.2】使用ServiceImpl接口查詢用戶信息

【測試案例】

@Test
void testQuery() {List<UserPO> userPOS = userService.listByIds(List.of(1, 2, 3, 4));System.out.println(userPOS);
}

【sql日志】

==>  Preparing: SELECT id,name,mobile_phone,addr FROM user_tbl WHERE id IN ( ? , ? , ? , ? )
==> Parameters: 1(Integer), 2(Integer), 3(Integer), 4(Integer)
<==    Columns: id, name, mobile_phone, addr
<==        Row: 1, user1, 17612342701, 成都天府三街101號
<==        Row: 2, user2, 110, 成都天府四街401號
<==        Row: 3, user3, 17612342703, 成都天府三街103號
<==        Row: 4, user4, 17612342704, 成都天府三街104號
<==      Total: 4

---

【5.2】基于restful風格實現下列接口

1）需求： 基于restful實現下面接口：

---

【5.2.1】restfulApi使用MyBatisPlus(無需編寫業務dao，自定義業務service繼承MyBatisPlus-ServiceImpl即可)

【RestfulUserController】restful風格的用戶控制器

@RestController
@RequestMapping("/restful/user")
@RequiredArgsConstructor
public class RestfulUserController {private final MyBatisPlusUserService myBatisPlusUserService;private final UserConverter userConverter;@PostMapping(path = "/saveUser", consumes = "application/json")public void saveUser(@RequestBody UserFormDTO userFormDTO) {myBatisPlusUserService.save(userConverter.toUserPO(userFormDTO));}@DeleteMapping(path = "/deleteUser/{id}", consumes = "application/json")public void deleteUser(@PathVariable("id") Long id) {myBatisPlusUserService.removeById(id);}@GetMapping(path = "/queryUserById/{id}", consumes = "application/json")public UserVO queryUserById(@PathVariable("id") Long id) {UserPO userPO = myBatisPlusUserService.getById(id);return userConverter.toUserVO(userPO);}@GetMapping(path = "/queryUserByIds", consumes = "application/json")public List<UserVO> queryUserByIds(@RequestParam("ids") List<Long> ids) {List<UserPO> userPOList = myBatisPlusUserService.listByIds(ids);return userConverter.toUserVOList(userPOList);}
}

【MyBatisPlusUserService】

自定義service繼承ServiceImpl，ServiceImpl由MyBatisPlus提供，其實現了IService的所有增刪改查接口；

@Service
public class MyBatisPlusUserService extends ServiceImpl<UserMapper, UserPO> {
}

【UserConverter】pojo轉換器(采用MapStruct工具)

@Mapper(componentModel = MappingConstants.ComponentModel.SPRING, unmappedTargetPolicy = ReportingPolicy.IGNORE)
public interface UserConverter {UserPO toUserPO(UserFormDTO userFormDTO);UserFormDTO toUserFormDTO(UserPO userPO);UserVO toUserVO(UserPO userPO);List<UserVO> toUserVOList(List<UserPO> userPOList);
}

---

【請求url】

根據id查詢：localhost:8081/restful/user/queryUserById/1

保存：localhost:8081/restful/user/saveUser

{"id": 100,"name": "user100","mobilePhone": "17712340100","addr": "成都天府三街100號"
}

刪除：localhost:8081/restful/user/deleteUser/100

根據id列表查詢：localhost:8081/restful/user/queryUserByIds?ids=110,111

---

【5.3】自定義用戶Mapper（ServiceImpl無法滿足復雜業務邏輯的情況）

【5.3.1】代碼實現

【RestfulUserController】 控制器層

@RestController
@RequestMapping("/restful/user")
@RequiredArgsConstructor
public class RestfulUserController {private final MyBatisPlusUserService myBatisPlusUserService;private final UserConverter userConverter;@PutMapping("/{id}/deductBalanceById/{money}")public void deductBalanceById(@PathVariable("id") long id, @PathVariable("money")BigDecimal money) {myBatisPlusUserService.deductBalance(id, money);}
}

【MyBatisPlusUserService】

@Service
public class MyBatisPlusUserService extends ServiceImpl<UserMapper, UserPO> {public void deductBalance(long id, BigDecimal money) {// 1 查詢用戶UserPO userPO = this.getById(id);// 2 校驗用戶狀態if (Objects.isNull(userPO) || "0".equals(userPO.getUserState())) {throw new RuntimeException("用戶狀態異常");}// 3 校驗余額是否充足if (userPO.getBalance().compareTo(money) < 0) {throw new RuntimeException("用戶余額不足");}// 4 扣減余額 update table set balance = balance - money where id = #{id}baseMapper.updateBalanceV2(id, money);//    ==>  Preparing: update user_tbl set balance = balance - ? where id = ?//            ==> Parameters: 150(BigDecimal), 1000(Long)//            <==    Updates: 1}
}

【UserMapper】自定義mapper方法

public interface UserMapper extends BaseMapper<UserPO> {void updateBalance(@Param(Constants.WRAPPER) LambdaQueryWrapper<UserPO> wrapper, @Param("balance") BigDecimal balance);@Update("update user_tbl set balance = balance - #{money} where id = #{id}")void updateBalanceV2(@Param("id") long id, @Param("money") BigDecimal money);
}

---

【5.3.2】測試效果

路徑：localhost:8081/restful/user/1000/deductBalanceById/150

方法：PUT

---

【6】IService的lambda方法

【6.1】IService-lambda方法實現多條件復雜查詢

業務場景：實現一個根據復雜條件查詢用戶的接口， 查詢條件如下：根據用戶名，用戶狀態，余額范圍查詢；上述3個查詢字段，為空則跳過，不為空才作為查詢條件；

【RestfulUserController】

@RestController
@RequestMapping("/restful/user")
@RequiredArgsConstructor
public class RestfulUserController {private final MyBatisPlusUserService myBatisPlusUserService;private final UserConverter userConverter;@PostMapping(path = "/queryUserByMultiCondition", consumes = "application/json")public List<UserVO> queryUserByMultiCondition(@RequestBody UserQueryDTO userQueryDTO) {List<UserPO> userPOList = myBatisPlusUserService.queryUserByMultiCondition(userQueryDTO);return userConverter.toUserVOList(userPOList);}
}

【MyBatisPlusUserService】

@Service
public class MyBatisPlusUserService extends ServiceImpl<UserMapper, UserPO> {public List<UserPO> queryUserByMultiCondition(UserQueryDTO userQueryDTO) {return lambdaQuery().like(userQueryDTO.getName() != null, UserPO::getName, userQueryDTO.getName()).eq(userQueryDTO.getUserState() != null, UserPO::getUserState, userQueryDTO.getUserState()).gt(userQueryDTO.getMinBalance() != null, UserPO::getBalance, userQueryDTO.getMinBalance()).lt(userQueryDTO.getMaxBalance() != null, UserPO::getBalance, userQueryDTO.getMaxBalance()).list();//        ==>  Preparing: SELECT id,name,mobile_phone,addr,balance,user_state FROM user_tbl WHERE (name LIKE ? AND user_state = ? AND balance > ? AND balance < ?)
//               ==> Parameters: %user10%(String), 1(String), 5(BigDecimal), 20000(BigDecimal)
//                <==    Columns: id, name, mobile_phone, addr, balance, user_state
//                <==        Row: 10, user10, 17712340010, 成都天府三街010號, 6.00, 1
//                <==        Row: 110, user101, 17612341010, 成都市天府大道110號, 16.00, 1
//                <==        Row: 1000, user1000, 17712341000, 成都天府三街1000號, 850.00, 1
//                <==      Total: 3}}

---

【6.1.1】測試用例

路徑：localhost:8081/restful/user/queryUserByMultiCondition

報文：

{"name": "user10","userState": "1","minBalance": "5","maxBalance": "20000"
}

---

【6.2】通過IService-Lambda方法改造根據id扣減用戶余額

1）業務場景如下：

• 對用戶狀態校驗，僅修改user_state=1的用戶的余額；
• 對用戶余額校驗，若余額小于扣減額，則不允許扣減；
• 如果扣減后余額為0，則將用戶state修改為0（不可用狀態）

【RestfulUserController】控制器

@PutMapping("/{id}/usingLambdaDeductBalanceById/{money}")
public void usingLambdaDeductBalanceById(@PathVariable("id") long id, @PathVariable("money")BigDecimal money) {myBatisPlusUserService.usingLambdaDeductBalance(id, money);
}

【MyBatisPlusUserService】

@Service
public class MyBatisPlusUserService extends ServiceImpl<UserMapper, UserPO> {    public void usingLambdaDeductBalance(long id, BigDecimal money) {// 1 查詢用戶UserPO userPO = this.getById(id);// 2 校驗用戶狀態if (Objects.isNull(userPO) || "0".equals(userPO.getUserState())) {throw new RuntimeException("用戶狀態異常");}// 3 校驗余額是否充足if (userPO.getBalance().compareTo(money) < 0) {throw new RuntimeException("用戶余額不足");}// 4 使用lambda表達式扣減余額 update table set balance = balance - money where id = #{id}BigDecimal reducedBalance = userPO.getBalance().subtract(money);lambdaUpdate().set(UserPO::getBalance, reducedBalance).set(reducedBalance.equals(BigDecimal.ZERO), UserPO::getUserState, 0).eq(UserPO::getId, id).update();
//        ==>  Preparing: UPDATE user_tbl SET balance=? WHERE (id = ?)// ==> Parameters: 0.00(BigDecimal), 10000(Long)
//                <==    Updates: 1}
}

【6.2.1】測試用例

localhost:8081/restful/user/10000/usingLambdaDeductBalanceById/10000

---

【7】IService批量新增

1）需求： 批量插入1萬筆用戶數據，并做出對比：

• 普通for循環插入；
• IService的批量插入（數據庫連接設置rewriteBatchedStatements=true ）；

spring.datasource.url=jdbc:mysql://localhost:3306/mywarn?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&useSSL=false&rewriteBatchedStatements=true

【7.1】多個循環插入用戶

private UserPO buildUserPO(int i) {UserPO userPO = new UserPO();userPO.setId(Integer.toUnsignedLong(i));userPO.setName("user0706_" + i);userPO.setMobilePhone("130" + String.format("08d", i));userPO.setAddr("成都市天府六街第" + i + "號");userPO.setBalance(new BigDecimal(i));return userPO;
}@Test
void testInsertUserOneByOne() {long start = System.currentTimeMillis();for (int i = 20000; i < 30000; i++) {userService.save(buildUserPO(i));}long end = System.currentTimeMillis();System.out.println("多個循環插入用戶，耗時（單位秒） = " + (end - start) / 1000);// 多個循環插入用戶，耗時（單位秒） = 45
}

【7.2】批量插入用戶

@Test
void testBatchInsertUser() {long start = System.currentTimeMillis();List<UserPO> userPOList = new ArrayList<>();int i = 30000;for (; i < 40000; i++) {userPOList.add(buildUserPO(i));// 每1000條作為一個批次插入if (i % 1000 == 0) {userService.saveBatch(userPOList);userPOList.clear();}}if (i % 1000 != 0) {userService.saveBatch(userPOList);}long end = System.currentTimeMillis();System.out.println("采用批量插入，耗時（單位秒） = " + (end - start) / 1000);// [數據庫連接設置rewriteBatchedStatements=true]采用批量插入，耗時（單位秒） = 3
}