基于Java High Level Client的Elasticsearch客户端的常用操作代码

package com.elastic.org.cn; import com.google.gson.Gson; import com.elastic.org.cn.entity.CarType; import com.elastic.org.cn.entity.Product; import com.elastic.org.cn.service.CarSerialBrandService; import com.elastic.org.cn.service.CarTypeService; import com.elastic.org.cn.service.ProductService; import com.elastic.org.cn.util.ESClient; import lombok.SneakyThrows; import org.apache.http.HttpHost; import org.elasticsearch.action.ActionListener; import org.elasticsearch.action.admin.indices.alias.Alias; import org.elasticsearch.action.admin.indices.create.CreateIndexRequest; import org.elasticsearch.action.admin.indices.create.CreateIndexResponse; import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; import org.elasticsearch.action.bulk.BulkRequest; import org.elasticsearch.action.bulk.BulkResponse; import org.elasticsearch.action.delete.DeleteRequest; import org.elasticsearch.action.delete.DeleteResponse; import org.elasticsearch.action.get.*; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.support.master.AcknowledgedResponse; import org.elasticsearch.action.update.UpdateResponse; import org.elasticsearch.client.*; import org.elasticsearch.client.indices.GetIndexRequest; import org.elasticsearch.client.indices.GetIndexResponse; import org.elasticsearch.client.sniff.ElasticsearchNodesSniffer; import org.elasticsearch.client.sniff.NodesSniffer; import org.elasticsearch.client.sniff.SniffOnFailureListener; import org.elasticsearch.client.sniff.Sniffer; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.TransportAddress; import org.elasticsearch.common.unit.TimeValue; import org.elasticsearch.common.xcontent.XContentFactory; import org.elasticsearch.common.xcontent.XContentType; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.index.reindex.BulkByScrollResponse; import org.elasticsearch.index.reindex.UpdateByQueryRequest; import org.elasticsearch.script.Script; import org.elasticsearch.script.ScriptType; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHits; import org.elasticsearch.search.aggregations.Aggregation; import org.elasticsearch.search.aggregations.AggregationBuilders; import org.elasticsearch.search.aggregations.bucket.histogram.DateHistogramInterval; import org.elasticsearch.search.aggregations.bucket.histogram.Histogram; import org.elasticsearch.search.aggregations.bucket.terms.StringTerms; import org.elasticsearch.search.aggregations.metrics.Avg; import org.elasticsearch.search.fetch.subphase.FetchSourceContext; import org.elasticsearch.transport.client.PreBuiltTransportClient; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest; import java.io.IOException; import java.util.*; import javax.annotation.Resource; import java.net.InetAddress; import java.time.format.DateTimeFormatter; @SpringBootTest class ESApplicationTests { @Resource private ProductService service; @Resource private CarSerialBrandService carService; @Resource private CarTypeService carTypeService; //region crud @Test @SneakyThrows void esCRUD() { Settings settings = Settings.builder() .put("cluster.name", "elasticsearch").build(); TransportClient client = new PreBuiltTransportClient(settings) // TransportClient client = new PreBuiltTransportClient(Settings.EMPTY) .addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"), 9300)); // 通讯端口号 //导入数据 create(client); //查询 get(client); getAll(client); update(client); delete(client); client.close(); System.out.println(client); //Add transport addresses and do something with the client... } //region 创建索引 @SneakyThrows private void create(TransportClient client) { List<Product> list = service.list(); for (Product item : list) { System.out.println(item.getDate().toLocalDateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); IndexResponse response = client.prepareIndex("product", "_doc", item.getId().toString()) .setSource(XContentFactory.jsonBuilder() .startObject() .field("name", item.getName()) .field("desc", item.getDesc()) .field("price", item.getPrice()) .field("date", item.getDate().toLocalDateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) .field("tags", item.getTags().replace("\"", "").split(",")) .endObject()) .get(); System.out.println(response.getResult()); } } //endregion //region 根据Id查找 /* * 功能描述: <br> * 〈〉 * @Param: [client] * @Return: void * @Author: wulei * @Date: 2020/6/16 23:28 */ @SneakyThrows private void get(TransportClient client) { GetResponse response = client.prepareGet("product", "_doc", "1").get(); String index = response.getIndex();//获取索引名称 String type = response.getType();//获取索引类型 String id = response.getId();//获取索引id System.out.println("index:" + index); System.out.println("type:" + type); System.out.println("id:" + id); System.out.println(response.getSourceAsString()); } //endregion //region 查询所有文档 private void getAll(TransportClient client) { SearchResponse response = client.prepareSearch("product") .get(); SearchHits searchHits = response.getHits(); SearchHit[] hits = searchHits.getHits(); for (SearchHit hit : hits) { String res = hit.getSourceAsString(); System.out.println("res" + res); } } //endregion //region 更新文档 @SneakyThrows private void update(TransportClient client) { UpdateResponse response = client.prepareUpdate("product", "_doc", "2") .setDoc(XContentFactory.jsonBuilder() .startObject() .field("name", "update name") .endObject()) .get(); System.out.println(response.getResult()); } //endregion //region 删除指定Id文档 @SneakyThrows private void delete(TransportClient client) { DeleteResponse response = client.prepareDelete("product", "_doc", "2").get(); System.out.println(response.getResult()); } //endregion //endregion //region 多条件查找 /* * 功能描述: <br> * 〈多条件查找〉 * @Param: [] * @Return: void * @Author: wulei * @Date: 2020/6/17 10:02 */ @Test @SneakyThrows void multiSearch() { TransportClient client = new PreBuiltTransportClient(Settings.EMPTY) .addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"), 9300)); SearchResponse response = client.prepareSearch("product") .setQuery(QueryBuilders.termQuery("name", "xiaomi"))//Query .setPostFilter(QueryBuilders.rangeQuery("price").from(0).to(4000)) .setFrom(1).setSize(2) .get(); SearchHits searchHits = response.getHits(); SearchHit[] hits = searchHits.getHits(); for (SearchHit hit : hits) { String res = hit.getSourceAsString(); System.out.println("res" + res); } client.close(); } //endr