java 集成kettle

java 集成kettle"/>

java 集成kettle

最近要对一个系统的数据同步到另一个系统中，要求新系统的数据结果完成之后，实时同步到另一个系统数据表中。

Java调用Kettle执行任务或转换，需要使用Kettle中的jar，可以先导入lib目录中的几个基本的jar，如：kettle-core.jar、kettle-db.jar、kettle-engine.jar ，其它jar根据情况进行添加，所需的jar在\lib、\libext下面都可以找到，本示例引用的jar如下图：

也就是动态的传一个关联的ID。由于旧系统是vb做的，无法提供webservice接口，并且同步的表涉及到十几张表，并且两个系统表结构完全不一样，所以想到了kettle。

虽然网上文章有说Java可以传递参数给kettle，不过只找到了传递参数给转换的文章，没有讲参数传递给job，kettle中如何使用java传递的参数。今天就以上问题，一并共享。import org.pentaho.di.core.KettleEnvironment;

import org.pentaho.di.core.util.EnvUtil;

import org.pentaho.di.job.Job;

import org.pentaho.di.job.JobMeta;

import org.pentaho.di.trans.Trans;

import org.pentaho.di.trans.Tran