Kettle 学习之从 .ktr 文件生成transMeta对象-阿里云开发者社区

Kettle 学习之从 .ktr 文件生成transMeta对象

2017-10-12 3632

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介：

https://github.com/pentaho/pdi-sdk-plugins/blob/master/kettle-sdk-embedding-samples/src/org/pentaho/di/sdk/samples/embedding/RunningTransformations.java

1，在DI设计器中设计好转换之后，该转换会以 .ktr 文件的形式持久存储到本地磁盘。并且Kettle提供了方法调用使得能从 .ktr 文件解析出 transMeta对象。而transMeta对象就是表征转换运行的一个JAVA对象。

2，从 .ktr 文件解析出transMeta对象非常简单，首先要进行运行环境的初始化。否则会报一个 DBCache 类的运行时错误。这个类的对象在创建transMeta对象时会用到。

try {
            KettleEnvironment.init();
        } catch (KettleException e) {
            e.printStackTrace();
            return;
        }

transMeta = new TransMeta(ktr, (Repository) null);

3，transMeta 对象是不能序列化的。因为TransMeta类里面有许多未实现Serializable接口的属性，如：

因此，要想传递transMeta对象，除了上面说到的从 .ktr 文件来解析，还有就是将 transMeta对象转成 String对象，这可以通过 String transMetaXML = transMeta.getXML(); 来完成；然后，再将transMetaXML 保存成文件的形式

saveMetaString(this.transMetaXML, fname)//将transMetaXML 保存成文件

readTransMetaFromFile(fname);//从该文件中解析出transMeta对象
----------------------------------------------------------------------------
private boolean saveMetaString( String transMetaString, String fname)
    {
        boolean saved = false;
        
        String xml = XMLHandler.getXMLHeader() + transMetaString;
        try
        {
            //write trans meta string into a tmp file fname
            DataOutputStream dos = new DataOutputStream(KettleVFS.getOutputStream(fname, false));
            dos.write(xml.getBytes(Const.XML_ENCODING));
            dos.close();
            saved = true;
        } catch( KettleFileException e )
        {
            e.printStackTrace();
        } catch( UnsupportedEncodingException e )
        {
            e.printStackTrace();
        } catch( IOException e )
        {
            e.printStackTrace();
        }
        return saved;
    }

private void readTransMetaFromFile(String fname)
    {
        try
        {
            //rebuild a TransMeta object from file
            Document document = XMLHandler.loadXMLFile(fname);
            Node root = document.getDocumentElement();
            if( transMeta == null )
            {
                transMeta = new TransMeta();
                transMeta.loadXML(root, fname, null, null, true, new Variables(), null);
            }
        } catch( KettleXMLException e )
        {
            e.printStackTrace();
        } catch( KettleMissingPluginsException e )
        {
            e.printStackTrace();
        }
        
    }