java对elasticsearch的操作

java中最主要的操作是对elasticsearch进行搜索

搜索文档

搜索文档需要创建SearchRequest对象。

设置搜索的索引：indices(String… indices)，elasticsearch允许对多个索引一起搜索，所以SearchRequest对象中的indices方法可以设置多个索引。
设置搜索的文档类型：types(String… types)，elasticsearch允许对多个文档类型一起搜索，所以SearchRequest对象中的types方法可以设置多个文档类型。
设置搜索条件：搜索条件需要封装在SearchSourceBuilder对象中，我们只需要new SearchSourceBuilder()出该对象出来，然后为该对象设置搜索条件和数据范围相关参数即可。数据范围由from(int from)方法和 size(int size)方法指定。搜索条件由query(QueryBuilder query)方法设置。QueryBuilder对象就是最终封装搜索条件的对象，一个搜索条件就需要创建出一个该对象，该对象不需要我们手动创建，可以从QueryBuilders获取，QueryBuilders定义了各种搜索匹配的方式，我们只需要传入搜索的文档字段即可。
设置搜索关键字高亮：当我们输入关键字搜索，如果能搜索出相应的文档，那一般我们都会在该文档上，把匹配到的关键字高亮显示，设置高亮显示的对象为HighlightBuilder，该对象有两个方法，preTags()高亮前缀，postTags()高亮后缀，通过这两个前缀和后缀，把搜索匹配到的文档中，出现的搜索关键字的地方包裹起来，实现高亮的效果。创建出来的HighlightBuilder设置到SearchSourceBuilder中。然后SearchSourceBuilder又设置到SearchRequest对象中。
搜索：调用高级REST客户端的search方法，并传入SearchRequest对象。
返回结果：返回SearchResponse对象，调用该对象的getHits()方法，获取返回结果，并最终转为我们自己的业务Page对象。

例一：

具体代码如下：

public PageResult search(QueryObject qo) throws Exception {
        SearchRequest request = new SearchRequest();
        request.indices(baseIndex);
        request.types(baseType);
        SearchSourceBuilder sourceBuilder = qo.createSearchSourceBuilder();
        HighlightBuilder highlightBuilder = qo.createHighlightBuilder();
        sourceBuilder.highlighter(highlightBuilder);
        request.source(sourceBuilder);
        SearchResponse response = client.search(request);
        SearchHits searchHits = response.getHits();
        long total = searchHits.getTotalHits();
        SearchHit[] searchHitArray = searchHits.getHits();
        List<T> data = new ArrayList<>();
        for(SearchHit hit : searchHitArray){
            Map<String, Object> source = hit.getSourceAsMap();
            T t = BeanUtil.map2Bean(source, clazz);
            qo.setHighlightFields(t,hit);
            data.add(t);
        }
        return new PageResult(data,Integer.parseInt(total+""),qo.getCurrentPage(),qo.getPageSize());

    }

说明：
1.创建SearchRequest对象
2.创建SearchSourceBuilder对象
3.将SearchSourceBuilder对象加到SearchRequest的source方法里
4.创建SearchResponse对象接受返回数据，将SearchRequest对象加到客户端的search方法里
5.创建SearchHits对象，通过SearchResponse对象的getHits方法获取返回的数据对象
6.创建数组，通过searchHits对象的getHits方法获取具体数据，类型为数组

例二：

 SearchRequest searchRequest = new  SearchRequest(esNamesAndTypesModel.getEsCustomerModelName());
searchRequest.types(esNamesAndTypesModel.getEsCustomerModelType()); 

BoolQueryBuilder boolQueryBuilder = commonCondition.baseCondition(customerQuery);
 boolQueryBuilder.filter(QueryBuilders.boolQuery().mustNot(QueryBuilders.termsQuery("customer_no", customerOptParam.getCustomerNosList())));
 
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.fetchSource("customer_no", null);            //筛选出customer_no，其他的过滤
        searchSourceBuilder.query(boolQueryBuilder);            //将boolQueryBuilder加到SearchSourceBuilder 对象的query方法里去      
        searchSourceBuilder.size(scrollSize);
        searchRequest.source(searchSourceBuilder);  //将SearchSourceBuilder加到SearchRequest对象的source方法里


//创建SearchResponse对象，调用客户端的search方法并把SearchRequest对象加进去进行查询
SearchResponse searchResponse = restHighLevelClient.search(searchRequest);


 Long totalHits = searchResponse.getHits().totalHits;
        for (SearchHit hit : searchResponse.getHits().getHits()) {    //遍数组获取具体数据
            customerNos.add(String.valueOf(hit.getSourceAsMap().get("customer_no")));
        }

说明：
1.创建SearchRequest对象
2.创建BoolQueryBuilder对象，具体的查询语句写在BoolQueryBuilder里
3.创建SearchSourceBuilder对象，将BoolQueryBuilder对象加到SearchSourceBuilder对象的query方法里，另外还可在SearchSourceBuilder里设置from，size等分页信息
4.将SearchSourceBuilder对象加到SearchRequest的source方法里
5.创建SearchResponse对象接受返回数据，将SearchRequest对象加到客户端的search方法里
6.创建SearchHits对象，通过SearchResponse对象的getHits方法获取返回的数据对象

bool查询


//分页查询
 BoolQueryBuilder qb = QueryBuilders.boolQuery();
   
        qb.must(QueryBuilders.matchQuery("title", query));

//精确匹配
 BoolQueryBuilder qb = QueryBuilders.boolQuery();
    qb.must(QueryBuilders.termQuery("author", query));

//模糊匹配
BoolQueryBuilder qb = QueryBuilders.boolQuery();
    qb.must(QueryBuilders.matchQuery("content", query));

//短语模糊匹配
BoolQueryBuilder qb = QueryBuilders.boolQuery();
    qb.must(QueryBuilders.matchPhraseQuery("content", query));

//范围查询
BoolQueryBuilder qb = QueryBuilders.boolQuery();
    qb.must(QueryBuilders.rangeQuery("time").gt(query));    //查询time中大于query的

//filter查询
  BoolQueryBuilder qb = QueryBuilders.boolQuery();
     qb.filter(QueryBuilders.termQuery("name",query.getName()));