通过了两个测试,但Elasticsearch只显示了第一个测试的结果



我得到了以下两个测试:

@Test
    public void shouldCreateSingleBookEntityWithRepository(){
        //given
        Book book = Book.builder().id("1").title("Clean Code").build();
        IndexQuery indexQuery = getIndexQuery(book);
        //when
        String documentId = bookService.saveBook(indexQuery);
        //then
        assertThat(bookService.findOne(book.getId()), is(notNullValue()));
        assertThat(bookService.findOne(book.getId()).getId(), is(documentId));
    }
    @Test
    public void shouldCheckAllDocumentsPresenceAfterInsertSingleThreaded(){
        //given
        List<IndexQuery> indexQueries = new ArrayList<>();
        indexQueries.add(Book.builder().id("1").title("Learn Scala").build().getIndexQuery());
        indexQueries.add(Book.builder().id("2").title("Clean Code").build().getIndexQuery());
        indexQueries.add(Book.builder().id("3").title("Head First: JPA").build().getIndexQuery());
        indexQueries.add(Book.builder().id("4").title("Effective Java").build().getIndexQuery());
        bookService.saveBulkOfBooks(indexQueries);
        SearchQuery searchQuery = new NativeSearchQueryBuilder()
                .withIndices(INDEX_NAME)
                .withTypes(BOOK_TYPE_NAME)
                .withQuery(matchAllQuery())
                .build();
        //when
        Long bookCount = elasticsearchTemplate.count(searchQuery);
        System.out.print("nn##########################################n"
                +indexQueries.size()+bookCount+ bookService.findOne("2").getTitle()+
                "n####################################################nn");
        //then
        assertThat(bookCount, is(Long.valueOf(indexQueries.size())));
        assertThat(bookService.findOne("1").getTitle(), is("Learn Scala"));
        assertThat(bookService.findOne("2").getTitle(), is("Clean Code"));
        assertThat(bookService.findOne("3").getTitle(), is("Head First: JPA"));
        assertThat(bookService.findOne("4").getTitle(), is("Effective Java"));
    }

每次我运行两个测试时,它们通过。然而,存储在ES中的结果仅代表一个book表单第一次测试。

GET /bookshop/book/_search
{
   "took": 34,
   "timed_out": false,
   "_shards": {
      "total": 2,
      "successful": 2,
      "failed": 0
   },
   "hits": {
      "total": 1,
      "max_score": 1,
      "hits": [
         {
            "_index": "bookshop",
            "_type": "book",
            "_id": "1",
            "_score": 1,
            "_source": {
               "title": "Clean Code",
               "id": "1"
            }
         }
      ]
   }
}

当我忽略第一个测试时,我从ES的第二个测试中得到了4本书的结果。

我只得到@Before方法在我的测试用例

@Before
    public void before() {
         elasticsearchTemplate.deleteIndex(Book.class);
         elasticsearchTemplate.createIndex(Book.class);
         elasticsearchTemplate.putMapping(Book.class);
         elasticsearchTemplate.refresh(Book.class);
    }

为什么测试通过了,但是ES只显示了第一次测试的一个文档本?

这是因为带有@Before注释的方法将在任何标有@Test的方法之前执行。您可以尝试使用@BeforeClass。但是,我在使用@BeforeClass时可以看到的问题是,您无法在那里访问elasticsearchTemplate,该方法必须是static

您可以使用@PostConstruct代替。例如

@PostConstruct
public void init() {
    elasticsearchTemplate.deleteIndex(Book.class);
    elasticsearchTemplate.createIndex(Book.class);
    elasticsearchTemplate.putMapping(Book.class);
    elasticsearchTemplate.refresh(Book.class);
}

相关内容

最新更新