• Java(100):Java操作ES增删查(RestHighLevelClient)

    Java操作elasticsearch增删查(RestHighLevelClient)

    版本：elasticsearch7.14

    一、参考官网API

    1、Index API | Java REST Client [7.14] | Elastic

    https://www.elastic.co/guide/en/elasticsearch/client/java-rest/7.14/java-rest-high-document-index.html

    搜索：

    2、 Search API | Java REST Client [7.14] | Elastic

    https://www.elastic.co/guide/en/elasticsearch/client/java-rest/7.14/java-rest-high-search.html

    二、Java操作ES增删查(RestHighLevelClient)

    2.1、引用依赖

    RestHighLevelClient的maven依赖为（使用前必须添加相应依赖）

    

    org.elasticsearch.client
    elasticsearch-rest-high-level-client
    7.14.0

    注意：以上的依赖版本可以根据你使用的ES的版本来定，向下兼容，但是无法向上兼容

    2.2、创建ES连接和关闭连接

    1.     private RestHighLevelClient esRestClient = null;
    2.     
    3.     /**
    4.      * 创建客户端连接
    5.      */
    6.     public  void restClientConnect(String IP,int PORT){
    7.         RestHighLevelClient restClient=null;
    8.         try {
    9.             RestClientBuilder builder = RestClient.builder(new HttpHost(IP, PORT, "http"));
    10.             restClient= new RestHighLevelClient(builder);
    11.         }catch (Exception e){
    12.             log.error(e.toString());
    13.         }
    14.         this.esRestClient = restClient;
    15.     }
    16.  
    17.  
    18.     /**
    19.      * 关闭客户端
    20.      */
    21.     public void closeEs() {
    22.           try {
    23.               if(esRestClient !=null) {
    24.                   esRestClient.close();
    25.               }
    26.           }catch (IOException e){
    27.               e.printStackTrace();
    28.           }
    29.       }

    2.3、新增数据

    RestHighLevelClient 支持对ES的增删改查、批量操作

    1.    /**
    2.      * 往索引插入文档数据,随机id插入数据
    3.      * @param indexName  索引名称
    4.      * @param jsonStr  Json数据
    5.      */
    6.     public void addData(String indexName,String jsonStr){
    7.         addData(indexName,jsonStr,null);
    8.     }
    9.  
    10.     /**
    11.      * 往索引插入文档数据
    12.      * @param indexName  索引名称
    13.      * @param jsonStr  Json数据
    14.      * @param id  id
    15.      */
    16.  
    17.     public void addData(String indexName,String jsonStr,String id){
    18.         IndexRequest request = new IndexRequest(indexName);
    19.         if(id !=null){
    20.             request.id(id);
    21.         }
    22.         request.source(jsonStr, XContentType.JSON);
    23.         request.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);//插入完成后立即强制刷新索引
    24.         try {
    25.             IndexResponse response = esRestClient.index(request,RequestOptions.DEFAULT);
    26.             log.info("addData: "+response.getShardInfo()+" ,indexName："+indexName);
    27.  
    28.         } catch (Exception e) {
    29.             e.printStackTrace();
    30.         }
    31.     }

    2.4、查询数据

    查询支持直接查询和条件查询，由于ES是根据索引、文档类型和文档ID确定一个唯一的文档的，所以直接查询必须要有索引和类型还有ID。

    1.     /**
    2.      * 根据条件获取文档数据
    3.      * @param indexName   索引名称
    4.      */
    5.     public void getData(String indexName)  {
    6.         //1 创建搜索文档请求
    7.         SearchRequest searchRequest=new SearchRequest(indexName);  //请求索引
    8.         try{
    9.             // 2 执行检索
    10.             SearchResponse response = esRestClient.search(searchRequest, RequestOptions.DEFAULT);
    11.             // 3 分析响应结果
    12.             //System.out.println(response.toString());
    13.             //遍历数据
    14.             SearchHit[] hits = response.getHits().getHits();
    15.             for (SearchHit hit : hits) {
    16.                 Map sourceAsMap = hit.getSourceAsMap();
    17.                 log.info("getData: "+sourceAsMap.toString()+" ,indexName："+indexName);
    18.  
    19.             }
    20.         } catch (Exception e) {
    21.             e.printStackTrace();
    22.         }
    23.     }
    24.  
    25.     /**
    26.      * 根据条件获取文档数据
    27.      * @param indexName   索引名称
    28.      * @param key   查询字段
    29.      * @param value  查询值
    30.      */
    31.      public void getData(String indexName,String key,String value)  {
    32.          //1 创建搜索文档请求
    33.          SearchRequest searchRequest=new SearchRequest(indexName);  //请求索引
    34.          SearchSourceBuilder builder = new SearchSourceBuilder();
    35.          builder.query(QueryBuilders.matchQuery(key,value));
    36.          searchRequest.source(builder);
    37.          try{
    38.               // 2 执行检索
    39.               SearchResponse response = esRestClient.search(searchRequest, RequestOptions.DEFAULT);
    40.               // 3 分析响应结果
    41.              log.info("getData: "+response.toString());
    42.               //遍历数据
    43.               SearchHit[] hits = response.getHits().getHits();
    44.               for (SearchHit hit : hits) {
    45.                       //String sourceAsString = hit.getSourceAsString();
    46.                       //System.out.println(sourceAsString);
    47.                       Map sourceAsMap = hit.getSourceAsMap();
    48.                       log.info("getData: "+sourceAsMap+" ,indexName："+indexName);
    49.  
    50.               }
    51.          } catch (Exception e) {
    52.              e.printStackTrace();
    53.          }
    54.      }

    2.5、删除数据

    1.    /**
    2.      * 根据索引和id进行删除
    3.      * @param indexName  索引名称
    4.      * @param id id号
    5.      */
    6.     public void deleteData(String indexName,String id) {
    7.         //创建删除文档请求
    8.         DeleteRequest request = new DeleteRequest();
    9.  
    10.         //设置属性：指定要删除的索引及id值
    11.         DeleteRequest delete = request.index(indexName).id(id);
    12.         try {
    13.             //执行删除请求
    14.             DeleteResponse deleteResponse = esRestClient.delete(delete, RequestOptions.DEFAULT);
    15.             if(deleteResponse.getResult().toString().equals("DELETED")){
    16.                 log.info("deleteData,删除成功,indexName: "+indexName+",id: "+id);
    17.             }
    18.         }catch (IOException e){
    19.             e.printStackTrace();
    20.         }
    21.  
    22.     }
    23.  
    24.  
    25.     /**
    26.      * 根据条件进行删除
    27.      * @param indexName 索引名称
    28.      * @param key  字段
    29.      * @param value 值
    30.      */
    31.  
    32.     public void deleteData(String indexName,String key,String value) {
    33.         //1 设置条件
    34.         //设置删除条件: key = value
    35.         MatchQueryBuilder nameSelect = QueryBuilders.matchQuery(key, value);
    36.  
    37.         //通过QueryBuilders中的搜索逻辑
    38.         BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
    39.         queryBuilder.should(nameSelect);
    40.  
    41.         //2 通过DeleteByQueryRequest来构建删除请求，setQuery来装载条件，indices来指定索引
    42.         DeleteByQueryRequest deleteByQueryRequest = new DeleteByQueryRequest();
    43.         deleteByQueryRequest.setQuery(queryBuilder);
    44.         deleteByQueryRequest.indices(indexName);  //指定删除索引
    45.         try {
    46.             //3 通过deleteByQuery来发起删除请求
    47.             BulkByScrollResponse deleteResponse=esRestClient.deleteByQuery(deleteByQueryRequest , RequestOptions.DEFAULT);
    48.             if(deleteResponse.getDeleted() >=1){
    49.                 log.info("deleteData,删除成功，删除文档条数: "+deleteResponse.getDeleted()+" ,indexName："+indexName);
    50.             }
    51.         } catch (IOException e) {
    52.             e.printStackTrace();
    53.         }
    54.  
    55.     }

    三、代码示例

    1. package elasticsearch;
    2.  
    3. import org.apache.http.HttpHost;
    4. import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
    5.  
    6. import org.elasticsearch.client.indices.CreateIndexRequest;
    7. import org.elasticsearch.client.indices.CreateIndexResponse;
    8.  
    9. import org.elasticsearch.action.admin.indices.get.GetIndexRequest;
    10. import org.elasticsearch.action.delete.DeleteRequest;
    11. import org.elasticsearch.action.delete.DeleteResponse;
    12. import org.elasticsearch.action.index.IndexRequest;
    13. import org.elasticsearch.action.index.IndexResponse;
    14. import org.elasticsearch.action.search.SearchRequest;
    15. import org.elasticsearch.action.search.SearchResponse;
    16. import org.elasticsearch.action.support.WriteRequest;
    17. import org.elasticsearch.action.support.master.AcknowledgedResponse;
    18. import org.elasticsearch.client.*;
    19. import org.elasticsearch.common.xcontent.XContentType;
    20. import org.elasticsearch.index.query.BoolQueryBuilder;
    21. import org.elasticsearch.index.query.MatchQueryBuilder;
    22. import org.elasticsearch.index.query.QueryBuilders;
    23. import org.elasticsearch.index.reindex.BulkByScrollResponse;
    24. import org.elasticsearch.index.reindex.DeleteByQueryRequest;
    25. import org.elasticsearch.search.SearchHit;
    26. import org.elasticsearch.search.builder.SearchSourceBuilder;
    27. import org.slf4j.Logger;
    28. import org.slf4j.LoggerFactory;
    29.  
    30. import java.io.IOException;
    31. import java.util.Map;
    32.  
    33.  
    34. /**
    35.  * ClassName EsTest
    36.  * description EsTest
    37.  *
    38.  * @author : HMF
    39.  * date: 2022/8/18 9:35
    40.  **/
    41.  
    42.  
    43. public class EsTest {
    44.     protected static Logger log = LoggerFactory.getLogger(EsTest.class);
    45.     private RestHighLevelClient esRestClient = null;
    46.  
    47.     /**
    48.      * 创建客户端
    49.      */
    50.     public  void restClientConnect(String IP,int PORT){
    51.         RestHighLevelClient restClient=null;
    52.         try {
    53.             RestClientBuilder builder = RestClient.builder(new HttpHost(IP, PORT, "http"));
    54.             restClient= new RestHighLevelClient(builder);
    55.         }catch (Exception e){
    56.             log.error(e.toString());
    57.         }
    58.         this.esRestClient = restClient;
    59.     }
    60.  
    61.  
    62.     /**
    63.      * 往索引插入文档数据,随机id插入数据
    64.      * @param indexName  索引名称
    65.      * @param jsonStr  Json数据
    66.      */
    67.     public void addData(String indexName,String jsonStr){
    68.         addData(indexName,jsonStr,null);
    69.     }
    70.  
    71.     /**
    72.      * 往索引插入文档数据
    73.      * @param indexName  索引名称
    74.      * @param jsonStr  Json数据
    75.      * @param id  id
    76.      */
    77.  
    78.     public void addData(String indexName,String jsonStr,String id){
    79.         IndexRequest request = new IndexRequest(indexName);
    80.         if(id !=null){
    81.             request.id(id);
    82.         }
    83.         request.source(jsonStr, XContentType.JSON);
    84.         request.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);//插入完成后立即强制刷新索引
    85.         try {
    86.             IndexResponse response = esRestClient.index(request,RequestOptions.DEFAULT);
    87.             log.info("addData: "+response.getShardInfo()+" ,indexName："+indexName);
    88.  
    89.         } catch (Exception e) {
    90.             e.printStackTrace();
    91.         }
    92.     }
    93.  
    94.     /**
    95.      * 根据条件获取文档数据
    96.      * @param indexName   索引名称
    97.      */
    98.     public void getData(String indexName)  {
    99.         //1 创建搜索文档请求
    100.         SearchRequest searchRequest=new SearchRequest(indexName);  //请求索引
    101.         try{
    102.             // 2 执行检索
    103.             SearchResponse response = esRestClient.search(searchRequest, RequestOptions.DEFAULT);
    104.             // 3 分析响应结果
    105.             //System.out.println(response.toString());
    106.             //遍历数据
    107.             SearchHit[] hits = response.getHits().getHits();
    108.             for (SearchHit hit : hits) {
    109.                 Map sourceAsMap = hit.getSourceAsMap();
    110.                 log.info("getData: "+sourceAsMap.toString()+" ,indexName："+indexName);
    111.  
    112.             }
    113.         } catch (Exception e) {
    114.             e.printStackTrace();
    115.         }
    116.     }
    117.  
    118.     /**
    119.      * 根据条件获取文档数据
    120.      * @param indexName   索引名称
    121.      * @param key   查询字段
    122.      * @param value  查询值
    123.      */
    124.      public void getData(String indexName,String key,String value)  {
    125.          //1 创建搜索文档请求
    126.          SearchRequest searchRequest=new SearchRequest(indexName);  //请求索引
    127.          SearchSourceBuilder builder = new SearchSourceBuilder();
    128.          builder.query(QueryBuilders.matchQuery(key,value));
    129.          searchRequest.source(builder);
    130.          try{
    131.               // 2 执行检索
    132.               SearchResponse response = esRestClient.search(searchRequest, RequestOptions.DEFAULT);
    133.               // 3 分析响应结果
    134.              log.info("getData: "+response.toString());
    135.               //遍历数据
    136.               SearchHit[] hits = response.getHits().getHits();
    137.               for (SearchHit hit : hits) {
    138.                       //String sourceAsString = hit.getSourceAsString();
    139.                       //System.out.println(sourceAsString);
    140.                       Map sourceAsMap = hit.getSourceAsMap();
    141.                       log.info("getData: "+sourceAsMap+" ,indexName："+indexName);
    142.  
    143.               }
    144.          } catch (Exception e) {
    145.              e.printStackTrace();
    146.          }
    147.      }
    148.  
    149.     /**
    150.      * 根据索引和id进行删除
    151.      * @param indexName  索引名称
    152.      * @param id id号
    153.      */
    154.     public void deleteData(String indexName,String id) {
    155.         //创建删除文档请求
    156.         DeleteRequest request = new DeleteRequest();
    157.  
    158.         //设置属性：指定要删除的索引及id值
    159.         DeleteRequest delete = request.index(indexName).id(id);
    160.         try {
    161.             //执行删除请求
    162.             DeleteResponse deleteResponse = esRestClient.delete(delete, RequestOptions.DEFAULT);
    163.             if(deleteResponse.getResult().toString().equals("DELETED")){
    164.                 log.info("deleteData,删除成功,indexName: "+indexName+",id: "+id);
    165.             }
    166.         }catch (IOException e){
    167.             e.printStackTrace();
    168.         }
    169.  
    170.     }
    171.  
    172.  
    173.     /**
    174.      * 根据条件进行删除
    175.      * @param indexName 索引名称
    176.      * @param key  字段
    177.      * @param value 值
    178.      */
    179.  
    180.     public void deleteData(String indexName,String key,String value) {
    181.         //1 设置条件
    182.         //设置删除条件: key = value
    183.         MatchQueryBuilder nameSelect = QueryBuilders.matchQuery(key, value);
    184.  
    185.         //通过QueryBuilders中的搜索逻辑
    186.         BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
    187.         queryBuilder.should(nameSelect);
    188.  
    189.         //2 通过DeleteByQueryRequest来构建删除请求，setQuery来装载条件，indices来指定索引
    190.         DeleteByQueryRequest deleteByQueryRequest = new DeleteByQueryRequest();
    191.         deleteByQueryRequest.setQuery(queryBuilder);
    192.         deleteByQueryRequest.indices(indexName);  //指定删除索引
    193.         try {
    194.             //3 通过deleteByQuery来发起删除请求
    195.             BulkByScrollResponse deleteResponse=esRestClient.deleteByQuery(deleteByQueryRequest , RequestOptions.DEFAULT);
    196.             if(deleteResponse.getDeleted() >=1){
    197.                 log.info("deleteData,删除成功，删除文档条数: "+deleteResponse.getDeleted()+" ,indexName："+indexName);
    198.             }
    199.         } catch (IOException e) {
    200.             e.printStackTrace();
    201.         }
    202.  
    203.     }
    204.  
    205.  
    206.     /**
    207.      * 关闭客户端
    208.      */
    209.     public void closeEs() {
    210.           try {
    211.               if(esRestClient !=null) {
    212.                   esRestClient.close();
    213.               }
    214.           }catch (IOException e){
    215.               e.printStackTrace();
    216.           }
    217.       }
    218.  
    219.  
    220. }

    调用：

    1.       public static void main(String[] args){
    2.           EsTest es=new EsTest();
    3.           es.restClientConnect("10.1.1.196",9200);   //创建客户端连接ES
    4.  
    5.           String indexName="autotest_java";
    6.           String jsonStr=" {\n" +
    7.                   "  \"aoeId\": \"1\",\n" +
    8.                   "  \"aoeAes\": \"李四\",\n" +
    9.                   "  \"aoeSm4\": \"Beijing Refining Network Technology Co.Ltd.\",\n" +
    10.                   "  \"aoeSm4A\": \"硬件开发工程师\",\n" +
    11.                   "  \"aoeEmail\": \"qianxiulan@yahoo.com\",\n" +
    12.                   "  \"aoePhone\": \"15652996964\",\n" +
    13.                   "  \"aoeIdCard\": \"210302199608124861\",\n" +
    14.                   "  \"aoeOfficerCard\": \"武水电字第3632734号\",\n" +
    15.                   "  \"aoePassport\": \"BWP018930705\",\n" +
    16.                   "  \"aoeGeneralIdCard\": \"0299233902\",\n" +
    17.                   "  \"aoeCreditCard\": \"6212262502009182455\",\n" +
    18.                   "  \"aoeString\":\"北京市海淀区恒润国际大厦710\"\n" +
    19.                   "}";
    20.           es.addData(indexName,jsonStr);
    21.  
    22.           String key="aoeAes";
    23.           String value="李四";
    24.           es.getData(indexName,key,value);
    25.           es.deleteData(indexName,key,value);
    26.  
    27.           //es.addData(indexName,jsonStr,"1");
    28.           //es.getData(indexName);
    29.           //es.deleteData(indexName,"1");
    30.           es.closeEs();
    31.  
    32.  
    33.       }
    34.

    执行结果：

     参考：

    https://www.jianshu.com/p/48f8911849cb

  • 相关阅读:
    java-net-php-python-jspm药品一体化管理系统演示录像2019计算机毕业设计程序
    C++类与对象 （上）
    SSM - Springboot - MyBatis-Plus 全栈体系（二十八）
    java常见集合
    DiskANN数据布局
    【pytorch记录】自动混合精度训练 torch.cuda.amp
    AtCoder Beginner Contest 263 G.Erasing Prime Pairs(二分图最大匹配-网络流)
    速冻品、预制菜商城小程序的作用有哪些
    Java基础知识面试题
    食品赛道崛起，舌尖美食走俏礼品市场
  • 原文地址：https://blog.csdn.net/fen_fen/article/details/126454013