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();

總結

以上是生活随笔為你收集整理的java调用kettle例子_Kettle API - Java调用示例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。