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