正文 

当前位置： 首页 > 程序 > java教程

elasticsearch在javaapi中的操作(入门)(代码片段)

周大仙1 周大仙1     2022-12-08     370

关键词：

目录

2.2.5 Java API 操作

(1)环境准备&创建ES客户端

(2)ES索引创建

(3)ES索引&查询&删除

(4)文档 新增&修改

新增

修改数据

(5)文档的批量新增&批量删除

批量新增

批量删除

(6)高级查询&全量查询

全量查询

(7)高级查询&分页查询&条件查询&字段查询

条件查询

分页查询

排序

包含和排除

​编辑

(8)高级查询&组合查询&范围查询组合查询

范围查询

(9)高级查询&模糊查询&高亮查询

模糊查询

高亮查询

(10)高级查询&聚合查询&分组查询

聚合查询

 分组查询

2.2.5 Java API 操作

ES软件是由Java语言开发的，所以也可以通过Java API的方式对ES服务进行访问

需要添加的依赖如下

<dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>7.8.0</version>
        </dependency>
        <!-- elasticsearch 的客户端 -->
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>7.8.0</version>
        </dependency>
        <!-- elasticsearch 依赖 2.x 的 log4j -->
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-api</artifactId>
            <version>2.8.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-core</artifactId>
            <version>2.8.2</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.9.9</version>
        </dependency>
        <!-- junit 单元测试 -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>

(1)环境准备&创建ES客户端

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;

import java.io.IOException;

//es创建客户端对象
public class EsDemo1 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        System.out.println(client);
        client.close();

(2)ES索引创建

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;

import java.io.IOException;

//Es索引创建
public class EsDemo2 
    public static void main(String[] args) throws IOException 
        //创建客户端对象
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http")));

        // 创建索引 - 请求对象
        CreateIndexRequest request = new CreateIndexRequest("root");
        // 发送请求，获取响应
        CreateIndexResponse response = client.indices().create(request,
                RequestOptions.DEFAULT);
        boolean acknowledged = response.isAcknowledged();
        // 响应状态
        System.out.println("操作状态 = " + acknowledged);

        // 关闭客户端连接
        client.close();

 响应结果为:root索引创建完成

(3)ES索引&查询&删除

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexAction;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.delete.DeleteRequest;
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.client.indices.GetIndexRequest;
import org.elasticsearch.client.indices.GetIndexResponse;

import java.io.IOException;

//Es索引  查询  删除
public class EsDemo3 
    public static void main(String[] args) throws IOException 
        // 创建客户端对象
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http")));

        // 查询索引 - 请求对象
        GetIndexRequest request = new GetIndexRequest("root");
        // 发送请求，获取响应
        GetIndexResponse response = client.indices().get(request,
                RequestOptions.DEFAULT);

        System.out.println("aliases:"+response.getAliases());
        System.out.println("mappings:"+response.getMappings());
        System.out.println("settings:"+response.getSettings());
        //删除索引

//        AcknowledgedResponse delete = delete(client);
//        System.out.println(delete.isAcknowledged());
        client.close();

    
    public static AcknowledgedResponse delete(RestHighLevelClient client) throws IOException 
        DeleteIndexRequest request2 = new DeleteIndexRequest("root");
        AcknowledgedResponse response2 = client.indices().delete(request2, RequestOptions.DEFAULT);
        return response2;

查询结果为

如果想要删除索引，将上面注释取消即可

(4)文档 新增&修改

新增

package com.jt.popj;

import lombok.Data;

@Data
public class User 
    private String name;
    private Integer age;
    private String sex;


package com.jt.test;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.jt.config.ConnectElasticsearch;
import com.jt.popj.User;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.common.xcontent.XContentType;

//新增
public class EsDemo5 
    public static void main(String[] args) 
        ConnectElasticsearch.connect(client -> 
            //新增文档 --请求对象
            IndexRequest request = new IndexRequest();
            //设置索引 唯一标识
            request.index("root").id("1001");

            //创建数据对象
            User user = new User();
            user.setAge(18);
            user.setName("张飞");
            user.setSex("男");

            ObjectMapper objectMapper = new ObjectMapper();
            String productJson  = objectMapper.writeValueAsString(user);
            //添加文档数据，格式为json
            request.source(productJson, XContentType.JSON);
            //客户端发送请求，获取相应对象
            IndexResponse response = client.index(request, RequestOptions.DEFAULT);

            System.out.println("索引："+response.getIndex());
            System.out.println("id:"+response.getId());
            System.out.println("数据"+response.getResult());
        );

修改数据

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;

import java.io.IOException;

//修改数据
public class EsDemo6 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        //修改数据
        UpdateRequest request = new UpdateRequest();
        request.index("root").id("1001");
        request.doc(XContentType.JSON,"sex","女");
        UpdateResponse response = esClient.update(request , RequestOptions.DEFAULT);
        System.out.println(response.getResult());
        esClient.close();

检测修改的结果

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.IndicesClient;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;

import java.io.IOException;

public class EsDemo7 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        GetRequest request = new GetRequest();
        request.index("root").id("1001");
        GetResponse reponse = esClient.get(request, RequestOptions.DEFAULT);
        System.out.println(reponse.getSourceAsString());

        esClient.close();

(5)文档的批量新增&批量删除

批量新增

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;

import java.io.IOException;

//批量新增和批量删除
public class EsDemo8 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        BulkRequest request = new BulkRequest();
        request.add(new IndexRequest().index("root").id("1002").source(XContentType.JSON,"name","刘备"));
        request.add(new IndexRequest().index("root").id("1002").source(XContentType.JSON,"name","赵云"));
        request.add(new IndexRequest().index("root").id("1002").source(XContentType.JSON,"name","关羽"));
        BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
        System.out.println(response.getTook());//花费的时间
        System.out.println(response.getItems());//响应信息
        esClient.close();

批量删除

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;

import java.io.IOException;

//批量新增和批量删除
public class EsDemo8 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        BulkRequest request = new BulkRequest();
        request.add(new DeleteRequest().index("root").id("1002"));
        request.add(new DeleteRequest().index("root").id("1002"));
        request.add(new DeleteRequest().index("root").id("1002"));
        BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
        System.out.println(response.getTook());//花费的时间
        System.out.println(response.getItems());//响应信息
        esClient.close();

(6)高级查询&全量查询

全量查询

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

//高级查询&全量查询
public class EsDemo9 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        //查询数据
        SearchRequest request = new SearchRequest();
        request.indices("root");
        //全量查询
        request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));//全量匹配
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits()); //条数
        System.out.println(response.getTook()); //时间

        for (SearchHit hit:hits)
            String sourceAsString = hit.getSourceAsString();
            System.out.println(sourceAsString);

查询结果

(7)高级查询&分页查询&条件查询&字段查询

条件查询

         RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        //查询数据
        SearchRequest request = new SearchRequest();
        request.indices("root");

        request.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("age",26)));//查询条件：age=26
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();

        for (SearchHit hit:hits)
            System.out.println(hit.getSourceAsString());
        
        esClient.close();
        //全量查询

分页查询

 from()括号中的参数: (页码数-1)*每页显式的条数    也就是size里面的参数

排序

 只需要在size().sort()就可以

包含和排除

 响应结果


(8)高级查询&组合查询&范围查询
组合查询

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
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.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

//高级查询&组合查询&范围查询
public class EsDemo11 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        //查询数据
        SearchRequest request = new SearchRequest();
        request.indices("root");

        SearchSourceBuilder builder = new SearchSourceBuilder();    //创建查询构造器
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();  //创建组合查询构造器
//        boolQueryBuilder.must(QueryBuilders.matchQuery("age",25));  //must等价于and 两者都满足
//        boolQueryBuilder.must(QueryBuilders.matchQuery("sex","男"));
//        boolQueryBuilder.mustNot(QueryBuilders.matchQuery("sex","男"));//mustnot 两者都不满足
//        boolQueryBuilder.mustNot(QueryBuilders.matchQuery("age",25));

        boolQueryBuilder.should(QueryBuilders.matchQuery("sex","男"));//should等价于or  其中有一个条件满足就可以
        boolQueryBuilder.should(QueryBuilders.matchQuery("age",25));
        builder.query(boolQueryBuilder);    //将组合构造器加入查询构造器
        request.source(builder);    //查询构造器加入查询请求
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        for (SearchHit hit:hits)
            System.out.println(hit.getSourceAsString());
        
        esClient.close();

范围查询

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
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.index.query.RangeQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

//高级查询&组合查询&范围查询
public class EsDemo11 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        //查询数据
        SearchRequest request = new SearchRequest();
        request.indices("root");

        SearchSourceBuilder builder = new SearchSourceBuilder();    //创建查询构造器
        RangeQueryBuilder rangeQueryBuilder = QueryBuilders.rangeQuery("age"); //范围查询rangeQuery,参数为字段
        rangeQueryBuilder.gte(22);//>= 22
        rangeQueryBuilder.lte(28);// <= 28
        builder.query(rangeQueryBuilder); //将范围查询构造器加入查询构造器
        request.source(builder);    //查询构造器加入查询请求
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        for (SearchHit hit:hits)
            System.out.println(hit.getSourceAsString());
        
        esClient.close();

(9)高级查询&模糊查询&高亮查询

模糊查询

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.unit.Fuzziness;
import org.elasticsearch.index.query.FuzzyQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;
//高级查询&模糊查询&高亮查询
public class EsDemo12 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        //查询数据
        SearchRequest request = new SearchRequest();
        request.indices("root");

        SearchSourceBuilder builder = new SearchSourceBuilder();    //创建查询构造器
        FuzzyQueryBuilder fuzzyQueryBuilder = QueryBuilders //模糊查询  Fuzziness.ONE  匹配多一个字符。比如：关羽1  x关羽  关x羽....
                .fuzzyQuery("name", "关羽").fuzziness(Fuzziness.ONE);
        builder.query(fuzzyQueryBuilder);
        request.source(builder);
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        for (SearchHit hit:hits)
            System.out.println(hit.getSourceAsString());
        
        esClient.close();

高亮查询

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.unit.Fuzziness;
import org.elasticsearch.index.query.FuzzyQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;

import java.io.IOException;

public class EsDemo12 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        //查询数据
        SearchRequest request = new SearchRequest();
        request.indices("root");
        SearchSourceBuilder builder = new SearchSourceBuilder();    //创建查询构造器
        TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("sex", "男");
        HighlightBuilder highlightBuilder = new HighlightBuilder();//创建高亮构造器
        highlightBuilder.preTags("<font color = 'red'>");
        highlightBuilder.postTags("</font>");
        highlightBuilder.field("sex");

        builder.highlighter(highlightBuilder);//高亮构造器加入查询构造器中
        builder.query(termQueryBuilder);
        request.source(builder);
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        for (SearchHit hit:hits)
            System.out.println(hit.getSourceAsString());
        
        esClient.close();

(10)高级查询&聚合查询&分组查询

聚合查询

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.metrics.AvgAggregationBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

//聚合查询和分组查询
public class EsDemo13 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        //查询数据
        SearchRequest request = new SearchRequest();
        request.indices("root");
        SearchSourceBuilder builder = new SearchSourceBuilder();    //创建查询构造器
        AggregationBuilder aggregationBuilder = AggregationBuilders.max("maxAge").field("age");//自定义最大值名字 maxAge
        builder.aggregation(aggregationBuilder);
        request.source(builder);
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        for (SearchHit hit:hits)
            System.out.println(hit.getSourceAsString());
        
        esClient.close();

查询结果

 分组查询

package com.jt.test;

import org.apache.http.HttpHost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.aggregations.AggregationBuilder;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.metrics.AvgAggregationBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;

import java.io.IOException;

//聚合查询和分组查询
public class EsDemo13 
    public static void main(String[] args) throws IOException 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );
        //查询数据
        SearchRequest request = new SearchRequest();
        request.indices("root");
        SearchSourceBuilder builder = new SearchSourceBuilder();    //创建查询构造器
      //  AggregationBuilder aggregationBuilder = AggregationBuilders.max("maxAge").field("age");//自定义最大值名字 maxAge
        AggregationBuilder aggregationBuilder = AggregationBuilders.terms("ageGroup").field("age");//自定义最大值名字 maxAge
        builder.aggregation(aggregationBuilder);
        request.source(builder);
        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        for (SearchHit hit:hits)
            System.out.println(hit.getSourceAsString());
        
        esClient.close();

查询结果为

elasticsearch——使用javaapi实现es中的索引映射文档操作(代码片段)

文章目录：1.开篇2.案例详解2.1创建ES客户端：完成与ES服务端的连接2.2创建索引2.3查看索引2.4删除索引2.5创建文档2.6修改文档2.7查看文档2.8删除文档2.9批量创建文档2.10批量删除文档2.11全量查询2.12条件查询2.13分页查询2.14... 查看详情

elasticsearch——使用javaapi实现es中的索引映射文档操作(代码片段)

文章目录：1.开篇2.案例详解2.1创建ES客户端：完成与ES服务端的连接2.2创建索引2.3查看索引2.4删除索引2.5创建文档2.6修改文档2.7查看文档2.8删除文档2.9批量创建文档2.10批量删除文档2.11全量查询2.12条件查询2.13分页查询2.14... 查看详情

javaapi操作elasticsearch（强烈推荐）(代码片段)

ElasticSearch高级1javaApi操作es环境搭建在elasticsearch官网中提供了各种语言的客户端：https://www.elastic.co/guide/en/elasticsearch/client/index.html而Java的客户端就有两个：不过JavaAPI这个客户端（TransportClient）已经在7.0以后过期... 查看详情

elasticsearch7.8.0版本入门——javaapi操作（索引操作）(代码片段)

目录一、创建索引代码示例二、查询索引代码示例二、删除索引代码示例一、创建索引代码示例创建索引代码示例packagecom.xz.esdemo.day1;importorg.apache.http.HttpHost;importorg.elasticsearch.client.RequestOptions;importorg.elasticsearch.client.RestClient;impor 查看详情

elasticsearch7.8.0版本入门——javaapi操作（批量操作文档）(代码片段)

...量删除文档代码示例一、pom文件依赖引入相关依赖<!--elasticsearch依赖--><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</arti 查看详情

elasticsearch7.8.0版本入门——javaapi操作（文档操作）(代码片段)

....4、删除文档代码示例一、pom文件依赖引入相关依赖<!--elasticsearch依赖--><dependency><groupId>org.elasticsearch</groupId><artifactI 查看详情

elasticsearch之javaapi操作es(代码片段)

...增1.5查询操作1JavaAPI1.1pom.xml<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-client</artifactId><version>7.9.0</version></dependency><dependency><groupId>org.elasticsearch</groupId><arti... 查看详情

elasticsearch7.8.0版本入门——javaapi操作（索引操作）(代码片段)

...示例packagecom.xz.esdemo.day1;importorg.apache.http.HttpHost;importorg.elasticsearch.client.RequestOptions;importorg.elasticsearch.client.RestClient;importorg.elasticsearch.client.RestHighLevelClient;importorg.elasticsearch.client.indices.CreateIndexRequest;importorg.elasticsearch.client.indices.C... 查看详情

elasticsearch7.8.0javaapi入门操作

环境：springboot2.3.3.RELEASE引入依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId></dependency 查看详情

elasticsearch5.0.1javaapi操作

 今天来说下使用ES5.0.1的API来进行编码。开始之前，简单说下5.0.1跟之前的几个变化。之前的ES自身是不支持delete-by-query的，也就是通过查询来删除，可以达到批量的效果，是因为刷新的原因，应该够近实时的特性相关。一直... 查看详情

elasticsearch7.8.0版本入门——javaapi操作（环境准备）(代码片段)

...et/article/details/91977374二、pom.xml文件引入相关maven依赖引入elasticsearch依赖<!--elasti 查看详情

elasticsearch-javaapi操作es7.15.0es7.x索引，文档；高级搜索(代码片段)

阅读本文前可先参考Elasticsearch-Elasticsearch详解；安装部署（一）_MinggeQingchun的博客-CSDN博客Elasticsearch软件是由Java语言开发的，所以也可以通过JavaAPI的方式对Elasticsearch服务进行访问以Elasticsearch7.15.0版本为例一、Ela... 查看详情

elasticsearch7.8.0版本入门——javaapi操作（批量操作文档）(代码片段)

...量删除文档代码示例一、pom文件依赖引入相关依赖<!--elasticsearch依赖--><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.8.0</version></dependency><!--elasticsearch的客户... 查看详情

elasticsearch-javaapi操作es7.16.0+es8.x索引，文档；高级搜索(代码片段)

阅读本文前可先参考Elasticsearch-JavaAPI操作ES7.15.0、ES7.x索引，文档；高级搜索（六）_MinggeQingchun的博客-CSDN博客Elasticsearch-JavaAPI（Lambda表达式）操作ES7.16.0+、ES8.x索引，文档；高 查看详情

elasticsearch-javaapi操作es7.16.0+es8.x索引，文档；高级搜索(代码片段)

阅读本文前可先参考https://blog.csdn.net/MinggeQingchun/article/details/126618387https://blog.csdn.net/MinggeQingchun/article/details/126762570Elasticsearch软件是由Java语言开发的，所以也可以通过JavaAPI的方式对Elasticsearch服务 查看详情

elasticsearch7.8.0版本入门——javaapi操作（环境准备）(代码片段)

...et/article/details/91977374二、pom.xml文件引入相关maven依赖引入elasticsearch依赖<!--elasticsearch依赖--><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.8.0</version></dependency><... 查看详情

elasticsearch7.8.0版本入门——javaapi操作（范围查询文档）(代码片段)

...围查询文档代码示例一、pom文件依赖引入相关依赖<!--elasticsearch依赖--><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.8.0</version></dependency><!--elasticsearch的客户... 查看详情

elasticsearch7.8.0版本入门——javaapi操作（模糊查询文档）(代码片段)

...糊查询文档代码示例一、pom文件依赖引入相关依赖<!--elasticsearch依赖--><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.8.0</version></dependency><!--elasticsearch的客户... 查看详情