SolrJ常用增删查

Solr搜索引擎一般是只会进行增删查&＃xff0c;对于Solr的数据结构&＃xff0c;可以理解为类似MongoDB的类型的数据库。

与MonogoDB的Schema Free不同。

Solr还是需要自己定义字段&＃xff0c;并且做一些设置的。

而Solr一般在修改索引的时候&＃xff0c;会选择全量更新&＃xff0c;所以一般不会有单条索引的更新操作。

SolrJ添加索引&＃xff1a;

public class SolrJAdd {public static void main(String[] args) {String urlString &＃61; "http://localhost:8983/solr";SolrServer solr &＃61; new HttpSolrServer(urlString);SolrInputDocument document &＃61; new SolrInputDocument();document.addField("id", "552199");document.addField("name", "Gouda cheese wheel");document.addField("price", "49.99");document.addField("weight", 147);//add an array field 针对 multivalue字段String[] features &＃61; {"yellow","salty","hard"} ;document.addField("features", features);try {UpdateResponse response &＃61; solr.add(document);// Remember to commit your changes!solr.commit();System.out.println("commit!");} catch (SolrServerException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}
}

SolrJ删除索引

public class SolrJDelete {public static void main(String[] args) {String urlString &＃61; "http://localhost:8983/solr";SolrServer solr &＃61; new HttpSolrServer(urlString);try {//删除查询到的索引信息solr.deleteByQuery("id:552199");solr.commit(true, true);System.out.println("delete success!");} catch (SolrServerException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}
}

SolrJ查询索引&＃xff1a; 

public class SolrJSearcher {public static void main(String[] args) throws SolrServerException {String urlString &＃61; "http://localhost:8983/solr";HttpSolrServer solr &＃61; new HttpSolrServer(urlString);SolrQuery query &＃61; new SolrQuery();//添加查询query.setQuery("cat:music");//添加过滤条件query.addFilterQuery("price:[50 TO 400]");// 排序query.addSort("id", ORDER.asc);// 分页&＃xff1a;start开始页&＃xff0c;rows每页显示记录条数query.setStart(0);query.setRows(20);// 设置高亮query.setHighlight(true); // 开启高亮组件query.addHighlightField("name");// 高亮字段query.setHighlightSimplePre("");// 标记&＃xff0c;高亮关键字前缀query.setHighlightSimplePost("");QueryResponse response &＃61; solr.query(query);SolrDocumentList docs &＃61; response.getResults();System.out.println("文档个数&＃xff1a;" &＃43; docs.getNumFound());System.out.println("查询时间&＃xff1a;" &＃43; response.getQTime());for (SolrDocument doc : docs) {System.out.println(doc.getFieldNames());System.out.println("id: " &＃43; doc.getFieldValue("id"));System.out.println("price: " &＃43; doc.getFieldValue("price"));System.out.println("name: " &＃43; doc.getFieldValue("name"));System.out.println();}}
}

SolrJ Facet查询&＃xff1a;

public class SolrJFacetSearch {public static void main(String[] args) {String urlString &＃61; "http://localhost:8983/solr";SolrServer solr &＃61; new HttpSolrServer(urlString);SolrQuery query &＃61; new SolrQuery();//Facet为solr中的层次分类查询//分片信息query.setFacet(true).setQuery("*:*").setFacetMinCount(1).setFacetLimit(5)//段//.setFacetPrefix("electronics", "cat").setFacetPrefix("cor")//查询manu、name中关键字前缀是cor的.addFacetField("manu").addFacetField("name");//分片字段try {QueryResponse response &＃61; solr.query(query);// 输出查询结果集SolrDocumentList list &＃61; response.getResults();System.out.println("Query result nums: " &＃43; list.getNumFound());for (int i &＃61; 0; i facets &＃61; response.getFacetFields();for (FacetField facet : facets) {System.out.println(facet);List facetCounts &＃61; facet.getValues();for (FacetField.Count count : facetCounts) {// 关键字 - 出现次数System.out.println(count.getName() &＃43; ": "&＃43; count.getCount());}}System.out.println("Search facet [name] filed result: ");// 输出分片信息FacetField facetField &＃61; response.getFacetField("name");List facetFields &＃61; facetField.getValues();for (Count count : facetFields) {// 关键字 - 出现次数System.out.println(count.getName() &＃43; ": " &＃43; count.getCount());}} catch (SolrServerException e) {e.printStackTrace();}}
}

 Refer to&＃xff1a;http://www.blogjava.net/hoojo/archive/2011/10/21/361747.html