運用Java調用Kettle Job和Trans（帶參數）

1.首先創建一個kettle trans

2.對表輸入進行編輯

${dateNow}為要傳入的參數。

3.代碼編寫

首先需要把包導入

import org.pentaho.di.core.KettleEnvironment;
import org.pentaho.di.core.exception.KettleException;
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 KettleTest {

    /**包
     * @param args
     * @throws KettleException 
     */
    public static void runJob(String jobFile) throws KettleException{
        KettleEnvironment.init();
        JobMeta jm = new JobMeta(jobFile,null);
        Job job = new Job(null,jm);
        job.setVariable("dateNow", "2016-01-05");
        job.start();
        job.waitUntilFinished();
    }
    
    public static void runTrans(String transFile) throws KettleException{
        KettleEnvironment.init();
        TransMeta tm = new TransMeta(transFile);
        Trans trans = new Trans(tm);
        trans.setVariable("dateNow", "2016-01-03");
        trans.execute(null);
        trans.waitUntilFinished();
    }
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        String fileName = "F:\\zcr\\工作空間\\kettleWorkSpace\\kettleTrans.ktr";
        try {
            runTrans(fileName);
        } catch (KettleException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}

trans 通過 Trans.setVariable(String,String)傳遞參數。

第一個參數就是ktr中的變量，比如上面的${dateNow}。我們可以通過Trans.setVariable(dateNow,”2016-01-05”)這個個函數把2016-01-05這個字符串賦給dateNow

Job通過Job.setVariable(String,String)傳遞參數，用法和trans用法一致。