场景：kettle 三：java调用job

kettle 3：java调用job

/**

* 调用本地job

*

* @param jobFileName

* job文件路径

* @throws KettleException

*/

public void callNativeJob(String jobFileName) throws KettleException {

// 初始化

EnvUtil.environmentInit();

JobEntryLoader.init();

StepLoader.init();

// 日志

LogWriter log = LogWriter.getInstance("TransTest.log", true,

LogWriter.LOG_LEVEL_DETAILED);

// job元对象

JobMeta jobMeta = new JobMeta(log, jobFileName, null);

// job

Job job = new Job(log, StepLoader.getInstance(), null, jobMeta);

jobMeta.setInternalKettleVariables(job);

// 执行job

job.execute();

// 等待job执行结束

job.waitUntilFinished();

}

/**

* 调用资源库中的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);

// job

Job job = new Job(log, steploader, rep, jobmeta);

// 执行job

job.execute();

// 等待job执行结束

job.waitUntilFinished();

}

1 楼

hepei120

2012-06-12

想问一下如果stop job