solrj操作solr索引庫(流程)
聲明：博主自己記錄以免忘記，所以無邏輯無參考價值。小女子就是醬紫任性
---------首先dao層
訪問索引庫的類。定義一些通用的數據訪問方法。
業務邏輯就是查詢索引庫。
參數：SolrQuery對象
業務邏輯：
1、根據Query對象進行查詢。
2、返回查詢結果。List<SearchItem>、查詢結果的總記錄數。
需要把返回結果封裝到pojo中，至少包含兩個屬性：List<SearchItem>、Long recordCount
再包含一個總頁數。
@Repository
public class ItemSearchDao {
//註入一個solrserver((springmvc中已配)
@Autowired
private SolrServer solrServer;
public SearchResult search(SolrQuery query) throws Exception{
//根據query對象查詢索引庫
QueryResponse response = solrServer.query(query);
//獲得商品列表
SolrDocumentList results = response.getResults();
List<SearchItem> itemList = new ArrayList<SearchItem>();
//商品列表
for (SolrDocument solrDocument : results) {
SearchItem item = new SearchItem();
item.setId((Long) solrDocument.get("id"));
item.setCategory_name((String) solrDocument.get("item_category_name"));
item.setImage((String) solrDocument.get("item_image"));
item.setPrice((long) solrDocument.get("item_price"));
item.setSell_point((String) solrDocument.get("item_sell_point"));
//取高亮顯示
Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
List<String> list = highlighting.get(solrDocument.get("id")).get("item_title");
String itemTitle = "";
//有高亮顯示的內容時。
if (list != null && list.size() > 0) {
itemTitle = list.get(0);
} else {
itemTitle = (String) solrDocument.get("item_title");
}
item.setTitle(itemTitle);
//添加到商品列表
itemList.add(item);
}
SearchResult result = new SearchResult();
result.setItemList(itemList);
result.setRecordCount(results.getNumFound());
return result;
}
}
-----接著service層
參數：queryString：查詢條件
Page：頁碼
Rows：每頁顯示的記錄數。
業務邏輯：
1、創建一個SolrQuery對象。
2、設置查詢條件
3、設置分頁條件
4、需要指定默認搜索域。
5、設置高亮
6、執行查詢，調用SearchDao。得到SearchResult
7、需要計算總頁數。
8、返回SearchResult
返回值：SearchResult
public class SearchServiceImpl implements SearchService {
// 註入dao
@Autowired
private ItemSearchDao itemSearchDao;
@Override
public SearchResult search(String queryString, int page, int rows)
throws Exception {
// 1、創建一個SolrQuery對象。
SolrQuery solrQuery = new SolrQuery();
// 2、設置查詢條件
solrQuery.set(queryString);
// 3、設置分頁條件
solrQuery.setStart((page-1)*rows);
solrQuery.setRows(rows);
// 4、需要指定默認搜索域。
solrQuery.set("df","item_title");
// 5、設置高亮
solrQuery.setHighlight(true);
//高亮的前綴後綴 還有高亮顯示域
solrQuery.addHighlightField("item_title");
solrQuery.setHighlightSimplePre("<em style=\"color:red\">");
solrQuery.setHighlightSimplePost("</em>");
// 6、執行查詢，調用SearchDao。得到SearchResult
SearchResult result = itemSearchDao.search(solrQuery);
// 7、需要計算總頁數。 還要判斷
long recordCount = result.getRecordCount();
long pageCount = recordCount / rows;
if(recordCount % rows >0){
pageCount++;
}
result.setPageCount(pageCount);
// 8、返回SearchResult
return result;
}
}
(別忘了dubbo要聲明暴露的接口)
------最後表現層
請求的url：/search
參數：
1、q 查詢條件。
2、page 頁碼。默認為1
返回值：
邏輯視圖，返回值。String。
業務邏輯：
1、接收參數
2、調用服務查詢商品列表
3、把查詢結果傳遞給頁面。需要參數回顯。
@Controller
public class SearchController {
@Autowired
private SearchService searchService;
@Value("${ITEM_COUNT}")
private Integer ITEM_COUNT;
@RequestMapping("/search")
public String search(@RequestParam("q") String querString,
@RequestParam(defaultValue = "1") Integer page, Model model)
throws Exception {
querString = new String(querString.getBytes("iso8859-1"),"utf-8");
SearchResult result = searchService
.search(querString, page, ITEM_COUNT);
// 傳遞給頁面
model.addAttribute("query", querString);
model.addAttribute("totalPages", result.getPageCount());
model.addAttribute("itemList", result.getItemList());
model.addAttribute("page", page);
return "search";
}
}
solrj操作solr索引庫(流程)