Elasticsearch入门之Java Api操作（索引操作、文档操作、高级查询）

我就是我 2024-03-26 15:48 41阅读 0赞

### Elasticsearch 基本操作 ###

#### Java Api 操作： ####

##### 创建Maven项目： #####

我们在 IDEA 开发工具中创建 Maven 项目，其中doc下面是Postman导出的json直接导入就能运行前面的实例  
![在这里插入图片描述][7f0d832a08ad49c593104cecdff60c93.png]  
git地址：[https://gitee.com/micai-code/es7.8.0-demo.git][https_gitee.com_micai-code_es7.8.0-demo.git]

修改 pom 文件，增加 Maven 依赖关系

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.zhaoxg.es</groupId>
        <artifactId>es7.8.0-demo</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <name>es7.8.0-demo</name>
        
        <url>http://www.example.com</url>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <maven.compiler.source>1.7</maven.compiler.source>
            <maven.compiler.target>1.7</maven.compiler.target>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.elasticsearch</groupId>
                <artifactId>elasticsearch</artifactId>
                <version>7.8.0</version>
            </dependency>
            
            <dependency>
                <groupId>org.elasticsearch.client</groupId>
                <artifactId>elasticsearch-rest-high-level-client</artifactId>
                <version>7.8.0</version>
            </dependency>
            
            <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>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.11</version>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <build>
            <pluginManagement>
                <plugins>
                    
                    <plugin>
                        <artifactId>maven-clean-plugin</artifactId>
                        <version>3.1.0</version>
                    </plugin>
                    
                    <plugin>
                        <artifactId>maven-resources-plugin</artifactId>
                        <version>3.0.2</version>
                    </plugin>
                    <plugin>
                        <artifactId>maven-compiler-plugin</artifactId>
                        <version>3.8.0</version>
                    </plugin>
                    <plugin>
                        <artifactId>maven-surefire-plugin</artifactId>
                        <version>2.22.1</version>
                    </plugin>
                    <plugin>
                        <artifactId>maven-jar-plugin</artifactId>
                        <version>3.0.2</version>
                    </plugin>
                    <plugin>
                        <artifactId>maven-install-plugin</artifactId>
                        <version>2.5.2</version>
                    </plugin>
                    <plugin>
                        <artifactId>maven-deploy-plugin</artifactId>
                        <version>2.8.2</version>
                    </plugin>
                    
                    <plugin>
                        <artifactId>maven-site-plugin</artifactId>
                        <version>3.7.1</version>
                    </plugin>
                    <plugin>
                        <artifactId>maven-project-info-reports-plugin</artifactId>
                        <version>3.0.0</version>
                    </plugin>
                </plugins>
            </pluginManagement>
        </build>
    </project>

##### 客户端对象： #####

###### 创建客户端代码： ######

package com.zhaoxg.es.client;
    
    import org.apache.http.HttpHost;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestHighLevelClient;
    import java.io.IOException;
    
    /**
     * @author zhaoxg on 2023年02月14日 22:57
     */
    public class ElasticsearchCreateClient {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

注意：9200 端口为 Elasticsearch 的 Web 通信端口 ，172.18.20.254为启动 ES 服务的主机名

执行代码，查看控制台信息  
![在这里插入图片描述][f507fd667b5845409c00f47959ce7bd5.png]

##### 索引操作： #####

###### 创建索引： ######

package com.zhaoxg.es.index;
    
    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;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:00
     */
    public class ElasticsearchCreateIndex {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
                // 创建索引 - 请求对象
                CreateIndexRequest request = new CreateIndexRequest("user");
                // 发送请求，获取响应
                CreateIndexResponse response = client.indices().create(request, RequestOptions.DEFAULT);
                boolean acknowledged = response.isAcknowledged();
                // 响应状态
                System.out.println("操作状态 = " + acknowledged);
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

操作结果：  
![在这里插入图片描述][b6963058b9634c02991f685e0411289b.png]

###### 查看索引： ######

package com.zhaoxg.es.index;
    
    import org.apache.http.HttpHost;
    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;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:00
     */
    public class ElasticsearchSelectIndex {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
                // 查询索引 - 请求对象
                GetIndexRequest request = new GetIndexRequest("user");
                // 发送请求，获取响应
                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());
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

操作结果：  
![在这里插入图片描述][52c18d09717b4a899966e4aa505319e5.png]

###### 删除索引： ######

package com.zhaoxg.es.index;
    
    import org.apache.http.HttpHost;
    import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
    import org.elasticsearch.action.support.master.AcknowledgedResponse;
    import org.elasticsearch.client.RequestOptions;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestHighLevelClient;
    
    import java.io.IOException;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:12
     */
    public class ElasticsearchDeleteIndex {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
                // 删除索引 - 请求对象
                DeleteIndexRequest request = new DeleteIndexRequest("user");
                // 发送请求，获取响应
                AcknowledgedResponse response = client.indices().delete(request,
                        RequestOptions.DEFAULT);
                // 操作结果
                System.out.println("操作结果 ： " + response.isAcknowledged());
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

操作结果：  
![在这里插入图片描述][f99a41476e27476b9b99dd8bd4a91c99.png]

##### 文档操作： #####

###### 新增文档： ######

###### 创建数据模型： ######

package com.zhaoxg.es.entity;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:21
     */
    public class User {
        
    
        private String name;
        private Integer age;
        private String sex;
    
        public String getName() {
        
            return name;
        }
    
        public void setName(String name) {
        
            this.name = name;
        }
    
        public Integer getAge() {
        
            return age;
        }
    
        public void setAge(Integer age) {
        
            this.age = age;
        }
    
        public String getSex() {
        
            return sex;
        }
    
        public void setSex(String sex) {
        
            this.sex = sex;
        }
    }

package com.zhaoxg.es.document;
    
    import com.fasterxml.jackson.databind.ObjectMapper;
    import com.zhaoxg.es.entity.User;
    import org.apache.http.HttpHost;
    import org.elasticsearch.action.index.IndexRequest;
    import org.elasticsearch.action.index.IndexResponse;
    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;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:23
     */
    public class ElasticsearchCreateDocument {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 新增文档 - 请求对象
                IndexRequest request = new IndexRequest();
                // 设置索引及唯一性标识
                request.index("user").id("1001");
                // 创建数据对象
                User user = new User();
                user.setName("zhangsan");
                user.setAge(30);
                user.setSex("男");
                ObjectMapper objectMapper = new ObjectMapper();
                String productJson = objectMapper.writeValueAsString(user);
                // 添加文档数据，数据格式为 JSON 格式
                request.source(productJson, XContentType.JSON);
                // 客户端发送请求，获取响应对象
                IndexResponse response = client.index(request, RequestOptions.DEFAULT);
                //3.打印结果信息
                System.out.println("_index:" + response.getIndex());
                System.out.println("_id:" + response.getId());
                System.out.println("_result:" + response.getResult());
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

操作结果：  
![在这里插入图片描述][d8a2ffb35224419b998346c81f60d29d.png]

###### 修改文档： ######

package com.zhaoxg.es.document;
    
    import com.fasterxml.jackson.databind.ObjectMapper;
    import com.zhaoxg.es.entity.User;
    import org.apache.http.HttpHost;
    import org.elasticsearch.action.index.IndexRequest;
    import org.elasticsearch.action.index.IndexResponse;
    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;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:23
     */
    public class ElasticsearchUpdateDocument {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 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("_index:" + response.getIndex());
                System.out.println("_id:" + response.getId());
                System.out.println("_result:" + response.getResult());
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

操作结果：  
![在这里插入图片描述][c0ad7b25f22740de9c52733479914590.png]

###### 查询文档： ######

package com.zhaoxg.es.document;
    
    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.RequestOptions;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.elasticsearch.common.xcontent.XContentType;
    
    import java.io.IOException;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:23
     */
    public class ElasticsearchSelectDocument {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                //1.创建请求对象
                GetRequest request = new GetRequest().index("user").id("1001");
                //2.客户端发送请求，获取响应对象
                GetResponse response = client.get(request, RequestOptions.DEFAULT);
                //3.打印结果信息
                System.out.println("_index:" + response.getIndex());
                System.out.println("_type:" + response.getType());
                System.out.println("_id:" + response.getId());
                System.out.println("source:" + response.getSourceAsString());
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

操作结果：  
![在这里插入图片描述][7e3a50a28b964fd9bdd8dd27ae6d256e.png]

###### 删除文档： ######

package com.zhaoxg.es.document;
    
    import org.apache.http.HttpHost;
    import org.elasticsearch.action.delete.DeleteRequest;
    import org.elasticsearch.action.delete.DeleteResponse;
    import org.elasticsearch.action.get.GetRequest;
    import org.elasticsearch.action.get.GetResponse;
    import org.elasticsearch.client.RequestOptions;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestHighLevelClient;
    
    import java.io.IOException;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:23
     */
    public class ElasticsearchDeleteDocument {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                //创建请求对象
                DeleteRequest request = new DeleteRequest().index("user").id("1001");
                //客户端发送请求，获取响应对象
                DeleteResponse response = client.delete(request, RequestOptions.DEFAULT);
                //打印信息
                System.out.println(response.toString());
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

操作结果：  
![在这里插入图片描述][bf7766b9e4b5496381a78af67979a8f5.png]

###### 批量操作： ######

###### 批量新增： ######

package com.zhaoxg.es.document;
    
    import com.fasterxml.jackson.databind.ObjectMapper;
    import com.fasterxml.jackson.databind.util.JSONPObject;
    import com.zhaoxg.es.entity.User;
    import org.apache.http.HttpHost;
    import org.elasticsearch.action.bulk.BulkItemResponse;
    import org.elasticsearch.action.bulk.BulkRequest;
    import org.elasticsearch.action.bulk.BulkResponse;
    import org.elasticsearch.action.index.IndexRequest;
    import org.elasticsearch.action.index.IndexResponse;
    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;
    
    import static org.elasticsearch.client.security.TemplateRoleName.Format.JSON;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:23
     */
    public class ElasticsearchBatchCreateDocument {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                //创建批量新增请求对象
                BulkRequest request = new BulkRequest();
                request.add(new IndexRequest().index("user").id("1001").source(XContentType.JSON, "name", "zhangsan"));
                request.add(new IndexRequest().index("user").id("1002").source(XContentType.JSON, "name", "lisi"));
                request.add(new IndexRequest().index("user").id("1003").source(XContentType.JSON, "name", "wangwu"));
                //客户端发送请求，获取响应对象
                BulkResponse responses = client.bulk(request, RequestOptions.DEFAULT);
                //打印结果信息
                System.out.println("took:" + responses.getTook());
                ObjectMapper objectMapper = new ObjectMapper();
                String items = objectMapper.writeValueAsString(responses.getItems());
                System.out.println("items:" + items);
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

操作结果：  
![在这里插入图片描述][5aa924b78d2f4ca1aa29fa119795b796.png]

###### 批量删除： ######

package com.zhaoxg.es.document;
    
    import com.fasterxml.jackson.databind.ObjectMapper;
    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;
    
    /**
     * @author zhaoxg on 2023年02月14日 23:23
     */
    public class ElasticsearchBatchDeleteDocument {
        
    
        public static void main(String[] args) {
        
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 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 responses = client.bulk(request, RequestOptions.DEFAULT);
                //打印结果信息
                System.out.println("took:" + responses.getTook());
                ObjectMapper objectMapper = new ObjectMapper();
                String items = objectMapper.writeValueAsString(responses.getItems());
                System.out.println("items:" + items);
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

操作结果：  
![在这里插入图片描述][0777c8a719514a56b783fa41de03b472.png]

##### 高级查询： #####

###### 请求体查询： ######

###### 查询所有索引数据： ######

package com.zhaoxg.es.query;
    
    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;
    
    /**
     * 查询所有索引数据
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QueryAllIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
    
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                // 查询所有数据
                sourceBuilder.query(QueryBuilders.matchAllQuery());
                request.source(sourceBuilder);
    
                SearchResponse response = client.search(request, RequestOptions.DEFAULT);
                // 查询匹配
                SearchHits hits = response.getHits();
                System.out.println("took:" + response.getTook());
                System.out.println("timeout:" + response.isTimedOut());
                System.out.println("total:" + hits.getTotalHits());
                System.out.println("MaxScore:" + hits.getMaxScore());
                System.out.println("hits========>>");
                for (SearchHit hit : hits) {
        
                //输出每条查询的结果信息
                    System.out.println(hit.getSourceAsString());
                }
                System.out.println("<<========");
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

操作结果：  
![在这里插入图片描述][6f39f6397dcc48908b2462f976849cde.png]

###### term 查询，查询条件为关键字： ######

package com.zhaoxg.es.query;
    
    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;
    
    /**
     * term 查询，查询条件为关键字
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QueryTermIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
    
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                // 查询所有数据
                sourceBuilder.query(QueryBuilders.termQuery("category", "苹果"));
                request.source(sourceBuilder);
    
                SearchResponse response = client.search(request, RequestOptions.DEFAULT);
                // 查询匹配
                SearchHits hits = response.getHits();
                System.out.println("took:" + response.getTook());
                System.out.println("timeout:" + response.isTimedOut());
                System.out.println("total:" + hits.getTotalHits());
                System.out.println("MaxScore:" + hits.getMaxScore());
                System.out.println("hits========>>");
                for (SearchHit hit : hits) {
        
                    System.out.println(hit.getSourceAsString());//输出每条查询的结果信息
                }
                System.out.println("<<========");
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

操作结果：  
![在这里插入图片描述][e4e4b7cdd182410492f37b351e3f80ec.png]

###### 分页查询： ######

package com.zhaoxg.es.query;
    
    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;
    
    /**
     * 分页查询
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QueryPageIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
    
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                // 查询所有数据
                sourceBuilder.query(QueryBuilders.matchAllQuery());
                // 分页查询
                // 当前页其实索引(第一条数据的顺序号)，from
                sourceBuilder.from(0);
                // 每页显示多少条 size
                sourceBuilder.size(2);
                request.source(sourceBuilder);
    
                SearchResponse response = client.search(request, RequestOptions.DEFAULT);
                // 查询匹配
                SearchHits hits = response.getHits();
                System.out.println("took:" + response.getTook());
                System.out.println("timeout:" + response.isTimedOut());
                System.out.println("total:" + hits.getTotalHits());
                System.out.println("MaxScore:" + hits.getMaxScore());
                System.out.println("hits========>>");
                for (SearchHit hit : hits) {
        
                    System.out.println(hit.getSourceAsString());//输出每条查询的结果信息
                }
                System.out.println("<<========");
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

操作结果：  
![在这里插入图片描述][320d92754bac4cd6b84ec554cca3c0d6.png]

###### 数据排序： ######

package com.zhaoxg.es.query;
    
    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 org.elasticsearch.search.sort.SortOrder;
    
    import java.io.IOException;
    
    /**
     * 数据排序
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QuerySortIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
    
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                sourceBuilder.query(QueryBuilders.matchAllQuery());
                // 排序
                sourceBuilder.sort("price", SortOrder.ASC);
                request.source(sourceBuilder);
    
                SearchResponse response = client.search(request, RequestOptions.DEFAULT);
                // 查询匹配
                SearchHits hits = response.getHits();
                System.out.println("took:" + response.getTook());
                System.out.println("timeout:" + response.isTimedOut());
                System.out.println("total:" + hits.getTotalHits());
                System.out.println("MaxScore:" + hits.getMaxScore());
                System.out.println("hits========>>");
                for (SearchHit hit : hits) {
        
                    System.out.println(hit.getSourceAsString());//输出每条查询的结果信息
                }
                System.out.println("<<========");
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

操作结果：  
![在这里插入图片描述][0692f5b19d654bdc9f7a0d63ca170ca5.png]

###### 过滤字段： ######

package com.zhaoxg.es.query;
    
    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 org.elasticsearch.search.sort.SortOrder;
    
    import java.io.IOException;
    
    /**
     * 过滤字段
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QueryFilterFieldsIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
    
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                sourceBuilder.query(QueryBuilders.matchAllQuery());
                //查询字段过滤
                String[] excludes = {
        };
                String[] includes = {
        "title", "price"};
                sourceBuilder.fetchSource(includes, excludes);
                request.source(sourceBuilder);
    
                SearchResponse response = client.search(request, RequestOptions.DEFAULT);
                // 查询匹配
                SearchHits hits = response.getHits();
                System.out.println("took:" + response.getTook());
                System.out.println("timeout:" + response.isTimedOut());
                System.out.println("total:" + hits.getTotalHits());
                System.out.println("MaxScore:" + hits.getMaxScore());
                System.out.println("hits========>>");
                for (SearchHit hit : hits) {
        
                    System.out.println(hit.getSourceAsString());//输出每条查询的结果信息
                }
                System.out.println("<<========");
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

操作结果：  
![在这里插入图片描述][43c9ec82cf8a4fdc8075dd45850c9193.png]

###### Bool 查询： ######

package com.zhaoxg.es.query;
    
    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.QueryBuilders;
    import org.elasticsearch.search.SearchHit;
    import org.elasticsearch.search.SearchHits;
    import org.elasticsearch.search.builder.SearchSourceBuilder;
    
    import java.io.IOException;
    
    /**
     * Bool 查询
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QueryBoolIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
    
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
                // 必须包含
                boolQueryBuilder.must(QueryBuilders.matchQuery("category", "小米"));
                // 一定不含
                boolQueryBuilder.mustNot(QueryBuilders.matchQuery("category", "华为"));
                // 可能包含
                boolQueryBuilder.should(QueryBuilders.matchQuery("price", "4999"));
                sourceBuilder.query(boolQueryBuilder);
                request.source(sourceBuilder);
    
                SearchResponse response = client.search(request, RequestOptions.DEFAULT);
                // 查询匹配
                SearchHits hits = response.getHits();
                System.out.println("took:" + response.getTook());
                System.out.println("timeout:" + response.isTimedOut());
                System.out.println("total:" + hits.getTotalHits());
                System.out.println("MaxScore:" + hits.getMaxScore());
                System.out.println("hits========>>");
                for (SearchHit hit : hits) {
        
                    System.out.println(hit.getSourceAsString());//输出每条查询的结果信息
                }
                System.out.println("<<========");
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

操作结果：  
![在这里插入图片描述][fdf2f34154344430a1c27e492f366003.png]

###### 范围查询： ######

package com.zhaoxg.es.query;
    
    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.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;
    
    /**
     * 范围查询
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QueryRangeIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
    
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                RangeQueryBuilder rangeQuery = QueryBuilders.rangeQuery("price");
                // 大于等于
                rangeQuery.gte("3999");
                // 小于等于
                rangeQuery.lte("5999");
                sourceBuilder.query(rangeQuery);
                request.source(sourceBuilder);
    
                SearchResponse response = client.search(request, RequestOptions.DEFAULT);
                // 查询匹配
                SearchHits hits = response.getHits();
                System.out.println("took:" + response.getTook());
                System.out.println("timeout:" + response.isTimedOut());
                System.out.println("total:" + hits.getTotalHits());
                System.out.println("MaxScore:" + hits.getMaxScore());
                System.out.println("hits========>>");
                for (SearchHit hit : hits) {
        
                    System.out.println(hit.getSourceAsString());//输出每条查询的结果信息
                }
                System.out.println("<<========");
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

操作结果：  
![在这里插入图片描述][b0338190b7064c92bf64b937247178ba.png]

###### 模糊查询： ######

package com.zhaoxg.es.query;
    
    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.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;
    
    /**
     * 模糊查询
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QueryFuzzinessIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
    
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                sourceBuilder.query(QueryBuilders.fuzzyQuery("title","小米").fuzziness(Fuzziness.ONE));
                request.source(sourceBuilder);
    
                SearchResponse response = client.search(request, RequestOptions.DEFAULT);
                // 查询匹配
                SearchHits hits = response.getHits();
                System.out.println("took:" + response.getTook());
                System.out.println("timeout:" + response.isTimedOut());
                System.out.println("total:" + hits.getTotalHits());
                System.out.println("MaxScore:" + hits.getMaxScore());
                System.out.println("hits========>>");
                for (SearchHit hit : hits) {
        
                    System.out.println(hit.getSourceAsString());//输出每条查询的结果信息
                }
                System.out.println("<<========");
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

操作结果：  
![在这里插入图片描述][599dc913feb0459aaa3ebfb13e82c98a.png]

###### 高亮查询： ######

package com.zhaoxg.es.query;
    
    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.MatchQueryBuilder;
    import org.elasticsearch.index.query.QueryBuilders;
    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 org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
    
    import java.io.IOException;
    import java.util.Map;
    
    /**
     * 高亮查询
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QueryHighlightIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                // 构建查询方式：高亮查询
                MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("title", "华为");
                // 设置查询方式
                sourceBuilder.query(matchQueryBuilder);
                // 构建高亮字段
                HighlightBuilder highlightBuilder = new HighlightBuilder();
                highlightBuilder.preTags("<font color='red'>");//设置标签前缀
                highlightBuilder.postTags("</font>");//设置标签后缀
                highlightBuilder.field("title");//设置高亮字段
                // 设置高亮构建对象
                sourceBuilder.highlighter(highlightBuilder);
                // 设置请求体
                request.source(sourceBuilder);
                SearchResponse response = client.search(request, RequestOptions.DEFAULT);
                // 查询匹配
                SearchHits hits = response.getHits();
                System.out.println("took:" + response.getTook());
                System.out.println("timeout:" + response.isTimedOut());
                System.out.println("total:" + hits.getTotalHits());
                System.out.println("MaxScore:" + hits.getMaxScore());
                System.out.println("hits========>>");
                for (SearchHit hit : hits) {
        
                    String sourceAsString = hit.getSourceAsString();
                    System.out.println(sourceAsString);
                    //打印高亮结果
                    Map<String, HighlightField> highlightFields = hit.getHighlightFields();
                    System.out.println(highlightFields);
                }
                System.out.println("<<========");
    
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

操作结果：  
![在这里插入图片描述][24dcc1d9498848a0b45a85244da85df5.png]

###### 聚合查询： ######

*  最高价格：
 *  分组统计

package com.zhaoxg.es.query;
    
    import com.fasterxml.jackson.databind.ObjectMapper;
    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.MatchQueryBuilder;
    import org.elasticsearch.index.query.QueryBuilders;
    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.bucket.terms.TermsAggregationBuilder;
    import org.elasticsearch.search.aggregations.metrics.MaxAggregationBuilder;
    import org.elasticsearch.search.builder.SearchSourceBuilder;
    import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
    import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
    
    import java.io.IOException;
    import java.util.Map;
    
    /**
     * 聚合查询
     * @author zhaoxg on 2023年02月15日 11:20
     */
    public class QueryAggIndexData {
        
    
        public static void main(String[] args) {
        
    
            try {
        
                // 创建客户端对象
                RestHighLevelClient client = new RestHighLevelClient(
                        RestClient.builder(new HttpHost("172.18.20.254", 9200, "http"))
                );
    
                // 创建搜索请求对象
                SearchRequest request = new SearchRequest();
                request.indices("shopping");
                // 构建查询的请求体
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                // 最高价格
                /*MaxAggregationBuilder maxAggregationBuilder = AggregationBuilders.max("maxPrice").field("price");
                sourceBuilder.aggregation(maxAggregationBuilder);*/
                // 分组统计
                TermsAggregationBuilder termsAggregationBuilder = AggregationBuilders.terms("price_groupby").field("price");
                sourceBuilder.aggregation(termsAggregationBuilder);
    
                // 设置请求体
                request.source(sourceBuilder);
                SearchResponse response =  client.search(request, RequestOptions.DEFAULT);
                SearchHits hits = response.getHits();
    
                System.out.println(new ObjectMapper().writeValueAsString(response.getAggregations()));
                System.out.println(hits.getTotalHits());
                System.out.println(response.getTook());
                for (SearchHit hit : hits) {
        
                    System.out.println(hit.getSourceAsString());
                }
                // 关闭客户端连接
                client.close();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
    
        }
    }

最高价格返回结果：  
![在这里插入图片描述][1f8c1a1cf8b04c3cbf70fb9f7a459024.png]  
分组统计返回结果：  
![在这里插入图片描述][66f04866a1ed44c5aeb9d8b2ab8a4198.png]

[7f0d832a08ad49c593104cecdff60c93.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/91b148be75b34314967cc52e78737369.png
[https_gitee.com_micai-code_es7.8.0-demo.git]: https://gitee.com/micai-code/es7.8.0-demo.git
[f507fd667b5845409c00f47959ce7bd5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/2cf1bfb99cdb44f8b71d204b54299d97.png
[b6963058b9634c02991f685e0411289b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/9b508e19dd084544897772dc3647ca0c.png
[52c18d09717b4a899966e4aa505319e5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/771115b55339401fbe4a0497d94da051.png
[f99a41476e27476b9b99dd8bd4a91c99.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/1dcca8ea003240498dca38dd10f24939.png
[d8a2ffb35224419b998346c81f60d29d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/64ce6d3e686649b891227004aa8cd437.png
[c0ad7b25f22740de9c52733479914590.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/4c752f31ea1846cb8f04a753cb54cbbf.png
[7e3a50a28b964fd9bdd8dd27ae6d256e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/220195de28ce4585aab5b0468b31fd86.png
[bf7766b9e4b5496381a78af67979a8f5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/72fa24b8cba64ab7ae64883e590cde11.png
[5aa924b78d2f4ca1aa29fa119795b796.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/c95f5f0f2cae40a9857a2b7b8fd7f9fc.png
[0777c8a719514a56b783fa41de03b472.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/15d7d585a6424a44bc84790ae0b4901c.png
[6f39f6397dcc48908b2462f976849cde.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/92726152d2a74fd589293acf2d494545.png
[e4e4b7cdd182410492f37b351e3f80ec.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/f556f0e74d99492f8f0e936a8f73d5a8.png
[320d92754bac4cd6b84ec554cca3c0d6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/49a0ca367ea342ccb59c29a9c4dea965.png
[0692f5b19d654bdc9f7a0d63ca170ca5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/69928415196a48d382596638934335ff.png
[43c9ec82cf8a4fdc8075dd45850c9193.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/615c4d53d4534d42ba37872ca73ac14e.png
[fdf2f34154344430a1c27e492f366003.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/2ce71f597cae4946b5ce8caef0a73f89.png
[b0338190b7064c92bf64b937247178ba.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/cdd8e4549bc2414abda4ee8ec40cf326.png
[599dc913feb0459aaa3ebfb13e82c98a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/280588bd84a043ffad0c4d1519f45974.png
[24dcc1d9498848a0b45a85244da85df5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/2a671b6818a545409d9f260d6f31a0f5.png
[1f8c1a1cf8b04c3cbf70fb9f7a459024.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/97bdb36dd0114a25bb6499b9d447cdf9.png
[66f04866a1ed44c5aeb9d8b2ab8a4198.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/f0dec40bb2464071b69f472494c6e180.png