Kettle4 Repository 操作示例 （登陆资源库,获取模型,运行）

Kettle4 Repository 操作示例 （登陆资源库,获取模型,运行）

/**
* Kettle 4.2.0 版本测试通过
*/
package zhangxin.test;

import java.util.List;

import org.pentaho.di.core.KettleEnvironment;
import org.pentaho.di.core.exception.KettleException;
import org.pentaho.di.core.plugins.PluginRegistry;
import org.pentaho.di.core.plugins.RepositoryPluginType;
import org.pentaho.di.repository.ObjectId;
import org.pentaho.di.repository.RepositoriesMeta;
import org.pentaho.di.repository.Repository;
import org.pentaho.di.repository.RepositoryElementMetaInterface;
import org.pentaho.di.repository.RepositoryMeta;
import org.pentaho.di.repository.StringObjectId;
import org.pentaho.di.trans.Trans;
import org.pentaho.di.trans.TransMeta;

/**
* 登陆资源库,获取模型,运行
*
* @author zhangxin
*
*/
public class TestRepository {

/**
* @param args
* @throws KettleException
*/
public static void main(String[] args) throws KettleException {
// 运行环境初始化（设置主目录、注册必须的插件等）
KettleEnvironment.init();
RepositoriesMeta repositoriesMeta = new RepositoriesMeta();
// 从文件读取登陆过的资源库信息
repositoriesMeta.readData();
// 选择登陆过的资源库
RepositoryMeta repositoryMeta = repositoriesMeta.findRepository("4_2");
// 获得资源库实例
Repository repository = PluginRegistry.getInstance().loadClass(RepositoryPluginType.class, repositoryMeta.getId(), Repository.class);
repository.init(repositoryMeta);
// 连接资源库
repository.connect("admin", "admin");
ObjectId id = new StringObjectId("0");
// 获取某个资源库的所有转换
List<RepositoryElementMetaInterface> li = repository.getTransformationObjects(id, false);
TransMeta transMeta = null;
if (li != null) {
for (RepositoryElementMetaInterface repe : li) {
System.out.println("TRANSFORMATION:" + repe.getObjectId() + "name:" + repe.getName());
TransMeta tm = repository.loadTransformation(repe.getObjectId(), null);
if ("测试转换".equals(tm.getName())) {
transMeta = tm;
}
}
}
// 执行指定转换
Trans trans = new Trans(transMeta);
trans.execute(null);
trans.waitUntilFinished();
if (trans.getErrors() > 0) {
throw new RuntimeException("There were errors during transformation execution.");
}
repository.disconnect();
}

}