xxl-job 适配人大金仓数据库 V8R6-编程知识

前言

由于一些众所周知的原因，项目需要需要进行改造使其适配人大金仓的数据库。

xxl-job适配人大金仓

特此说明：当前修改的xxl-job版本为 2.4.1-SNAPSHOT

mysql上的xxl-job库迁移到人大金仓数据库上

pom中新增依赖 kingbase8 驱动注意版本

<!--KingBase-->
<dependency><groupId>cn.com.kingbase</groupId><artifactId>kingbase8</artifactId><version>8.6.0</version>
</dependency>

注释掉原有的MySQL驱动
修改application.properties 数据库连接以及账号密码还有驱动类

### xxl-job, datasource
## 修改为人大金仓的 数据库协议 数据库地址 以及账号密码 
spring.datasource.url=jdbc:kingbase8://xx:xxx/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
spring.datasource.username=xx
spring.datasource.password=xxx
#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
# 替换驱动为 kingbase8的驱动
spring.datasource.driver-class-name=com.kingbase8.Driver

配置没问题的话应该就可以启动了

接下来会遇到第一个问题

com.xxl.job.admin.core.thread.JobScheduleHelper#start的 73行

                        preparedStatement = conn.prepareStatement(  "select * from xxl_job_lock where lock_name = 'schedule_lock' for update" );

提示xxl_job_lock表不存在但是数据库里是存在的
经查阅资料发现加上库名即可（可能读取的datasource没有包含库名应该是个bug）
解决：修改为如下增加库名

                        preparedStatement = conn.prepareStatement(  "select * from xxl_job.xxl_job_lock where lock_name = 'schedule_lock' for update" );

第二个问题
com.xxl.job.admin.core.thread.JobFailMonitorHelper#start
的41行提示 xxl_job_log 表不存在
刚开始以为也需要添加库名，然后尝试加了启动依然报错

后续查询资料是不支持 `这个符号
解决：全局替换 xml中的这个符号即可
示例

<!-- 修改前 -->
<select id="findFailJobLogIds" resultType="long">SELECT idFROM `xxl_job.xxl_job_log`WHERE !((trigger_code in (0, 200)and handle_code = 0)OR(handle_code = 200))AND alarm_status = 0ORDER BY id ASCLIMIT #{pagesize}
</select>
<!-- 修改后  -->
<select id="findFailJobLogIds" resultType="long">SELECT idFROM xxl_job.xxl_job_logWHERE !((trigger_code in (0, 200)and handle_code = 0)OR(handle_code = 200))AND alarm_status = 0ORDER BY id ASCLIMIT #{pagesize}
</select>

后续全局替换 xml中的这个符号即可

第三个问题
com.xxl.job.admin.core.thread.JobRegistryHelper#start 66行报错

							List<Integer> ids = XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().findDead(RegistryConfig.DEAD_TIMEOUT, new Date());

提示 bad SOL grammar [1: nested exception is
com. kinabases.util.KsoLException：错误：函数 DATE ADD(unknown . interval）不存在
Hint：没有匹配指定名称和参数类型的函数.
您也许需要增加明确的类型转换.

解决- 替换新的实现方式
查询资料说是替换新的实现方式尝试多次均不可

 DATE_ADD(#{nowTime},INTERVAL -#{timeout} SECOND) 为 
date '${nowTime}' - INTERVAL '${timeout} second'

类似的修改等等

官方的地址说明： https://help.kingbase.com.cn/v8/development/sql-plsql/ref-extended-plug-in/kdb_date_function.html#id5

直接看终极解决办法替换现有实现
本质来讲就是需要个工具类将传入的时间减去一个传入的秒数返回修改后的时间

直接在工具类com.xxl.job.core.util.DateUtil 中添加如下方法

public static Date addSeconds(final Date date, final int amount) {return add(date, Calendar.SECOND, amount);
}

然后在 com.xxl.job.admin.dao.XxlJobRegistryDao 新增两个dao的方法

public List<Integer> findDeadByTime(@Param("nowTime") Date nowTime);public List<XxlJobRegistry> findAllByTime(@Param("nowTime") Date nowTime);

在mapper文件 XxlJobRegistryMapper.xml 中新增两个方法对应的sql 内容

<select id="findDeadByTime" resultType="java.lang.Integer">SELECT <include refid="Base_Column_List" />FROM xxl_job.xxl_job_registry AS tWHERE t.update_time <![CDATA[ < ]]> #{nowTime}
</select><select id="findAllByTime" resultType="com.xxl.job.admin.core.model.XxlJobRegistry">SELECT <include refid="Base_Column_List" />FROM xxl_job.xxl_job_registry AS tWHERE t.update_time > #{nowTime}
</select>

最后在 com.xxl.job.admin.core.thread.JobRegistryHelper#registryMonitorThread 文件中替换实现

//List<Integer> ids = XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().findDead(RegistryConfig.DEAD_TIMEOUT, new Date());
//新增修改后的内容
Date beforeDate = DateUtil.addSeconds(new Date(), -1 * RegistryConfig.DEAD_TIMEOUT);
List<Integer> ids = XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().findDeadByTime(beforeDate);
if (ids!=null && ids.size()>0) {XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().removeDead(ids);
}// fresh online address (admin/executor)
HashMap<String, List<String>> appAddressMap = new HashMap<String, List<String>>();
//List<XxlJobRegistry> list = XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().findAll(RegistryConfig.DEAD_TIMEOUT, new Date());
//新增的内容
Date nowDate = DateUtil.addSeconds(new Date(), -1 * RegistryConfig.DEAD_TIMEOUT);
List<XxlJobRegistry> list = XxlJobAdminConfig.getAdminConfig().getXxlJobRegistryDao().findAllByTime(nowDate);

第四个问题最**

sql语句中找不到表报错提示: bad SQL grammar []; nested exception is com.kingbase8.util.KSQLException: 错误: 关系 “表名” 不存在

第一个问题的解决办法适用于SQL不多的场景要是SQL 过多 SQL改动就很大

找不到表的问题解决办法：新建一个人大金仓的数据库账号账号为 xxl_job 然后修改 application.properties 的数据库连接信息

spring.datasource.url=jdbc:kingbase8://xxx:54321/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
spring.datasource.username=xxl_job
spring.datasource.password=xxxx
#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.driver-class-name=com.kingbase8.Driver

其他找不到的表的问题也可参考此方案如果项目使用到test 库项目中使用人大金仓的数据库提示表不存在（确保表真的存在）然后新建的对应库名的账号然后项目配置中替换用户密码配置