elasticsearch7.2的增删改查语法

本篇内容主要讲解“elasticsearch7.2的增删改查语法”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“elasticsearch7.2的增删改查语法”吧!

首先在pom.xml里面导入es相关依赖：

  <!-- 引入Elasticsearch相关jar包--> <dependency>      <groupId>org.elasticsearch</groupId>      <artifactId>elasticsearch</artifactId>      <version>7.2.0</version>    </dependency><!--    <dependency>--><!--      <groupId>org.elasticsearch.client</groupId>--><!--      <artifactId>transport</artifactId>--><!--      <version>7.2.0</version>--><!--    </dependency>-->    <dependency>      <groupId>org.elasticsearch.client</groupId>      <artifactId>elasticsearch-rest-high-level-client</artifactId>      <version>7.2.0</version>    </dependency>    <dependency>      <groupId>org.elasticsearch.client</groupId>      <artifactId>elasticsearch-rest-client</artifactId>      <version>7.2.0</version>    </dependency>    <!-- <dependency>      <groupId>org.apache.lucene</groupId>      <artifactId>lucene-core</artifactId>      <version>8.0.0</version>    </dependency> -->

代码如下：

import com.alibaba.fastJSON.jsON; import com.alibaba.fastjson.JSONObject; import org.apache.Http.HttpHost; //import org.elasticsearch.action.get.GetRequest; //import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest; import org.elasticsearch.action.delete.DeleteRequest; 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.update.UpdateRequest; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestClient; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.index.query.BoolQueryBuilder; //import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.builder.SearchSourceBuilder; import java.io.IOException; import java.util.*;

public class Demo1 {     private static RestHighLevelClient client;     private static final String ip="170.60.140.120";     private static final int port=9200;

public static void main(String[] args) throws Exception{    client=new RestHighLevelClient(RestClient.builder(            new HttpHost(ip, port, "http")));            //      indexincrement();        indexsearch();//      indexdelete();//      indexupdate();        client.close();    }

创建索引

 private static void indexincrement() throws Exception{        HashMap<String, Object> jsonmap = new HashMap<>();        jsonmap.put("name","王五");        jsonmap.put("age",32);        IndexRequest indexRequest = new IndexRequest("post").source(jsonmap);        IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);        System.out.println("indexresponse = "+indexResponse);        System.out.println("indexResponse.status() = "+indexResponse.status());}

删除索引

 private static void indexdelete() throws Exception{         //第一种，按索引id删除某个文档。       //第二种，一次性删除整个索引        //第三种，先按条件查询出某范围内所有Id，再一个一个删除        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();        sourceBuilder.query(boolQueryBuilder);        sourceBuilder.size(100);        SearchRequest searchRequest = new SearchRequest().indices("post");        searchRequest.source(sourceBuilder);        SearchResponse response1 = client.search(searchRequest, RequestOptions.DEFAULT);        SearchHit[] hits = response1.getHits().getHits();        for(SearchHit hit:hits){            String id = hit.getId();            DeleteRequest deleteRequest = new DeleteRequest("post", id);            client.delete(deleteRequest,RequestOptions.DEFAULT);        }

更新文档，（以map方式为例）

private static void indexupdate() throws Exception{    UpdateRequest updateRequest = new UpdateRequest("post","kCfJHHIBCUDx2GUCB0Dk");    HashMap<String, Object> jsonmap = new HashMap<>();    jsonmap.put("name","赵六");    jsonmap.put("age",16);    updateRequest.doc(jsonmap);    client.update(updateRequest,RequestOptions.DEFAULT);}

查询索引

  private static void indexsearch(Connection conn) throws Exception{            BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();    sourceBuilder.query(boolQueryBuilder); //这里设置查询7万条数据    sourceBuilder.size(70000);//        SearchRequest searchRequest=new SearchRequest();        SearchRequest searchRequest = new SearchRequest().indices("middleware_apache_server_access");        searchRequest.source(sourceBuilder);        SearchResponse response1 = client.search(searchRequest, RequestOptions.DEFAULT);        List<JSONObject> list = new ArrayList<>();        response1.getHits().forEach(item ->            list.add(JSON.parseObject(item.getSourceAsString())));        System.out.println("list.size() = "+list.size());//        Iterator<JSONObject> iterator = list.iterator();        for(int i=0;i<list.size();i++){            JSONObject jsonObject = list.get(i);            System.out.println("jsonObject = "+jsonObject);           }  }

}

到此，相信大家对“elasticsearch7.2的增删改查语法”有了更深的了解，不妨来实际操作一番吧！这里是编程网网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！