目前正在做的项目需要用将主业务库的部分数据同步出去以作统计用，为了保持数据实时同步需要定时执行同步操作。同步工具运用了比较流行的ETL工具kettle，首先我们在kettle界面工具Spoon中设计好同步文件如 studentTableETL.ktr，然后在web项目通过quartz定时调用studentTableETL.ktr即可。

1、以下是pom.xml中的依赖包 pentaho.kettlekettle-core3.2.0-GApentaho.kettlekettle-db3.2.0-GApentaho.kettlekettle-engine3.2.0-GApentaho.kettlekettle-ui-swt3.2.0-GApentaho.kettlekettle-vfs3.2.0-GAognlognl3.0.3org.quartz-schedulerquartzlog4jlog4jcommons-digestercommons-digester1.8

2、spring-quartz.xml

true

0 59 23 * * ?

kettleEtl

3、KettleLoader.java

package com.anyuan.edu.sas.service; import org.pentaho.di.core.exception.KettleException;

import org.pentaho.di.core.util.EnvUtil;

import org.pentaho.di.trans.StepLoader;

import org.pentaho.di.trans.Trans;

import org.pentaho.di.trans.TransMeta;

/**

kettle文件加载类

*/ public class KettleLoader{ public void kettleEtl() throws KettleException { String[] etlTables = {"classroomTableETL","studentTableETL","courseTableETL","chapterTableETL"}; int monitor = 0; try{ for(int i=0;i

callNativeTransWithParam(filename); } }catch(Exception e){ System.out.println(etlTables[monitor]+" failed");

} System.out.println("ok");

}

/**

* 调用本地的转换文件(带参数)

*

* @Description:

* [@param](https://my.oschina.net/u/2303379) transFileName

* [@throws](https://my.oschina.net/throws) KettleException

*/

public static void callNativeTransWithParam(String transFileName) throws KettleException {

// 初始化

EnvUtil.environmentInit();

StepLoader.init();

// 转换元对象

TransMeta transMeta = new TransMeta(transFileName);

// 转换

Trans trans = new Trans(transMeta);

String[] params = {};

// 执行转换

trans.execute(params);

// 等待转换执行结束

trans.waitUntilFinished();

}

}

我这里每次执行4个ktr文件，所以定义了一个数组String[] etlTables = {"classroomTableETL","studentTableETL","courseTableETL","chapterTableETL"};然后循环调用 如果只有一个文件的话，就不需要这个循环了。