devbox
我家小花儿
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

elasticsearch(8) : javaApi_elasticsearch8 java api

作者：我家小花儿 | 2024-02-08 11:08:26

赞

踩

elasticsearch8 java api

参考 : ES工具类ESUtils_心静自然禅的专栏-CSDN博客_es工具类 

maven

  1. <dependency>
  2.             <groupId>commons-beanutils</groupId>
  3.             <artifactId>commons-beanutils</artifactId>
  4.             <version>1.9.3</version>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>org.elasticsearch.client</groupId>
  8.             <artifactId>elasticsearch-rest-high-level-client</artifactId>
  9.             <version>7.4.2</version>
  10.             <exclusions>
  11.                 <exclusion>
  12.                     <groupId>org.elasticsearch</groupId>
  13.                     <artifactId>elasticsearch</artifactId>
  14.                 </exclusion>
  15.                 <exclusion>
  16.                     <groupId>org.elasticsearch.client</groupId>
  17.                     <artifactId>elasticsearch-rest-client</artifactId>
  18.                 </exclusion>
  19.             </exclusions>
  20.         </dependency>
  21.         <dependency>
  22.             <groupId>org.elasticsearch.client</groupId>
  23.             <artifactId>elasticsearch-rest-client</artifactId>
  24.             <version>7.4.2</version>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.elasticsearch</groupId>
  28.             <artifactId>elasticsearch</artifactId>
  29.             <version>7.4.2</version>
  30.         </dependency>

springboot java代码

  1. import com.alibaba.fastjson.JSON;
  2. import com.aliyun.autodeploy.agent.service.bo.LogSourceBO;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.apache.commons.beanutils.BeanUtils;
  5. import org.apache.http.HttpHost;
  6. import org.apache.http.client.config.RequestConfig;
  7. import org.elasticsearch.action.bulk.BulkRequest;
  8. import org.elasticsearch.action.bulk.BulkResponse;
  9. import org.elasticsearch.action.index.IndexRequest;
  10. import org.elasticsearch.action.index.IndexResponse;
  11. import org.elasticsearch.action.search.SearchRequest;
  12. import org.elasticsearch.action.search.SearchResponse;
  13. import org.elasticsearch.client.RequestOptions;
  14. import org.elasticsearch.client.RestClient;
  15. import org.elasticsearch.client.RestClientBuilder;
  16. import org.elasticsearch.client.RestHighLevelClient;
  17. import org.elasticsearch.common.xcontent.XContentType;
  18. import org.elasticsearch.index.query.QueryBuilder;
  19. import org.elasticsearch.index.query.QueryBuilders;
  20. import org.elasticsearch.search.SearchHit;
  21. import org.elasticsearch.search.builder.SearchSourceBuilder;
  22. import org.springframework.beans.factory.annotation.Value;
  23. import org.springframework.stereotype.Service;
  24.  
  25. import javax.annotation.PostConstruct;
  26. import java.util.LinkedList;
  27. import java.util.List;
  28. import java.util.Map;
  29.  
  30. /**
  31.  * @Author: liyue
  32.  * @Date: 2021/12/10/17:41
  33.  * @Description:
  34.  */
  35. @Service
  36. @Slf4j
  37. public class ElasticsearchService {
  38.  
  39.     private RestHighLevelClient restHighLevelClient;
  40.  
  41.     @Value("${es.hostname}")
  42.     private String esHostname;
  43.  
  44.     @Value("${es.port}")
  45.     private Integer esPort;
  46.  
  47.     @PostConstruct
  48.     private void run() {
  49.         // 设置IP
  50.         HttpHost esHost = new HttpHost(esHostname, esPort);
  51.         RestClientBuilder restClientBuilder = RestClient.builder(esHost);
  52.         setTimeout(restClientBuilder);
  53.         restHighLevelClient = new RestHighLevelClient(restClientBuilder);
  54.     }
  55.  
  56.     /**
  57.      * 设置超时时间
  58.      */
  59.     private void setTimeout(RestClientBuilder restClientBuilder) {
  60.         restClientBuilder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
  61.             @Override
  62.             public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder builder) {
  63.                 return builder.setConnectTimeout(3000)
  64.                         .setSocketTimeout(50000);
  65.             }
  66.         });
  67.     }
  68.  
  69.     /**
  70.      * 新增
  71.      * @return 保存结果
  72.      * @throws Exception exception
  73.      */
  74.     public IndexResponse save(Object o, String index){
  75.         try {
  76.             IndexRequest indexRequest = new IndexRequest(index);
  77.             indexRequest.source(JSON.toJSONString(o), XContentType.JSON);
  78.             indexRequest.id();
  79.             return restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
  80.         } catch (Exception e) {
  81.             log.error("插入数据失败",e);
  82.             return null;
  83.         }
  84.     }
  85.  
  86.     /**
  87.      * 批量新增
  88.      *
  89.      * @param list       数据list
  90.      * @return 返回保存结果
  91.      * @throws Exception exception
  92.      */
  93.     public BulkResponse batchSave(List<LogSourceBO> list, String index){
  94.         try {
  95.             log.info("数据发送ES,size:{},index:{}",list.size(),index);
  96.             BulkRequest bulkRequest = new BulkRequest();
  97.             IndexRequest indexRequest;
  98.             for (LogSourceBO item : list) {
  99.                 indexRequest = new IndexRequest(index);
  100.                 indexRequest.source(JSON.toJSONString(item), XContentType.JSON);
  101.                 indexRequest.id();
  102.                 bulkRequest.add(indexRequest);
  103.             }
  104.             return restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
  105.         }catch (Exception e){
  106.             log.error("批量保存失败",e);
  107.             return null;
  108.         }
  109.  
  110.     }
  111.  
  112.     /**
  113.      * 查询符合查询条件的所有数据
  114.      *
  115.      * @return 返回结果list
  116.      * @throws Exception exception
  117.      */
  118.     public List<LogSourceBO> query(Long startTime, Long endTime, String index) {
  119.         List<LogSourceBO> logSourceBOS = new LinkedList<>();
  120.         try {
  121.             SearchRequest request = new SearchRequest();
  122.             request.indices(index);
  123.             SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  124.             QueryBuilder queryBuilder = QueryBuilders.boolQuery()
  125.                     .must(QueryBuilders.rangeQuery("timestamp")
  126.                             .gte(startTime)
  127.                             .lte(endTime));
  128.             searchSourceBuilder.query(queryBuilder);
  129.             request.source(searchSourceBuilder);
  130.             SearchResponse res = restHighLevelClient.search(request, RequestOptions.DEFAULT);
  131.             if (res.getHits().getHits() != null) {
  132.                 SearchHit[] hits = res.getHits().getHits();
  133.                 for (SearchHit hit : hits) {
  134.                     Map<String, Object> resultOne = hit.getSourceAsMap();
  135.                     logSourceBOS.add(convertMap2Model(resultOne));
  136.                 }
  137.             }
  138.         }catch (Exception e){
  139.             log.error("查询失败",e);
  140.         }
  141.         return logSourceBOS;
  142.  
  143.     }
  144.  
  145.  
  146.     private LogSourceBO convertMap2Model(Map<String, Object> map) throws Exception {
  147.         LogSourceBO logSourceBO = new LogSourceBO();
  148.         BeanUtils.populate(logSourceBO, map);
  149.         return logSourceBO;
  150.     }
  151. }

测试

  1.  
  2. import com.alibaba.fastjson.JSON;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.aliyun.gts.tt.ms.service.bo.LogSourceBO;
  5. import org.apache.commons.beanutils.BeanUtils;
  6. import org.apache.http.HttpHost;
  7. import org.apache.http.client.config.RequestConfig;
  8. import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
  9. import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
  10. import org.elasticsearch.action.admin.indices.get.GetIndexRequest;
  11. import org.elasticsearch.action.index.IndexRequest;
  12. import org.elasticsearch.action.index.IndexResponse;
  13. import org.elasticsearch.action.search.SearchRequest;
  14. import org.elasticsearch.action.search.SearchResponse;
  15. import org.elasticsearch.client.RequestOptions;
  16. import org.elasticsearch.client.RestClient;
  17. import org.elasticsearch.client.RestClientBuilder;
  18. import org.elasticsearch.client.RestHighLevelClient;
  19. import org.elasticsearch.common.xcontent.XContentType;
  20. import org.elasticsearch.index.query.QueryBuilder;
  21. import org.elasticsearch.index.query.QueryBuilders;
  22. import org.elasticsearch.search.SearchHit;
  23. import org.elasticsearch.search.builder.SearchSourceBuilder;
  24.  
  25. import java.io.IOException;
  26. import java.util.LinkedList;
  27. import java.util.List;
  28. import java.util.Map;
  29.  
  30. /**
  31.  * @Author: liyue
  32.  * @Date: 2021/12/10/16:29
  33.  * @Description:
  34.  */
  35. public class Test {
  36.  
  37.     public static final String INDEX = "test_index_2021_12_10";
  38.  
  39.     private static RestHighLevelClient restHighLevelClient;
  40.  
  41.     static {
  42.         HttpHost esHost = new HttpHost("127.0.0.1", 9200);
  43.         RestClientBuilder restClientBuilder = RestClient.builder(esHost);
  44.         setTimeout(restClientBuilder);
  45.         restHighLevelClient = new RestHighLevelClient(restClientBuilder);
  46.     }
  47.  
  48.     public static void main(String[] args) throws Exception {
  49.  
  50.        /* LogSourceBO testDTO = new LogSourceBO(
  51.                 System.currentTimeMillis(),
  52.                 "g1","u1","d1","k1",1.0
  53.         );
  54.         save(testDTO);
  55. */
  56.         List<LogSourceBO> g1 = query(1639150440001L, 1639150440001L);
  57.  
  58.         System.out.println(JSONObject.toJSONString(g1));
  59.         restHighLevelClient.close();
  60.     }
  61.  
  62.     /**
  63.      * 查询符合查询条件的所有数据
  64.      * @return 返回结果list
  65.      * @throws Exception exception
  66.      */
  67.     public static List<LogSourceBO> query(Long startTime, Long endTime) throws Exception {
  68.         List<LogSourceBO> logSourceBOS = new LinkedList<>();
  69.         SearchRequest request = new SearchRequest();
  70.         request.indices(INDEX);
  71.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  72.         QueryBuilder queryBuilder = QueryBuilders.boolQuery()
  73.                 .must(QueryBuilders.rangeQuery("timestamp")
  74.                         .gte(startTime)
  75.                         .lte(endTime));
  76.         searchSourceBuilder.query(queryBuilder);
  77.         request.source(searchSourceBuilder);
  78.         SearchResponse res = restHighLevelClient.search(request, RequestOptions.DEFAULT);
  79.         if (res.getHits().getHits() != null) {
  80.             SearchHit[] hits = res.getHits().getHits();
  81.             for (SearchHit hit : hits) {
  82.                 Map<String, Object> resultOne = hit.getSourceAsMap();
  83.                 logSourceBOS.add(convertMap2Model(resultOne));
  84.             }
  85.         }
  86.         return logSourceBOS;
  87.     }
  88.  
  89.  
  90.  
  91.     private static LogSourceBO convertMap2Model(Map<String, Object> map) throws Exception {
  92.         LogSourceBO logSourceBO = new LogSourceBO();
  93.         BeanUtils.populate(logSourceBO, map);
  94.         return logSourceBO;
  95.     }
  96.  
  97.     /**
  98.      * 创建索引，新版ES插入数据时自动创建
  99.      *
  100.      * @return 返回索引创建结果
  101.      * @throws IOException exception
  102.      */
  103.     public static CreateIndexResponse createIndex() throws IOException {
  104.         CreateIndexRequest createIndexRequest = new CreateIndexRequest(INDEX);
  105.         return restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);
  106.     }
  107.  
  108.     /**
  109.      * 索引是否存在
  110.      *
  111.      * @return true/false
  112.      */
  113.     public static boolean existIndex() {
  114.         GetIndexRequest request = new GetIndexRequest();
  115.         request.indices(INDEX);
  116.         try {
  117.             return restHighLevelClient.indices().exists(request, RequestOptions.DEFAULT);
  118.         } catch (IOException e) {
  119.             e.printStackTrace();
  120.             return false;
  121.         }
  122.     }
  123.  
  124.  
  125.     /**
  126.      * 新增/修改数据
  127.      *
  128.      * @return 保存结果
  129.      * @throws Exception exception
  130.      */
  131.     public static IndexResponse save(Object o) throws Exception {
  132.         IndexRequest indexRequest = new IndexRequest(INDEX);
  133.         indexRequest.source(JSON.toJSONString(o), XContentType.JSON);
  134.         indexRequest.id();
  135.         return restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
  136.     }
  137.  
  138.     /**
  139.      * 设置超时时间
  140.      */
  141.     private static void setTimeout(RestClientBuilder restClientBuilder) {
  142.         restClientBuilder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
  143.             @Override
  144.             public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder builder) {
  145.                 return builder.setConnectTimeout(3000)
  146.                         .setSocketTimeout(50000);
  147.             }
  148.         });
  149.     }
  150. }

参考

  1.  
  2. import com.alibaba.fastjson.JSON;
  3. import org.apache.commons.beanutils.BeanUtils;
  4. import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
  5. import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
  6. import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
  7. import org.elasticsearch.action.admin.indices.get.GetIndexRequest;
  8. import org.elasticsearch.action.bulk.BulkRequest;
  9. import org.elasticsearch.action.bulk.BulkResponse;
  10. import org.elasticsearch.action.get.GetRequest;
  11. import org.elasticsearch.action.get.GetResponse;
  12. import org.elasticsearch.action.index.IndexRequest;
  13. import org.elasticsearch.action.index.IndexResponse;
  14. import org.elasticsearch.action.search.SearchRequest;
  15. import org.elasticsearch.action.search.SearchResponse;
  16. import org.elasticsearch.action.support.master.AcknowledgedResponse;
  17. import org.elasticsearch.client.RequestOptions;
  18. import org.elasticsearch.client.RestClientBuilder;
  19. import org.elasticsearch.client.RestHighLevelClient;
  20. import org.elasticsearch.common.xcontent.XContentType;
  21. import org.elasticsearch.index.query.QueryBuilder;
  22. import org.elasticsearch.search.SearchHit;
  23. import org.elasticsearch.search.builder.SearchSourceBuilder;
  24. import org.elasticsearch.search.sort.SortOrder;
  25.  
  26. import java.io.IOException;
  27. import java.lang.reflect.Method;
  28. import java.util.ArrayList;
  29. import java.util.List;
  30. import java.util.Map;
  31.  
  32. /**
  33.  * @ProjectName: pet_data
  34.  * @Package: com.example.demo.es
  35.  * @ClassName: EsUtils
  36.  * @Author: Devin.W.Zhang
  37.  * @Description: ES 操作工具类
  38.  * @Date: 12/22/2020 10:58 AM
  39.  * @Version: 1.0
  40.  */
  41. public class EsUtils<T> {
  42.  
  43.     public static final String INDEX = "ly-test-20211210";
  44.  
  45.     private RestHighLevelClient restHighLevelClient;
  46.  
  47.  
  48.     /**
  49.      * 索引是否存在
  50.      *
  51.      * @param indexName 索引名称
  52.      * @return true/false
  53.      */
  54.     public boolean existIndex(String indexName) {
  55.         GetIndexRequest request = new GetIndexRequest();
  56.         request.indices(indexName);
  57.         try {
  58.             return restHighLevelClient.indices().exists(request, RequestOptions.DEFAULT);
  59.         } catch (IOException e) {
  60.             e.printStackTrace();
  61.             return false;
  62.         }
  63.     }
  64.  
  65.     /**
  66.      * 创建索引，新版ES插入数据时自动创建
  67.      *
  68.      * @param index 索引
  69.      * @return 返回索引创建结果
  70.      * @throws IOException exception
  71.      */
  72.     public CreateIndexResponse createIndex(String index) throws IOException {
  73.         CreateIndexRequest createIndexRequest = new CreateIndexRequest(index);
  74.         return restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);
  75.     }
  76.  
  77.     /**
  78.      * 删除索引
  79.      *
  80.      * @param index 索引
  81.      * @return 返回删除结果
  82.      * @throws IOException exception
  83.      */
  84.     public AcknowledgedResponse deleteIndex(String index) throws IOException {
  85.         DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest(index);
  86.         return restHighLevelClient.indices().delete(deleteIndexRequest, RequestOptions.DEFAULT);
  87.     }
  88.  
  89.     /**
  90.      * 通过id获取数据
  91.      *
  92.      * @param id 主键
  93.      * @return 返回查询到的结果
  94.      * @throws IOException exception
  95.      */
  96.     public T get(String id, Class<T> classT) throws Exception {
  97.         System.out.println(String.format("get the data from es, id:%s", id));
  98.         GetRequest request = new GetRequest(INDEX, id);
  99.         GetResponse getResponse = restHighLevelClient.get(request, RequestOptions.DEFAULT);
  100.         Map<String, Object> result = getResponse.getSourceAsMap();
  101.         System.out.println(String.format("the es response:%s", result));
  102.         T t = convertMap2Model(result, classT);
  103.         System.out.println(String.format("change the result to %s: ,the result is :%s", classT, t));
  104.         return t;
  105.     }
  106.  
  107.     /**
  108.      * 新增/修改数据
  109.      *
  110.      * @param t          数据对象
  111.      * @param primaryKey 主键字段名
  112.      * @return 保存结果
  113.      * @throws Exception exception
  114.      */
  115.     public IndexResponse save(T t, String primaryKey) throws Exception {
  116.         IndexRequest indexRequest = new IndexRequest(INDEX);
  117.         indexRequest.source(JSON.toJSONString(t), XContentType.JSON);
  118.         indexRequest.id(getId(t, primaryKey));
  119.         return restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
  120.     }
  121.  
  122.     /**
  123.      * 批量 新增/修改数据
  124.      *
  125.      * @param list       数据list
  126.      * @param primaryKey 主键
  127.      * @return 返回保存结果
  128.      * @throws Exception exception
  129.      */
  130.     public BulkResponse batchSave(List<T> list, String primaryKey) throws Exception {
  131.         BulkRequest bulkRequest = new BulkRequest();
  132.         IndexRequest indexRequest;
  133.         for (T item : list) {
  134.             indexRequest = new IndexRequest(INDEX);
  135.             indexRequest.source(JSON.toJSONString(item), XContentType.JSON);
  136.             indexRequest.id(getId(item, primaryKey));
  137.             bulkRequest.add(indexRequest);
  138.         }
  139.         return restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
  140.     }
  141.  
  142.     /**
  143.      * 查询符合查询条件的所有数据
  144.      *
  145.      * @param queryBuilder queryBuilder
  146.      * @param orders       排序map
  147.      * @param tClass       class
  148.      * @return 返回结果list
  149.      * @throws Exception exception
  150.      */
  151.     public List<T> query(QueryBuilder queryBuilder, Map<String, SortOrder> orders, Class<T> tClass) throws Exception {
  152.         final int currentPage = 1;
  153.         final int pageSize = 100000;
  154.         Object[] obj = pageQuery(currentPage, pageSize, queryBuilder, orders, tClass);
  155.         return (List<T>) obj[1];
  156.     }
  157.  
  158.     /**
  159.      * 分页查询
  160.      * <p>
  161.      * 注意当 (currentPage * pageSize >10000) 该分页查询会报错，
  162.      * 通过postman put方式调用 http://127.0.0.1:9200/_all/_settings?preserve_existing=true 设置 {"index.max_result_window" : "1000000"}
  163.      * 设置成功会返回 {"acknowledged": true}
  164.      * </p>
  165.      *
  166.      * @param currentPage  当前页
  167.      * @param pageSize     每页条数
  168.      * @param queryBuilder queryBuilder
  169.      * @param orders       排序map
  170.      * @param tClass       class
  171.      * @return 返回 总条数和数据list
  172.      * @throws Exception exception
  173.      */
  174.     public Object[] pageQuery(int currentPage, int pageSize, QueryBuilder queryBuilder, Map<String, SortOrder> orders, Class<T> tClass) throws Exception {
  175.         Object[] result = new Object[2];
  176.  
  177.         long totalCount;
  178.         List<T> list = new ArrayList<>();
  179.  
  180.         SearchRequest request = new SearchRequest();
  181.         request.indices(INDEX);
  182.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  183.         searchSourceBuilder.query(queryBuilder);
  184.         request.source(searchSourceBuilder);
  185.  
  186.         //下面的配置为true则如果总条数显示为实际查询到的条数，否则最大只显示10000
  187.         searchSourceBuilder.trackTotalHits(true);
  188.         //起始
  189.         searchSourceBuilder.from((currentPage - 1) * pageSize);
  190.         //默认最大10000
  191.         searchSourceBuilder.size(pageSize);
  192.         //排序
  193.         if (null != orders) {
  194.             for (Map.Entry<String, SortOrder> order : orders.entrySet()) {
  195.                 searchSourceBuilder.sort(order.getKey(), order.getValue());
  196.             }
  197.         }
  198.  
  199.         SearchResponse res = restHighLevelClient.search(request, RequestOptions.DEFAULT);
  200.         totalCount = res.getHits().getTotalHits().value;
  201.         System.out.println(String.format("totalHits: %s", totalCount));
  202.  
  203.         if (res.getHits().getHits() != null) {
  204.             SearchHit[] hits = res.getHits().getHits();
  205.             for (SearchHit hit : hits) {
  206.                 Map<String, Object> resultOne = hit.getSourceAsMap();
  207.                 T t = convertMap2Model(resultOne, tClass);
  208.                 list.add(t);
  209.             }
  210.         }
  211.         result[0] = totalCount;
  212.         result[1] = list;
  213.         return result;
  214.     }
  215.  
  216.  
  217.     /*下面是一些辅助方法*/
  218.  
  219.     /**
  220.      * 通过反射获取主键的值
  221.      *
  222.      * @param t          对象
  223.      * @param primaryKey 主键字段名称
  224.      * @return 返回主键的值
  225.      * @throws Exception exception
  226.      */
  227.     private String getId(T t, String primaryKey) throws Exception {
  228.         Class<?> aClass = t.getClass();
  229.         String methodName = "get" + (primaryKey.charAt(0) + "").toUpperCase() + primaryKey.substring(1);
  230.         Method method = aClass.getDeclaredMethod(methodName);
  231.         return (String) method.invoke(t);
  232.     }
  233.  
  234.     private T convertMap2Model(Map<String, Object> map, Class<T> classT) throws Exception {
  235.         Object o = classT.newInstance();
  236.         BeanUtils.populate(o, map);
  237.         return (T) o;
  238.     }
  239.  
  240.     /**
  241.      * 关闭连接
  242.      */
  243.     public void close() {
  244.         try {
  245.             if (restHighLevelClient != null) {
  246.                 restHighLevelClient.close();
  247.             }
  248.         } catch (Exception e) {
  249.             e.printStackTrace();
  250.         }
  251.     }
  252. }

扩展

范围查询+精确查询

  1. SearchRequest request = new SearchRequest();
  2.             request.indices(index);
  3.             SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  4.             QueryBuilder queryBuilder = QueryBuilders.boolQuery()
  5.                     .must(QueryBuilders.rangeQuery("time")
  6.                             .gte(startTime)
  7.                             .lte(endTime))
  8.                     .must(QueryBuilders.termQuery("age","18));
  9.             searchSourceBuilder.query(queryBuilder);
  10.             searchSourceBuilder.size(10);
  11.             searchSourceBuilder.from(0);
  12.             request.source(searchSourceBuilder);
  13.             SearchResponse res = restHighLevelClient.search(request, RequestOptions.DEFAULT);

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/我家小花儿/article/detail/68757
推荐阅读
相关标签

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

  

闽ICP备14008679号