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

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條評論
主站蜘蛛池模板: 欧美一区二区三区播放 | 日本一级大黄毛片免费基地 | 色爱区综合激情五月综合激情 | 亚洲视频在线视频 | 日本不卡视频免费 | 色综合色狠狠天天久久婷婷基地 | 国产精品va一区二区三区 | 综合网五月 | 97看片吧| 中文字幕在线观看2023 | 久久亚洲精品国产精品婷婷 | 美女视频很黄很黄又免费的 | 日韩视频一区 | 一级中文字幕 | 欧美一级视频在线观看 | 国产一区二区在线免费观看 | 欧美国产影院 | 亚洲视频日韩视频 | 日本h片a毛片在线播放 | 天天躁日日2018躁狠狠躁 | 欧美一线视频 | 天天操天天摸天天干 | 国产综合久久久久 | 中文字幕亚洲精品日韩精品 | 男人看的网址 | 97se视频| 久久国产精品广西柳州门 | 久久综合视频网 | 99久久精品国产高清一区二区 | 国产片网址 | 中文字幕日韩在线一区国内 | 49xxx中国妇女内谢视频 | 欧美日韩精品国产一区二区 | 免费播放美女一级毛片 | 国产伦精品一区二区三区无广告 | 亚洲欧美日韩在线一区二区三区 | 免费a级毛片大学生免费观看 | 日本无吗中文字幕免费婷婷 | 婷婷的久久五月综合先锋影音 | 国产二级毛片 | 欧美操操操 |