ElasticSearch入門-搜索(java api)

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; /*** * * @類編號:* @類名稱:ElasticSearchHandler* @內容摘要: //搜索控制類* @author:鹿偉偉* @創建日期:2016年3月22日 下午3:26:52* @修改人:* @修改日期:* @修改描述:簡單描述修改的內容* @version 1.0.0**/ public class ElasticSearchHandler {private Client client = ESTools.getClient();public void searcher(String key, String indexId, String type) {try {// 創建查詢索引,參數productindex表示要查詢的索引庫為productindexSearchRequestBuilder searchRequestBuilder = client.prepareSearch(indexId);// 設置查詢索引類型,setTypes("productType1", "productType2","productType3");// 用來設定在多個類型中搜索searchRequestBuilder.setTypes(type);// 設置查詢類型 1.SearchType.DFS_QUERY_THEN_FETCH = 精確查詢 2.SearchType.SCAN// = 掃描查詢,無序searchRequestBuilder.setSearchType(SearchType.DFS_QUERY_THEN_FETCH);// 設置查詢關鍵詞searchRequestBuilder.setQuery(QueryBuilders.termQuery("title", key));// // 查詢過濾器過濾價格在4000-5000內// 這里范圍為[4000,5000]區間閉包含,搜索結果包含價格為4000和價格為5000的數據// searchRequestBuilder.setFilter(FilterBuilders.rangeFilter("price")// .from(4000).to(5000));//// // 分頁應用// searchRequestBuilder.setFrom(0).setSize(3);// 設置是否按查詢匹配度排序searchRequestBuilder.setExplain(true);// 設置高亮顯示searchRequestBuilder.addHighlightedField("title");searchRequestBuilder.setHighlighterPreTags("<span style=\"color:red\">");searchRequestBuilder.setHighlighterPostTags("</span>");// 執行搜索,返回搜索響應信息SearchResponse response = searchRequestBuilder.execute().actionGet(); // System.out.println(response.toString());// 獲取搜索的文檔結果SearchHits searchHits = response.getHits();SearchHit[] hits = searchHits.getHits();// ObjectMapper mapper = new ObjectMapper();for (int i = 0; i < hits.length; i++) {SearchHit hit = hits[i];// 將文檔中的每一個對象轉換json串值String json = hit.getSourceAsString();// 將json串值轉換成對應的實體對象// Product product = mapper.readValue(json, Product.class);NewsInfo newsInfo = JsonUtils.readToObject(json, NewsInfo.class);// 獲取對應的高亮域Map<String, HighlightField> result = hit.highlightFields();// 從設定的高亮域中取得指定域HighlightField titleField = result.get("title");// 取得定義的高亮標簽Text[] titleTexts = titleField.fragments();System.out.println(titleTexts.toString());// 為title串值增加自定義的高亮標簽String title = "";for (Text text : titleTexts) {title += text;}// 將追加了高亮標簽的串值重新填充到對應的對象newsInfo.setTitle(title);// 打印高亮標簽追加完成后的實體對象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("齊魯壹點", QlydConstants.INDEX, QlydConstants.TYPE);} }

總結

以上是生活随笔為你收集整理的ElasticSearch入门-搜索(java api)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。