Java操作Solr之SolrJ

添加SolrJ的jar包

　　solrj是訪問Solr服務的java客戶端，提供索引和搜索的請求方法，SolrJ通常在嵌入在業務系統中，通過SolrJ的API接口操作Solr服務，

<dependency>
    <groupId>org.apache.solr</groupId>
    <artifactId>solr-solrj</artifactId>
    <version>4.10.4</version>
</dependency>
<dependency>
    <groupId>commons-logging</groupId>
    <artifactId>commons-logging</artifactId>
    <version>1.2</version>
</dependency>

創建索引

　　使用SolrJ創建索引，通過調用SolrJ提供的API請求Solr服務，Document通過SolrInputDocument進行構建。

// 創建索引
public static void createIndex() throws Exception {  3     SolrServer solrServer = new HttpSolrServer("http://192.168.50.50:8080/solr/collection1");  4     SolrInputDocument document = new SolrInputDocument();  5     document.addField("id", "00001");  6     document.addField("name", "solr全文檢索");  7     document.addField("price", 86.5f);  8     document.addField("description", "這是一本關於solr的書籍！");  9     UpdateResponse response = solrServer.add(document); 10  solrServer.commit(); 11 }

刪除索引

//刪除索引
public void deleteIndex() throws Exception {  3     SolrServer solrServer = new HttpSolrServer(solrUrl);  4     //根據id刪除
    UpdateResponse response = solrServer.deleteById("c0001");  6     //根據多個id刪除
    solrServer.deleteById("0001,0002");  8     //自動查詢條件刪除
    solrServer.deleteByQuery("name:教程"); 10  solrServer.commit(); 11 }

搜索索引

//查詢索引
public static void selectIndex() throws Exception {  3     SolrServer solr = new HttpSolrServer(solrUrl);  4     // 查詢對象
    SolrQuery query = new SolrQuery();  6     //設置查詢條件,名稱“q”是固定的且必須的  7     //搜索keywords域，keywords是復制域包括name和description
    query.set("q", "keywords:java教程");  9     // 設置商品分類、關鍵字查詢
    query.setQuery("name:數據 AND price:11.1"); 11     // 設置價格范圍
    query.set("fq", "price:[1 TO 20]"); 13     // 查詢結果按照價格降序排序 14     //query.set("sort", "price desc");
    query.addSort("price", ORDER.desc); 16     // 請求查詢
    QueryResponse response = solr.query(query); 18     // 查詢結果
    SolrDocumentList docs = response.getResults(); 20     // 查詢文檔總數
    System.out.println("查詢文檔總數" + docs.getNumFound()); 22     for (SolrDocument doc : docs) { 23         String id = (String) doc.getFieldValue("id"); 24         String name = (String)doc.getFieldValue("name"); 25         Float price = (Float)doc.getFieldValue("price"); 26         String description = (String)doc.getFieldValue("description"); 27  System.out.println(id); 28  } 29 }

高亮搜索索引

// 分頁和高亮
public static void selectHeightLight() throws Exception {  3     SolrServer solr = new HttpSolrServer(solrUrl);  4     // 查詢對象
    SolrQuery query = new SolrQuery();  6     // text是name、title等眾多字段的復制域
    query.setQuery("text:算");  8     // 每頁顯示記錄數
    int pageSize = 2; 10     // 當前頁碼
    int curPage = 1; 12     // 開始記錄下標
    int begin = pageSize * (curPage - 1); 14     // 起始下標
 query.setStart(begin); 16     // 結束下標
 query.setRows(pageSize); 18     // 設置高亮參數
    query.setHighlight(true); // 開啟高亮組件
    query.addHighlightField("name");// 高亮字段
    query.setHighlightSimplePre("<span color='red'>");//前綴標記
    query.setHighlightSimplePost("</span>");// 后綴標記 23     // 請求查詢
    QueryResponse response = solr.query(query); 25     // 查詢結果
    SolrDocumentList docs = response.getResults(); 27     // 查詢文檔總數
    System.out.println("查詢文檔總數" + docs.getNumFound()); 29     for (SolrDocument doc : docs) { 30         // 商品主鍵
        String id = (String) doc.getFieldValue("id"); 32         // 商品名稱
        String name = (String)doc.getFieldValue("name"); 34         // 高亮信息
        if(response.getHighlighting() != null) { 36             if(response.getHighlighting().get(id) != null) { 37                 // 取出高亮片段
                Map<String, List<String>> map = response.getHighlighting().get(id); 39                 if(map.get("name") != null) { 40                     for(String s : map.get("name")) { 41  System.out.println(s); 42  } 43  } 44  } 45  } 46  } 47 }