- 創(chuàng)建索引
- 創(chuàng)建索引別名
- 索引的相關設置
- 查詢索引數(shù)據(jù)
- bulk 導入數(shù)據(jù)
- 持續(xù)更新中~
pom的坐標文章來源地址http://www.zghlxwxcb.cn/news/detail-807261.html
<!--es相關-->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<version>7.10.2</version> <!-- 請根據(jù)需要選擇合適的版本 -->
</dependency>
package es;
import com.alibaba.fastjson.JSONObject;
import org.apache.http.HttpHost;
import org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequest;
import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
import org.elasticsearch.search.sort.SortOrder;
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
public class EsConnectionExample {
public static void main(String[] args) throws IOException {
// 創(chuàng)建客戶端
// 連接es的地址
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(
new HttpHost("ip", 9200, "http"))); // 修改為你的ES地址和端口
//創(chuàng)建索引
CreateIndexRequest createIndexRequest = new CreateIndexRequest("my_index"); // 創(chuàng)建名為"my_index"的索引
createIndexRequest.settings(Settings.builder()
.put("index.number_of_shards", 3) // 設置分片數(shù)
.put("index.number_of_replicas", 2) // 設置副本數(shù)
);
CreateIndexResponse createIndexResponse = client.indices().create(createIndexRequest, RequestOptions.DEFAULT);
System.out.println("索引創(chuàng)建成功：" + createIndexResponse.isAcknowledged());
//給索引插入數(shù)據(jù)
Map<String, Object> data = new HashMap<>();
data.put("name", "huangi"); // 設置文檔標題
data.put("age", "18"); // 設置文檔內(nèi)容
IndexRequest indexRequest = new IndexRequest("my_index"); // 將數(shù)據(jù)插入到"my_index"索引中
indexRequest.id("1"); // 設置文檔ID為1
indexRequest.source(data, XContentType.JSON); // 將數(shù)據(jù)轉(zhuǎn)換為JSON格式并設置到索引請求中
IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
System.out.println("數(shù)據(jù)插入成功：" + indexResponse.getResult().name().toLowerCase());
//---------------------------------------------------------------------
//查詢一個名叫my_index的索引下列是age，值為25的數(shù)據(jù)，不是格式化展示
// 構建查詢請求
// 創(chuàng)建搜索索引請求
SearchRequest searchRequest = new SearchRequest("my_index"); // "posts" 是 index 的名字
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(QueryBuilders.matchAllQuery()); // 查詢所有文檔
//searchSourceBuilder.sort("created_at", SortOrder.DESC); // 按 created_at 字段降序排序
searchSourceBuilder.highlighter(new HighlightBuilder().field("content").preTags("<em>").postTags("</em>")); // 對 content 字段進行高亮顯示
searchRequest.source(searchSourceBuilder);
// 執(zhí)行搜索并獲取響應
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
System.out.println("Total hits: " + searchResponse.getHits().getTotalHits().value);
Map<String, HighlightField> highlightFields = searchResponse.getHits().getHits()[0].getHighlightFields();
for (HighlightField highlightField : highlightFields.values()) {
System.out.println("輸出："+highlightField.fragments()[0].string()); // 輸出高亮顯示的內(nèi)容片段
}
//---------------------------------------------------------------------
//查詢一個名叫my_index的索引下列是age，值為25的數(shù)據(jù)，并格式化展示
// 構建查詢請求
SearchRequest searchRequest1 = new SearchRequest("my_index"); // 將"your_index"替換為您要查詢的索引名稱
SearchSourceBuilder searchSourceBuilder1 = new SearchSourceBuilder();
searchSourceBuilder1.query(QueryBuilders.matchQuery("age", "25")); // 將"field_name"替換為您要查詢的字段名稱，將"query_value"替換為您要匹配的查詢值
searchRequest1.source(searchSourceBuilder1);
// 執(zhí)行查詢請求并獲取響應
SearchResponse searchResponse1 = client.search(searchRequest1, RequestOptions.DEFAULT);
// 處理響應數(shù)據(jù)（例如打印結果）
System.out.println("Total hits: " + searchResponse1.getHits().getTotalHits().value);
System.out.println("Hits: " + JSONObject.toJSONString(searchResponse1.getHits().getHits()));
// 處理響應數(shù)據(jù)（例如打印結果）
for (SearchHit hit : searchResponse1.getHits()) {
HighlightField highlightField = hit.getHighlightFields().get("field_name"); // 將"field_name"替換為您要高亮的字段名稱
String highlightedValue = highlightField != null ? highlightField.getFragments()[0].string() : hit.getSourceAsString(); // 如果存在高亮結果，則獲取第一個片段的值，否則獲取原始字段的值
System.out.println(highlightedValue); // 打印字段的值
}
//---------------------------------------------------------------------
//創(chuàng)建索引別名
// 索引名稱和別名
String indexName = "my_index";
String aliasName = "my_index_alias";
// 創(chuàng)建一個別名請求
IndicesAliasesRequest request = new IndicesAliasesRequest();
IndicesAliasesRequest.AliasActions aliasAction = new IndicesAliasesRequest.AliasActions(IndicesAliasesRequest.AliasActions.Type.ADD)
.index(indexName)
.alias(aliasName);
request.addAliasAction(aliasAction);
// 執(zhí)行請求
AcknowledgedResponse indicesAliasesResponse = client.indices().updateAliases(request, RequestOptions.DEFAULT);
// 檢查操作是否成功
boolean acknowledged = indicesAliasesResponse.isAcknowledged();
if (acknowledged) {
System.out.println("Alias was successfully added to the index.");
} else {
System.out.println("Alias addition was not acknowledged.");
}
//---------------------------------------------------------------------
//bulk 導入
try (BufferedReader reader = new BufferedReader(new FileReader("user.json"))) {
String line;
// 構造 BulkRequest 對象并添加要導入的文檔
BulkRequest request1 = new BulkRequest();
while ((line = reader.readLine()) != null) {
XContentBuilder builder = XContentFactory.jsonBuilder()
.startObject()
.field("name", line)
.field("age", line)
.field("sex" , line)
.field("telephone", line)
.endObject();
IndexRequest indexRequest1 = new IndexRequest("my_index")
.source(builder);
request1.add(indexRequest1);
}
// 發(fā)送 BulkRequest 請求
BulkResponse response = client.bulk(request1, RequestOptions.DEFAULT);
if (response.hasFailures()) {
System.out.println("Failed to import documents.");
} else {
System.out.println("Documents imported successfully!");
}
} catch (IOException e) {
e.printStackTrace();
} finally {
// 關閉 ElasticSearch 客戶端連接
client.close();
}
// 關閉客戶端連接
client.close();
}
}
文章來源：http://www.zghlxwxcb.cn/news/detail-807261.html
到了這里，關于java 操作es 的基本操作的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章，希望大家以后多多支持TOY模板網(wǎng)！
