devbox
weixin_40725706
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

ElasticSearch 的增删改查_elasticsearch head 修改数据

作者：weixin_40725706 | 2024-02-08 11:06:18

赞

踩

elasticsearch head 修改数据

下面会记录对ElasticSearch 的详细使用方法进,内容包括索引的增删,数据的增删查

一 创建开发环境

首先需要安装es集群 这里使用的是7.17.8

二 当es能正常启动的时候,开始对es进行做操作

1.索引操作

   可以使用shell语法创建索引与删除索引,以及插入

  1. curl -X PUT "http://节点ip:9200/索引名称"
  2. curl -u 你的账号:你的密码 -XDELETE 'http://节点ip:9200/索引名称'
  3. curl -H "Content-Type: application/json" -XPUT 'http://note1:9200/index_test/doc/1' -d '{"age":128}'

   也可以所使用的java代码发送http请求

  1. import com.alibaba.fastjson.JSONObject;
  2. import org.apache.http.HttpEntity;
  3. import org.apache.http.HttpResponse;
  4. import org.apache.http.HttpStatus;
  5. import org.apache.http.client.config.RequestConfig;
  6. import org.apache.http.client.methods.CloseableHttpResponse;
  7. import org.apache.http.client.methods.HttpDelete;
  8. import org.apache.http.client.methods.HttpPost;
  9. import org.apache.http.client.methods.HttpPut;
  10. import org.apache.http.entity.StringEntity;
  11. import org.apache.http.impl.client.CloseableHttpClient;
  12. import org.apache.http.impl.client.HttpClientBuilder;
  13. import org.apache.http.impl.client.HttpClients;
  14. import org.apache.http.util.EntityUtils;
  15.  
  16. import java.io.IOException;
  17. import java.util.Map;
  18.  
  19. /*  pom坐标
  20. <dependency>
  21. <groupId>org.elasticsearch</groupId>
  22. <artifactId>elasticsearch</artifactId>
  23. <version>7.17.8</version>
  24. </dependency>
  25. <dependency>
  26. <groupId>org.apache.httpcomponents</groupId>
  27. <artifactId>httpclient</artifactId>
  28. <version>4.5</version>
  29. </dependency>
  30. <dependency>
  31. <groupId>com.alibaba</groupId>
  32. <artifactId>fastjson</artifactId>
  33. <version>1.2.73</version>
  34. </dependency>
  35. */
  36. /**
  37.  * 通过http对es进行索引的增删改
  38.  */
  39. public class ESUtils {
  40.  
  41.     /**
  42.      * 关闭资源
  43.      *
  44.      * @param client
  45.      */
  46.     public static void close(CloseableHttpClient client) {
  47.         if (client != null) try {
  48.             client.close();
  49.         } catch (IOException e) {
  50.             e.printStackTrace();
  51.         }
  52.  
  53.     }
  54.  
  55.     public static void close(CloseableHttpResponse client) {
  56.         if (client != null) try {
  57.             client.close();
  58.         } catch (IOException e) {
  59.             e.printStackTrace();
  60.         }
  61.  
  62.     }
  63.  
  64.     public static String sendDelete(String url, JSONObject headJson) throws Exception {
  65.         String result = null;
  66.  
  67.         CloseableHttpClient client = null;
  68.         try {
  69.             client = HttpClientBuilder.create().build();
  70.             HttpDelete put = new HttpDelete(url);
  71.             if (headJson != null) {//设置请求头
  72.                 for (Map.Entry<String, Object> entry : headJson.entrySet()) {
  73.                     put.addHeader(entry.getKey(), String.valueOf(entry.getValue()));
  74.                 }
  75.             }
  76.             HttpResponse res = client.execute(put);
  77.             if (res.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
  78.                 result = EntityUtils.toString(res.getEntity());// 返回json格式：
  79.             }
  80.         } catch (Exception e) {
  81.             throw new Exception(e);
  82.         } finally {
  83.             close(client);
  84.         }
  85.         return result;
  86.     }
  87.  
  88.  
  89.     public static String sendPost(String url, JSONObject headJson, String bodyJson) throws Exception {
  90.         CloseableHttpClient client = null;
  91.         String result = null;
  92.         try {
  93.             client = HttpClientBuilder.create().build();
  94.             HttpPost post = new HttpPost(url);//支持get/post与put和delete - > HttpDelete
  95.             if (headJson != null) {//设置请求头
  96.                 for (Map.Entry<String, Object> head : headJson.entrySet()) {
  97.                     post.addHeader(head.getKey(), head.getValue().toString());
  98.                 }
  99.             }
  100.             StringEntity body = new StringEntity(bodyJson, "utf-8");//设置请求体
  101.             body.setContentEncoding("UTF-8");
  102.             body.setContentType("application/json");//设置发送的请求体数据为json数据
  103.             post.setEntity(body);
  104.             HttpResponse res = client.execute(post);
  105.             result = EntityUtils.toString(res.getEntity());// 返回json格式：
  106.         } catch (Exception e) {
  107.             throw new Exception(e);
  108.         } finally {
  109.             close(client);
  110.         }
  111.         return result;
  112.     }
  113.  
  114.  
  115.     public static String sendPut(String url, String jsonStr) {
  116.  
  117.         CloseableHttpClient httpClient = HttpClients.createDefault();
  118.         HttpPut httpPut = new HttpPut(url);
  119.         RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(35000).setConnectionRequestTimeout(35000).setSocketTimeout(60000).build();
  120.         httpPut.setConfig(requestConfig);
  121.         httpPut.setHeader("Content-type", "application/json");
  122.         httpPut.setHeader("DataEncoding", "UTF-8");
  123.  
  124.         CloseableHttpResponse httpResponse = null;
  125.         try {
  126.             if (jsonStr != null) httpPut.setEntity(new StringEntity(jsonStr));
  127.             httpResponse = httpClient.execute(httpPut);
  128.             HttpEntity entity = httpResponse.getEntity();
  129.             String result = EntityUtils.toString(entity);
  130.             return result;
  131.         } catch (Exception e) {
  132.             e.printStackTrace();
  133.         } finally {
  134.             close(httpResponse);
  135.             close(httpClient);
  136.         }
  137.         return null;
  138.     }
  139.  
  140.  
  141.     public static void main(String[] args) throws Exception {
  142.  
  143.         String respCreate = ESUtils.sendPut("http://note1:9200/index_test", null);//创建索引
  144.         //映射最外层需要properties
  145.         String mapping = "{\"properties\":{\"name\":{\"type\":\"text\",\"index\":true},\"sex\":{\"type\":\"text\",\"index\":false},\"age\":{\"type\":\"long\",\"index\":false}}}";
  146.         String respUpdate = ESUtils.sendPut("http://note1:9200/index_test/doc/_mapping?include_type_name=true", mapping);//设置mapping映射
  147.  
  148.         String url = "http://note2:9200/index_test/doc?";//url后的路径表示: 索引/分类/id id的uri可以不要,即自动生成id
  149.  
  150.         String respInsert = sendPost(url, null, "{\"name\":\"张三123\",\"sex\":\"这是一段文本\",\"age\":128}");
  151.  
  152.         String respDelete = ESUtils.sendDelete("http://note1:9200/index_test", null);//删除索引
  153.  
  154.         System.out.println("respCreate创建索引响应: " + respCreate);
  155.         System.out.println("respUpdate设置映射响应: " + respUpdate);
  156.         System.out.println("respInsert插入数据响应: " + respInsert);
  157.         System.out.println("respDelete删除索引响应: " + respDelete);
  158.     }
  159.  
  160. }

运行结果如下

 使用代码进行批处理入库

  1. import org.apache.http.HttpHost;
  2. import org.elasticsearch.action.bulk.BulkRequest;
  3. import org.elasticsearch.action.bulk.BulkResponse;
  4. import org.elasticsearch.action.index.IndexRequest;
  5. import org.elasticsearch.client.RequestOptions;
  6. import org.elasticsearch.client.RestClient;
  7. import org.elasticsearch.client.RestHighLevelClient;
  8.  
  9. import java.io.IOException;
  10. import java.util.HashMap;
  11. import java.util.Map;
  12. import java.util.UUID;
  13.  
  14. /*
  15. <dependency>
  16. <groupId>org.elasticsearch.client</groupId>
  17. <artifactId>elasticsearch-rest-high-level-client</artifactId>
  18. <version>7.17.7</version>
  19. <!-- 版本7.17.8有bug 使用7.17.7文件-->
  20. </dependency>
  21.  */
  22.  
  23. /**
  24.  * 批处理
  25.  */
  26. public class ESBatch {
  27.     public static void main(String[] args) throws IOException {
  28.         RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(
  29.                 new HttpHost("note1", 9200),
  30.                 new HttpHost("note2", 9200),
  31.                 new HttpHost("note3", 9200)));
  32.         BulkRequest bulkRequest = new BulkRequest();
  33.         Map<String,Object> map = new HashMap();
  34.         map.put("name", UUID.randomUUID().toString());
  35.         bulkRequest.add(new IndexRequest().index("index_test").source(map));
  36.         bulkRequest.add(new IndexRequest().index("index_test").source(map));
  37.         bulkRequest.add(new IndexRequest().index("index_test").source(map));
  38.         BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
  39.         System.out.println("批量插，Took: " + bulkResponse.getTook());
  40.         System.out.println("批量插入，Items: " + bulkResponse.getItems().length);
  41.         client.close();
  42.     }
  43. }

运行结果

 ​​​

 字段类型与映射数据说明

2.查询

`````````````````````````````

 2.获取操作elasticsearch的客户端

Settings settings = Settings.builder().put("cluster.name", "集群名称").build();
TransportClient client = new PreBuiltTransportClient(settings)
    .addTransportAddress(new TransportAddress(InetAddress.getByName("mini1"), 9300));
    .addTransportAddress(new TransportAddress(InetAddress.getByName("mini2"), 9300));
    .addTransportAddress(new TransportAddress(InetAddress.getByName("mini3"), 9300));

3.使用客户端client操作集群

    (1)导入数据

         处理数据

  1.     String json = "{\"key\":\"value\"}";
  2.     response = client.prepareIndex("索引名称", "类型", "id").setSource(json).get();

        批处理

           

  1.     String json = "{\"key\":\"value\"}";  //数据
  2.     IndexRequestBuilder indexRequestBuilder = client.prepareIndex("索引名称", "doc", "100").setSource(json);//创建请求
  3.     BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();//批处理对象
  4.     bulkRequestBuilder.add(indexRequestBuilder);//添加到批处理
  5.     bulkRequestBuilder.add(indexRequestBuilder);
  6.     BulkResponse bulkItemResponses = bulkRequestBuilder.execute().actionGet();//执行处理获取结果集
  7.     BulkItemResponse[] items = bulkItemResponses.getItems();//获取每一条数据的处理结果

    (2)查询

        全文检索

  1.     QueryBuilder query = QueryBuilders.matchAllQuery();//查询类,查询全部
  2.     SearchResponse searchResponse = client.prepareSearch("索引").setTypes("类型").setQuery(query).execute().actionGet();//创建请求并获取结果
  3.     SearchHits hits = searchResponse.getHits();//获取数据集合
  4.     for (SearchHit sh:hits) {//遍历
  5.         System.out.println(sh.getSource());//获取单条数据
  6.     }

        搜索

  1.     QueryBuilder query = QueryBuilders.matchQuery("字段名","字段值").operator(Operator.OR);//过滤查询,查询固定值
  2.     ...

       多字段检索

 
   QueryBuilder query = QueryBuilders.multiMatchQuery("值","字段1","字段2");//同时指定多个field，不同field之间是或的关系

       多条件查询

  1.      QueryBuilder query1 = QueryBuilders.queryStringQuery("值1");//查询类1
  2.     QueryBuilder query2 = QueryBuilders.queryStringQuery("值2");//查询类2
  3.     SearchResponse searchResponse = client.prepareSearch("索引").setTypes("格式").setQuery(query1).setQuery(query2).get();//请求结果

       前缀查询

    QueryBuilder query = QueryBuilders.prefixQuery("字段", "值");

       通用匹配

    QueryBuilder query =  QueryBuilders.wildcardQuery("字段", "值.*");

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/weixin_40725706/article/detail/68737
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号