通过java代码来调用kettle的简单实现

package pub;

import org.pentaho.di.core.KettleEnvironment;
import org.pentaho.di.core.exception.KettleException;
import org.pentaho.di.job.Job;
import org.pentaho.di.job.JobMeta;

/**
* @date 2015-4-29
* @version 1.0
*
*/
public class TestKettle {
public static void main(String[] args) {
String jobFileName = "C:\\Users\\hly\\Desktop\\TestJob.kjb";
try {
callKettleJob(jobFileName);
} catch (KettleException e) {
e.printStackTrace();
}
}
public static void callKettleJob(String jobFileName) throws KettleException{
KettleEnvironment.init();//初始化
JobMeta jobMeta = new JobMeta(jobFileName,null);//jobFileName是job脚本路径及文件名
Job job = new Job(null,jobMeta);
job.setVariable("AJBH" ,"123");//传入参数
job.start();
job.waitUntilFinished();
if(job.getErrors() > 0){
throw new KettleException("job执行不成功，有步骤失败！");
}
}
}