package com.qlyd.searchhelper;
import java.util.Map;
import net.sf.json.JSONObject;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.client.Client;
import org.elasticsearch.common.text.Text;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.highlight.HighlightField;
import com.qlyd.business.newsinfo.po.NewsInfo;
import com.qlyd.common.QlydConstants;
import com.qlyd.utils.ESTools;
import com.qlyd.utils.JsonUtils;
/**
*
*
* @類編號(hào):
* @類名稱:ElasticSearchHandler
* @內(nèi)容摘要: //搜索控制類
* @author:鹿偉偉
* @創(chuàng)建日期:2016年3月22日 下午3:26:52
* @修改人:
* @修改日期:
* @修改描述:簡單描述修改的內(nèi)容
* @version 1.0.0
*
*/
public class ElasticSearchHandler {
private Client client = ESTools.getClient();
public void searcher(String key, String indexId, String type) {
try {
// 創(chuàng)建查詢索引,參數(shù)productindex表示要查詢的索引庫為productindex
SearchRequestBuilder searchRequestBuilder = client
.prepareSearch(indexId);
// 設(shè)置查詢索引類型,setTypes("productType1", "productType2","productType3");
// 用來設(shè)定在多個(gè)類型中搜索
searchRequestBuilder.setTypes(type);
// 設(shè)置查詢類型 1.SearchType.DFS_QUERY_THEN_FETCH = 精確查詢 2.SearchType.SCAN
// = 掃描查詢,無序
searchRequestBuilder.setSearchType(SearchType.DFS_QUERY_THEN_FETCH);
// 設(shè)置查詢關(guān)鍵詞
searchRequestBuilder
.setQuery(QueryBuilders.termQuery("title", key));
// // 查詢過濾器過濾價(jià)格在4000-5000內(nèi)
// 這里范圍為[4000,5000]區(qū)間閉包含,搜索結(jié)果包含價(jià)格為4000和價(jià)格為5000的數(shù)據(jù)
// searchRequestBuilder.setFilter(FilterBuilders.rangeFilter("price")
// .from(4000).to(5000));
//
// // 分頁應(yīng)用
// searchRequestBuilder.setFrom(0).setSize(3);
// 設(shè)置是否按查詢匹配度排序
searchRequestBuilder.setExplain(true);
// 設(shè)置高亮顯示
searchRequestBuilder.addHighlightedField("title");
searchRequestBuilder
.setHighlighterPreTags("<span style=\"color:red\">");
searchRequestBuilder.setHighlighterPostTags("</span>");
// 執(zhí)行搜索,返回搜索響應(yīng)信息
SearchResponse response = searchRequestBuilder.execute()
.actionGet();
// System.out.println(response.toString());
// 獲取搜索的文檔結(jié)果
SearchHits searchHits = response.getHits();
SearchHit[] hits = searchHits.getHits();
// ObjectMapper mapper = new ObjectMapper();
for (int i = 0; i < hits.length; i++) {
SearchHit hit = hits[i];
// 將文檔中的每一個(gè)對(duì)象轉(zhuǎn)換json串值
String json = hit.getSourceAsString();
// 將json串值轉(zhuǎn)換成對(duì)應(yīng)的實(shí)體對(duì)象
// Product product = mapper.readValue(json, Product.class);
NewsInfo newsInfo = JsonUtils
.readToObject(json, NewsInfo.class);
// 獲取對(duì)應(yīng)的高亮域
Map<String, HighlightField> result = hit.highlightFields();
// 從設(shè)定的高亮域中取得指定域
HighlightField titleField = result.get("title");
// 取得定義的高亮標(biāo)簽
Text[] titleTexts = titleField.fragments();
System.out.println(titleTexts.toString());
// 為title串值增加自定義的高亮標(biāo)簽
String title = "";
for (Text text : titleTexts) {
title += text;
}
// 將追加了高亮標(biāo)簽的串值重新填充到對(duì)應(yīng)的對(duì)象
newsInfo.setTitle(title);
// 打印高亮標(biāo)簽追加完成后的實(shí)體對(duì)象
System.out.println(newsInfo);
}
System.out.println("search success ..");
} catch (Exception e) {
// TODO: handle exception
}
}
public static void main(String[] args) {
ElasticSearchHandler esHandler = new ElasticSearchHandler();
System.out.println("++++++高亮查詢+++++++");
esHandler.searcher("齊魯壹點(diǎn)", QlydConstants.INDEX, QlydConstants.TYPE);
}
}
SearchRequestBuilder常用方法說明
(1) setIndices(String... indices)：上文中描述過核偿，參數(shù)可為一個(gè)或多個(gè)字符串，表示要進(jìn)行檢索的index顽染；
(2) setTypes(String... types)：參數(shù)可為一個(gè)或多個(gè)字符串漾岳，表示要進(jìn)行檢索的type，當(dāng)參數(shù)為0個(gè)或者不調(diào)用此方法時(shí)粉寞，表示查詢所有的type尼荆；
setSearchType(SearchType searchType)：執(zhí)行檢索的類別，值為org.elasticsearch.action.search.SearchType的元素仁锯，SearchType是一個(gè)枚舉類型的類耀找，
其值如下所示：
QUERY_THEN_FETCH:查詢是針對(duì)所有的塊執(zhí)行的，但返回的是足夠的信息，而不是文檔內(nèi)容（Document）野芒。結(jié)果會(huì)被排序和分級(jí)蓄愁，基于此，只有相關(guān)的塊的文檔對(duì)象會(huì)被返回狞悲。由于被取到的僅僅是這些撮抓，故而返回的hit的大小正好等于指定的size。這對(duì)于有許多塊的index來說是很便利的（返回結(jié)果不會(huì)有重復(fù)的摇锋，因?yàn)閴K被分組了）
QUERY_AND_FETCH:最原始（也可能是最快的）實(shí)現(xiàn)就是簡單的在所有相關(guān)的shard上執(zhí)行檢索并返回結(jié)果丹拯。每個(gè)shard返回一定尺寸的結(jié)果。由于每個(gè)shard已經(jīng)返回了一定尺寸的hit荸恕，這種類型實(shí)際上是返回多個(gè)shard的一定尺寸的結(jié)果給調(diào)用者乖酬。
DFS_QUERY_THEN_FETCH：與QUERY_THEN_FETCH相同，預(yù)期一個(gè)初始的散射相伴用來為更準(zhǔn)確的score計(jì)算分配了的term頻率融求。
DFS_QUERY_AND_FETCH:與QUERY_AND_FETCH相同咬像，預(yù)期一個(gè)初始的散射相伴用來為更準(zhǔn)確的score計(jì)算分配了的term頻率。
SCAN：在執(zhí)行了沒有進(jìn)行任何排序的檢索時(shí)執(zhí)行瀏覽生宛。此時(shí)將會(huì)自動(dòng)的開始滾動(dòng)結(jié)果集县昂。
COUNT：只計(jì)算結(jié)果的數(shù)量，也會(huì)執(zhí)行facet陷舅。
(4) setSearchType(String searchType)倒彰，與setSearchType(SearchType searchType)類似，區(qū)別在于其值為字符串型的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)旨袒，設(shè)置滾動(dòng)，參數(shù)為Scroll時(shí)术辐，直接用new Scroll(TimeValue)構(gòu)造一個(gè)Scroll砚尽，為TimeValue或String時(shí)需要將TimeValue和String轉(zhuǎn)化為Scroll；
(6) setTimeout(TimeValue timeout)和setTimeout(String timeout)辉词，設(shè)置搜索的超時(shí)時(shí)間必孤；
(7) setQuery，設(shè)置查詢使用的Query；
(8) setFilter敷搪，設(shè)置過濾器兴想；
(9) setMinScore，設(shè)置Score的最小數(shù)量赡勘；
(10) setFrom嫂便，從哪一個(gè)Score開始查；
(11) setSize闸与，需要查詢出多少條結(jié)果毙替；
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
