如何在Java集成测试中清除Elasticsearch的所有数据？

我有一个基于Micronaut的应用，使用Java Client API连接Elasticsearch，通过ElasticsearchClient进行数据的存储与查询。

我正在使用@MicronautTest注解编写集成测试用例，通过docker-compose.yml启动Docker容器，配置如下：

version: "3.0"

services:
  elasticsearch:
    container_name: es-container
    image: docker.elastic.co/elasticsearch/elasticsearch:7.16.0
    environment:
      - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
      - discovery.type=single-node
      - node.store.allow_mmap=false
      - xpack.security.enabled=false
    ports:
      - "9200:9200"

当前测试类存在的问题是：每个测试用例都会插入数据，但之前的测试数据未被清理，导致部分测试用例结果异常。请问如何在每个测试用例执行前删除Elasticsearch中的所有数据？

测试类代码 #

@MicronautTest
public class ElasticSearchTest {

  @Autowired
  private MockMvc mockMvc;

  @Test
  public void test1() {

    // 插入测试数据到ElasticSearch

    // 调用mockmvc API并断言响应
   }

  @Test
  public void test2()  {
   // 插入测试数据到ElasticSearch
  

  // 调用mockmvc API并断言响应
   }
 }

可以通过以下几种方式在每个测试用例执行前清理Elasticsearch数据：

1. 用JUnit @BeforeEach执行前置清理 #

注入ElasticsearchClient，在每个测试方法执行前调用API删除索引或清空数据：

@MicronautTest
public class ElasticSearchTest {

  @Autowired
  private MockMvc mockMvc;
  @Autowired
  private ElasticsearchClient esClient;

  @BeforeEach
  void setUp() throws IOException {
    // 方式1：删除所有业务索引（避免误删系统索引，可指定多个索引，用逗号分隔）
    esClient.indices().delete(d -> d.index("your-index-1,your-index-2"));

    // 方式2：清空指定索引数据（保留索引结构，适合需要保留mapping的场景）
    // esClient.deleteByQuery(d -> d.index("your-index-name").query(q -> q.matchAll(m -> m)));
  }

  @Test
  public void test1() {
    // 插入测试数据到ElasticSearch
    // 调用mockmvc API并断言响应
   }

  @Test
  public void test2()  {
   // 插入测试数据到ElasticSearch
   // 调用mockmvc API并断言响应
   }
 }

2. 删除后重建指定索引 #

如果需要保留索引结构（比如自定义mapping），可以先删除已有索引再重新创建：

@BeforeEach
void setUp() throws IOException {
    String targetIndex = "test-index";
    // 判断索引是否存在，存在则删除
    if (esClient.indices().exists(e -> e.index(targetIndex)).value()) {
        esClient.indices().delete(d -> d.index(targetIndex));
    }
    // 重新创建索引（可在此处指定自定义mapping）
    esClient.indices().create(c -> c.index(targetIndex));
}

3. 使用Testcontainers隔离测试环境 #

直接为每个测试启动全新的Elasticsearch容器，天然隔离测试数据，无需手动清理：

@Testcontainers
@MicronautTest
public class ElasticSearchTest {

  @Container
  private static final ElasticsearchContainer esContainer = new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:7.16.0")
          .withEnv("ES_JAVA_OPTS", "-Xms512m -Xmx512m")
          .withEnv("discovery.type", "single-node")
          .withEnv("node.store.allow_mmap", "false")
          .withEnv("xpack.security.enabled", "false")
          .withExposedPorts(9200);

  @Autowired
  private MockMvc mockMvc;
  @Autowired
  private ElasticsearchClient esClient;

  // 测试方法...
}

需添加Testcontainers相关依赖（以Gradle为例）：

testImplementation "org.testcontainers:elasticsearch:1.19.0"
testImplementation "io.micronaut.test:micronaut-test-testcontainers"

内容的提问来源于stack exchange，提问作者Ryuzaki L