问题描述
我正在尝试为下面的 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 (将#修改为@)