java - 使用 ControllerService 进行 NiFi 处理器 JUnit 测试

Question

我正在开发一个NiFi处理器，想用JUnit测试它，但Processor的属性之一是ControllerService，即DBCPConnectionPool，但我不知道如何将此服务添加到JUnit测试中？

我尝试 new DBCPConnectionPool()，但没有这样命名的对象，尽管我已将所有依赖项添加到我的 pom 文件中，如下所示:

    <dependency>
             <groupId>org.apache.nifi</groupId>
             <artifactId>nifi-dbcp-service-api</artifactId>
         </dependency>
         <dependency>
             <groupId>org.apache.nifi</groupId>
             <artifactId>nifi-utils</artifactId>
         </dependency>
         <dependency>
             <groupId>org.apache.nifi</groupId>
             <artifactId>nifi-standard-services-api-nar</artifactId>
             <type>nar</type>
         </dependency>
         <dependency>
             <groupId>org.apache.nifi</groupId>
             <artifactId>nifi-dbcp-service-api</artifactId>
         </dependency>
        <dependency>
            <groupId>org.apache.nifi</groupId>
            <artifactId>nifi-mock</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.nifi</groupId>
            <artifactId>nifi-api</artifactId>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.nifi</groupId>
            <artifactId>nifi-processor-utils</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.nifi</groupId>
            <artifactId>nifi-utils</artifactId>
        </dependency>
                <dependency>
            <groupId>org.apache.nifi</groupId>
            <artifactId>nifi-dbcp-service-api</artifactId>
        </dependency>

runner.addControllerService(...);

请就如何编写此单元测试提供一些建议，谢谢。

Answer 1

看起来您两次包含了 nifi-dbcp-service-api 模块，但其中之一应该是 nifi-dbcp-service，其中包含实现类。

然后看DBCPServiceTest有关如何在单元测试中使用 DBCPConnectionPool 的示例。