ElasticSearch的基本操作

直接上java整合吧

测试连接

Easticsearch 的官方地址：https://www.elastic.co/cn/

进入bin目录，点击 elasticsearch.bat 文件启动 ES 服务，注意这里的版本要和pom里面的版本对应

新建一个maven项目即可，我这里创建springboot项目

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> 
    <modelVersion>4.0.0</modelVersion> 
    <parent> 
        <groupId>org.springframework.boot</groupId> 
        <artifactId>spring-boot-starter-parent</artifactId> 
        <version>2.3.4.RELEASE</version> 
        <relativePath/> <!-- lookup parent from repository --> 
    </parent> 
    <groupId>com.ssm</groupId> 
    <artifactId>es-test</artifactId> 
    <version>0.0.1-SNAPSHOT</version> 
    <name>es-test</name> 
    <description>es-test</description> 
    <properties> 
        <java.version>1.8</java.version> 
    </properties> 
    <dependencies> 
        <dependency> 
            <groupId>org.springframework.boot</groupId> 
            <artifactId>spring-boot-starter-web</artifactId> 
        </dependency> 
        <dependency> 
            <groupId>org.elasticsearch</groupId> 
            <artifactId>elasticsearch</artifactId> 
            <version>7.6.1</version> 
        </dependency> 
        <!-- elasticsearch 的客户端 --> 
        <dependency> 
            <groupId>org.elasticsearch.client</groupId> 
            <artifactId>elasticsearch-rest-high-level-client</artifactId> 
            <version>7.6.1</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.3</version> 
        </dependency> 
        <!-- junit 单元测试 --> 
        <dependency> 
            <groupId>junit</groupId> 
            <artifactId>junit</artifactId> 
            <version>4.12</version> 
        </dependency> 
    </dependencies>


    <build> 
        <plugins> 
            <plugin> 
                <groupId>org.springframework.boot</groupId> 
                <artifactId>spring-boot-maven-plugin</artifactId> 
            </plugin> 
        </plugins> 
    </build>

</project>

创建测试客户端

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 测试es连接客户端
 */
public class ESTestClient {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        client.close();
    }
}

创建索引

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 创建索引
 */
public class ESTestClient_Create {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 创建索引 
        CreateIndexRequest user = new CreateIndexRequest("user");
        CreateIndexResponse createIndexResponse = client.indices().create(user, RequestOptions.DEFAULT);
        // 响应状态 
        boolean acknowledged = createIndexResponse.isAcknowledged();
        System.out.println("索引操作: " + acknowledged);
        client.close();
    }
}

访问：http://127.0.0.1:9200/_cat/indices?v

查询索引

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 查询索引
 */
public class ESTestClient_Search {
    public static void main(String[] args) throws Exception {
        //创建ES客户端 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost",9200,"http"))
        );

        //查询索引 
        GetIndexRequest request = new GetIndexRequest("user");
        GetIndexResponse getIndexResponse =
                esClient.indices().get(request, RequestOptions.DEFAULT);

        //响应状态
        System.out.println(getIndexResponse.getAliases());
        System.out.println(getIndexResponse.getMappings());
        System.out.println(getIndexResponse.getSettings());
        esClient.close();
    }
}

删除索引

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 删除索引
 */
public class ESTestClient_Delete {
    public static void main(String[] args) throws Exception {
        //创建ES客户端 
        RestHighLevelClient esClient = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );

        //删除索引 
        DeleteIndexRequest request = new DeleteIndexRequest("user");

        AcknowledgedResponse response = esClient.indices().delete(request, RequestOptions.DEFAULT);

        //响应状态
        System.out.println(response.isAcknowledged());

        esClient.close();
    }
}

文档操作

文档插入数据

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 插入数据
 */
public class ESTest_Doc_Insert {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 插入数据 
        IndexRequest indexRequest = new IndexRequest();
        indexRequest.index("user").id("1001");
        User user = new User();
        user.setAge(20);
        user.setName("ssm");
        user.setSex("男");

        ObjectMapper objectMapper = new ObjectMapper();
        String userJson = objectMapper.writeValueAsString(user);
        indexRequest.source(userJson, XContentType.JSON);
        IndexResponse response = client.index(indexRequest, RequestOptions.DEFAULT);

        response.getResult();

        client.close();
    }
}

输入地址测试：http://127.0.0.1:9200/user/_doc/1001

文档修改数据

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 修改数据
 */
public class ESTest_Doc_Update {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 修改数据 
        UpdateRequest request = new UpdateRequest();
        request.index("user").id("1001");

        request.doc(XContentType.JSON, "sex", "女");
        UpdateResponse response = client.update(request, RequestOptions.DEFAULT);

        System.out.println(response.getResult());

        client.close();
    }
}

输入地址测试：http://127.0.0.1:9200/user/_doc/1001

文档查询数据

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 查询数据
 */
public class ESTest_Doc_Get {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 查询数据 
        GetRequest request = new GetRequest();
        request.index("user").id("1001");


        GetResponse response = client.get(request, RequestOptions.DEFAULT);

        System.out.println(response.getSourceAsString());

        client.close();
    }
}

文档删除数据

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 删除数据
 */
public class ESTest_Doc_Delete {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 查询数据 
        DeleteRequest request = new DeleteRequest();
        request.index("user").id("1001");

        DeleteResponse response = client.delete(request, RequestOptions.DEFAULT);

        System.out.println(response.toString());

        client.close();
    }
}

文档批量插入数据

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 批量插入数据
 */
public class ESTest_Doc_Insert_Bath {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        BulkRequest request = new BulkRequest();
        request.add(new IndexRequest().index("user").id("1001").source(XContentType.JSON, "name", "zhangsan", "age", 20, "sex", "男"));
        request.add(new IndexRequest().index("user").id("1002").source(XContentType.JSON, "name", "zhangsan2", "age", 22, "sex", "男"));
        request.add(new IndexRequest().index("user").id("1003").source(XContentType.JSON, "name", "zhangsan2", "age", 23, "sex", "男"));

        BulkResponse response = client.bulk(request, RequestOptions.DEFAULT);
        System.out.println("响应时间：" +response.getTook());
        System.out.println("创建的内容：" + response.getItems());
        client.close();
    }
}

文档批量删除数据

/**
 * @author shaoshao
 * @Date 2022/11/25 21:05
 * @Description:
 */
public class ESTest_Doc_Delete_Bath {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        BulkRequest request = new BulkRequest();
        request.add(new DeleteRequest().index("user").id("1001"));
        request.add(new DeleteRequest().index("user").id("1002"));
        request.add(new DeleteRequest().index("user").id("1003"));

        BulkResponse response = client.bulk(request, RequestOptions.DEFAULT);
        System.out.println("响应时间：" + response.getTook());
        System.out.println("创建的内容：" + response.getItems());
        client.close();
    }
}

输入地址测试：http://127.0.0.1:9200/user/_search

高级查询

这里可以先插入几条数据

查询所有

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 查询所有数据
 */
public class ESTest_Doc_Query {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 查询索引中全部数据 
        SearchRequest request = new SearchRequest();
        request.indices("user");
        request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));

        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }
        client.close();
    }
}

条件查询

term terms

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 条件查询数据
 */
public class ESTest_Doc_Query_Condition {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 条件查询索引中数据 termQuery 
        SearchRequest request = new SearchRequest();
        request.indices("user");
        // 查询年龄为20的
//        request.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("age",20)));
        request.source(new SearchSourceBuilder().query(QueryBuilders.termsQuery("age","20","22")));

        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }
        
        client.close();
    }
}

分页查询

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 分页查询数据
 */
public class ESTest_Doc_Query_Page {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 分页查询索引中数据 
        SearchRequest request = new SearchRequest();
        request.indices("user");
        SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
        // (当前页码-1)*每页显示数据条数
        builder.from(2);
        builder.size(2);
        request.source(builder);

        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        client.close();
    }
}

排序查询

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 排序查询数据
 */
public class ESTest_Doc_Query_Order {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 排序查询索引中数据 
        SearchRequest request = new SearchRequest();
        request.indices("user");
        SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
        // 按年龄降序
        builder.sort("age", SortOrder.DESC);
        SearchResponse response = client.search(request.source(builder), RequestOptions.DEFAULT);
        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        client.close();
    }
}

过滤字段

package com.ssm.estest;

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;

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 文档 过滤查询数据
 */
public class ESTest_Doc_Query_Filter {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 过滤字段 
        SearchRequest request = new SearchRequest();
        request.indices("user");
        SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
        // 过滤条件
        String[] excludes = {"age"};
        String[] includes = {"name","sex"};
        builder.fetchSource(includes, excludes);
        SearchResponse response = client.search(request.source(builder), RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        client.close();
    }
}

条件组合查询

package com.ssm.estest;

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.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;

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 条件组合查询数据
 */
public class ESTest_Doc_Query_Condition_Combination {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 过滤字段 
        SearchRequest request = new SearchRequest();
        request.indices("user");
        SearchSourceBuilder builder = new SearchSourceBuilder();
        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
        // 年龄必须20 性别必须男
//        boolQueryBuilder.must(QueryBuilders.matchQuery("age", 20));
        boolQueryBuilder.must(QueryBuilders.matchQuery("sex", "男"));
        // 年龄不是22
        boolQueryBuilder.mustNot(QueryBuilders.matchQuery("age", 22));
        // 年龄应该20
        boolQueryBuilder.should(QueryBuilders.matchQuery("age", 20));
//        boolQueryBuilder.should(QueryBuilders.matchQuery("age", 30));
        builder.query(boolQueryBuilder);
        SearchResponse response = client.search(request.source(builder), RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        client.close();
    }
}

模糊查询

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 模糊查询数据
 */
public class ESTest_Doc_Query_Like {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );

        SearchRequest request = new SearchRequest();
        request.indices("user");
        SearchSourceBuilder builder = new SearchSourceBuilder();
        FuzzyQueryBuilder fuzzyQueryBuilder = QueryBuilders.fuzzyQuery("name", "zhangsa").fuzziness(Fuzziness.TWO);
        builder.query(fuzzyQueryBuilder);
        request.source(builder);

        SearchResponse response = client.search(request, RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        client.close();
    }
}

高亮查询

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 高亮查询数据
 */
public class ESTest_Doc_Query_HighLight {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        // 过滤字段 
        SearchRequest request = new SearchRequest();
        request.indices("user");
        SearchSourceBuilder builder = new SearchSourceBuilder();
        TermsQueryBuilder termsQueryBuilder = QueryBuilders.termsQuery("name", "zhangsan");

        HighlightBuilder highlightBuilder = new HighlightBuilder();
        highlightBuilder.preTags("<font color='red'>");
        highlightBuilder.postTags("</>");
        highlightBuilder.field("name");
        builder.highlighter(highlightBuilder);
        builder.query(termsQueryBuilder);
        request.source(builder);

        SearchResponse response = client.search(request, RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        client.close();
    }
}

最大值查询

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 最大值查询数据
 */
public class ESTest_Doc_Query_Max {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
		
        SearchRequest request = new SearchRequest();
        request.indices("user");
        SearchSourceBuilder builder = new SearchSourceBuilder();
        AggregationBuilder aggregationBuilder = AggregationBuilders.max("maxAge").field("age");

        builder.aggregation(aggregationBuilder);
        request.source(builder);

        SearchResponse response = client.search(request, RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        client.close();
    }
}

分组查询

/**
 * @author shaoshao
 * @Date 2022/11/25 19:26
 * @Description: 分组查询数据
 */
public class ESTest_Doc_Query_Group {
    public static void main(String[] args) throws Exception {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http"))
        );
        
        SearchRequest request = new SearchRequest();
        request.indices("user");
        SearchSourceBuilder builder = new SearchSourceBuilder();
        // 根据年龄分组 
        AggregationBuilder aggregationBuilder = AggregationBuilders.terms("ageGroup").field("age");

        builder.aggregation(aggregationBuilder);
        request.source(builder);

        SearchResponse response = client.search(request, RequestOptions.DEFAULT);

        SearchHits hits = response.getHits();
        System.out.println(hits.getTotalHits());
        System.out.println(response.getTook());
        for (SearchHit hit : hits) {
            System.out.println(hit.getSourceAsString());
        }

        client.close();
    }
}

ElasticSearch的基本操作

测试连接

创建索引

查询索引

删除索引

文档操作

文档 插入数据

文档 修改数据

文档 查询数据

文档 删除数据

文档 批量插入数据

文档 批量删除数据

高级查询

查询所有

条件查询

分页查询

排序查询

过滤字段

条件组合查询

模糊查询

高亮查询

最大值查询

分组查询

文档插入数据

文档修改数据

文档查询数据

文档删除数据

文档批量插入数据

文档批量删除数据