kettle 三：java调用job

kettle 3：java调用job

/** * 调用资源库中的job *  * @throws KettleException */public void executeJobs() throws KettleException {// 初始化EnvUtil.environmentInit();JobEntryLoader.init();StepLoader.init();// 日志LogWriter log = LogWriter.getInstance("TransTest.log", true,LogWriter.LOG_LEVEL_DETAILED);// 用户UserInfo userInfo = new UserInfo();userInfo.setLogin("admin");userInfo.setPassword("admin");// 数据库连接元对象DatabaseMeta connection = new DatabaseMeta("merit113", "Oracle","Native", "localhost", "merit113", "1521", "kettle", "merit");// 资源库元对象RepositoryMeta repinfo = new RepositoryMeta();repinfo.setConnection(connection);// 资源库Repository rep = new Repository(log, repinfo, userInfo);// 连接资源库rep.connect("");// 资源库目录对象RepositoryDirectory dir = new RepositoryDirectory(rep);// 步骤加载对象StepLoader steploader = StepLoader.getInstance();// job元对象JobMeta jobmeta = new JobMeta(log, rep, "job1", dir);// jobJob job = new Job(log, steploader, rep, jobmeta);// 执行jobjob.execute();// 等待job执行结束job.waitUntilFinished();}