package org.springblade.es.service;
|
|
import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
|
import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
|
import org.elasticsearch.client.RequestOptions;
|
import org.elasticsearch.client.RestHighLevelClient;
|
import org.elasticsearch.xcontent.XContentBuilder;
|
import org.elasticsearch.xcontent.json.JsonXContent;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.io.IOException;
|
|
@Service
|
public class ElasticsearchIndexService {
|
|
@Autowired
|
private RestHighLevelClient client;
|
|
public void createIndex() throws IOException {
|
CreateIndexRequest request = new CreateIndexRequest("your_index");
|
|
XContentBuilder builder = JsonXContent.contentBuilder()
|
.startObject()
|
.startObject("properties")
|
.startObject("field1").field("type", "text").endObject()
|
.startObject("field2").field("type", "text").endObject()
|
// ... 定义其他字段
|
.endObject()
|
.endObject();
|
|
request.mapping("_doc", builder);
|
CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
|
boolean acknowledged = createIndexResponse.isAcknowledged();
|
System.out.println(acknowledged);
|
}
|
}
|
