java调用kettlejob传参_java调用kettle向job（任务）和transformation（转换）传递参数实例...

虽然网上文章有说java可以传递参数给kettle&＃xff0c;不过只找到了传递参数给转换的文章&＃xff0c;没有讲参数传递给job&＃xff0c;kettle中如何使用java传递的参数。今天就以上问题&＃xff0c;一并共享。

/**

* 本测试类慎用&＃xff01;&＃xff01;&＃xff01;&＃xff01;&＃xff01;&＃xff01;&＃xff01;

*

* &＃64;param args

*/

public static void main(String[] args) {

String datetime &＃61; "2014-12-19 23:20:45";

String[] params &＃61; {"707", datetime}; // 传递参数

String path &＃61; "F:\\job7.kjb";

//runTransfer(params, path);

runJob(params, path);

// runJob();

//jbResource();

}

/**

* 运行转换文件方法

* &＃64;param params 多个参数变量值

* &＃64;param ktrPath 转换文件的路径&＃xff0c;后缀ktr

*/

public static void runTransfer(String[] params, String ktrPath) {

Trans trans &＃61; null;

try {

// // 初始化

// 转换元对象

KettleEnvironment.init();// 初始化

EnvUtil.environmentInit();

TransMeta transMeta &＃61; new TransMeta(ktrPath);

// 转换

trans &＃61; new Trans(transMeta);

// 执行转换

trans.execute(params);

// 等待转换执行结束

trans.waitUntilFinished();

// 抛出异常

if (trans.getErrors() > 0) {

throw new Exception(

"There are errors during transformation exception!(传输过程中发生异常)");

}

} catch (Exception e) {

e.printStackTrace();

}

}

/**

* java 调用 kettle 的job

*

* &＃64;param jobname

* 如&＃xff1a; String fName&＃61; "D:\\kettle\\informix_to_am_4.ktr";

*/

public static void runJob(String[] params, String jobPath) {

try {

KettleEnvironment.init();

// jobname 是Job脚本的路径及名称

JobMeta jobMeta &＃61; new JobMeta(jobPath, null);

Job job &＃61; new Job(null, jobMeta);

// 向Job 脚本传递参数&＃xff0c;脚本中获取参数值&＃xff1a;${参数名}

// job.setVariable(paraname, paravalue);

job.setVariable("id", params[0]);

job.setVariable("dt", params[1]);

job.start();

job.waitUntilFinished();

if (job.getErrors() > 0) {

throw new Exception(

"There are errors during job exception!(执行job发生异常)");

}

} catch (Exception e) {

e.printStackTrace();

}

}

以上是片段。实现了调用任务和转换的方法&＃xff0c;我只给出了调用任务和转换文件的方法&＃xff0c;连接数据库的在此略过。

下面就是如何使用java传递的参数了。

转换的网上有例子&＃xff0c;转换工作台&＃xff0c;打开输入&＃xff0c;找到“获取系统信息”

进行变量定义&＃xff0c;选择命令参数1。。。n即可

就可以引用我示例中的1&＃xff0c;2参数了。

但是我们的迁移工作是要按顺序执行的&＃xff0c;调用转换不够用&＃xff0c;需要job来定义执行顺序&＃xff0c;

比如上面的转换作为第一步&＃xff0c;操作完进行其他步骤&＃xff0c;那么在这个基础上&＃xff0c;可以画一个job

这时候问题来了&＃xff0c;我们要活得java的数据&＃xff0c;同时这个job需要把参数传递给test2转换使用。

其实很简单&＃xff0c;点开test2&＃xff0c;切换到参数选型&＃xff0c;将java定义的参数写进去&＃xff0c;记住带{}

这样就大功搞成了。java已经能够顺利的将值传递给job&＃xff0c;job可以顺利的将值传递给转换。

点击run this job 在variable中定义参数名称跟java传递的参数一致&＃xff0c;可以写值进行测试。

注意事项&＃xff1a;任务和转换要存成文件格式&＃xff0c;任务中引用的转换也要是文件格式&＃xff0c;

否则就都需要数据库支撑&＃xff0c;数据库方法调用了。

原文&＃xff1a;http://blog.csdn.net/dirful/article/details/42026545