MyBatis-Plus的基本CRUD

一、BaseMapperMyBatis-Plus中的基本CRUD在内置的BaseMapper中都已得到了实现我们可以直接使用接口如下public interface BaseMapperT extends MapperT { int insert(T entity); int deleteById(Serializable id); int deleteById(T entity); int deleteByMap(Param(cm) MapString, Object columnMap); int delete(Param(ew) WrapperT queryWrapper); int deleteBatchIds(Param(coll) Collection? idList); int updateById(Param(et) T entity); int update(Param(et) T entity, Param(ew) WrapperT updateWrapper); T selectById(Serializable id); ListT selectBatchIds(Param(coll) Collection? extends Serializable idList); ListT selectByMap(Param(cm) MapString, Object columnMap); default T selectOne(Param(ew) WrapperT queryWrapper) { ListT 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, new Object[0]); } else { return ts.get(0); } } else { return null; } } default boolean exists(WrapperT queryWrapper) { Long count this.selectCount(queryWrapper); return null ! count count 0L; } Long selectCount(Param(ew) WrapperT queryWrapper); ListT selectList(Param(ew) WrapperT queryWrapper); ListMapString, Object selectMaps(Param(ew) WrapperT queryWrapper); ListObject selectObjs(Param(ew) WrapperT queryWrapper); P extends IPageT P selectPage(P page, Param(ew) WrapperT queryWrapper); P extends IPageMapString, Object P selectMapsPage(P page, Param(ew) WrapperT queryWrapper); }1. 插入注意MyBatis-Plus在实现插入数据时会默认基于雪花算法的策略生成id/** * 用户插入功能的方法。 * 该方法创建一个User对象并将其插入数据库验证插入操作是否成功 * 并输出受影响的行数以及自动生成的用户ID。 */ Test public void testInsert(){ // 创建一个新的User对象ID为null表示由数据库自动生成 User user new User(null, 张三, 23, zhangsanqcby.com,null,null); // 执行插入操作将用户数据保存到数据库中 //INSERT INTO user ( id, name, age, email ) VALUES ( ?, ?, ?, ? ) int result userMapper.insert(user); // 输出插入操作影响的行数正常情况下应为1 System.out.println(受影响行数result); // 输出数据库自动生成的用户ID,MyBatis-Plus在实现插入数据时会默认基于雪花算法的策略生成id //2020478658078167042 System.out.println(id自动获取user.getId()); }2. 删除/** * 通过ID删除用户信息的功能。 * 该方法调用userMapper的deleteById方法传入指定的用户ID进行删除操作 * 并输出受影响的行数以验证删除结果。 */ Test public void testDeleteById(){ //通过id删除用户信息 //DELETE FROM user WHERE id? int result userMapper.deleteById(2020488576042545170L); System.out.println(受影响行数result); } Test public void testDeleteBatchIds(){ //通过多个id批量删除 //DELETE FROM user WHERE id IN ( ? , ? ) ListLong idList Arrays.asList(1L, 3L); int result userMapper.deleteBatchIds(idList); System.out.println(受影响行数result); } /** * 通过Map条件删除用户记录的功能。 * 该方法构造一个包含删除条件的Map对象并调用userMapper的deleteByMap方法执行删除操作 * 最后输出受影响的行数。 * param map 包含删除条件的键值对集合其中key为字段名value为对应的条件值。。 * return 受影响的行数表示成功删除的记录数量。 */ Test public void testDeleteByMap(){ //根据map集合中所设置的条件删除记录 // 构造删除条件的Map集合 //DELETE FROM user WHERE name ? AND age ? MapString, Object map new HashMap(); map.put(age, 23); map.put(name, 张三); int result userMapper.deleteByMap(map); System.out.println(受影响行数result); }3. 修改/** * 通过ID更新用户信息的功能。 * 该方法创建一个User对象并调用userMapper的updateById方法来更新数据库中的对应记录。 * 最后输出受影响的行数。 */ Test public void testUpdateById(){ //创建User对象并设置要修改的属性,null不传参 User user new User(4L, test, null, null, null, null); //UPDATE user SET name?, age? WHERE id? int result userMapper.updateById(user); System.out.println(受影响行数result); }4. 查询/** * 通过ID查询用户信息的功能。 * 该方法调用userMapper的selectById方法传入指定的用户ID进行查询 * 并将查询结果打印到控制台。 */ Test public void testSelectById(){ //根据id查询用户信息 //SELECT id,name,age,email FROM user WHERE id? User user userMapper.selectById(4L); System.out.println(user); } /** * 通过多个ID批量查询用户信息的功能。 * 该方法调用userMapper的selectBatchIds方法传入指定的用户ID列表进行批量查询 * 并将查询结果打印到控制台。 */ Test public void testSelectBatchIds(){ //根据id批量查询 //SELECT id,name,age,email FROM user WHERE id IN ( ? , ? ) ListUser list userMapper.selectBatchIds(Arrays.asList(4, 2)); list.forEach(System.out::println); } /** * 通过Map条件查询用户信息列表的功能。 * 该方法构造一个包含查询条件的Map对象并调用userMapper的selectByMap方法执行查询操作 * 最后将查询结果打印到控制台。 */ Test public void testSelectByMap(){ //根据map查询用户信息此时null传参 //SELECT id,name,age,email FROM user WHERE name ? AND age ? MapString, Object map new HashMap(); map.put(name, Jack); map.put(age, 20); ListUser list userMapper.selectByMap(map); list.forEach(System.out::println); } /** * 通过条件查询用户信息列表的功能。 * 该方法创建一个User对象并调用userMapper的selectOne方法来查询数据库中的对应记录。 * 最后将查询结果打印到控制台。 */ Test public void testSelectOne(){ //查询用户信息根据条件查询最多只能查询一条 //SELECT id,name,age,email FROM user WHERE name ? AND age ? User user new User(); user.setName(Jack); user.setAge(20); User one userMapper.selectOne(new QueryWrapper(user)); System.out.println(one); } /** * 查询所有数据selectList()功能。 * 该方法通过调用userMapper的selectList()方法查询数据 * 并将查询结果打印到控制台。 * selectList()方法根据MyBatis-Plus内置的条件构造器查询一个list集合。 * 传入null表示没有查询条件即查询所有数据。 */ Test public void testSelectList(){ //selectList()根据MP内置的条件构造器查询一个list集合null表示没有条件即查询所有 userMapper.selectList( null).forEach(System.out::println); }5. 其他重要接口// selectPage分页查询 复杂条件 Test public void testSelectPage() { // 分页参数第2页每页3条 PageUser page new Page(2, 3); QueryWrapperUser queryWrapper new QueryWrapper(); queryWrapper.gt(age, 18) // 年龄18 .like(email, test.com) // 邮箱包含test.com .orderByDesc(age); // 按年龄降序 IPageUser userIPage userMapper.selectPage(page, queryWrapper); System.out.println(selectPage-总条数 userIPage.getTotal()); System.out.println(selectPage-当前页数据); userIPage.getRecords().forEach(System.out::println); } // selectMapsPage分页查询返回Map集合仅查指定字段 Test public void testSelectMapsPage() { PageMapString, Object page new Page(1, 5); QueryWrapperUser queryWrapper new QueryWrapper(); queryWrapper.select(uid, name, age) // 只查3个字段 .between(age, 18, 30); // 年龄在18-30之间 IPageMapString, Object mapIPage userMapper.selectMapsPage(page, queryWrapper); System.out.println(selectMapsPage-总页数 mapIPage.getPages()); System.out.println(selectMapsPage-当前页Map数据); mapIPage.getRecords().forEach(System.out::println); } // selectObjs仅查询指定字段返回Object集合适合单字段查询 Test public void testSelectObjs() { QueryWrapperUser queryWrapper new QueryWrapper(); queryWrapper.select(name) // 只查name字段 .eq(age, 20); ListObject nameList userMapper.selectObjs(queryWrapper); System.out.println(selectObjs-仅查询name字段结果); nameList.forEach(System.out::println); } // updateUpdateWrapper条件更新非ID更新 Test public void testUpdateWithWrapper() { User user new User(); user.setEmail(update_wrappertest.com); // 要更新的字段 UpdateWrapperUser updateWrapper new UpdateWrapper(); updateWrapper.eq(name, 张三) .gt(age, 18); // 条件name张三 且 age18 int rows userMapper.update(user, updateWrapper); System.out.println(testUpdateWithWrapper-影响行数 rows); } // update链式UpdateWrapper直接设置更新字段无需new User Test public void testUpdateForSet() { UpdateWrapperUser updateWrapper new UpdateWrapper(); updateWrapper.eq(uid, 1L) .set(age, 28) // 直接设置要更新的字段和值 .set(email, update_settest.com); int rows userMapper.update(null, updateWrapper); System.out.println(testUpdateForSet-影响行数 rows); } // deleteQueryWrapper条件删除支持复杂条件 Test public void testDeleteWithWrapper() { QueryWrapperUser queryWrapper new QueryWrapper(); queryWrapper.like(name, 测试删除) .lt(age, 18); // 条件name含测试删除 且 age18 int rows userMapper.delete(queryWrapper); System.out.println(testDeleteWithWrapper-影响行数 rows); }二、IServceMyBatis-Plus中有一个接口IService和其实现类ServiceImpl封装了常见的业务层逻辑。采用get查询单行、remove删除、list查询集合、page分页前缀命名方式区分mapper层避免混淆。接口如下public interface IServiceT { int DEFAULT_BATCH_SIZE 1000; default boolean save(T entity) { return SqlHelper.retBool(this.getBaseMapper().insert(entity)); } Transactional( rollbackFor {Exception.class} ) default boolean saveBatch(CollectionT entityList) { return this.saveBatch(entityList, 1000); } boolean saveBatch(CollectionT entityList, int batchSize); Transactional( rollbackFor {Exception.class} ) default boolean saveOrUpdateBatch(CollectionT entityList) { return this.saveOrUpdateBatch(entityList, 1000); } boolean saveOrUpdateBatch(CollectionT entityList, int batchSize); default boolean removeById(Serializable id) { return SqlHelper.retBool(this.getBaseMapper().deleteById(id)); } default boolean removeById(Serializable id, boolean useFill) { throw new UnsupportedOperationException(不支持的方法!); } default boolean removeById(T entity) { return SqlHelper.retBool(this.getBaseMapper().deleteById(entity)); } default boolean removeByMap(MapString, Object columnMap) { Assert.notEmpty(columnMap, error: columnMap must not be empty, new Object[0]); return SqlHelper.retBool(this.getBaseMapper().deleteByMap(columnMap)); } default boolean remove(WrapperT queryWrapper) { return SqlHelper.retBool(this.getBaseMapper().delete(queryWrapper)); } default boolean removeByIds(Collection? list) { return CollectionUtils.isEmpty(list) ? false : SqlHelper.retBool(this.getBaseMapper().deleteBatchIds(list)); } Transactional( rollbackFor {Exception.class} ) default boolean removeByIds(Collection? list, boolean useFill) { if (CollectionUtils.isEmpty(list)) { return false; } else { return useFill ? this.removeBatchByIds(list, true) : SqlHelper.retBool(this.getBaseMapper().deleteBatchIds(list)); } } Transactional( rollbackFor {Exception.class} ) default boolean removeBatchByIds(Collection? list) { return this.removeBatchByIds(list, 1000); } Transactional( rollbackFor {Exception.class} ) default boolean removeBatchByIds(Collection? list, boolean useFill) { return this.removeBatchByIds(list, 1000, useFill); } default boolean removeBatchByIds(Collection? list, int batchSize) { throw new UnsupportedOperationException(不支持的方法!); } default boolean removeBatchByIds(Collection? list, int batchSize, boolean useFill) { throw new UnsupportedOperationException(不支持的方法!); } default boolean updateById(T entity) { return SqlHelper.retBool(this.getBaseMapper().updateById(entity)); } default boolean update(WrapperT updateWrapper) { return this.update((Object)null, updateWrapper); } default boolean update(T entity, WrapperT updateWrapper) { return SqlHelper.retBool(this.getBaseMapper().update(entity, updateWrapper)); } Transactional( rollbackFor {Exception.class} ) default boolean updateBatchById(CollectionT entityList) { return this.updateBatchById(entityList, 1000); } boolean updateBatchById(CollectionT entityList, int batchSize); boolean saveOrUpdate(T entity); default T getById(Serializable id) { return this.getBaseMapper().selectById(id); } default ListT listByIds(Collection? extends Serializable idList) { return this.getBaseMapper().selectBatchIds(idList); } default ListT listByMap(MapString, Object columnMap) { return this.getBaseMapper().selectByMap(columnMap); } default T getOne(WrapperT queryWrapper) { return this.getOne(queryWrapper, true); } T getOne(WrapperT queryWrapper, boolean throwEx); MapString, Object getMap(WrapperT queryWrapper); V V getObj(WrapperT queryWrapper, Function? super Object, V mapper); default long count() { return this.count(Wrappers.emptyWrapper()); } default long count(WrapperT queryWrapper) { return SqlHelper.retCount(this.getBaseMapper().selectCount(queryWrapper)); } default ListT list(WrapperT queryWrapper) { return this.getBaseMapper().selectList(queryWrapper); } default ListT list() { return this.list(Wrappers.emptyWrapper()); } default E extends IPageT E page(E page, WrapperT queryWrapper) { return this.getBaseMapper().selectPage(page, queryWrapper); } default E extends IPageT E page(E page) { return this.page(page, Wrappers.emptyWrapper()); } default ListMapString, Object listMaps(WrapperT queryWrapper) { return this.getBaseMapper().selectMaps(queryWrapper); } default ListMapString, Object listMaps() { return this.listMaps(Wrappers.emptyWrapper()); } default ListObject listObjs() { return this.listObjs(Function.identity()); } default V ListV listObjs(Function? super Object, V mapper) { return this.listObjs(Wrappers.emptyWrapper(), mapper); } default ListObject listObjs(WrapperT queryWrapper) { return this.listObjs(queryWrapper, Function.identity()); } default V ListV listObjs(WrapperT queryWrapper, Function? super Object, V mapper) { return (List)this.getBaseMapper().selectObjs(queryWrapper).stream().filter(Objects::nonNull).map(mapper).collect(Collectors.toList()); } default E extends IPageMapString, Object E pageMaps(E page, WrapperT queryWrapper) { return this.getBaseMapper().selectMapsPage(page, queryWrapper); } default E extends IPageMapString, Object E pageMaps(E page) { return this.pageMaps(page, Wrappers.emptyWrapper()); } BaseMapperT getBaseMapper(); ClassT getEntityClass(); default QueryChainWrapperT query() { return ChainWrappers.queryChain(this.getBaseMapper()); } default LambdaQueryChainWrapperT lambdaQuery() { return ChainWrappers.lambdaQueryChain(this.getBaseMapper()); } default KtQueryChainWrapperT ktQuery() { return ChainWrappers.ktQueryChain(this.getBaseMapper(), this.getEntityClass()); } default KtUpdateChainWrapperT ktUpdate() { return ChainWrappers.ktUpdateChain(this.getBaseMapper(), this.getEntityClass()); } default UpdateChainWrapperT update() { return ChainWrappers.updateChain(this.getBaseMapper()); } default LambdaUpdateChainWrapperT lambdaUpdate() { return ChainWrappers.lambdaUpdateChain(this.getBaseMapper()); } default boolean saveOrUpdate(T entity, WrapperT updateWrapper) { return this.update(entity, updateWrapper) || this.saveOrUpdate(entity); } }1. 创建Service接口和实现类/** * UserService继承IService模板提供的基础功能 */ public interface UserService extends IServiceUser {}/** * ServiceImpl实现了IService提供了IService中基础功能的实现 * 若ServiceImpl无法满足业务需求则可以使用自定的UserService定义方法并在实现类中实现 */ Service public class UserServiceImpl extends ServiceImplUserMapper, User implements UserService {}2. 测试查询记录数Autowired private UserService userService; Test public void testGetCount(){ long count userService.count(); System.out.println(总记录数 count); }3. 测试批量插入/** * 批量插入 */ Test public void testSaveBatch(){ // SQL长度有限制海量数据插入单条SQL无法实行 // 因此MP将批量插入放在了通用Service中实现而不是通用Mapper ArrayListUser users new ArrayList(); // 未传参的字段默认为null但是id雪花自增 for (int i 0; i 5; i) { User user new User(); // 字符串拼接 user.setName(kk i); // 加法运算 user.setAge(20 i); users.add(user); } //SQL:INSERT INTO user ( username, age ) VALUES ( ?, ? ) userService.saveBatch(users); }4. 其他常用接口// 测试saveOrUpdate新增或更新有ID则更新无则新增 Test public void testSaveOrUpdate() { // 场景1无ID → 新增 User user1 new User(); user1.setName(新增或更新1); user1.setAge(23); user1.setEmail(saveOrUpdate1test.com); userService.saveOrUpdate(user1); // 场景2有ID → 更新 User user2 new User(); user2.setId(1L); user2.setName(新增或更新2); user2.setAge(24); userService.saveOrUpdate(user2); } // 测试saveOrUpdateBatch批量新增或更新 Test public void testSaveOrUpdateBatch() { User user1 new User(); user1.setId(1L); // 有ID → 更新 user1.setName(批量更新); user1.setAge(25); User user2 new User(); // 无ID → 新增 user2.setName(批量新增); user2.setAge(26); ListUser userList Arrays.asList(user1, user2); boolean result userService.saveOrUpdateBatch(userList); System.out.println(批量新增/更新是否成功 result); } // 测试updateBatchById批量更新按ID Test public void testUpdateBatchById() { User user1 new User(); user1.setId(1L); user1.setAge(30); User user2 new User(); user2.setId(2L); user2.setAge(31); ListUser userList Arrays.asList(user1, user2); boolean result userService.updateBatchById(userList); System.out.println(批量更新是否成功 result); } // 测试removeById根据ID删除 Test public void testRemoveById() { boolean result userService.removeById(1L); System.out.println(删除是否成功 result); } // 测试removeByIds批量删除 Test public void testRemoveByIds() { ListLong idList Arrays.asList(7L, 8L); boolean result userService.removeByIds(idList); System.out.println(批量删除是否成功 result); } // 测试remove按条件删除 Test public void testRemove() { LambdaQueryWrapperUser queryWrapper new LambdaQueryWrapper(); queryWrapper.eq(User::getName, 测试删除).eq(User::getAge, 0); boolean result userService.remove(queryWrapper); System.out.println(条件删除是否成功 result); } // 测试getById根据ID查询 Test public void testGetById() { User user userService.getById(1L); System.out.println(user); } // 测试listByIds批量查询 Test public void testListByIds() { ListLong idList Arrays.asList(1L, 2L); ListUser userList userService.listByIds(idList); userList.forEach(System.out::println); } // 测试listPage分页查询 Test public void testListPage() { PageUser page new Page(1, 5); LambdaQueryWrapperUser queryWrapper new LambdaQueryWrapper(); queryWrapper.gt(User::getAge, 18); IPageUser userIPage userService.page(page, queryWrapper); System.out.println(总条数 userIPage.getTotal()); userIPage.getRecords().forEach(System.out::println); } // 测试count统计总数 Test public void testCount() { LambdaQueryWrapperUser queryWrapper new LambdaQueryWrapper(); queryWrapper.gt(User::getAge, 20); long count userService.count(queryWrapper); System.out.println(年龄大于20的用户数 count); } // 测试链式查询LambdaQueryChainWrapper Test public void testLambdaQueryChain() { ListUser userList new LambdaQueryChainWrapper(userService.getBaseMapper()) .eq(User::getAge, 20) .like(User::getName, 张三) .list(); userList.forEach(System.out::println); } // 测试事务性批量操作Transactional Test Transactional // 测试完成后回滚避免污染数据 public void testTransactionalBatch() { // 批量新增 ListUser saveList Arrays.asList( new User(null, 事务测试1, 28, tx1test.com, SexEnum.MALE, null), new User(null, 事务测试2, 29, tx2test.com, SexEnum.FEMALE,null) ); userService.saveBatch(saveList); // 批量更新 ListUser updateList Arrays.asList( new User(2026L, 事务更新1, 30, null, SexEnum.MALE, null), new User(2027L, 事务更新2, 31, null, SexEnum.FEMALE, null) ); userService.updateBatchById(updateList); // 验证事务内可查事务外回滚 System.out.println(事务内查询 userService.getById(2026L)); }