前言

很难想想会在600条数据和4万条数据的两张表联表查询的的情况下，查询花了10多s。这里记录一下排查过程吧，最后的错误原因也抽象的。

前置知识

联表查询

Inner Join

显示两个表的交集，如果不在两张表中就不进行显示

left join

以表1为驱动表，表2为被驱动表的数据，查出来的结果显示左边的所有数据，然后右边显示的是和左边有交集部分的数据。

right join

以表2为驱动表，表1为被驱动表的数据，查出来的结果显示右边的所有数据，然后左边显示的是和右边有交集部分的数据。

环境

JDK8、Maven3.X、SSM项目、Oracle

背景描述

每两个小时拉取最新的结果数据，在这种情况下，生成一个统计报表。其中当前4万多条的被驱动表称为A，600+数据的驱动表称为B。

问题展示

最初代码

SELECT
t1.CAR_IMG,
t1.VEH_LIC_PLT_NO,
t1.ALARM_TM,
t1.WARN_TP,
t2.DIST_NM,
t2.ENT_NM,
t1.ENT_MGMT_MBR,
t1.CON_PHONE,
t2.IND_NM
FROM
T_VEHICLE_POLLUT_QA_INFO t1,
T_VEHICLE_POLLUT_ENT_BASE_INFO t2
WHERE
t2.ENT_CODE = t2.ENT_CODE
AND t1.ALARM_TM BETWEEN TO_DATE ('2023-03-02 11:55:15', 'yyyy-mm-dd hh24:mi:ss')
AND TO_DATE ('2023-03-07 11:55:15', 'yyyy-mm-dd hh24:mi:ss');

没错跑了20S都没跑出来，直接依托答辩。

问题解决过程

优化一

left join 把数据量小的表作为驱动表，数据量大的作为被驱动表，同时提前将表按条件过滤，代码如下：

    <select id="selectByMap" resultMap="AlarmInfoMap">
        select t1.CAR_IMG,
        t1.VEH_LIC_PLT_NO,
        t1.ALARM_TM,
        t1.WARN_TP,
        t1.DIST_NM,
        t1.ENT_NM,
        t1.ENT_MGMT_MBR,
        t1.CON_PHONE,
        t2.IND_NM
        from
        (select ENT_CODE,IND_NM from T_VEHICLE_POLLUT_ENT_BASE_INFO
        <where>
            <if test="distCode != null and distCode != 0">
                and DIST_CODE = #{distCode,jdbcType=VARCHAR}
            </if>
            <if test="indTp != null and indTp != 0">
                and IND_NM = #{indTp,jdbcType=VARCHAR}
            </if>
        </where>
        )t2
        left join
        (
        select ENT_CODE,DIST_NM,ENT_NM,CAR_IMG,VEH_LIC_PLT_NO, ALARM_TM,WARN_TP,ENT_MGMT_MBR,CON_PHONE
        from T_VEHICLE_POLLUT_QA_INFO
        <where>
            <if test="distCode != null and distCode != 0">
                and DIST_CODE = #{distCode,jdbcType=VARCHAR}
            </if>
            <if test="startTime != null and endTime != null">
                and ALARM_TM between to_date(#{startTime,jdbcType=VARCHAR}, 'yyyy-mm-dd hh24:mi:ss') and
                to_date(#{endTime,jdbcType=VARCHAR},'yyyy-mm-dd hh24:mi:ss')
            </if>
        </where>
        ) t1
         on t1.ENT_CODE = t2.ENT_CODE
    </select>

优化二

对所有的查询字段设置索引，同时对联表的外键也建立索引。

被驱动表索引
驱动表索引

优化三

既然查数据库很慢，那么就Juc 进行异步IO查数据库，当然这里异步查最后的响应时间也是取决于最耗费时间的任务。

CompletableFuture<List<GuardVo>> guardFuture = CompletableFuture.supplyAsync(() -> guardDao.selectByMap(params), ThreadPoolUtil.getExecutorService());
CompletableFuture<List<AlarmInfoVo>> alarmFuture = CompletableFuture.supplyAsync(() -> alarmInfoDao.selectByMap(params), ThreadPoolUtil.getExecutorService());