Kettle API - Java调用示例
对向前兼容性的推荐：如果想要动态地创造Transformation (例如:从元数据)，使用XML文件方法(KTR)而不是使用API。XML文件兼容Kettle所有版本，同样对job有效的。
1.下面的例子进行以下操作：
1创建Transformation
2保存Transformation信息到XML文件
3获取在目标表操作的SQL
4执行Transformation
5drop目标表，使这个示例可以重复。
// 创建“复制表”的transformation元数据.
TransMeta transMeta = TransBuilder.buildCopyTable(
transformationName,
sourceDatabaseName,
sourceTableName,
sourceFields,
targetDatabaseName,
targetTableName,
targetFields
);
// 保存为文件:
String xml = transMeta.getXML();
DataOutputStream dos = new DataOutputStream(new FileOutputStream(new File(fileName))); dos.write(xml.getBytes("UTF-8"));
dos.close();
System.out.println("Saved transformation to file: "+fileName);
//获取在目标表操作的SQL
String sql = transMeta.getSQLStatementsString();
// 在目标表执行sql:
Database targetDatabase = new Database(transMeta.findDatabase(targetDatabaseName)); targetDatabase.connect();
targetDatabase.execStatements(sql);
//现在执行transformation
Trans trans = new Trans(transMeta);
trans.execute(null);
trans.waitUntilFinished();
//为了重复测试,再次drop目标表
targetDatabase.execStatement("drop table "+targetTableName);
targetDatabase.disconnect();
