Springboot调用kettle9。3

　　Springboot调用kettle9.3
　　作业如下：
　　maven POM文件配置
　　      commons-codec     commons-codec     1.15     system     ${kettle_project.dir}/lib/commons-codec-1.15.jar       org.apache.commons     commons-io     2.2     system     ${kettle_project.dir}/lib/commons-io-2.2.jar        com.google.common     guava     17.0     system     ${kettle_project.dir}/lib/guava-17.0.jar       org.pentaho.di     kettle-core     9.3.0     system     ${kettle_project.dir}/lib/kettle-core-9.3.0.0-428.jar       org.pentaho.di     kettle-engine     9.3.0     system     ${kettle_project.dir}/lib/kettle-engine-9.3.0.0-428.jar       org.pentaho.metastore     metastore     9.3.0     system     ${kettle_project.dir}/lib/metastore-9.3.0.0-428.jar       org.apache.commons     commons-vfs2     2.7.0     system     ${kettle_project.dir}/lib/commons-vfs2-2.7.0.jar       org.pentaho     pentaho-encryption-support     9.3.0.0-428     system     ${kettle_project.dir}/lib/pentaho-encryption-support-9.3.0.0-428.jar       net.sourceforge.jexcelapi     jxl     2.6.12     system     ${kettle_project.dir}/lib/jxl-2.6.12.jar       commons-dbcp     commons-dbcp     1.4     system     ${kettle_project.dir}/lib/commons-dbcp-1.4.jar       commons-pool     commons-pool     1.5.7     system     ${kettle_project.dir}/lib/commons-pool-1.5.7.jar 
　　以上使用本地kettle中的包，本地kettle路径lib如下
　　导入kettle-password-encoder-plugins.xml文件,放在根目录之下，如图
　　      Kettle Password Encoder     org.pentaho.support.encryption.KettleTwoWayPasswordEncoder  
　　Kettle工具类
　　作业路径
　　service
　　@Value(＂${kettle.script.path}＂) private String dirPath;  public void runKtr(String trans_name){     try{         KettleEnvironment.init();         TransMeta transMeta=new TransMeta(dirPath+trans_name+＂.ktr＂);         Trans trans=new Trans(transMeta);         trans.execute(null);         trans.waitUntilFinished();         //System.out.println(＂---------dzz＂);     }catch(KettleException e){         e.printStackTrace();     } }  public void runKjb(String job_name,Map params){     try{         KettleEnvironment.init();         JobMeta jm=new JobMeta(dirPath+job_name+＂.kjb＂,null);         Job job=new Job(null,jm);         if(params!=null){             Iterator> entries=params.entrySet().iterator();             while(entries.hasNext()){                 Map.Entry entry=entries.next();                 job.setVariable(entry.getKey(),entry.getValue());//设置变量                 //job.setParameterValue(entry.getKey(),entry.getValue());                 //System.out.println(＂------1---dzz--＂+entry.toString());             }         }         job.start();         //Result result=new Result();         //job.execute(0,result);         job.waitUntilFinished();          //System.out.println(＂------result---dzz＂+result.toString());     }catch(KettleException e){         e.printStackTrace();     } }
　　controller
　　内容如下 //-------------------------------------------     @ResponseBody     @RequestMapping(＂/toKettle/trans/{trans_name}＂)     public String toKettle_tran(@PathVariable(＂trans_name＂) String trans_name)     {         kettleservice.runKtr(trans_name);         return ＂kettle trans finished＂;     }      @ResponseBody     @RequestMapping(＂/toKettle/job/{job_name}＂)     public String toKettle_job(@PathVariable(＂job_name＂) String job_name)     {         Map map=new HashMap();         map.put(＂filename＂,＂结算主单11＂);         //map.put(＂filename2＂,＂结算主单22＂);         kettleservice.runKjb(job_name,map);         return ＂kettle job finished＂;     }
　　执行
　　2023-2-8