Kettle数据库资源库连接执行示例

1、初始化 Kettle环境: org.pentaho.di.core.KettleEnvironment
KettleEnvironment.init();
2、创建 Kettle数据库资源库: org.pentaho.di.repository.kdr. KettleDatabaseRepository
// 此时的资源库对象仓库还是个空对象
KettleDatabaseRepository repository = new KettleDatabaseRepository();
3、创建资源库的数据库连接: org.pentaho.di.core.database.DatabaseMeta
DatabaseMeta databaseMeta = new DatabaseMeta("melo", "Oracle", "Native", "10.40.11.206", "orcl1", "1521", "melodemo", "melodemo");
Kettle数据库资源库连接执行示例_第1张图片
 
4、创建数据库资源库元信息: org.pentaho.di.repository.kdr.KettleDatabaseRepositoryMeta
        id、名称、描述可随意定义,不重复即可
KettleDatabaseRepositoryMeta kettleDatabaseMeta = new KettleDatabaseRepositoryMeta("melo", "melo", "melo", databaseMeta);
5、可数据库资源库初始化赋值
repository.init(kettleDatabaseMeta);
6、连接数据库资源库
repository.connect("admin", "admin");
7、根据目录地址获取 Kettle目录对象: org.pentaho.di.repository.RepositoryDirectoryInterface
RepositoryDirectoryInterface directory = repository.findDirectory("/melo");
8、获取数据库资源库中的 ktr  xml元信息: org.pentaho.di.trans.TransMeta
TransMeta transMeta = ((Repository) repository).loadTransformation("melo", directory, null, true, null);
9、获取xml内容,可放在Kettle可视化工具中执行查看
String xmlContent = transMeta.getXML();
10、创建 Transform ktr对象: org.pentaho.di.trans.Trans
Trans trans = new Trans(transMeta);
11、执行 Transform
trans.execute(null);
trans.waitUntilFinished(); // 等待执行完毕
12、获取执行异常结果
if (trans.getErrors() > 0)
     System.err.println("Transformation run Failure!");
else
     System.out.println("Transformation run successfully!");
13、获取 Transform执行影响数据量
System.out.println(trans.getLastProcessed());
 

你可能感兴趣的