模拟给出错误的服务类方法

Question

我是新的mockito和jUnit我不明白为什么我得到错误和如何模仿这个服务类方法

请帮我解决这个问题。是否需要模拟可分页和切片对象。为什么在嘲笑PartnerEventRepository之后，我也会说

“需要但未调用：partnerEventRepository.findAll（Cassandra页面请求[编号：0，大小5，排序：未排序，分页状态：null]）

@Service
public class PartnerIndexServiceImpl implements PartnerIndexService {


    private Logger logger = LoggerFactory.getLogger(this.getClass());


    private EventHandler<Event<Entity>, Index> indexEventHandler;
    private PartnerProjectionQueryRepository queryRepository;
    private PartnerEventRepository partnerEventRepository;
    private MessageSource msgSource;


    @Autowired
    private GlobalPartnerProjectionQueryRepository globalPartnerQueryRepo;

    @Autowired
    public PartnerIndexServiceImpl(PartnerProjectionQueryRepository queryRepository,
                              PartnerEventRepository partnerEventRepository,
                              @Qualifier(value = "partnerEventHandler") EventHandler<Event<Entity>, Index> indexEventHandler,
                              MessageSource msgSource) {
        this.queryRepository = queryRepository;
        this.partnerEventRepository = partnerEventRepository;
        this.indexEventHandler = indexEventHandler;
        this.msgSource = msgSource;
    }

    @Override
    public void partnerReIndexing() {
        logger.info("ReIndexing start time : "+new Date());

        List<PartnerEvent> partnerList = new ArrayList<>();
        Pageable pageable = CassandraPageRequest.of(0, 5);
        Slice<PartnerEvent> page = partnerEventRepository.findAll(pageable);
        partnerList.addAll(page.getContent());
        while (page.hasNext()){
            page = partnerEventRepository.findAll(page.nextPageable());
            partnerList.addAll(page.getContent());
        };

        if (partnerList != null) {
            partnerList.parallelStream().forEach(event -> {
                Index index = createPartnerProjection(event);
                indexEventHandler.reIndexEvent(event, index);
            });
        }
        logger.info("ReIndexing end time : "+new Date());
    }


    /*public Slice<PartnerEvent> getPartnersOnBatch(Pageable pageable){
        Slice<PartnerEvent> events = partnerEventRepository.findAll(pageable);
        return events;
    }*/


    private Index createPartnerProjection(PartnerEvent event) {
        PartnerProjectionView.PartnerProjectViewBuilder builder = PartnerProjectionView.builder();

        Partner partner = (Partner) event.getEntity();

        if (partner.getGlobalPartnerRef() != null) {
            String uuid = partner.getGlobalPartnerRef().getUuid();
            if (uuid != null && globalPartnerQueryRepo.findByIdentifier(uuid) == null) {
                throw new BadRequestException("105", "Global Partner with uuid: " + uuid + " doesn't exist");
            }
        }

        builder.uuid(partner.getId());

        List<Attributes> paList = partner.getPartnerAttributes().stream()
                .filter(pa -> pa.getAttributeGroup().equalsIgnoreCase(GROUP_NAME_PARTNER)).map(pa -> pa.getAttributes())
                .findFirst().orElse(null);

        if (paList != null && !paList.isEmpty()) {
            paList.stream().forEach(a -> {
                if ("partnerTaxRegime".equalsIgnoreCase(a.getName())) {
                    builder.partnerTaxRegion(a.getValues().stream()
                            .filter(w -> "*".equals(w.getLang()) || "en".equalsIgnoreCase(w.getLang()))
                            .map(w -> w.getValue()).findFirst().orElse(null));
                } else if ("taxOrganisationType".equalsIgnoreCase(a.getName())) {
                    builder.taxOrganisationType(a.getValues().stream()
                            .filter(w -> "*".equals(w.getLang()) || "en".equalsIgnoreCase(w.getLang()))
                            .map(w -> w.getValue()).findFirst().orElse(null));
                } else if ("partnerStatus".equalsIgnoreCase(a.getName())) {
                    builder.status(a.getValues().stream()
                            .filter(w -> "*".equals(w.getLang()) || "en".equalsIgnoreCase(w.getLang()))
                            .map(w -> w.getValue()).findFirst().orElse(null));
                } else if ("partnername".equalsIgnoreCase(a.getName())) {
                    builder.name(a.getValues().stream()
                            .filter(w -> "*".equals(w.getLang()) || "en".equalsIgnoreCase(w.getLang()))
                            .map(w -> w.getValue()).findFirst().orElse(null));
                } else if ("partnernumber".equalsIgnoreCase(a.getName())) {
                    builder.number(a.getValues().stream()
                            .filter(w -> "*".equals(w.getLang()) || "en".equalsIgnoreCase(w.getLang()))
                            .map(w -> w.getValue()).findFirst().orElse(null));
                }
            });
        }

        return builder.build();
    }

}

莫基托

@RunWith(SpringRunner.class)
public class PartnerIndexServiceImplTest {

    @MockBean
    private PartnerProjectionQueryRepository queryRepository;
    @MockBean
    private PartnerEventRepository partnerEventRepository;
    @MockBean
    private EventHandler<Event<Entity>, Index> partnerEventHandler;
    @MockBean
    private MessageSource msgSource;

    PartnerIndexService partnerService;

    @Before
    public void setup() {
        partnerService = new PartnerIndexServiceImpl(queryRepository, partnerEventRepository, partnerEventHandler,
                msgSource);
    }

    @Test
    public void partnerReIndexing_withPartnerEvent()throws Exception{


        Pageable page = CassandraPageRequest.of(0,5);



        when(partnerEventRepository.findAll(page)).thenReturn(new SliceImpl<>(Collections.EMPTY_LIST));
        verify(partnerEventRepository,times(1)).findAll(page);

    }

}

Answer 1

你把@Test称为“partnerReIndexing”，但我看不到对partnerService的调用。partnerReIndexing（）。这有用吗？

@Test
public void partnerReIndexing_withPartnerEvent()throws Exception{
    Pageable page = CassandraPageRequest.of(0,5);
    when(partnerEventRepository.findAll(page)).thenReturn(new SliceImpl<>(Collections.EMPTY_LIST));
    // HERE COMES THE NEW LINE, THAT "ACT" PART OF THE TEST:
    partnerService.partnerReIndexing();
    verify(partnerEventRepository,times(1)).findAll(page);
}