向solr索引庫添加數據


一.

寫一個測試用例:
向索引庫添加文檔(數據)
創建一個SolrServer對象。創建一個HttpSolrServer對象
需要指定solr服務的url
創建一個文檔對象SolrInputDocument
向文檔中添加域,必須有id域,域的名稱必須在schema.xml中定義
把文檔對象寫入索引庫
提交
@Test
    public void testAddDocument() throws Exception {
        //創建一個SolrServer對象。創建一個HttpSolrServer對象
        //需要指定solr服務的url
        SolrServer solrServer = new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
        //創建一個文檔對象SolrInputDocument
        SolrInputDocument document = new SolrInputDocument();
        //向文檔中添加域,必須有id域,域的名稱必須在schema.xml中定義
        document.addField("id", "1234");
        document.addField("item_title", "測試商品34");
        document.addField("item_price", 1000);
        //把文檔對象寫入索引庫
        solrServer.add(document);
        //提交
        solrServer.commit();
    }
    @Test
    public void deleteDocumentById() throws Exception {
        SolrServer solrServer = new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
        solrServer.deleteById("1234");
        //提交
        solrServer.commit();
    }
 
    @Test
    public void deleteDocumentByQuery() throws Exception {
        SolrServer solrServer = new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
        solrServer.deleteByQuery("item_title:測試商品3");
        solrServer.deleteByQuery("*:*");
        solrServer.commit();
    }
二.往索引庫循環寫數據
SolrServer solrServer=new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
try {
     //1、先查詢所有商品數據
     List<SearchItem> itemList = this.searchItemDao.getItemList();
     //2、遍歷商品數據添加到索引庫
     for (SearchItem searchItem : itemList) {
         //創建文檔對象
         SolrInputDocument document = new SolrInputDocument();
         //向文檔中添加域
         document.addField("id", searchItem.getId());
         document.addField("item_title", searchItem.getTitle());
         document.addField("item_sell_point", searchItem.getSell_point());
         document.addField("item_price", searchItem.getPrice());
         document.addField("item_image", searchItem.getImage());
         document.addField("item_category_name", searchItem.getCategory_name());
         document.addField("item_desc", searchItem.getItem_desc());
         //把文檔寫入索引庫
         solrServer.add(document);
     }
     //3、提交
     solrServer.commit();
     System.out.println("success");
     a=1;
} catch (Exception e) {
     e.printStackTrace();
}
三.出現錯誤:java異常 java.lang.NoClassDefFoundError: org/slf4j/LoggerFactory
原因:錯誤的原因是因為缺少slf4j日志組件jar包造成的,slf4j是一個開源的日志組件,和log4j類似,都是用來記錄日志的開源組件。
    SLF4J,即簡單日志門面(Simple Logging Facade for Java),不是具體的日志解決方案,它只服務於各種各樣的日志系統。按照官方的說法,SLF4J是一個用於日志系統的簡單Facade,允許最終用戶在部署其應用時使用其所希望的日志系統。
    實際上,SLF4J所提供的核心API是一些接口以及一個LoggerFactory的工廠類。從某種程度上,SLF4J有點類似JDBC,不過比JDBC更簡單,在JDBC中,你需要指定驅動程序,而在使用SLF4J的時候,不需要在代碼中或配置文件中指定你打算使用那個具體的日志系統。如同使用JDBC基本不用考慮具體數據庫一樣,SLF4J提供了統一的記錄日志的接口,只要按照其提供的方法記錄即可,最終日志的格式、記錄級別、輸出方式等通過具體日志系統的配置來實現,因此可以在應用中靈活切換日志系統。
四.解決方法:
解決
配置pom.xml
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-api -->
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-api</artifactId>
    <version>1.7.22</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-log4j12 -->
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-log4j12</artifactId>
    <version>1.7.22</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-simple -->
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-simple</artifactId>
<version>1.7.22</version>
五.用solr進行結果查詢
進行結果查詢:
進行測試練習
import org.junit.jupiter.api.Test;
 
@Test
    public void searchDocumet() throws Exception {
        //創建一個SolrServer對象
        SolrServer solrServer = new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
        //創建一個SolrQuery對象
        SolrQuery query = new SolrQuery();
        //設置查詢條件、過濾條件、分頁條件、排序條件、高亮
        //query.set("q", "*:*");
        query.setQuery("手機");
        //分頁條件
        query.setStart(0);
        query.setRows(10);
        //設置默認搜索域
        query.set("df", "item_keywords");
        //設置高亮
        query.setHighlight(true);
        //高亮顯示的域
        query.addHighlightField("item_title");
        query.setHighlightSimplePre("<div>");
        query.setHighlightSimplePost("</div>");
        //執行查詢,得到一個Response對象
        QueryResponse response = solrServer.query(query);
        //取查詢結果
        SolrDocumentList solrDocumentList = response.getResults();
        //取查詢結果總記錄數
        System.out.println("查詢結果總記錄數:" + solrDocumentList.getNumFound());
        for (SolrDocument solrDocument : solrDocumentList) {
            System.out.println(solrDocument.get("id"));
            //取高亮顯示
            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");
            }
            System.out.println(itemTitle);
            System.out.println(solrDocument.get("item_sell_point"));
            System.out.println(solrDocument.get("item_price"));
            System.out.println(solrDocument.get("item_image"));
            System.out.println(solrDocument.get("item_category_name"));
            System.out.println("=============================================");
        }
    }
寫dao層
寫service層
寫controller層


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM