如何解决Junit Mockito 测试用例使用 Jupiter for Hazelcast Jet Pipiline
我正在尝试为下面的 hazelcast Jet Pipeline 编写 Junit 测试用例。
我的组件:
@Component
public class UserJetJob extends AbstarctJetJob {
private static final String TABLE_NAME = "User";
@Autowired
private ClientConfig clientConfig;
@Value("${jdbc.connection_url}")
private String connectionUrl;
@Override
public Pipeline buildPipeline() {
Pipeline p = Pipeline.create();
p.readFrom(Sources.jdbc(connectionUrl,"SELECT * FROM " + TABLE_NAME,UserJetJob::buildUser))
.map(a -> Util.entry(a.getId(),a))
.writeTo(Sinks.remoteMap("userMap",clientConfig));
return p;
}
}
我正在为方法 JUnit
编写一个 public Pipeline buildPipeline()
测试用例,但由于结果集而失败。
@ExtendWith(MockitoExtension.class)
public class UserJetJobTest extends JetTestSupport {
@InjectMocks
UserJetJob userJetJob;
@Mock
private JetInstance jet;
@Mock
private ClientConfig clientConfig;
@Test
public void buildPipelineUser() {
Pipeline p = Mockito.mock(Pipeline.class);
// Mockito.when(p.readFrom(Sources.jdbc(Mockito.anyString(),Mockito.anyString(),Mockito.eq(ResultSet.class))).then
userJetJob.buildPipeline();
}
}
你能帮我写下 JUnit 测试用例吗?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。