云资源分享:依赖包+kjb+ktr+测试源码 Kettle【付诸实践 04】Java环境实现KJB和KTR脚本文件执行v9版本9.0.0.0-423相关依赖说明

资源链接在文章末尾，包含文件：

test.job 和 test.ktr 都是简单的创建一个文件，目的是能够快速看到执行结果：

1.需求说明 【云资源分享:依赖包+kjb+ktr+测试源码 Kettle【付诸实践 04】Java环境实现KJB和KTR脚本文件执行v9版本9.0.0.0-423相关依赖说明】Kettle 是用 Java 开发的，有些时候编写的 KJB 或者 KTR 脚本会实现特定的功能，比如从一个表导数据到另一个表等等，如果想要在 Java 项目中使用这些脚本，就需要在项目中引入 KJB 或者 KTR 脚本的执行环境所依赖的jar包。
2.依赖及代码实现 2.1 依赖及说明 com.kettlemetastore>system9.0.0.0-423>${project.basedir}/lib/metastore-9.0.0.0-423.jarcom.kettlecommons-lang>system2.6>${project.basedir}/lib/commons-lang-2.6.jarcom.kettlevfs2>system2.2>${project.basedir}/lib/commons-vfs2-2.2.jarcom.kettlecore>system9.0.0.0-423>${project.basedir}/lib/kettle-core-9.0.0.0-423.jarcom.kettleengine>system9.0.0.0-423>${project.basedir}/lib/kettle-engine-9.0.0.0-423.jar 2.2 代码实现 JOB执行代码：
// 初始化执行环境KettleEnvironment.init();AtomicBoolean jobStarted = new AtomicBoolean(true);int countOfCheckers = 100;HashMap> checkers = new HashMap<>(16);String testJobFullPath = "E:\\kettle-git\\file\\test.kjb";JobMeta jm = new JobMeta(testJobFullPath, null);final Job job = new Job(null, jm);ExecutorService executorService = Executors.newFixedThreadPool(countOfCheckers);for (int i = 0; i < countOfCheckers; i++) {Future> future = executorService.submit(new Callable>() {private StringBuilder statusCollector = new StringBuilder();@Overridepublic StringBuilder call() throws Exception {while (jobStarted.get()) {statusCollector.append(job.getStatus());//add the sleep to reduce the count of logged status and prevent OOMThread.sleep(10);}return statusCollector;}});checkers.put(i, future);}job.start();job.waitUntilFinished();jobStarted.set(false);for (Future> checker : checkers.values()) {System.out.println(checkOrderStatus(checker.get().toString()));}// 关闭执行器executorService.shutdown();// 关闭执行环境KettleEnvironment.shutdown(); 执行日志信息：

KTR执行代码：
// 初始化运行环境KettleEnvironment.init();// 初始化ktrString path = "E:\\kettle-git\\file\\test.ktr";TransMeta constantTrans = new TransMeta(path, new Variables());Trans trans = new Trans(constantTrans);trans.prepareExecution(new String[]{});trans.setPreview(true);trans.startThreads();trans.waitUntilFinished();// 关闭执行环境KettleEnvironment.shutdown(); 执行日志信息：
3.技术总结上边的代码只是简单的执行 KJB 和 KTR 脚本，对传参、流程控制、日志打印等没有进行操作，后续会进行更新。
【资源连接】
链接：https://pan.baidu.com/s/1NC910l5tTRuJfdKoUMh-nA
提取码：d3gu