Pentaho Kettle解决方案：使用PDI构建开源ETL解决方案.所有源码及脚本

package example.ch22;

import org.pentaho.di.core.KettleEnvironment;
import org.pentaho.di.core.database.Databasemeta;
import org.pentaho.di.shared.Sharedobjects;
import org.pentaho.di.trans.Trans;
import org.pentaho.di.trans.Transmeta;

public class ChangeDatabaseInTrans {
  public static void main（String[] args） throws Exception {
    String filename = args[0];
    
    KettleEnvironment.init（）;
    
    Databasemeta databasemeta = new Databasemeta（“DB“ “MySQL“ “JDBC“ “localhost“ “test“ “3306“ “user“ “password“）;
    
    Sharedobjects sharedobjects = new Sharedobjects（）;
    sharedobjects.storeobject（databasemeta）;
    sharedobjects.setFilename（“/tmp/shared.xml“）;
    sharedobjects.saveToFile（）;
    
    // System.setProperty（Const.KETTLE_SHARED_objectS “/tmp/shared.xml“）;
    
    Transmeta transmeta = new Transmeta（filename）;
    transmeta.setSharedobjectsFile（“/tmp/shared.xml“）;
    transmeta.readSharedobjects（）;
    
    Trans trans = new Trans（transmeta）;
    trans.prepareExecution（null）;
    trans.startThreads（）;
    trans.waitUntilFinished（）;
    
    if （trans.getErrors（）!=0） {
      System.out.println（“Error“）;
    }
  }
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     文件        8787  2010-05-20 02:23  635179_code_ch22.classpath
     文件         368  2010-05-20 01:39  635179_code_ch22.project
     目录           0  2010-08-04 21:55  635179_code_ch22src
     目录           0  2010-08-04 21:55  635179_code_ch22srcexample
     目录           0  2010-08-04 21:55  635179_code_ch22srcexamplech22
     文件        1161  2010-07-20 04:21  635179_code_ch22srcexamplech22ChangeDatabaseInTrans.java
     文件        5369  2010-07-20 04:21  635179_code_ch22srcexamplech22CsvFileReader.java
     文件        3182  2010-07-20 04:37  635179_code_ch22srcexamplech22DynamicJob.java
     文件         522  2010-07-20 04:21  635179_code_ch22srcexamplech22ExecuteJob.java
     文件         569  2010-07-20 04:21  635179_code_ch22srcexamplech22ExecuteTrans.java
     文件        2769  2010-07-20 04:21  635179_code_ch22srcexamplech22InjectDataIntoTransformation.java
     文件         704  2010-07-20 04:21  635179_code_ch22srcexamplech22ParameterTrans.java
     文件        1773  2010-07-20 04:21  635179_code_ch22srcexamplech22PassDataToTransformation.java
     文件        1444  2010-07-20 04:21  635179_code_ch22srcexamplech22ReadFromStep.java
     目录           0  2010-08-04 21:55  635179_code_ch22
     目录           0  2010-08-04 21:55  635179_code_ch23src
     目录           0  2010-08-04 21:55  635179_code_ch23srcorg
     目录           0  2010-08-04 21:55  635179_code_ch23srcorgkettlesolutions
     目录           0  2010-08-04 21:55  635179_code_ch23srcorgkettlesolutionsplugin
     目录           0  2010-08-04 21:55  635179_code_ch23srcorgkettlesolutionsplugindatabase
     目录           0  2010-08-04 21:55  635179_code_ch23srcorgkettlesolutionsplugindatabasemysql51db
     文件         618  2010-07-02 02:29  635179_code_ch23srcorgkettlesolutionsplugindatabasemysql51dbMySQL51Databasemeta.java
     文件         547  2010-03-19 08:33  635179_code_ch23srcorgkettlesolutionsplugindatabasemysql51dbmysql51_jndi.xul
     文件        1183  2010-03-19 08:33  635179_code_ch23srcorgkettlesolutionsplugindatabasemysql51dbmysql51_native.xul
     目录           0  2010-08-04 21:55  635179_code_ch23srcorgkettlesolutionspluginjobentry
     目录           0  2010-08-04 21:55  635179_code_ch23srcorgkettlesolutionspluginjobentryhelloworld
     文件        2421  2010-03-23 10:05  635179_code_ch23srcorgkettlesolutionspluginjobentryhelloworldHelloworldJobEntry.java
     文件        6594  2010-03-23 10:02  635179_code_ch23srcorgkettlesolutionspluginjobentryhelloworldHelloworldJobEntryDialog.java
     目录           0  2010-08-04 21:55  635179_code_ch23srcorgkettlesolutionspluginjobentryhelloworldmessages
     文件         333  2010-03-23 09:51  635179_code_ch23srcorgkettlesolutionspluginjobentryhelloworldmessagesmessages_en_US.properties
     目录           0  2010-08-04 21:55  635179_code_ch23srcorgkettlesolutionspluginpartitioner
............此处省略179个文件信息