亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

solr4使用solrj操作索引庫

系統 2035 0

solr配套有好多的客戶端用于操作索引庫,下面我們來講如何用solrj去操作solr索引庫。

一、認識solrj

solrj是solr的java客戶端,用于訪問solr索引庫。它提供了添加、刪除、查詢、優化等功能。

二、下載

????????? 百度、google以下solrj下載,你會發現根本就沒有,那么我們該到哪兒下載呢?其實,它是集成到solr壓縮包里的,解壓文件后,有個目錄/dist/solrj-lib,里面就存放了solrj所用到的jar,你把這些jar都添加到你的classpath就ok。

如果你是使用Maven來構建項目,添加以下代碼到你的pom.xml配置文件中:

      <dependency> 

        <artifactId>solr-solrj</artifactId> 

        <groupId>org.apache.solr</groupId> 

        <version>1.4.0</version> 

        <type>jar</type>

        <scope>compile</scope> 

</dependency>
    
      <dependency> 

        <groupId>org.slf4j</groupId>

        <artifactId>slf4j-simple</artifactId>

        <version>1.5.6</version> 

</dependency>
    

下面是具體使用Solr4j的工具類

?

      
        package
      
      
         x.y.z;




      
      
        import
      
      
         java.io.IOException;


      
      
        import
      
      
         java.util.ArrayList;


      
      
        import
      
      
         java.util.LinkedList;


      
      
        import
      
      
         java.util.List;


      
      
        import
      
      
         java.util.Map;




      
      
        import
      
      
         my.VirtualProxy;




      
      
        import
      
      
         org.apache.log4j.Logger;


      
      
        import
      
      
         org.apache.solr.client.solrj.SolrQuery;


      
      
        import
      
      
         org.apache.solr.client.solrj.SolrServer;


      
      
        import
      
      
         org.apache.solr.client.solrj.SolrServerException;


      
      
        import
      
      
         org.apache.solr.client.solrj.impl.HttpSolrServer;


      
      
        import
      
      
         org.apache.solr.client.solrj.response.FacetField;


      
      
        import
      
      
         org.apache.solr.client.solrj.response.FacetField.Count;


      
      
        import
      
      
         org.apache.solr.client.solrj.response.QueryResponse;


      
      
        import
      
      
         org.apache.solr.common.SolrDocument;


      
      
        import
      
      
         org.apache.solr.common.SolrDocumentList;


      
      
        import
      
      
         org.springframework.beans.factory.annotation.Autowired;


      
      
        import
      
      
         org.springframework.stereotype.Repository;


      
      
        import
      
      
         org.springframework.stereotype.Service;


      
      
        import
      
      
         org.springframework.util.StringUtils;




      
      
        import
      
      
         x.y.z.framework.search.vo.Content;


      
      
        import
      
      
         x.y.z.framework.search.vo.Search;




      
      
        //
      
      
        @Repository & @Autowired is use spring annotations
      
      
        @Repository


      
      
        public
      
      
        class
      
       SearchDAOImpl 
      
        implements
      
      
         SearchDAO

{

    
      
      
        private
      
      
        static
      
       Logger logger = Logger.getLogger(SearchDAOImpl.
      
        class
      
      
        );

    

    
      
      
        //
      
      
        @Autowired
      
      
        private
      
      
         HttpSolrServer solrServer;

    

    @Override

    
      
      
        public
      
      
        void
      
      
         init()

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      

        String SearchService_Url = "http://localhost:8983/solr"
      
        ;

        

        
      
      
        this
      
      .solrServer = 
      
        new
      
      
         HttpSolrServer(SearchService_Url);

        
      
      
        try
      
      
        

        {

            solrServer.ping();

        }

        
      
      
        catch
      
      
         (Exception e)

        {

            
      
      
        //
      
      
         TODO Auto-generated catch block
      
      
                    e.printStackTrace();

        }

    }

    

    @Override

    
      
      
        public
      
      
        void
      
      
         init(String url)

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      
        this
      
      .solrServer = 
      
        new
      
      
         HttpSolrServer(url);

        
      
      
        try
      
      
        

        {

            solrServer.ping();

        }

        
      
      
        catch
      
      
         (Exception e)

        {

            
      
      
        //
      
      
         TODO Auto-generated catch block
      
      
                    e.printStackTrace();

        }

    }

    

    @Override

    
      
      
        public
      
      
        boolean
      
      
         ping()

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      
        try
      
      
        

        {

            
      
      
        if
      
      (
      
        this
      
      .solrServer != 
      
        null
      
      
        )

            {

                
      
      
        this
      
      
        .solrServer.ping();

                
      
      
        return
      
      
        true
      
      
        ;

            }

            
      
      
        else
      
      
        

            {

                logger.debug(
      
      "Manipulate null object.SolrServer must init."
      
        );

                
      
      
        return
      
      
        false
      
      
        ;

            }

        }

        
      
      
        catch
      
      
         (Exception e)

        {

            
      
      
        //
      
      
         TODO Auto-generated catch block
      
      
                    e.printStackTrace();

            
      
      
        return
      
      
        false
      
      
        ;

        }

    }



    @Override

    
      
      
        public
      
      
        void
      
      
         addIndex(Content add)

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      
                

    }



    @Override

    
      
      
        public
      
      
        void
      
      
         deleteIndex(Content delete)

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      
                

    }



    @Override

    
      
      
        public
      
      
        void
      
      
         changeIndex(Content old_index, Content new_index)

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      
                

    }

    

    @Override

    
      
      
        public
      
       Search query(String query, 
      
        int
      
       start, 
      
        int
      
       rows,String SortField, 
      
        boolean
      
      
         Highlight)

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      
        if
      
      (
      
        this
      
      .solrServer != 
      
        null
      
      
        )

        {

            SolrQuery solrQuery 
      
      = 
      
        new
      
      
         SolrQuery();

            solrQuery.setQuery(query);



            
      
      
        //
      
      
        start the query and show the rows number
      
      
                    solrQuery.setStart(start);

            solrQuery.setRows(rows);

            

            
      
      
        //
      
      
        Sequence 

            
      
      
        //
      
      
        Sequence for the asscet time and Weights for the sort result

            
      
      
        //
      
      
        the seq must not a null value 
      
      
                    solrQuery.addSortField(SortField, SolrQuery.ORDER.asc);

            

            
      
      
        //
      
      
        high light 
      
      

            solrQuery.setHighlight(
      
        true
      
      
        );

            solrQuery.addHighlightField(
      
      "name"
      
        );

            solrQuery.addHighlightField(
      
      "id"
      
        );

            solrQuery.addHighlightField(
      
      "title"
      
        );

            solrQuery.addHighlightField(
      
      "features"
      
        );

            solrQuery.addHighlightField(
      
      "content"
      
        );

            

            solrQuery.setHighlightSimplePre(
      
      "<font color='red'>"
      
        );

            solrQuery.setHighlightSimplePost(
      
      "</font>"
      
        );



            solrQuery.setHighlightSnippets(
      
      1);
      
        //
      
      
        結果分片數,默認為1
      
      

            solrQuery.setHighlightFragsize(1000);
      
        //
      
      
        每個分片的最大長度,默認為100
      
      
                    

            solrQuery.setFacet(
      
      
        true
      
      ).setFacetMinCount(1).setFacetLimit(5).addFacetField("id").addFacetField("inStock"
      
        );

            solrQuery.setFacet(
      
      
        true
      
      ).setFacetMinCount(1).setFacetLimit(5).addFacetField("content").addFacetField("inStock"
      
        );

            

            QueryResponse queryResponse 
      
      = 
      
        null
      
      
        ;

            
      
      
        try
      
      
        

            {

                queryResponse 
      
      =
      
         solrServer.query(solrQuery);

                SolrDocumentList solrDocumentList 
      
      =
      
         queryResponse.getResults();



                
      
      
        return
      
      
        new
      
      
         Search(queryResponse,solrDocumentList);

            }

            
      
      
        catch
      
      
         (SolrServerException e)

            {

                
      
      
        //
      
      
         TODO Auto-generated catch block
      
      
                        e.printStackTrace();

            }

            

        }

        
      
      
        else
      
      
        

        {

            logger.debug(
      
      "The Search Server is null value."
      
        );

        }

        
      
      
        return
      
      
        null
      
      
        ;

    }



    @Override

    
      
      
        public
      
      
        void
      
      
         close()

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      
        if
      
      (
      
        this
      
      .solrServer != 
      
        null
      
      
        )

        {

            
      
      
        this
      
      
        .solrServer.shutdown();

        }

        
      
      
        else
      
      
        

        {

            logger.debug(
      
      "Manipulate null object.SolrServer must init."
      
        );

        }

    }







    @Override

    
      
      
        public
      
       List<Content>
      
         queryAll()

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      

        List<Content> list = 
      
        new
      
       ArrayList<Content>
      
         ();

        

        
      
      
        if
      
      (
      
        this
      
      .solrServer != 
      
        null
      
      
        )

        {

            

            SolrQuery solrQuery 
      
      = 
      
        new
      
      
         SolrQuery();

            
      
      
        //
      
      
        String query = "GB";
      
      

            String query = "*:*"
      
        ;

            solrQuery.setQuery(query);

            

            
      
      
        //
      
      
        add the 
      
      

            Integer start = 0
      
        ;

            Integer rows  
      
      = 20
      
        ;

            solrQuery.setStart(start);

            solrQuery.setRows(rows);

            

            
      
      
        //
      
      
        Sequence 

            
      
      
        //
      
      
        Sequence for the asscet time and Weights for the sort result

            
      
      
        //
      
      
        the seq must not a null value 

            
      
      
        //
      
      
        solrQuery.addSortField("name", SolrQuery.ORDER.asc);
      
      

            solrQuery.addSortField("id"
      
        , SolrQuery.ORDER.asc);

            

            
      
      
        //
      
      
        high light 
      
      

            solrQuery.setHighlight(
      
        true
      
      
        );

            solrQuery.addHighlightField(
      
      "name"
      
        );

            solrQuery.addHighlightField(
      
      "id"
      
        );

            solrQuery.addHighlightField(
      
      "title"
      
        );

            solrQuery.addHighlightField(
      
      "features"
      
        );

            solrQuery.addHighlightField(
      
      "content"
      
        );

            

            solrQuery.setParam(
      
      "hl.fl", "content"
      
        );

            

            solrQuery.setHighlightSimplePre(
      
      "<font color=\"red\">"
      
        );

            solrQuery.setHighlightSimplePost(
      
      "</font>"
      
        );

            

            solrQuery.setFacet(
      
      
        true
      
      ).setFacetMinCount(1).setFacetLimit(5).addFacetField("id"
      
        );

            solrQuery.setFacet(
      
      
        true
      
      ).setFacetMinCount(1).setFacetLimit(5).addFacetField("content"
      
        );

            solrQuery.setFacet(
      
      
        true
      
      ).setFacetMinCount(1).setFacetLimit(5).addFacetField("features"
      
        );

            

            
      
      
        try
      
      
        

            {

                QueryResponse queryResponse 
      
      =
      
         solrServer.query(solrQuery);

                SolrDocumentList docs 
      
      =
      
         queryResponse.getResults();

                

                System.out.println(
      
      "doc number found :" +
      
         docs.getNumFound());

                System.out.println(
      
      "doc max score :" +
      
         docs.getMaxScore());

                

                
      
      
        for
      
      
        (SolrDocument doc : docs)

                {

                    String name 
      
      = (String) doc.getFieldValue("name"
      
        );  

                    String id 
      
      = (String) doc.getFieldValue("id"
      
        );  

                    ArrayList features 
      
      = (ArrayList)doc.getFieldValue("features"
      
        );

                    

                    
      
      
        //
      
      
        to add the list value must use the temp object
      
      

                    Content vo = 
      
        new
      
      
         Content();

                    

                    
      
      
        //
      
      
        Set the vo object
      
      
                            vo.setId(id);

                    vo.setName(name);

                    vo.setFeatures(features);

                    

                    list.add(vo);

                    

                    
      
      
        //
      
      
        Print the list value
      
      

                    System.out.println("id        :" +
      
         id);  

                    System.out.println(
      
      "name        :" +
      
         name);  

                    
      
      
        if
      
      (features != 
      
        null
      
      
        )

                    {

                        
      
      
        for
      
      
        (Object feature : features.toArray())

                        {

                            System.out.println(
      
      "feature        :" +
      
         feature.toString());

                        }

                    }

                }

            }

            
      
      
        catch
      
      
         (SolrServerException e)

            {

                
      
      
        //
      
      
         TODO Auto-generated catch block
      
      
                        e.printStackTrace();

            }

        }

        
      
      
        else
      
      
        

        {

            logger.debug(
      
      "The Search Server is null value."
      
        );

        }

        
      
      
        return
      
      
         list;

    }



    @Override

    
      
      
        public
      
      
        int
      
      
         queryTotal(String query)

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      
        if
      
      (
      
        this
      
      .solrServer != 
      
        null
      
      
        )

        {

            

            SolrQuery solrQuery 
      
      = 
      
        new
      
      
         SolrQuery();

            solrQuery.setQuery(query);

            QueryResponse queryResponse;

            
      
      
        try
      
      
        

            {

                queryResponse 
      
      =
      
         solrServer.query(solrQuery);

                
      
      
        return
      
      
         queryResponse.getResults().size();

            }

            
      
      
        catch
      
      
         (SolrServerException e)

            {

                
      
      
        //
      
      
         TODO Auto-generated catch block
      
      
                        e.printStackTrace();

            }

        }

        
      
      
        return
      
       0
      
        ;

    }



    
      
      
        /*
      
      
        

     * (non-Javadoc)

     * @Warning it will clear ALL the index

     * @see com.cfp.framework.search.dao.SearchDAO#clearAll()

     
      
      
        */
      
      
        

    @Override

    
      
      
        public
      
      
        void
      
      
         clearAll()

    {

        
      
      
        //
      
      
         TODO Auto-generated method stub
      
      
        try
      
      
        

        {

            solrServer.deleteByQuery(
      
      "*:*"
      
        );

            solrServer.commit();

        }

        
      
      
        catch
      
      
         (SolrServerException e)

        {

            
      
      
        //
      
      
         TODO Auto-generated catch block
      
      
                    e.printStackTrace();

        }

        
      
      
        catch
      
      
         (IOException e)

        {

            
      
      
        //
      
      
         TODO Auto-generated catch block
      
      
                    e.printStackTrace();

        }

    }

}
      
    

?

solr4使用solrj操作索引庫


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 亚洲精品一二三区-久久 | 高清成人| 欧美亚洲国产一区 | 久久青草免费91线频观看站街 | 香蕉视频精品 | 综合成人在线 | 国产欧美综合一区二区 | 一区二区三区日韩精品 | 久久精品在这里 | 纯欧美一级毛片_免费 | 久久www免费人成高清 | h在线观看免费 | 亚洲国产精品久久久久网站 | 成人夜色视频网站在线观看 | 久久精品国产69国产精品亚洲 | 久久精品国产精品亚洲综合 | 丁香婷婷六月 | 色综合久久天天影视网 | 日韩成人免费aa在线看 | 中文字幕久精品免费视频 | 亚洲欧美人成人综合在线50p | 亚洲国产成人久久精品图片 | 久久亚洲福利 | 九九天天影视 | 久久久久久日本一区99 | 免费中日高清无专码有限公司 | 久久国产香蕉 | 亚洲韩精品欧美一区二区三区 | 亚洲成人www | 伊人五月天婷婷琪琪综合 | 538在线视频二三区视视频 | 亚洲aa视频| 成人小视频在线观看免费 | 国产精品99久久99久久久看片 | 久久草在线视频 | 精品久久伊人 | 香蕉网视频 | 看免费黄色一级视频 | 九九影视理伦片 | 亚州精品永久观看视频 | 成人精品第一区二区三区 |