我有一个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()?