前言

在积累的过程中要学会思考，才能成长。

1.导入jar包

新建一个spring boot项目后，为了使整合的项目正常运行需要导入kettle相应的jar包，我所用kettle的版本为8.20。使用的jar包如下图所示（这些jar包可以在kettle的lib目录下找到）

2.spring boot调用ktr文件

添加jar包后就可以进行代码的编写了，我将调用ktr的代码写在测试类中如下

private String filename = "C:\\Users\\Administrator\\Desktop\\SpoonDemo\\demo1.ktr";@Test
public void testEtl() {try {//初始化KettleEnvironment.init();//将filename存储的数据加载到trans对象中TransMeta transMeta = new TransMeta(filename);Trans trans = new Trans(transMeta);//启动trans.execute(null);//等待文件的运行完成trans.waitUntilFinished();} catch (KettleException e) {e.printStackTrace();}
}

该代码运行成功后的控制台会打印相应的日志信息如图

3.spring boot整合kettle调用kjb文件

调用kjb文件的方法与调用ktr类似代码如下

private String jobname = "C:\\Users\\Administrator\\Desktop\\SpoonDemo\\test.kjb";
@Test
public void testEtl() {try {//初始化KettleEnvironment.init();//加载路径信息JobMeta JobMeta = new JobMeta(jobname,null);Job job = new Job(null,JobMeta);//启动job.start();//等待运行完成job.waitUntilFinished();} catch (KettleException e) {e.printStackTrace();}
}

打印的日志信息如下