`

elasticsearch java API ------搜索

阅读更多

elasticsearch java API ------搜索

 

在创建索引时,我们根据IndexResponse,得到了index、type和id,Get一条记录的方法很简单:

 

[java] view plaincopy
 
 
  1. GetResponse getResponse = client.prepareGet(index, type, id).execute().actionGet();   


        分布式搜索Elasticsearch——创建索引一文中提到如何将一个实体转化为Json字符串,我们推荐的方法是使用Jackson,那么,在Get得到Response后,也使用Jackson将Json字符串转化为你的实体:

 

 

[java] view plaincopy
 
 
  1. Person newPerson = mapper.readValue(getResponse.getSourceAsString(), Person.class);  

 

简单的搜索:

 

[java] view plaincopy
 
 
  1. SearchResponse response = client.prepareSearch("user")  
  2.         .setTypes("tb_person0""tb_person1""tb_person2""tb_person3""tb_person4")  
  3.         .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)  
  4.         .setQuery(QueryBuilders.fieldQuery("name""张三"))             // Query  
  5.         .setFilter(FilterBuilders.rangeFilter("age").from(20).to(22))   // Filter  
  6.         .setFrom(0).setSize(60).setExplain(true)  
  7.         .execute()  
  8.         .actionGet();  
  9.   
  10. SearchHits hits = response.getHits();  
  11. for (SearchHit hit : hits) {  
  12.     String json = hit.getSourceAsString();  
  13.       
  14.     Person newPerson = mapper.readValue(json,  
  15.             Person.class);  
  16.     System.out.println("name\t\t" + newPerson.getName());  
  17.     System.out.println("sex\t\t" + newPerson.getSex());  
  18.     System.out.println("age\t\t" + newPerson.getAge());  
  19.     System.out.println("isStudent\t\t" + newPerson.getIsStudent());  
  20. }  


        client.prepareSearch用来创建一个SearchRequestBuilder,搜索即由SearchRequestBuilder执行。

 

        client.prepareSearch方法有参数为一个或多个index,表现在数据库中,即零个或多个数据库名,你既可以使用:

 

[java] view plaincopy
 
 
  1. client.prepareSearch().setIndices("index1","index2","index3","index4");  


        也可以使用以下方式取代:

 

 

[java] view plaincopy
 
 
  1. client.prepareSearch("index1","index2","index3","index4");  

        

 

        SearchRequestBuilder有很多很实用的方法:

        (1) setIndices(String... indices):上文中描述过,参数可为一个或多个字符串,表示要进行检索的index;

        (2) setTypes(String... types):参数可为一个或多个字符串,表示要进行检索的type,当参数为0个或者不调用此方法时,表示查询所有的type;

        (3) setSearchType(SearchType searchType):执行检索的类别,值为org.elasticsearch.action.search.SearchType的元素,SearchType是一个枚举类型的类,其值如下所示:

元素 含义
QUERY_THEN_FETCH

查询是针对所有的块执行的,但返回的是足够的信息,而不是文档内容(Document)。

结果会被排序和分级,基于此,只有相关的块的文档对象会被返回。由于被取到的仅仅是这些,

故而返回的hit的大小正好等于指定的size。这对于有许多块的index来说是很便利的

(返回结果不会有重复的,因为块被分组了)。

QUERY_AND_FETCH

最原始(也可能是最快的)实现就是简单的在所有相关的shard上执行检索并返回结果

。每个shard返回一定尺寸的结果。由于每个shard已经返回了一定尺寸的hit,

这种类型实际上是返回多个shard的一定尺寸的结果给调用者。

DFS_QUERY_THEN_FETCH

与QUERY_THEN_FETCH相同

,预期一个初始的散射相伴用来为更准确的score计算分配了的term频率。

DFS_QUERY_AND_FETCH

与QUERY_AND_FETCH相同

,预期一个初始的散射相伴用来为更准确的score计算分配了的term频率。

SCAN

在执行了没有进行任何排序的检索时执行浏览

。此时将会自动的开始滚动结果集。

COUNT 只计算结果的数量,也会执行facet。

      (4) setSearchType(String searchType),与setSearchType(SearchType searchType)类似,区别在于其值为字符串型的SearchType,值可为dfs_query_then_fetch、dfsQueryThenFetch、dfs_query_and_fetch、dfsQueryAndFetch、query_then_fetch、queryThenFetch、query_and_fetch或queryAndFetch;

        (5) setScroll(Scroll scroll)、setScroll(TimeValue keepAlive)和setScroll(String keepAlive),设置滚动,参数为Scroll时,直接用new Scroll(TimeValue)构造一个Scroll,为TimeValue或String时需要将TimeValue和String转化为Scroll;

        (6) setTimeout(TimeValue timeout)和setTimeout(String timeout),设置搜索的超时时间;

        (7) setQuery,设置查询使用的Query;

        (8) setFilter,设置过滤器;

        (9) setMinScore,设置Score的最小数量;

        (10) setFrom,从哪一个Score开始查;

        (11) setSize,需要查询出多少条结果;

        除以上列举的这些,SearchRequestBuilder还有很多方法,这些方法用于不同的场景,需要大家在实际使用中去体验。

 

        检索出结果后,通过response..getHits()可以得到所有的SearchHit,得到Hit后,便可迭代Hit取到对应的Document,转化成为需要的实体。

 

 

 

      前面提到如何进行搜索,并将SearchRequestBuilder的一些方法进行了列举,本文调用了SearchRequestBuilder的用于高亮的方法,处理了检索中的高亮问题:

 

[java] view plaincopy
 
 
  1. SearchResponse response1 = client.prepareSearch("user")  
  2.         .setTypes("tb_person0""tb_person1""tb_person2""tb_person3""tb_person4")  
  3.         .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)  
  4.         .setQuery(QueryBuilders.fieldQuery("name""张三"))             // Query  
  5.         .addHighlightedField("name")  
  6.         .setHighlighterPreTags("<span style=\"color:red\">")  
  7.         .setHighlighterPostTags("</span>")  
  8.         .setFilter(FilterBuilders.rangeFilter("age").from(20).to(22))   // Filter  
  9.         .setFrom(0).setSize(60).setExplain(true)  
  10.         .execute()  
  11.         .actionGet();  
  12.   
  13. SearchHits hits1 = response1.getHits();    
  14.       for(SearchHit hit : hits1){    
  15.     String json = hit.getSourceAsString();  
  16.       
  17.     Person newPerson = mapper.readValue(json,  
  18.             Person.class);  
  19.       
  20.           Map<String, HighlightField> result = hit.highlightFields();    
  21.           HighlightField titleField = result.get("name");    
  22.           Text[] titleTexts =  titleField.fragments();    
  23.             
  24.           String name = "";  
  25.             
  26.           for(Text text : titleTexts){    
  27.               name += text;  
  28.           }    
  29.           newPerson.setName(name);  
  30.             
  31.     System.out.println("name\t\t" + newPerson.getName());  
  32.     System.out.println("sex\t\t" + newPerson.getSex());  
  33.     System.out.println("age\t\t" + newPerson.getAge());  
  34.     System.out.println("isStudent\t\t" + newPerson.getIsStudent());  
  35.   
  36.       
  37.           System.out.println("--------------------------");    
  38.       }   


        addHighlightedField(String fieldName)指明要进行高亮处理的Field;setHighlighterPreTags设定了高亮文字的前缀;setHighlighterPostTags设定了高亮文字的后缀。

 

        取得hit后,使用hit.highlightFields()取得结果中进行了高亮标识的域名-域值对,然后对这些域名-域值对进行分析得到高亮的域结果。

 

 

 

//游标使用

public void scan(){

//QueryBuilder qb = QueryBuilders.termQuery("description", "descript");


SearchResponse scrollResp = client.prepareSearch("productindex")
               .setSearchType(SearchType.SCAN)
               .setScroll(new TimeValue(60000))
//               .setQuery(qb.buildAsBytes())
               .setSize(100).execute().actionGet(); //100 hits per shard will be returned for each scroll
//Scroll until no hits are returned
while (true) {
   scrollResp = client.prepareSearchScroll(scrollResp.getScrollId()).setScroll(new TimeValue(600000)).execute().actionGet();
   boolean hitsRead = false;
   for (SearchHit hit : scrollResp.getHits()) {
       hitsRead = true;
       System.out.println(hit.getSourceAsString());
       //Handle the hit...
   }
   //Break condition: No hits are returned
   if (!hitsRead) {
       break;
   }
}
}
public void query3(){
QueryBuilder qb3 = QueryBuilders.filteredQuery( 
QueryBuilders.termQuery("name.first", "shay"),  
FilterBuilders.rangeFilter("age") 
               .from(23) 
               .to(54) 
               .includeLower(true) 
               .includeUpper(false) 
           );
SearchResponse searchResponse = client.prepareSearch("productindex")   
       .setQuery(qb3)   
       .setFrom(0).setSize(60).setExplain(true)   
       .execute()   
       .actionGet();  
SearchHits hits = searchResponse.hits();
System.out.println(hits.totalHits());
for (int i = 0; i < hits.totalHits(); i++) {
System.out.println(hits.getAt(i).getSource().toString());
}
}

public void query2(){
QueryBuilder qb2 = QueryBuilders.boolQuery() 
                .must(QueryBuilders.termQuery("content", "test1")) 
                .must(QueryBuilders.termQuery("content", "test4")) 
                .mustNot(QueryBuilders.termQuery("content", "test2")) 
                .should(QueryBuilders.termQuery("content", "test3")); 
SearchResponse searchResponse = client.prepareSearch("productindex")   
       .setQuery(qb2)   
       .setFrom(0).setSize(60).setExplain(true)   
       .execute()   
       .actionGet();  
SearchHits hits = searchResponse.hits();
System.out.println(hits.totalHits());
for (int i = 0; i < hits.totalHits(); i++) {
System.out.println(hits.getAt(i).getSource().toString());
}
}

public void query1(){
QueryBuilder qb1 = QueryBuilders.rangeQuery("type").from(0).to(10).includeLower(true).includeUpper(true);
SearchResponse searchResponse = client.prepareSearch("productindex")   
       .setQuery(qb1)   
       .setFrom(0).setSize(60).setExplain(true)   
       .execute()   
       .actionGet();  
SearchHits hits = searchResponse.hits();
System.out.println(hits.totalHits());
for (int i = 0; i < hits.totalHits(); i++) {
System.out.println(hits.getAt(i).getSource().toString());
}
}

public void query(){
QueryBuilder qb1 = QueryBuilders.termQuery("title", "this"); 
SearchResponse searchResponse = client.prepareSearch("productindex")   
       .setQuery(qb1)   
       .setFrom(0).setSize(60).setExplain(true)   
       .execute()   
       .actionGet();  
SearchHits hits = searchResponse.hits();
System.out.println(hits.totalHits());
for (int i = 0; i < hits.totalHits(); i++) {
System.out.println(hits.getAt(i).getSource().get("description"));
}

}

分享到:
评论

相关推荐

    elasticsearch-rest-high-level-client-6.8.3-API文档-中文版.zip

    赠送jar包:elasticsearch-rest-high-level-client-6.8.3.jar;...标签:elasticsearch、client、rest、high、level、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵

    elasticsearch-6.2.3-API文档-中文版.zip

    标签:elasticsearch、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。

    elasticsearch-rest-client-6.8.3-API文档-中文版.zip

    标签:elasticsearch、client、rest、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译...

    elasticsearch-6.3.0-API文档-中文版.zip

    标签:elasticsearch、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。

    elasticsearch-rest-high-level-client-6.8.3-API文档-中英对照版.zip

    赠送jar包:elasticsearch-rest-high-level-client-6.8.3.jar;...标签:elasticsearch、client、rest、high、level、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.htm

    ElasticSearch Java API 中文文档

    标签《ES Java API 中文文档》强调了文档的内容属性,它属于ElasticSearch的一个重要组成部分,即用Java语言进行数据交互和操作的应用程序接口部分。 从部分内容中可以提取出以下知识点: 1. **Transport Client**...

    elasticsearch-x-content-6.3.0-API文档-中英对照版.zip

    标签:elasticsearch、x、content、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准...

    elasticsearch-6.8.3-API文档-中文版.zip

    标签:elasticsearch、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。

    esapi-java-legacysource-esapi-2.1.0.1.zip

    ESAPI (Enterprise Security API) 是一个开源项目,由OWASP(Open Web Application Security Project)组织维护,旨在提供一套全面的、统一的安全编程接口,帮助Java开发者编写更安全的应用程序。这个压缩包“esapi-...

    elasticsearch-x-content-6.3.0-API文档-中文版.zip

    标签:elasticsearch、x、content、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,...

    elasticsearch-rest-client-6.3.0-API文档-中文版.zip

    标签:elasticsearch、client、rest、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译...

    elasticsearch-rest-client-6.3.0-API文档-中英对照版.zip

    标签:elasticsearch、client、rest、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准...

    esapi-2.1.0.1.zip(esapi-2.1.0.1.jar)

    ESAPI,全称为“Enterprise Security API”,是一款开源的安全软件开发框架,主要针对Java平台。它由OWASP(开放网络应用安全项目)维护,旨在提供一套全面的、易于使用的安全编程接口,帮助开发者在构建应用程序时...

    elasticsearch-rest-client-6.2.3-API文档-中英对照版.zip

    标签:elasticsearch、client、rest、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准...

    elasticsearch-x-content-6.8.3-API文档-中文版.zip

    标签:elasticsearch、x、content、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,...

    elasticsearch-rest-client-6.8.3-API文档-中英对照版.zip

    标签:elasticsearch、client、rest、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准...

    elasticsearch-analysis-dynamic-synonym-7.2.0

    Elasticsearch(ES)是一款功能强大的全文搜索引擎,广泛应用于数据检索、数据分析等领域。为了提高搜索的准确性和便利性,Elasticsearch提供了丰富的分析插件,其中"elasticsearch-analysis-dynamic-synonym-7.2.0...

    elasticsearch-cli-6.8.3-API文档-中英对照版.zip

    标签:elasticsearch、cli、中英对照文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请...

    elasticsearch-core-6.3.0-API文档-中文版.zip

    标签:elasticsearch、core、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心...

    elasticsearch-core-6.8.3-API文档-中文版.zip

    标签:elasticsearch、core、中文文档、jar包、java; 使用方法:解压翻译后的API文档,用浏览器打开“index.html”文件,即可纵览文档内容。 人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心...

Global site tag (gtag.js) - Google Analytics