当前位置: 首页 > news >正文

Mybatis学习笔记(九)

常见问题与解决方案

简要描述:总结MyBatis-Plus开发过程中常见的问题、错误及其解决方案,帮助开发者快速定位和解决问题。

核心概念

  • 常见错误:开发中经常遇到的错误类型
  • 性能问题:性能相关问题的排查和解决
  • 配置问题:配置相关的常见问题
  • 最佳实践:推荐的开发实践和规范

常见错误及解决

简要描述:MyBatis-Plus开发中常见的错误类型及其解决方法。

核心概念

  • SQL错误:SQL语法和执行错误
  • 映射错误:实体类和数据库字段映射错误
  • 配置错误:配置文件相关错误
  • 注解错误:注解使用不当导致的错误

SQL相关错误

// 1. 字段不存在错误
// 错误示例:
QueryWrapper<User> wrapper = new QueryWrapper<>();
wrapper.eq("user_name", "张三"); // 数据库字段是username,不是user_name// 解决方案:
@TableField("username") // 明确指定数据库字段名
private String userName;// 或者在QueryWrapper中使用正确的字段名
wrapper.eq("username", "张三");// 2. 表名不存在错误
// 错误示例:
@TableName("sys_user") // 数据库表名是user,不是sys_user
public class User {// ...
}// 解决方案:
@TableName("user") // 使用正确的表名
public class User {// ...
}// 3. 主键策略错误
// 错误示例:
@TableId(type = IdType.AUTO) // 数据库主键不是自增的
private Long id;// 解决方案:
@TableId(type = IdType.ASSIGN_ID) // 使用雪花算法生成ID
private Long id;// 4. 逻辑删除字段错误
// 错误示例:
@TableLogic
private Integer deleted; // 数据库字段类型是TINYINT,但使用了Integer// 解决方案:
@TableLogic(value = "0", delval = "1")
private Boolean deleted; // 使用Boolean类型

分页查询错误

// 1. 分页插件未配置
// 错误现象:分页查询返回全部数据
// 解决方案:正确配置分页插件
@Configuration
public class MybatisPlusConfig {@Beanpublic MybatisPlusInterceptor mybatisPlusInterceptor() {MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));return interceptor;}
}// 2. 分页参数错误
// 错误示例:
Page<User> page = new Page<>(0, 10); // 页码从0开始// 解决方案:
Page<User> page = new Page<>(1, 10); // 页码从1开始// 3. 分页查询count错误
// 错误示例:
Page<User> page = new Page<>(1, 10);
page.setSearchCount(false); // 禁用count查询但又需要总数// 解决方案:
Page<User> page = new Page<>(1, 10);
page.setSearchCount(true); // 启用count查询

事务相关错误

// 1. 事务不生效
// 错误示例:
@Service
public class UserService {@Transactionalprivate void updateUser(User user) { // private方法,事务不生效// ...}
}// 解决方案:
@Service
public class UserService {@Transactionalpublic void updateUser(User user) { // public方法// ...}
}// 2. 异常被捕获导致事务不回滚
// 错误示例:
@Transactional
public void updateUser(User user) {try {userMapper.updateById(user);int i = 1 / 0; // 抛出异常} catch (Exception e) {log.error("更新用户失败", e); // 异常被捕获,事务不回滚}
}// 解决方案:
@Transactional(rollbackFor = Exception.class)
public void updateUser(User user) {try {userMapper.updateById(user);int i = 1 / 0;} catch (Exception e) {log.error("更新用户失败", e);throw e; // 重新抛出异常,触发事务回滚}
}

性能问题排查

简要描述:识别和解决MyBatis-Plus应用中的性能问题。

核心概念

  • 慢查询识别:识别执行缓慢的SQL
  • 内存泄漏:排查内存泄漏问题
  • 连接池问题:数据库连接池相关问题
  • 缓存问题:缓存使用不当导致的性能问题

慢查询排查

// 1. 开启SQL日志
// application.yml
logging:level:com.example.mapper: debugorg.springframework.jdbc: debug// 2. 使用性能分析插件
@Configuration
public class PerformanceConfig {@Bean@Profile("dev")public PerformanceInterceptor performanceInterceptor() {PerformanceInterceptor interceptor = new PerformanceInterceptor();interceptor.setMaxTime(1000); // 超过1秒的SQL会被记录interceptor.setFormat(true);return interceptor;}
}// 3. 自定义慢查询监控
@Component
public class SlowQueryMonitor {private static final Logger logger = LoggerFactory.getLogger(SlowQueryMonitor.class);@EventListenerpublic void handleSlowQuery(SlowQueryEvent event) {if (event.getExecutionTime() > 1000) {logger.warn("慢查询检测: SQL={}, 执行时间={}ms, 参数={}", event.getSql(), event.getExecutionTime(), event.getParameters());// 可以发送告警通知sendSlowQueryAlert(event);}}private void sendSlowQueryAlert(SlowQueryEvent event) {// 发送告警逻辑}
}

内存泄漏排查

// 1. SqlSession未关闭导致内存泄漏
// 错误示例:
public List<User> findUsers() {SqlSession sqlSession = sqlSessionFactory.openSession();List<User> users = sqlSession.selectList("findUsers");// 未关闭SqlSession,导致内存泄漏return users;
}// 解决方案:
public List<User> findUsers() {try (SqlSession sqlSession = sqlSessionFactory.openSession()) {return sqlSession.selectList("findUsers");} // 自动关闭SqlSession
}// 2. 大结果集查询导致内存溢出
// 错误示例:
public List<User> findAllUsers() {return userMapper.selectList(null); // 查询所有数据,可能导致内存溢出
}// 解决方案:使用分页查询
public List<User> findAllUsers() {List<User> allUsers = new ArrayList<>();int pageSize = 1000;int current = 1;while (true) {Page<User> page = new Page<>(current, pageSize);IPage<User> result = userMapper.selectPage(page, null);allUsers.addAll(result.getRecords());if (result.getRecords().size() < pageSize) {break;}current++;}return allUsers;
}

版本升级注意事项

简要描述:MyBatis-Plus版本升级过程中需要注意的重要事项和兼容性问题。

核心概念

  • 版本兼容性:不同版本间的兼容性问题
  • API变更:API接口的变更和废弃
  • 配置变更:配置方式的变化
  • 依赖升级:相关依赖的升级要求

3.x升级到4.x注意事项

# 1. 依赖变更
# 旧版本(3.x)
<dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.3</version>
</dependency># 新版本(4.x)
<dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>4.0.0</version>
</dependency># 2. 配置变更
# 旧配置方式
mybatis-plus:global-config:db-config:id-type: autologic-delete-value: 1logic-not-delete-value: 0# 新配置方式
mybatis-plus:global-config:db-config:id-type: autologic-delete-field: deletedlogic-delete-value: 1logic-not-delete-value: 0

API变更处理

// 1. 分页插件配置变更
// 旧版本配置
@Configuration
public class MybatisPlusConfig {@Beanpublic PaginationInterceptor paginationInterceptor() {PaginationInterceptor paginationInterceptor = new PaginationInterceptor();paginationInterceptor.setCountSqlParser(new JsqlParserCountOptimize(true));return paginationInterceptor;}
}// 新版本配置
@Configuration
public class MybatisPlusConfig {@Beanpublic MybatisPlusInterceptor mybatisPlusInterceptor() {MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));return interceptor;}
}// 2. 性能分析插件变更
// 旧版本
@Bean
public PerformanceInterceptor performanceInterceptor() {return new PerformanceInterceptor();
}// 新版本(已废弃,建议使用第三方工具)
// 使用p6spy或其他性能监控工具

升级检查清单

// 升级前检查清单
public class UpgradeChecklist {/*** 1. 检查依赖兼容性* - Spring Boot版本兼容性* - JDK版本要求* - 其他依赖库版本*//*** 2. 检查配置文件* - application.yml配置项变更* - 插件配置方式变更* - 全局配置项变更*//*** 3. 检查代码兼容性* - 废弃API的替换* - 新增注解的使用* - 方法签名变更*//*** 4. 测试验证* - 单元测试通过* - 集成测试通过* - 性能测试对比*/
}

最佳实践总结

简要描述:MyBatis-Plus开发的最佳实践和推荐规范总结。

核心概念

  • 代码规范:代码编写规范
  • 性能优化:性能优化建议
  • 安全实践:安全相关的最佳实践
  • 维护性:提高代码可维护性的建议

开发规范总结

// 1. 实体类设计规范
@Data
@EqualsAndHashCode(callSuper = false)
@TableName("sys_user")
public class User implements Serializable {private static final long serialVersionUID = 1L;@TableId(value = "id", type = IdType.ASSIGN_ID)private Long id;@TableField("username")@NotBlank(message = "用户名不能为空")private String username;@TableField(value = "create_time", fill = FieldFill.INSERT)private LocalDateTime createTime;@TableLogic(value = "0", delval = "1")private Boolean deleted;@Versionprivate Integer version;
}// 2. Mapper接口规范
@Mapper
public interface UserMapper extends BaseMapper<User> {/*** 自定义查询方法要有明确的注释*/List<User> selectByCustomCondition(@Param("condition") UserQueryCondition condition);
}// 3. Service层规范
@Service
@Transactional(rollbackFor = Exception.class)
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {@Overridepublic IPage<User> findUserPage(UserPageRequest request) {// 参数校验validatePageRequest(request);// 构建查询条件LambdaQueryWrapper<User> wrapper = buildQueryWrapper(request);// 执行分页查询Page<User> page = new Page<>(request.getCurrent(), request.getSize());return baseMapper.selectPage(page, wrapper);}private void validatePageRequest(UserPageRequest request) {if (request.getCurrent() < 1) {throw new IllegalArgumentException("页码不能小于1");}if (request.getSize() > 100) {throw new IllegalArgumentException("每页大小不能超过100");}}
}

性能优化总结

// 1. 查询优化
public class QueryOptimization {// 使用字段选择,避免查询不必要的字段public List<UserSimpleVO> findUserSimpleList() {LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();wrapper.select(User::getId, User::getUsername, User::getEmail);return baseMapper.selectList(wrapper);}// 使用批量操作public boolean batchUpdateStatus(List<Long> userIds, Integer status) {if (CollectionUtils.isEmpty(userIds)) {return true;}List<User> users = userIds.stream().map(id -> {User user = new User();user.setId(id);user.setStatus(status);return user;}).collect(Collectors.toList());return updateBatchById(users);}// 使用缓存@Cacheable(value = "users", key = "#id")public User findById(Long id) {return baseMapper.selectById(id);}
}// 2. 连接池优化
spring:datasource:hikari:maximum-pool-size: 20minimum-idle: 5connection-timeout: 30000idle-timeout: 600000max-lifetime: 1800000

安全实践总结

// 1. 防止SQL注入
public class SecurityPractice {// 正确:使用参数化查询public List<User> findUsersByName(String username) {LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();wrapper.eq(User::getUsername, username);return baseMapper.selectList(wrapper);}// 错误:直接拼接SQLpublic List<User> findUsersByNameBad(String username) {QueryWrapper<User> wrapper = new QueryWrapper<>();wrapper.apply("username = '" + username + "'"); // 危险!return baseMapper.selectList(wrapper);}// 2. 敏感信息处理public UserVO getUserInfo(Long userId) {User user = baseMapper.selectById(userId);if (user == null) {return null;}UserVO userVO = new UserVO();BeanUtils.copyProperties(user, userVO);userVO.setPassword(null); // 不返回密码return userVO;}
}
http://www.lryc.cn/news/621146.html

相关文章:

  • C#WPF实战出真汁01--搭建项目三层架构
  • 计算机视觉第一课opencv(二)保姆级教
  • 【CLR via C#(第3版)阅读笔记】类型基础
  • (论文速读)DiffusionDet - 扩散模型在目标检测中的开创性应用
  • 【C#】跨平台创建你的WinForms窗体应用(WindowsUbuntu)
  • 从零开始的云计算生活——第四十三天,激流勇进,kubernetes模块之Pod资源对象
  • Ansible企业级实战
  • 设计模式(2)
  • sql的关键字 limit 和offset
  • 第16届蓝桥杯C++中高级选拔赛(STEMA)2024年10月20日真题
  • Ansys FreeFlow入门:对搅拌罐进行建模
  • pull request是啥意思
  • Serverless 架构核心解析与应用实践
  • 第三十一天(系统io)
  • 如何让手机访问本地服务器部署的网页?无公网IP内网主机应用,自定义外网地址,给任意网设备访问
  • 从0-1学习Java(三)快速了解字符串、数组、“==“与equals比较
  • 【框架】跨平台开发框架自用整理
  • 每日任务day0814:小小勇者成长记之钓鱼日记(字典推导式)
  • Steam移动游戏存储位置
  • 如何使用 AI 大语言模型解决生活中的实际小事情?
  • 《算法导论》第 25 章:所有结点对的最短路径问题
  • 深入解析 GitHub Actions 工作流文件编写:从入门到实战
  • flutter 开发 鸿蒙 App
  • 解决因取消VMware快照删除导致的虚拟机磁盘损坏问题
  • shellgpt
  • AI大模型+Meta分析:助力发表高水平SCI论文
  • 部署文件到受管主机
  • 远程影音访问:通过 cpolar 内网穿透服务使用 LibreTV
  • 高效TypeScript开发:VSCode终极配置指南
  • 莫队 + 离散化 Ann and Books