redis 中缓存 百万级别表的查询数据 堕落：Query execution was interrupte ...

项目配景：项目需要 首检及格率 这个效果，但是sql实验非常慢，就想着利用redis来优化接口的速度。如今我需要将数据库查询效果存储到redis，但是就是这一小步，也非常困难。我是用定时使命来实现上面的目的。

1. @Component
2. @Slf4j
3. public class FirstInspectionPassRateTask {
4.     @Autowired
5.     private CheckResultMapper checkResultMapper;
7.     @Autowired
8.     private InspectionStationInfoMapper inspectionStationInfoMapper;
10.     @Autowired
11.     private RedisTemplate redisTemplate;
13.     @Scheduled(cron = "0 32 13 * * ?")
14.     public void calculateFirstInspectionPassRate(){
15.         log.info("####### 定时任务开启......");
16.         ValueOperations<String ,String> operations = redisTemplate.opsForValue();
18.         NumberFormat numberFormat = NumberFormat.getPercentInstance();
19.         numberFormat.setMinimumFractionDigits(2);
21.         List<String> unitIdList = inspectionStationInfoMapper.selectUnitId();//单位id 集合
22.         unitIdList = Optional.ofNullable(unitIdList).orElse(new ArrayList<>());
23.         //这里只给2024表中的统计数据，因为首检合格率需要跨表，目前我也想不出如何编写 TODO
24.         List<String> monthList = new ArrayList<>(Arrays.asList("03"));
26.         unitIdList.forEach(unitId -> {
27.             monthList.forEach(month -> {
28.                 List<String> bgList = new ArrayList<>();
29.                 //查询指定机构的 首检报告列表
30.                 bgList = checkResultMapper.getFirstInspectionReportCount(unitId, "2024", month);
31.                 bgList = Optional.ofNullable(bgList).orElse(new ArrayList<>());
32.                 //计算指定机构的 首检报告数量
33.                 Long bgSum = (long) bgList.size();
35.                 //首检合格率
36.                 String rate = "0.00%";
37.                 if(bgSum != 0){
38.                     //计算异常的首检报告数量
39.                     Long warnBgSum = checkResultMapper.getWarnFirstInspectionReportCount(unitId,"2024",month,bgList);
40.                     rate = numberFormat.format((bgSum-warnBgSum)/bgSum.doubleValue());
41.                 }
42.                 rate = rate.substring(0,rate.length() -1 );//去除最后的 % 方便前端处理
44.                 String key = String.format("SZJDC:CHECKRESULT:BGBH:%s",unitId+"-2024-"+month);
45.                 operations.set(key,rate,20, TimeUnit.DAYS);
46.             });
47.         });
48.     }
50. }

复制代码

 就在实验这个定时使命，我出现了非常多的报错：Query execution was interrupted

1. Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@6eaf527b]
2. 10:45:18.655 [pool-2-thread-1] ERROR o.s.s.s.TaskUtils$LoggingErrorHandler - Unexpected error occurred in scheduled task
3. org.springframework.dao.QueryTimeoutException:
4. ### Error querying database. Cause: java.sql.SQLTimeoutException: Query execution was interrupted
5. ### The error may exist in file [D:\workspace\IdeaProjects\szjdc-service\sz-warning-platform\target\classes\mappers\CheckResultMapper.xml]
6. ### The error may involve com.iflytek.warning.mapper.CheckResultMapper.getFirstInspectionReportCount
7. ### The error occurred while handling results
8. ### SQL: select BGBH from check_result_2024 cr WHERE year(CHECK_DATE) = ? and month(CHECK_DATE) = ? and UNIT_ID = ? and NOT EXISTS ( select CHECK_ID from check_result_2024 pcr WHERE pcr.CHECK_DATE between DATE_SUB(cr.CHECK_DATE, INTERVAL 4 MONTH) and DATE_SUB(cr.CHECK_DATE , INTERVAL 1 DAY) and cr.VIN = pcr.VIN and UNIT_ID = ? )
9. ### Cause: java.sql.SQLTimeoutException: Query execution was interrupted

复制代码

这里给出我的解决办法：

 这上面处理完了之后照旧出现了该报错，然后我请教前辈

 就解决了，不愧是前辈

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。