28

我的单元/集成测试包括搜索功能测试。

我的想法是在每次测试之前都有空的搜索索引。所以，我试图删除setup方法索引中的所有元素（它是 Groovy 代码）：

Client client = searchConnection.client

SearchResponse response = client.prepareSearch("item")
    .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
    .setQuery(termQuery('name', 'test')) //tried also matchAllQuery()
    .setFrom(0).setSize(100).setExplain(false).execute().actionGet()

List<String> ids = response.hits.hits.collect {
    return it.id
}
client.close()

client = searchConnection.client

ids.each {
    DeleteResponse delete = client.prepareDelete("item", "item", it)
        .setOperationThreaded(false)
        .execute().actionGet()
}

client.close()

似乎它正在异步处理所有删除，所以我Thread.sleep(5000)在它之后添加了。如您所见，我试图打开/关闭连接几次 - 它在那里无济于事。

有时需要更多时间，有时需要超过 5 秒才能删除，有时找不到刚刚添加的数据（来自以前的测试）等问题。最烦人的是集成测试变得不稳定。把它放在Thread.sleep()任何可能的地方看起来不是很好的解决方案。

有什么方法可以提交最后的更改，或者锁定直到所有数据都被写入？

4

4 回答 4

33

找到解决方案：

IndicesAdminClient adminClient = searchConnection.client.admin().indices();
String indexName = "location";
DeleteIndexResponse delete = adminClient.delete(new DeleteIndexRequest(indexName)).actionGet()
if (!delete.isAcknowledged()) {
    log.error("Index {} wasn't deleted", indexName);
}

和

client.admin().indices().flush(new FlushRequest('location')).actionGet();

将新数据放入索引后。

于 2012-06-04T05:10:45.523 回答
30

首先，您不必通过对每个文档 ID 发出删除来清除所有数据。您可以通过查询匹配所有文档来删除所有数据http://www.elasticsearch.org/guide/reference/api/delete-by-query.html话虽如此，我也不建议这样做，因为它不是建议经常在大型文档集合上执行此操作（请参阅文档）。

你真正想做的是删除整个索引（它很快）http://www.elasticsearch.org/guide/reference/api/admin-indices-delete-index.html，重新创建它，放入数据，这是重要的是刷新索引以“提交”更改并使其可见。http://www.elasticsearch.org/guide/reference/api/admin-indices-refresh.html

我在测试中这样做，从来没有遇到过问题。

于 2011-11-05T20:32:49.590 回答
5
  1. 它不是异步调用（您可以添加一个侦听器并避免使用 actionGet 来获取异步调用）

  2. 通过以下方式删除所有项目：

    client.prepareDeleteByQuery(indexName).
            setQuery(QueryBuilders.matchAllQuery()).
            setTypes(indexType).
            execute().actionGet();

  3. 刷新索引以查看更改（仅在单元测试中需要）

于 2011-11-05T15:52:42.547 回答
0

我的想法是在每次测试之前都有空的搜索索引

所以在测试开始时创建一个新索引，不要重复使用旧索引。那你肯定是空的。在测试的拆解中，您可以删除测试索引。

有什么方法可以提交最后的更改，或者锁定直到所有数据都被写入？

不，ElasticSearch 没有事务或锁定。

如果您不想每次都创建新索引，请尝试添加一个循环来检查索引是否为空，然后等待并再次尝试，直到它是。

于 2011-11-05T10:11:34.053 回答