java調用kettle動態傳參修改數據庫連接

感言：網絡的確幫助了我們，但是kettle的資料真實太少，英語學好是有必要的；

整體思路：創建javaproject→導入kettle所需要的包→實現kettle中的對象→重寫對象內容→調用對象執行；

package kettle;

//需要導入的包
import java.util.List;
import java.util.Map;
import java.util.Set;

import org.pentaho.di.core.KettleEnvironment;
import org.pentaho.di.core.database.DatabaseMeta;
import org.pentaho.di.trans.Trans;
import org.pentaho.di.trans.TransMeta;

import com.enfo.common.utils.StringUtils;




public class ExecuteLocalTran {
    /**
     * java調用本地的tran並且傳遞參數(包括給SQL傳參和動態修改數據庫連接)
     * 
     * 
     */
   public static void main(String arg[]) throws Exception 
    {
       
       //前台頁面傳遞的參數
       String idname="7";//作為參數值
       String filename="./test.ktr";//ktr路徑
       
       String conn_name="output_dbconnection";
       String host_name="128.8.28.124";
       String db_name="TestWork";
       String db_port="1433";
       String user_name="wxj";
       String pass_word="wxj1988";
       
       KettleEnvironment.init();//初始化kettle環境
       TransMeta transMeta = new TransMeta(filename);//new tran的源數據對象
       
       //DatabaseMeta dm =transMeta.getDatabase(1); 
       List<DatabaseMeta>  dmlist=transMeta.getDatabases();
       for(DatabaseMeta dm : dmlist)
           {
                String connection_name=StringUtils.trimNull(dm.getName());
                if(connection_name.equals(conn_name))
                {   
                    dm.setHostname(host_name); //連接地址
                    dm.setDBName(db_name); //數據庫名稱
                    dm.setDBPort(db_port); //端口
                    dm.setUsername(user_name); //用戶
                    dm.setPassword(pass_word); //密碼
                    /*
                    System.out.println("DatabaseMeta:"+dm.getName());
                    System.out.println("AccessType:"+dm.getAccessType());
                    System.out.println("DatabaseName:"+dm.getDatabaseName());
                    System.out.println("Hostname:"+dm.getHostname());
                    System.out.println("Username:"+dm.getUsername());
                    System.out.println("Password:"+dm.getPassword());
                    */
                 }
                
            }
       Trans trans = new Trans(transMeta);//創建tran對象
       trans.setVariable("namevalue",idname);//給對象傳參
       trans.prepareExecution(null);//異常處理
       trans.startThreads();//開始執行
       trans.waitUntilFinished();//等待執行完畢
       if(trans.getErrors()!=0)
       {
           System.out.println("Error encountered!"); 
       }
    }

}

更多參考：http://javadoc.pentaho.com/kettle/