重新索引嵌入式elasticsearch

import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;

import java.io.IOException;
import java.util.List;

public class ReindexExample {

    public static void main(String[] args) {
        RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http")));

        try {
            // 假设我们有一个旧索引 oldIndex 和一个新索引 newIndex
            String oldIndex = "old_index";
            String newIndex = "new_index";

            // 获取旧索引的所有文档
            SearchRequest searchRequest = new SearchRequest(oldIndex);
            SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
            SearchHit[] searchHits = searchResponse.getHits().getHits();

            // 创建批量请求
            BulkRequest bulkRequest = new BulkRequest();

            for (SearchHit hit : searchHits) {
                String sourceAsString = hit.getSourceAsString();
                IndexRequest indexRequest = new IndexRequest(newIndex)
                        .id(hit.getId())
                        .source(sourceAsString, XContentType.JSON);
                bulkRequest.add(indexRequest);
            }

            // 执行批量请求
            BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);

            if (bulkResponse.hasFailures()) {
                System.out.println("Reindexing failed: " + bulkResponse.buildFailureMessage());
            } else {
                System.out.println("Reindexing completed successfully");
            }

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}