1. 复现错误
今天写好hive表导入的回调
的接口,如下代码所示:
/**
* hive表导入的回调接口
*
* @author super先生
* @datetime 2023/3/20:16:32
* @return
*/
@ResponseBody
@PostMapping(value = "/xxx/importTables/callback")
public ServiceStatusData callbackLocalHiveImportTables(
@RequestParam("missionId") String missionId) {
logger.info("mock数据的入参记录:missionId={}", missionId);
if (isBlank(missionId)) {
return new ServiceStatusData(ServiceStatusData.Status.Fail, "入参错误:缺少任务id", null);
}
return hiveImportTaskService.callbackLocalHiveImportTables(missionId);
}
启动postman
访问该接口,确报出如下错误:
即Try setting a different JdbcType for this parameter or a different configuration property
2. 分析错误
将错误信息Try setting a different JdbcType for this parameter or a different configuration property
,翻译成中文尝试给这个参数设置不同的jdbcType,或者配置不同的属性
。
这个参数(this parameter
)是指上图中的missionId
,为什么要给它设置不同的JdbcType
呢?
首先经过打断点的方式,来定位错误之处,如下代码所示:
由断点可以初步判断,问题可能出现在hiveImportTaskMapper.updateCallbackTimeByMissionId(missionId);
方法中,继续断点往下走:
由此可以确定,问题出现在hiveImportTaskMapper.updateCallbackTimeByMissionId(missionId);
方法中。
于是,进入到hiveImportTaskMapper.updateCallbackTimeByMissionId(missionId)
方法,如下代码所示:
@Mapper
@Repository
public interface HiveImportTaskMapper {
/**
* 更新回调时间
*
* @author super先生
* @datetime 2023/3/24:11:45
* @param missionId 抽取逻辑id
* @return
*/
Long updateCallbackTimeByMissionId(String missionId);
}
接着进入到hiveImportTaskMapper.xml
文件中,找到id = updateCallbackTimeByMissionId
的update
标签,如下代码所示:
<update id="updateCallbackTimeByMissionId" parameterType="java.lang.Long">
UPDATE
hive_import_task
SET
call_back_time = NOW() ,
update_time = NOW()
where
deleted = 0 and mission_id = #{missionId}
</update>
可以清晰地看到:
-
HiveImportTaskMapper
类中的updateCallbackTimeByMissionId(missionId);
方法的形参是String
类型 -
hiveImportTaskMapper.xml
文件中的parameterType
是Long
类型。
因而,类型不一致才让我给missionId
设置不同的JdbcType
。
3. 解决错误
既然是 HiveImportTaskMapper
类中的updateCallbackTimeByMissionId(missionId);
方法的形参类型和hiveImportTaskMapper.xml
文件中的parameterType
类型不一致,导致了这个错误,可进行如下修改。
将hiveImportTaskMapper.xml
文件中的parameterType
类型,修改为java.lang.String
即可,如下代码所示:
<update id="updateCallbackTimeByMissionId" parameterType="java.lang.String">
UPDATE
hive_import_task
SET
call_back_time = NOW() ,
update_time = NOW()
where
deleted = 0 and mission_id = #{missionId}
</update>
重新启动项目,再次使用postman
测试,方可成功运行,如下图所示: