二十六、solr的基本使用
public class Message {
??? private String id;
??? private String title;
??? private String[] content;
???
???
??? public Message() {
??? ??? super();
??? }
??? public Message(String id, String title, String[] content) {
??? ??? super();
??? ??? this.id = id;
??? ??? this.title = title;
??? ??? this.content = content;
??? }
??? public String getId() {
??? ??? return id;
??? }
???
??? @Field
??? public void setId(String id) {
??? ??? this.id = id;
??? }
??? public String getTitle() {
??? ??? return title;
??? }
???
???? //使用solr的注解
??? @Field("msg_title")
??? public void setTitle(String title) {
??? ??? this.title = title;
??? }
??? public String[] getContent() {
??? ??? return content;
??? }
???
??? @Field("msg_content")
??? public void setContent(String[] content) {
??? ??? this.content = content;
??? }
}
public class SolrTest {
??? private final static String??? ??? URL??? ??? = "http://localhost:8080/solr";
??? private CommonsHttpSolrServer??? server??? = null;
???
??? @Before
??? public void init() {
??? ??? try {
??? ??? ??? server = new CommonsHttpSolrServer(URL);
??? ??? } catch (MalformedURLException e) {
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
???
??? @Test
??? public void test01() {
??? ??? try {
??? ??? ??? SolrInputDocument doc = new SolrInputDocument();
??? ??? ??? //id是唯一的主键，当多次添加的时候，最后添加的相同id的域会覆盖前面的域
??? ??? ??? doc.addField("id", "1");
?????????????? //具体的Field需要在schema.xml文件中通过field标签定义，并且定义好分词器
??? ??? ??? doc.addField("msg_title", "这是我的第一个solrj的程序");
??? ??? ??? doc.addField("msg_content", "我的solrj的程序究竟能不能跑得起来呢？");
??? ??? ??? server.add(doc);
??? ??? ??? server.commit();
??? ??? } catch (MalformedURLException e) {
??? ??? ??? e.printStackTrace();
??? ??? } catch (SolrServerException e) {
??? ??? ??? e.printStackTrace();
??? ??? } catch (IOException e) {
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
???
??? @Test
??? public void test02() {
??? ??? try {
??? ??? ??? List<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
??? ??? ??? SolrInputDocument doc = new SolrInputDocument();
??? ??? ??? doc.addField("id", "2");
??? ??? ??? doc.addField("msg_title", "很好！solr可以工作了");
??? ??? ??? doc.addField("msg_content", "slor总算可以正式工作了");
??? ??? ??? docs.add(doc);
??? ??? ??? doc = new SolrInputDocument();
??? ??? ??? doc.addField("id", "3");
??? ??? ??? doc.addField("msg_title", "测试一下solr的添加");
??? ??? ??? doc.addField("msg_content", "看看能不能添加一个列表信息");
??? ??? ??? docs.add(doc);
??? ??? ??? server.add(docs);
??? ??? ??? server.commit();
??? ??? } catch (SolrServerException e) {
??? ??? ??? e.printStackTrace();
??? ??? } catch (IOException e) {
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
???
??? @Test
??? public void test03() {
??? ??? try {
??? ??? ??? List<Message> msgs = new ArrayList<Message>();
??? ??? ??? msgs.add(new Message("4", "基于java bean的添加", new String[] { "通过java bean完成添加",
??? ??? ??? ??? ??? "java bean的添加附件" }));
?????????????? //添加的域如果是个数组，需要将schema.xml中field的mutilValue设置成true
??? ??? ??? msgs.add(new Message("5", "基于java bean的列表数据的添加", new String[] { "测试如何通过一个对象完成添加",
??? ??? ??? ??? ??? "通过对象完成添加的附件" }));
??? ??? ??? server.addBeans(msgs);
??? ??? ??? server.commit();
??? ??? } catch (SolrServerException e) {
??? ??? ??? e.printStackTrace();
??? ??? } catch (IOException e) {
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
???
??? @Test
??? public void test04() {
??? ??? try {
??? ??? ??? //定义查询字符串
??? ??? ??? SolrQuery query = new SolrQuery("*");
?????????????? //分页
??? ??? ??? query.setStart(0);
??? ??? ??? query.setRows(3);
??? ??? ??? QueryResponse resp = server.query(query);
??? ??? ??? //查询出来的结果都保存在SolrDocumentList中
??? ??? ??? SolrDocumentList sdl = resp.getResults();
??? ??? ??? System.out.println(sdl.getNumFound());
??? ??? ??? for (SolrDocument sd : sdl) {
??? ??? ??? ??? //??? ??? ??? ??? System.out.println(sd);
??? ??? ??? ??? System.out.println(sd.getFieldValue("msg_title") + ","
??? ??? ??? ??? ??? ??? ??? ??? ??? + sd.getFieldValue("msg_content"));
??? ??? ??? }
??? ??? } catch (SolrServerException e) {
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
???
??? @Test
??? public void test05() {
??? ??? try {
??? ??? ??? SolrQuery query = new SolrQuery("*");
??? ??? ??? query.setStart(0);
??? ??? ??? query.setRows(3);
??? ??? ??? QueryResponse resp = server.query(query);
??? ??? ??? //可以直接查询相应的bean对象，但是不是很常用
??? ??? ??? List<Message> list = resp.getBeans(Message.class);
??? ??? ??? System.out.println(list.size());
??? ??? ??? for (Message msg : list) {
??? ??? ??? ??? System.out.println(msg.getTitle());
??? ??? ??? }
??? ??? } catch (SolrServerException e) {
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
???
??? @Test
??? public void test06() {
??? ??? try {
??? ??? ??? SolrQuery query = new SolrQuery("测试");
??? ??? ??? query.setHighlight(true).setHighlightSimplePre("<span class='highligter'>")
??? ??? ??? ??? .setHighlightSimplePost("</span>").setStart(0).setRows(5);
??????????? //设置哪些字段高亮
??? ??? ??? query.setParam("hl.fl", "msg_title,msg_content");
??? ??? ??? QueryResponse resp = server.query(query);
??? ??? ??? //查询出来的结果都保存在SolrDocumentList中
??? ??? ??? SolrDocumentList sdl = resp.getResults();
??? ??? ??? System.out.println(sdl.getNumFound());
??? ??? ??? for (SolrDocument sd : sdl) {
??? ??? ??? ??? String id = (String) sd.getFieldValue("id");
??????????????????? //取出高亮字段
??? ??? ??? ??? System.out.println(resp.getHighlighting().get(id).get("msg_content"));
??? ??? ??? }
??? ??? } catch (SolrServerException e) {
??? ??? ??? e.printStackTrace();
??? ??? }
??? }
}
