java調用kettle_實現（2）

本文轉載自查看原文 2017-04-21 19:29 3785 ETL

（1）.參照“java調用kettle_導入jar包（1）”,應用etl工具下lib里的所有jar

（2）.

最近要對一個系統的數據同步到另一個系統中，要求新系統的數據結果完成之后，實時同步到另一個系統數據表中。
也就是動態的傳一個關聯的ID。由於舊系統是vb做的，無法提供webservice接口，並且同步的表涉及到十幾張表，並且兩個系統表結構完全不一樣，所以想到了kettle。
java集成kettle網上有現成的實例，很簡單。如：http://bakcom.iteye.com/blog/1399587

雖然網上文章有說Java可以傳遞參數給kettle，不過只找到了傳遞參數給轉換的文章，沒有講參數傳遞給job，kettle中如何使用java傳遞的參數。今天就以上問題，一並共享。

import org.pentaho.di.core.KettleEnvironment;
import org.pentaho.di.core.util.EnvUtil;
import org.pentaho.di.job.Job;
import org.pentaho.di.job.JobMeta;
import org.pentaho.di.trans.Trans;
import org.pentaho.di.trans.TransMeta;

public class tests {

   /**
     * 本測試類慎用！！！！！！！
     *
     * @param args
     */
    public static void main(String[] args) {
       String datetime = "2014-12-19 23:20:45";
       String[] params = {"707", datetime}; // 傳遞參數
       String path = "E:\\job.kjb";
       for (int i = 0; i < 3; i++) {
           params[0] += i;
           runJob(params, path);
   }
    }

    /**
     * 運行轉換文件方法
     * @param params 多個參數變量值
     * @param ktrPath 轉換文件的路徑，后綴ktr
     */
    public static void runTransfer(String[] params, String ktrPath) {
        Trans trans = null;
        try {
            // // 初始化
            // 轉換元對象
            //KettleEnvironment.init();// 初始化
            EnvUtil.environmentInit();
            TransMeta transMeta = new TransMeta(ktrPath);
            // 轉換
            trans = new Trans(transMeta);

            // 執行轉換
            trans.execute(params);
            // 等待轉換執行結束
            trans.waitUntilFinished();
            // 拋出異常
            if (trans.getErrors() > 0) {
                throw new Exception(
                        "There are errors during transformation exception!(傳輸過程中發生異常)");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * java 調用 kettle 的job
     *
     * @param jobname
     *            如： String fName= "D:\\kettle\\informix_to_am_4.ktr";
     */
    public static void runJob(String[] params, String jobPath) {
        try {
           KettleEnvironment.init();
            // jobname 是Job腳本的路徑及名稱
            JobMeta jobMeta = new JobMeta(jobPath, null);
            Job job = new Job(null, jobMeta);
            // 向Job 腳本傳遞參數，腳本中獲取參數值：${參數名}
            // job.setVariable(paraname, paravalue);
            job.setVariable("id", params[0]);
            System.err.println(params[0]+"=========="+params[1]);
            job.setVariable("dt", params[1]);
            job.start();
            job.waitUntilFinished();
            if (job.getErrors() > 0) {
                throw new Exception(
                        "There are errors during job exception!(執行job發生異常)");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}