xiaochuan 发表于 2017-12-18 18:50:22

solr环境搭建及java小demo

package com.hlrj.lxl.test;  

  
import java.io.IOException;
  
import java.util.ArrayList;
  
import java.util.List;
  

  
import org.apache.solr.client.solrj.SolrQuery;
  
import org.apache.solr.client.solrj.SolrServerException;
  
import org.apache.solr.client.solrj.impl.HttpSolrServer;
  
import org.apache.solr.client.solrj.response.QueryResponse;
  
import org.apache.solr.client.solrj.response.UpdateResponse;
  
import org.apache.solr.common.SolrDocumentList;
  
import org.apache.solr.update.SolrCmdDistributor.Response;
  

  
import com.hlrj.lxl.bean.SolrTestBean;
  
import com.hlrj.lxl.bean.SorlBean;
  
import com.hlrj.lxl.util.SorlUtils;
  


  
public>  
   
  
   public static void main(String[] args) {
  
         //获得solr服务
  
         HttpSolrServer hs=new HttpSolrServer("http://localhost:8888/solr");
  
         /*SorlUtils sorlUtils=SorlUtils.getInstance();*/
  
         //solr对象实体
  
         SolrTestBean sb=new SolrTestBean();
  
         sb.setId("1");
  
         sb.setTitle("hello word!!!");
  
         List<SolrTestBean> lst=new ArrayList<SolrTestBean>();
  
         for (int i=2;i<15;i++) {
  
             sb=new SolrTestBean();
  
             sb.setId(i+"");
  
             sb.setTitle("hello word!!!"+i);
  
             lst.add(sb);
  
         }
  
         try {
  
            
  
             //添加数据
  
//            UpdateResponse ur=hs.addBean(sb);
  
//            hs.commit();//提交
  
             //添加批量数据
  
//            UpdateResponse ur=hs.addBeans(lst);
  
//            hs.commit();//提交
  
             //删除数据
  
//            hs.deleteById("1");
  
//            hs.commit();//提交
  
            
  
             //查询数据
  
             SolrQuery query=new SolrQuery("hello word");
  
             query.setRows(15);
  
             //得到查询响应对象
  
             QueryResponse response=hs.query(query);
  
             //得到返回结果集
  
             SolrDocumentList doclist=response.getResults();
  
            
  
             for(int i=0;i<doclist.getNumFound()-1;i++)
  
             {
  
               System.out.println("id:"+doclist.get(i).get("id")+"---title:"+doclist.get(i).get("title"));
  
             }
  
            
  
             /*int result= ur.getStatus();
  
             System.out.println(result);*/
  
         } catch (Exception e) {
  
             // TODO Auto-generated catch block
  
             e.printStackTrace();
  
         }
  
   }
  
}
页: [1]
查看完整版本: solr环境搭建及java小demo