Solr的常用操作，

Solr的常用操作，

1. import java.io.IOException;
2. import java.util.List;
3. import java.util.Map;
5. import org.apache.solr.client.solrj.SolrQuery;
6. import org.apache.solr.client.solrj.SolrServerException;
7. import org.apache.solr.client.solrj.impl.HttpSolrServer;
8. import org.apache.solr.client.solrj.response.QueryResponse;
9. import org.apache.solr.common.SolrInputDocument;
10. import org.junit.Test;
12. import cn.itcast.solr.domain.Article;
14. public class SolrjTest {
16. /**
17. * 根据SolrInputDocument添加数据或者更新数据
18. * @throws SolrServerException
19. * @throws IOException
20. */
21. @Test
22. public void testCreateOrUpdateBySolrInputDocument() throws SolrServerException, IOException{
24. // 连接服务
25. String baseURL = "http://localhost:8080/solr/article/";
26. HttpSolrServer httpSolrServer = new HttpSolrServer(baseURL); // solr服务的地址
28. // 创建SolrInputDocument
29. SolrInputDocument solrInputDocument = new SolrInputDocument();
30. solrInputDocument.addField("id", 1106327947);
31. solrInputDocument.addField("title", "macbook");
32. solrInputDocument.addField("content", "256G");
34. // 添加数据
35. httpSolrServer.add(solrInputDocument);
36. httpSolrServer.commit();
37. }
39. /**
40. * 通过注解添加或更新数据
41. * @throws SolrServerException
42. * @throws IOException
43. */
44. @Test
45. public void testCreateOrUpdateByBean() throws SolrServerException, IOException{
47. // 连接服务
48. String baseURL = "http://localhost:8080/solr/article/";
49. HttpSolrServer httpSolrServer = new HttpSolrServer(baseURL); // solr服务的地址
51. // Article自己写的一个对象
52. Article article = new Article();
53. article.setId("1106327948");
54. article.setTitle("oppoe");
55. article.setContent("充电五分钟通话两小时");
57. // 添加数据
58. httpSolrServer.addBean(article);
59. httpSolrServer.commit();
60. }
62. /**
63. * 根据SolrQuery查询
64. * @throws SolrServerException
65. * @throws IOException
66. */
67. @Test
68. public void testQueryBySolrQuery() throws SolrServerException, IOException{
70. // 连接服务
71. String baseURL = "http://localhost:8080/solr/article/";
72. HttpSolrServer httpSolrServer = new HttpSolrServer(baseURL); // solr服务的地址
74. // SolrParams params = new SolrQuery("三星"); //这样写也ok
75. // SolrQuery params = new SolrQuery("三星"); // SolrQuery可设置其他条件，这是默认字段的值
76. SolrQuery params =new SolrQuery();
77. params.set(("q", "id:1106327948"); // 设置制定字段的值
78. params.set("fl", "title");
80. QueryResponse queryResponse = httpSolrServer.query(params);
81. List<Article> articles = queryResponse.getBeans(Article.class);
82. System.out.println(articles);
83. }
85. /**
86. * 对结果高亮显示
87. * @throws SolrServerException
88. * @throws IOException
89. */
90. @Test
91. public void testQueryByHL() throws SolrServerException, IOException{
93. // 连接服务
94. String baseURL = "http://localhost:8080/solr/article/";
95. HttpSolrServer httpSolrServer = new HttpSolrServer(baseURL); // solr服务的地址
97. // SolrParams params = new SolrQuery("三星");
98. SolrQuery params = new SolrQuery("三星"); // SolrQuery可设置其他条件
99. params.addHighlightField("title");
101. params.setHighlight(true); // 开启高亮
102. params.setHighlightSimplePre("<em>");
103. params.setHighlightSimplePost("</em>");
105. QueryResponse queryResponse = httpSolrServer.query(params);
106. Map<String, Map<String, List<String>>> map = queryResponse.getHighlighting();
107. System.out.println(map);
108. }
110. /**
111. * 根据id删除数据
112. * @throws SolrServerException
113. * @throws IOException
114. */
115. @Test
116. public void testDeleteById() throws SolrServerException, IOException{
118. // 连接服务
119. String baseURL = "http://localhost:8080/solr/article/";
120. HttpSolrServer httpSolrServer = new HttpSolrServer(baseURL); // solr服务的地址
122. httpSolrServer.deleteById("1105271766");
123. httpSolrServer.commit();
124. }
126. /**
127. * 先查后删
128. * @throws SolrServerException
129. * @throws IOException
130. */
131. @Test
132. public void testDeleteByQuery() throws SolrServerException, IOException{
134. // 连接服务
135. String baseURL = "http://localhost:8080/solr/article/";
136. HttpSolrServer httpSolrServer = new HttpSolrServer(baseURL); // solr服务的地址
138. httpSolrServer.deleteByQuery("title:全高清");
139. httpSolrServer.commit();
140. }
143. }