基于
介绍
spring-boot的kettle调度项目参照了Zha小东9860的代码,并参照了其中的页面管理。 后台代码可以自行参考API进行工具化制作,在原代码中添加以下功能1,将数据库更改为oracle2,方便添加mybatis相关的依赖关系。 将jpa依次替换为mybatis3,增加传递给kettle脚本的参数,动态化脚本4,删除转换名称,添加不允许重复的约束5,在页面上添加转换描述显示6,为了调度提取任务7,redis,redis2020-06-15重要更新说明1、修改日志级别的错误。 在TransMate中设定的日志级别无效,将日志级别设定为Trans。 2、同时执行相同的脚本,从日志ID获取日志时会发生错误。 日志ID根据转换名称计算,对于同一转换,用不同的参数手动设置到LogChannel
2020-06-05重要的更新说明页面样式的变更
首页
项目截图
。登录页面的屏幕快照
首页的屏幕快照(更新的样式) )
**新的转换任务(更新的样式) **转换任务添加页面传输参数,手动写入json格式的数据库k_trans表,添加trans_params字段,然后添加相应的实体执行任务时,从trans获取参数,并将其设置为相应的脚本
//class name org.kettle.scheduler.system.biz.quartz.trans quartz
@Override
公共语音执行(JobexecutioncontextJobexecutioncontext ) throws JobExecutionException {
.
integertransid=jobexecutioncontext.getmergedjobdatamap ().getint ) ' id );
获取//转换
传输=传输服务. gettransbyid (传输);
//设定执行参数
MapString,string params=新hashmap (2;
stringtransparams=trans.gettransparams (;
mapjsontomap=JSON.parse对象(传输参数);
Params.Putall(jsontomap;
if (string util.hastext (trans.getsyncstrategy () ) ) )
integer day=integer.value of (trans.getsyncstrategy ().substring(2,trans.getsyncstrategy ) );
params.put (开始时间),dateutil.getdatetimestr ) date util.ad days (日期实用程序. gettodaystartime,-日期) )
params.put (结束时间),dateutil.getdatetimestr ) date util.ad days (日期实用程序. gettodayendtime,-日期) )
}
.……
}
安装教程
1、将docs的kettle-scheduler-oracle.sql文件导入到oracle数据库中