elasticsearch JAVA客户端操作---搜索的过滤、分组高亮，elasticsearchjava

elasticsearch JAVA客户端操作---搜索的过滤、分组高亮，elasticsearchjava

public void search01() {
QueryBuilder query = QueryBuilders.queryString("9");

// 设置搜索的内容和现实的大小
SearchResponse res = client.prepareSearch("test").setQuery(query)
.setFrom(0).setSize(60).execute().actionGet();
SearchHits shs = res.getHits();
System.out.println("总共有数据：" + shs.getHits().length);
for (SearchHit it : shs) {
System.out.println(it.getSource());
}
}

// 分组fact类似于sql的group
public void search02() {
// 定义一个分组并为其命名
TermsFacetBuilder facetBuilder = FacetBuilders.termsFacet("groupBysex");
// 按照哪个字段进行分组
facetBuilder.field("sex").size(1);
// 过滤器匹配所有文件
facetBuilder.facetFilter(FilterBuilders.matchAllFilter());

SearchResponse res = client.prepareSearch("test2").setTypes("test02")
.addFacet(facetBuilder).execute().actionGet();

// 获取搜索结果中的分组
Facets facet = res.getFacets();
// 多个分组是以map的形式存储
TermsFacet fac = (TermsFacet) facet.getFacets().get("groupBysex");
for (TermsFacet.Entry tf : fac.entries()) {
System.out.println(tf.getCount() + "======" + tf.getTerm());
}
}

// QUERY
public void search03() {
// 按照字段进行索引，只要内容含有即可不用全部符合
QueryBuilder queryBuilder = QueryBuilders.fieldQuery("name",
"李四1后面有内容也可以");

//整个 数据内容中只要 有 这个字即可
QueryBuilder qb =QueryBuilders.queryString("四");

//组合查询 name为 张三，sex为boy的记录 must表示必须有，mustNot表示不包含，should表示可以存在
QueryBuilder queryBuilder2 = QueryBuilders.fieldQuery("name",
"张三");
QueryBuilder queryBuilder3 = QueryBuilders.fieldQuery("sex",
"boy");
QueryBuilder qbmust = QueryBuilders.boolQuery().must(queryBuilder2).should(queryBuilder3);

//过滤查询
QueryBuilder qb3 = QueryBuilders.filteredQuery(
queryBuilder2,
FilterBuilders.prefixFilter("sex", "bo")
);

SearchResponse res = client.prepareSearch("test").setTypes("test01")
.setSearchType(SearchType.DEFAULT)
.setQuery(qb3).execute().actionGet();
SearchHits shs = res.getHits();
System.out.println("共查到数据：" + shs.getHits().length);
for (SearchHit it : shs) {
System.out.println(it.getSource());
}
}

// 高亮显示
public void search04() {
//前缀过滤器 汉字不好用
FilterBuilder fb =  FilterBuilders.prefixFilter("sex", "bo");
//范围过滤
FilterBuilder fb2 =   FilterBuilders.rangeFilter("id").from(1).to(10);
//组合过滤
FilterBuilder fb3 =  FilterBuilders.andFilter(
FilterBuilders.rangeFilter("id").from(1).to(10),
FilterBuilders.prefixFilter("sex", "bo")
).cache(true);//默认false
SearchResponse res = client.prepareSearch("test").setTypes("test01")
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setFilter(fb3)
.execute().actionGet();

SearchHits shs = res.hits();
System.out.println("总共有数据：" + shs.getHits().length);
for (SearchHit it : shs) {
System.out.println(it.getSource());

}
}

// 高亮显示
public void search05() {
QueryBuilder qb1 = QueryBuilders.termQuery("name", "张三_4");
// FilterBuilder filter =FilterBuilders.prefixFilter("name", "张三");
SearchResponse res = client.prepareSearch("test4").setTypes("test04")
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setQuery(QueryBuilders.fieldQuery("id", "1"))
.addHighlightedField("id").setHighlighterPreTags("<spand>")
.setHighlighterPostTags("</bod>").execute().actionGet();

SearchHits shs = res.hits();
System.out.println("总共有数据：" + shs.getHits().length);
for (SearchHit it : shs) {
System.out.println(it.getSource());
// 获取对应的高亮域
Map<String, HighlightField> result = it.highlightFields();
// 从设定的高亮域中取得指定域
HighlightField titleField = result.get("id");
// 取得定义的高亮标签
String[] titleTexts = titleField.fragments();
// 为title串值增加自定义的高亮标签
String title = "";
for (String text : titleTexts) {
title += text;
}
// 将追加了高亮标签的串值重新填充到对应的对象
// product.setTitle(title);
// 打印高亮标签追加完成后的实体对象
System.out.println(title);

}
}