记录一次es商品门店查询，关键字SearchSourceBuilder

SearchSourceBuilder 使用说明
参考：https://www.cnblogs.com/reycg-blog/p/9946821.html@Override
public List<String> baseProductShopNotExistEsSearch(ReqBaseProductShopPageEsQueryVO reqVO) {try {SearchRequest searchRequest = new SearchRequest(EsOperateTables.BASE_PRODUCT_SHOP_SAP.getAlias());SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();sourceBuilder.fetchSource("shop_code", null);//过滤门店编码为null数据Collection<String> ids = reqVO.getIds();if (CollectionUtils.isNotEmpty(ids)) {ids=ids.stream().distinct().collect(Collectors.toList());sourceBuilder.query(QueryBuilders.termsQuery(EsUtils.ID, ids));//根据ID查询}else{throw new RRException("请求参数不能为空");}sourceBuilder.timeout(TimeValue.timeValueMinutes(2L));sourceBuilder.size(new Long(ConstantsUtils.QueryPartams.MAX_RESULT_COUNT).intValue());//分页量sourceBuilder.sort(EsUtils.ID, SortOrder.DESC);//排序searchRequest.source(sourceBuilder);//scroll 分页搜索Scroll scroll = new Scroll(TimeValue.timeValueMinutes(1L));searchRequest.scroll(scroll);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);String scrollId = searchResponse.getScrollId();SearchHit[] searchHits = searchResponse.getHits().getHits();List<String> mapList = Lists.newArrayList();ClearScrollRequest clearScrollRequest = new ClearScrollRequest();while (true) {if(StringUtils.isNotBlank(scrollId)){clearScrollRequest.addScrollId(scrollId);}if(searchHits == null || searchHits.length == 0){break;}Arrays.stream(searchHits).forEach(hit -> mapList.add(hit.getId()));SearchScrollRequest scrollRequest = new SearchScrollRequest(scrollId);scroll = new Scroll(TimeValue.timeValueMinutes(1L));scrollRequest.scroll(scroll);searchResponse = restHighLevelClient.scroll(scrollRequest, RequestOptions.DEFAULT);scrollId = searchResponse.getScrollId();searchHits = searchResponse.getHits().getHits();}ClearScrollResponse clearScrollResponse = restHighLevelClient.clearScroll(clearScrollRequest, RequestOptions.DEFAULT);boolean succeeded = clearScrollResponse.isSucceeded();if(!succeeded){throw new RRException("清除es游标失败");}if(CollectionUtils.isNotEmpty(mapList)){return Lists.newArrayList(CollectionUtils.disjunction(ids,mapList));}else{return Lists.newArrayList(ids);}} catch (Exception e) {log.error(e.getMessage());throw new RRException(e.getMessage());}
}

记录一次es商品门店查询，关键字SearchSourceBuilder相关推荐

ES 查询关键字(match, term, range,terms)、组合多查询(must, should, must_not,filter)、分页、排序sort、高亮highlight
一.常用查询关键字 1. match 查询 match查询会将搜索词分词,再与目标查询字段进行匹配,若分词中的任意一个词与目标字段匹配上,则可查询到. { "match": { & ...
es解决只能查询10000条数据方案
引言在使用es进行数据查询时,由于es官方默认限制了索引一次性最多只能查询10000条数据,查询第10001条数据开始就会报错, 错误的内容大致为:Result window is too larg ...
实战 Java 第10天：商品分页查询
实战 Java 第10天:商品分页查询前言一.添加pagehelper相关依赖二.在 ProductService 类中添加接口三.在 ProductMapper 类中添加接口四.增加 sq ...
MySQL表查询关键字
文章目录对表的SQL语句补充表的查询关键字查询关键字之select与from 查询关键字之where筛选查询关键字之group by分组查询关键字之having过滤查询关键字之distin ...
es java 模糊查询_java使用elasticsearch进行模糊查询-已在项目中实际应用
java使用elasticsearch进行模糊查询使用环境上篇文章本人已书写过,需要maven坐标,ES连接工具类的请看上一篇文章,以下是内容是笔者在真实项目中运用总结而产生,并写的是主要方法和思路 ...
ES中SQL查询详解
一.Elasticsearch SQL简介 Elasticsearch SQL 是一个 X-Pack 组件,它允许对 Elasticsearch 实时执行类似 SQL 的查询.无论是使用 REST 接 ...
Elasticsearch基本查询关键字介绍
话不多说,开整 term(完全匹配) {"query": {"bool": {"must": [{"term": { # ...
week7 day3 记录相关操作之单表查询
week7 day3 记录相关操作之单表查询 1.1 单表查询的用法 1.2 关键字的执行优先级(重点) 1.3 简单查询 1.4 WHERE约束 1.5 分组查询GROUP BY 1.6 HAVIN ...
Mysql外键与查询关键字
今日内容概要 1 > 自增特性 2 > 约束条件之外键 2.1 > 外键简介 2.2 > 外键关系 2.2.1 > 一对多 2.2.2 > 多对多 2.2.3 &g ...
Servlet+JDBC+商品列表查询和修改
代码仓库+文档:https://gitee.com/DerekAndroid/ServletJDBC.git 分析: 效果: http://localhost:8080/ServletJDBC_war ...

记录一次es商品门店查询，关键字SearchSourceBuilder

记录一次es商品门店查询，关键字SearchSourceBuilder相关推荐

最新文章

热门文章