使用示例 #

    RestHighLevelClient client = initEasysearchClient(userName, password);

    // 创建索引
    CreateIndexRequest createIndexRequest = new CreateIndexRequest("test-index");
    createIndexRequest.settings(Settings.builder()
        .put("index.number_of_shards", 1)
        .put("index.number_of_replicas", 1)
    );
    client.indices().create(createIndexRequest, RequestOptions.DEFAULT);

    // 批量写入
    BulkRequest bulkRequest = new BulkRequest();
    for (int i = 0; i < 10; i++) {
      IndexRequest indexRequest = new IndexRequest("test-index") // 替换为您的索引名称
          .id(Integer.toString(i)) // 文档ID
          .source("{\"field1\":\"value" + i + "\"}", XContentType.JSON);
      bulkRequest.add(indexRequest);
    }
    BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
    if (bulkResponse.hasFailures()) {
      System.out.println("Bulk operation had failures: " + bulkResponse.buildFailureMessage());
    } else {
      System.out.println("Bulk operation completed successfully");
    }

    // GET操作
    GetRequest getRequest = new GetRequest("test-index", "1");
    GetResponse response = client.get(getRequest, RequestOptions.DEFAULT);
    System.out.println(response.getSourceAsString());

    // 删除文档
    DeleteRequest deleteDocumentRequest = new DeleteRequest("test-index", "1");
    DeleteResponse deleteResponse = client.delete(deleteDocumentRequest, RequestOptions.DEFAULT);
    System.out.println(Strings.toString(deleteResponse));

    // 删除索引
    DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest("test-index"); //Index name.
    AcknowledgedResponse deleteIndexResponse = client.indices().delete(deleteIndexRequest, RequestOptions.DEFAULT);
    System.out.println(Strings.toString(deleteIndexResponse));
    
    // 关闭客户端，释放资源
    client.close();