我有一个Kettle作业,它将从数据库X获取数据并将数据复制到另一个数据库Y。

我使用了一些水壶罐从Java运行此作业,并且工作正常。

现在,我的要求是,如何从Java动态将数据库名称传递给作业?

例:

String filename = "myJob.kjb";
KettleEnvironment.init();
JobMeta jobMeta = new JobMeta(filename, null);
jobMeta.setParameterValue("TEST_DB", "MyDatabase");
jobMeta.setInternalKettleVariables();
Job job = new Job(null, jobMeta);
job.start();
job.waitUntilFinished();

最佳答案

您是否尝试过jobMeta.activateParameters()?

10-08 18:58