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]