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

es使用java来查询文档（基于es7.8）_java查询es文档

作者：菜鸟追梦旅行 | 2024-02-08 10:19:39

赞

踩

java查询es文档

注意，索引的字段mapping是如下类型，如果index是FALSE的话，会导致条件查询失败：

先引入pom依赖：

  1. <dependencies>
  2.         <dependency>
  3.             <groupId>org.elasticsearch</groupId>
  4.             <artifactId>elasticsearch</artifactId>
  5.             <version>7.8.0</version>
  6.         </dependency>
  7.         <!-- elasticsearch的客户端 -->
  8.         <dependency>
  9.             <groupId>org.elasticsearch.client</groupId>
  10.             <artifactId>elasticsearch-rest-high-level-client</artifactId>
  11.             <version>7.8.0</version>
  12.         </dependency>
  13.         <!-- elasticsearch依赖2.x的log4j -->
  14.         <dependency>
  15.             <groupId>org.apache.logging.log4j</groupId>
  16.             <artifactId>log4j-api</artifactId>
  17.             <version>2.8.2</version>
  18.         </dependency>
  19.         <dependency>
  20.             <groupId>org.apache.logging.log4j</groupId>
  21.             <artifactId>log4j-core</artifactId>
  22.             <version>2.8.2</version>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>com.fasterxml.jackson.core</groupId>
  26.             <artifactId>jackson-databind</artifactId>
  27.             <version>2.9.9</version>
  28.         </dependency>
  29.         <!-- junit单元测试 -->
  30.         <dependency>
  31.             <groupId>junit</groupId>
  32.             <artifactId>junit</artifactId>
  33.             <version>4.12</version>
  34.         </dependency>
  35.     </dependencies>

创建User类：

  1.  
  2. public class User {
  3.     private String name;
  4.     private String sex;
  5.     private Integer age;
  6.  
  7.     public String getName() {
  8.         return name;
  9.     }
  10.  
  11.     public void setName(String name) {
  12.         this.name = name;
  13.     }
  14.  
  15.     public String getSex() {
  16.         return sex;
  17.     }
  18.  
  19.     public void setSex(String sex) {
  20.         this.sex = sex;
  21.     }
  22.  
  23.     public Integer getAge() {
  24.         return age;
  25.     }
  26.  
  27.     public void setAge(Integer age) {
  28.         this.age = age;
  29.     }
  30. }

然后在名为user的索引里，插入多条数据，在main方法里进行测试：

  1.  
  2. import org.apache.http.HttpHost;
  3. import org.elasticsearch.action.bulk.BulkRequest;
  4. import org.elasticsearch.action.bulk.BulkResponse;
  5. import org.elasticsearch.action.index.IndexRequest;
  6. import org.elasticsearch.client.RequestOptions;
  7. import org.elasticsearch.client.RestClient;
  8. import org.elasticsearch.client.RestHighLevelClient;
  9. import org.elasticsearch.common.xcontent.XContentType;
  10.  
  11. public class ESTest_Doc_Insert_Batch {
  12.     public static void main(String[] args) throws Exception {
  13.  
  14.         RestHighLevelClient esClient = new RestHighLevelClient(
  15.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
  16.         );
  17.  
  18.         // 批量插入数据
  19.         BulkRequest request = new BulkRequest();
  20.  
  21.         request.add(new IndexRequest().index("user").id("1001").source(XContentType.JSON, "name", "zhangsan", "age",30,"sex","男"));
  22.         request.add(new IndexRequest().index("user").id("1002").source(XContentType.JSON, "name", "lisi", "age",30,"sex","女"));
  23.         request.add(new IndexRequest().index("user").id("1003").source(XContentType.JSON, "name", "wangwu", "age",40,"sex","男"));
  24.         request.add(new IndexRequest().index("user").id("1004").source(XContentType.JSON, "name", "wangwu1", "age",40,"sex","女"));
  25.         request.add(new IndexRequest().index("user").id("1005").source(XContentType.JSON, "name", "wangwu2", "age",50,"sex","男"));
  26.         request.add(new IndexRequest().index("user").id("1006").source(XContentType.JSON, "name", "wangwu3", "age",50,"sex","男"));
  27.         request.add(new IndexRequest().index("user").id("1007").source(XContentType.JSON, "name", "wangwu44", "age",60,"sex","男"));
  28.         request.add(new IndexRequest().index("user").id("1008").source(XContentType.JSON, "name", "wangwu555", "age",60,"sex","男"));
  29.         request.add(new IndexRequest().index("user").id("1009").source(XContentType.JSON, "name", "wangwu66666", "age",60,"sex","男"));
  30.  
  31.         BulkResponse response = esClient.bulk(request, RequestOptions.DEFAULT);
  32.         System.out.println("====>"+response.getTook());
  33.         System.out.println("====>"+response.getItems());
  34.  
  35.         esClient.close();
  36.     }
  37. }

然后进行测试：

  1.  
  2. import org.apache.http.HttpHost;
  3. import org.elasticsearch.action.search.SearchRequest;
  4. import org.elasticsearch.action.search.SearchResponse;
  5. import org.elasticsearch.client.RequestOptions;
  6. import org.elasticsearch.client.RestClient;
  7. import org.elasticsearch.client.RestHighLevelClient;
  8. import org.elasticsearch.common.unit.Fuzziness;
  9. import org.elasticsearch.index.query.QueryBuilders;
  10. import org.elasticsearch.search.SearchHit;
  11. import org.elasticsearch.search.SearchHits;
  12. import org.elasticsearch.search.builder.SearchSourceBuilder;
  13.  
  14. public class ESTest_Doc_Query {
  15.     public static void main(String[] args) throws Exception {
  16.  
  17.         RestHighLevelClient esClient = new RestHighLevelClient(
  18.                 RestClient.builder(new HttpHost("localhost", 9200, "http"))
  19.         );
  20.  
  21.         // 1. 查询索引中全部的数据
  22. //        SearchRequest request = new SearchRequest();
  23. //        request.indices("user");
  24. //
  25. //        request.source(new SearchSourceBuilder().query(QueryBuilders.matchAllQuery()));
  26. //
  27. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  28. //
  29. //        SearchHits hits = response.getHits();
  30. //
  31. //        System.out.println(hits.getTotalHits());
  32. //        System.out.println(response.getTook());
  33. //
  34. //        for ( SearchHit hit : hits ) {
  35. //            System.out.println(hit.getSourceAsString());
  36. //        }
  37.  
  38.         // 2. 条件查询 : termQuery
  39. //        SearchRequest request = new SearchRequest();
  40. //        request.indices("user");
  41. //
  42. //        request.source(new SearchSourceBuilder().query(QueryBuilders.termQuery("age", 40)));
  43. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  44. //
  45. //        SearchHits hits = response.getHits();
  46. //
  47. //        System.out.println(hits.getTotalHits());
  48. //        System.out.println(response.getTook());
  49. //
  50. //        for ( SearchHit hit : hits ) {
  51. //            System.out.println(hit.getSourceAsString());
  52. //        }
  53.  
  54.         // 3. 分页查询
  55. //        SearchRequest request = new SearchRequest();
  56. //        request.indices("user");
  57. //
  58. //        SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
  59. //        // (当前页码-1)*每页显示数据条数
  60. //        builder.from(2);
  61. //        builder.size(2);
  62. //        request.source(builder);
  63. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  64. //
  65. //        SearchHits hits = response.getHits();
  66. //
  67. //        System.out.println(hits.getTotalHits());
  68. //        System.out.println(response.getTook());
  69. //
  70. //        for ( SearchHit hit : hits ) {
  71. //            System.out.println(hit.getSourceAsString());
  72. //        }
  73.  
  74. //        // 4. 查询排序
  75. //        SearchRequest request = new SearchRequest();
  76. //        request.indices("user");
  77. //
  78. //        SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
  79. //        //
  80. //        builder.sort("age", SortOrder.DESC);
  81. //
  82. //        request.source(builder);
  83. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  84. //
  85. //        SearchHits hits = response.getHits();
  86. //
  87. //        System.out.println(hits.getTotalHits());
  88. //        System.out.println(response.getTook());
  89. //
  90. //        for ( SearchHit hit : hits ) {
  91. //            System.out.println(hit.getSourceAsString());
  92. //        }
  93.  
  94. //        // 5. 过滤字段
  95. //        SearchRequest request = new SearchRequest();
  96. //        request.indices("user");
  97. //
  98. //        SearchSourceBuilder builder = new SearchSourceBuilder().query(QueryBuilders.matchAllQuery());
  99. //        //
  100. //        String[] excludes = {"age"};
  101. //        String[] includes = {};
  102. //        builder.fetchSource(includes, excludes);
  103. //
  104. //        request.source(builder);
  105. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  106. //
  107. //        SearchHits hits = response.getHits();
  108. //
  109. //        System.out.println(hits.getTotalHits());
  110. //        System.out.println(response.getTook());
  111. //
  112. //        for ( SearchHit hit : hits ) {
  113. //            System.out.println(hit.getSourceAsString());
  114. //        }
  115.  
  116. //        // 6. 组合查询
  117. //        SearchRequest request = new SearchRequest();
  118. //        request.indices("user");
  119. //
  120. //        SearchSourceBuilder builder = new SearchSourceBuilder();
  121. //        BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  122. //
  123. //        //boolQueryBuilder.must(QueryBuilders.matchQuery("age", 30));
  124. //        //boolQueryBuilder.must(QueryBuilders.matchQuery("sex", "男"));
  125. //        //boolQueryBuilder.mustNot(QueryBuilders.matchQuery("sex", "男"));
  126. //        boolQueryBuilder.should(QueryBuilders.matchQuery("age", 30));
  127. //        boolQueryBuilder.should(QueryBuilders.matchQuery("age", 40));
  128. //
  129. //        builder.query(boolQueryBuilder);
  130. //
  131. //        request.source(builder);
  132. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  133. //
  134. //        SearchHits hits = response.getHits();
  135. //
  136. //        System.out.println(hits.getTotalHits());
  137. //        System.out.println(response.getTook());
  138. //
  139. //        for ( SearchHit hit : hits ) {
  140. //            System.out.println(hit.getSourceAsString());
  141. //        }
  142.  
  143. //        // 7. 范围查询
  144. //        SearchRequest request = new SearchRequest();
  145. //        request.indices("user");
  146. //
  147. //        SearchSourceBuilder builder = new SearchSourceBuilder();
  148. //        RangeQueryBuilder rangeQuery = QueryBuilders.rangeQuery("age");
  149. //
  150. //        rangeQuery.gte(30);
  151. //        rangeQuery.lt(50);
  152. //
  153. //        builder.query(rangeQuery);
  154. //
  155. //        request.source(builder);
  156. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  157. //
  158. //        SearchHits hits = response.getHits();
  159. //
  160. //        System.out.println(hits.getTotalHits());
  161. //        System.out.println(response.getTook());
  162. //
  163. //        for ( SearchHit hit : hits ) {
  164. //            System.out.println(hit.getSourceAsString());
  165. //        }
  166.  
  167.         // 8. 模糊查询
  168.         SearchRequest request = new SearchRequest();
  169.         request.indices("user");
  170.  
  171.         SearchSourceBuilder builder = new SearchSourceBuilder();
  172.         //这里的Fuzziness.TWO是查询结果的字符串长度偏差，可以设置成Fuzziness.ONE看一下效果
  173.         builder.query(QueryBuilders.fuzzyQuery("name", "wangwu").fuzziness(Fuzziness.TWO));
  174.  
  175.         request.source(builder);
  176.         SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  177.  
  178.         SearchHits hits = response.getHits();
  179.  
  180.         System.out.println(hits.getTotalHits());
  181.         System.out.println(response.getTook());
  182.  
  183.         for ( SearchHit hit : hits ) {
  184.             System.out.println(hit.getSourceAsString());
  185.         }
  186.  
  187. //        // 9. 高亮查询
  188. //        SearchRequest request = new SearchRequest();
  189. //        request.indices("user");
  190. //
  191. //        SearchSourceBuilder builder = new SearchSourceBuilder();
  192. //        TermsQueryBuilder termsQueryBuilder = QueryBuilders.termsQuery("name", "zhangsan");
  193. //
  194. //        HighlightBuilder highlightBuilder = new HighlightBuilder();
  195. //        highlightBuilder.preTags("<font color='red'>");
  196. //        highlightBuilder.postTags("</font>");
  197. //        highlightBuilder.field("name");
  198. //
  199. //        builder.highlighter(highlightBuilder);
  200. //        builder.query(termsQueryBuilder);
  201. //
  202. //        request.source(builder);
  203. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  204. //
  205. //        SearchHits hits = response.getHits();
  206. //
  207. //        System.out.println(hits.getTotalHits());
  208. //        System.out.println(response.getTook());
  209. //
  210. //        for ( SearchHit hit : hits ) {
  211. //            System.out.println(hit.getSourceAsString());
  212. //        }
  213.  
  214. //        // 10. 聚合查询
  215. //        SearchRequest request = new SearchRequest();
  216. //        request.indices("user");
  217. //
  218. //        SearchSourceBuilder builder = new SearchSourceBuilder();
  219. //
  220. //        AggregationBuilder aggregationBuilder = AggregationBuilders.max("maxAge").field("age");
  221. //        builder.aggregation(aggregationBuilder);
  222. //
  223. //        request.source(builder);
  224. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  225. //
  226. //        SearchHits hits = response.getHits();
  227. //
  228. //        System.out.println(hits.getTotalHits());
  229. //        System.out.println(response.getTook());
  230. //
  231. //        for ( SearchHit hit : hits ) {
  232. //            System.out.println(hit.getSourceAsString());
  233. //        }
  234.  
  235.         // 11. 分组查询
  236. //        SearchRequest request = new SearchRequest();
  237. //        request.indices("user");
  238. //
  239. //        SearchSourceBuilder builder = new SearchSourceBuilder();
  240. //
  241. //        AggregationBuilder aggregationBuilder = AggregationBuilders.terms("ageGroup").field("age");
  242. //        builder.aggregation(aggregationBuilder);
  243. //
  244. //        request.source(builder);
  245. //        SearchResponse response = esClient.search(request, RequestOptions.DEFAULT);
  246. //
  247. //        SearchHits hits = response.getHits();
  248. //
  249. //        System.out.println(hits.getTotalHits());
  250. //        System.out.println(response.getTook());
  251. //
  252. //        for ( SearchHit hit : hits ) {
  253. //            System.out.println(hit.getSourceAsString());
  254. //        }
  255.         esClient.close();
  256.     }
  257. }
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/菜鸟追梦旅行/article/detail/68311
推荐阅读
相关标签

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

  

闽ICP备14008679号