package org.springblade.es.service;
|
|
import org.elasticsearch.client.RequestOptions;
|
import org.elasticsearch.client.RestHighLevelClient;
|
import org.elasticsearch.client.indices.CreateIndexRequest;
|
import org.elasticsearch.client.indices.GetIndexRequest;
|
import org.elasticsearch.xcontent.XContentType;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
@Service
|
public class ElasticsearchIndexInitializer {
|
|
@Autowired
|
private RestHighLevelClient client;
|
|
public void initializeIndex(String indexName, String mappingJson) {
|
try {
|
// 检查索引是否已存在
|
GetIndexRequest request = new GetIndexRequest(indexName);
|
boolean indexExists = client.indices().exists(request, RequestOptions.DEFAULT);
|
|
// 如果索引不存在，则创建索引并设置映射
|
if (!indexExists) {
|
CreateIndexRequest createIndexRequest = new CreateIndexRequest(indexName);
|
createIndexRequest.mapping(mappingJson, XContentType.JSON);
|
client.indices().create(createIndexRequest, RequestOptions.DEFAULT);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
