java - 如何从 Java 使用数据库运行 PDI 转换？

Question

我正在尝试从 Java 运行涉及数据库(任何数据库，但更喜欢 noSQL 数据库)的 PDI 转换。

我试过使用 mongodb 和 cassandradb，但缺少插件，我已经在这里问过:Running PDI Kettle on Java - Mongodb Step Missing Plugins , 但还没有人回复。

我也尝试过使用 PostgreSQL 切换到 SQL DB，但它仍然不起作用。从我所做的研究来看，我认为这是因为我没有彻底从 Java 连接数据库，但我还没有找到任何适合我的教程或方向。我已尝试按照此博客中的说明进行操作:http://ameethpaatil.blogspot.co.id/2010/11/pentaho-data-integration-java-maven.html : 但仍然有一些关于存储库的问题(因为我没有，但似乎需要)。

当我从 Spoon 运行它时，转换很好。只有当我从 Java 运行它时它才会失败。

任何人都可以帮助我如何运行涉及数据库的 PDI 转换？我哪里出错了？

有没有人成功地运行涉及 noSQL 和 SQL 数据库的 PDI 转换？你用的什么数据库？

对不起，如果我问了太多问题，我很绝望。任何类型的信息将不胜感激。谢谢。

Answer 1

从 Java 执行 PDI 作业非常简单。您只需要导入所有必要的 jar 文件(用于数据库)，然后调用 kettle 类。最好的方法显然是使用“Maven”来控制依赖关系。在 maven pom.xml 文件中，调用数据库驱动即可。

假设您使用 pentaho v5.0.0GA 和数据库作为 PostgreSQL，示例 Maven 文件如下所示:

<dependencies>
    <!-- Pentaho Kettle Core dependencies development -->
    <dependency>
        <groupId>pentaho-kettle</groupId>
        <artifactId>kettle-core</artifactId>
        <version>5.0.0.1</version>
    </dependency>
    <dependency>
        <groupId>pentaho-kettle</groupId>
        <artifactId>kettle-dbdialog</artifactId>
        <version>5.0.0.1</version>
    </dependency>
    <dependency>
        <groupId>pentaho-kettle</groupId>
        <artifactId>kettle-engine</artifactId>
        <version>5.0.0.1</version>
    </dependency>
    <dependency>
        <groupId>pentaho-kettle</groupId>
        <artifactId>kettle-ui-swt</artifactId>
        <version>5.0.0.1</version>
    </dependency>
    <dependency>
        <groupId>pentaho-kettle</groupId>
        <artifactId>kettle5-log4j-plugin</artifactId>
        <version>5.0.0.1</version>
    </dependency>

    <!-- The database dependency files. Use it if your kettle file involves database connectivity. -->
    <dependency>
        <groupId>postgresql</groupId>
        <artifactId>postgresql</artifactId>
        <version>9.1-902.jdbc4</version>
    </dependency>

可以查看my blog for more .它适用于数据库连接。

希望这有帮助:)