创建HttpSolrServer对象, 连接Solr服务;
创建查询对象(SolrQuery), 设置查询条件;
使用HttpSolrServer对象, 执行查询, 返回查询响应对象(QueryResponse);
使用QueryResponse对象, 获取查询数据;
处理结果集.
3.2 示例代码 /** * SolrJ高级查询 */ @Test public void queryIndexSenior() throws Exception { // 1. 创建HttpSolrServer对象, 连接Solr服务 // 参数baseURL：指定Solr的服务地址 HttpSolrServer solrServer = new HttpSolrServer("http://127.0.0.1:7070/solr/collection1"); // 2. 创建查询对象(SolrQuery), 设置查询条件 SolrQuery solrQuery = new SolrQuery(); // 2.1 设置查询表达式 solrQuery.setQuery("花儿朵朵"); // 2.2 设置过滤条件 solrQuery.setFilterQueries("product_price:[* TO 20]"); // 2.3 设置排序sort solrQuery.setSort("product_price", ORDER.desc); // 2.4 设置分页: start, rows solrQuery.setStart(0); solrQuery.setRows(10); // 2.5 设置显示的域列表 solrQuery.setFields("id", "product_name", "product_price", "product_catalog_name"); // 2.6 设置默认的搜索域 solrQuery.set("df", "product_name"); // 2.7 设置响应格式 solrQuery.set("wt", "json"); // 2.8 设置高亮显示 solrQuery.setHighlight(true); // 开启高亮显示 // 或者: solrQuery.setParam("hl", "true"); solrQuery.addHighlightField("product_name"); // 添加高亮显示的域 solrQuery.setHighlightSimplePre("<font color='red'>"); // 设置高亮显示的HTML标签的前缀 solrQuery.setHighlightSimplePost("<font>"); // 设置高亮显示的HTML标签的后缀 // 2.9 设置分片统计facet solrQuery.setFacet(true); // 开启分片统计 solrQuery.addFacetField("product_catalog_name"); // 添加分片统计的域 // 3. 使用HttpSolrServer对象, 执行查询, 返回查询相应对象 QueryResponse queryResponse = solrServer.query(solrQuery); /* 处理结果集 NamedList list = (NamedList) queryResponse.getResponse().get("highlighting"); for (int i = 0; i < list.size(); i++) { System.out.println("id=" + list.getName(i) + "高亮字段: " + list.getVal(i)); } */ // 4. 使用QueryResponse对象, 获取查询数据 // 4.1 获取查询结果集 SolrDocumentList results = queryResponse.getResults(); // 4.2 获取高亮显示数据 // 第一个Map的key是文档的id, 第二个Map的key是高亮显示的字段名, 第二个Map中的value是处理过的高亮显示结果集, 类型为List<String> Map<String, Map<String, List<String>>> hlMap = queryResponse.getHighlighting(); // 4.3 获取分片统计数据 List<FacetField> facetFields = queryResponse.getFacetFields(); // 6. 处理结果集 System.out.println("结果数量：" + results.getNumFound()); for (SolrDocument doc : results) { System.out.println("= = = = = = = = = = = = = = = = = = ="); // id, product_name, product_price, product_catalog_name // 获取商品id String pid = doc.get("id").toString(); // 获取商品名称: 先从高亮显示结果中获取, 若没有获取到, 再从doc中获取 String pname = ""; List<String> list = hlMap.get(pid).get("product_name"); if (null != list && list.size() > 0) { pname = list.get(0); } else { pname = doc.get("product_name").toString(); } // 获取商品价格 String pprice = doc.get("product_price").toString(); // 获取商品的分类名称 String pcatalogName = doc.get("product_catalog_name").toString(); // 输出结果 System.out.println("商品id: " + pid); System.out.println("商品名称: " + pname); System.out.println("商品价格: " + pprice); System.out.println("商品分类名称: " + pcatalogName); } } 3.3 代码搜索结果作者: ma_shoufeng(马瘦风)
出处: 博客园 马瘦风的博客
您的支持是对博主的极大鼓励, 感谢您的阅读.
本文版权归博主所有, 欢迎转载, 但未经博主同意必须保留此段声明, 且在文章页面明显位置给出原文链接, 否则博主保留追究法律责任的权利.