一.
寫一個測試用例:
向索引庫添加文檔(數據)
創建一個SolrServer對象。創建一個HttpSolrServer對象
需要指定solr服務的url
創建一個文檔對象SolrInputDocument
向文檔中添加域,必須有id域,域的名稱必須在schema.xml中定義
把文檔對象寫入索引庫
提交
@Test
public void testAddDocument() throws Exception {
//創建一個SolrServer對象。創建一個HttpSolrServer對象
//需要指定solr服務的url
SolrServer solrServer = new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
//創建一個文檔對象SolrInputDocument
SolrInputDocument document = new SolrInputDocument();
//向文檔中添加域,必須有id域,域的名稱必須在schema.xml中定義
document.addField("id", "1234");
document.addField("item_title", "測試商品34");
document.addField("item_price", 1000);
//把文檔對象寫入索引庫
solrServer.add(document);
//提交
solrServer.commit();
}
@Test
public void deleteDocumentById() throws Exception {
SolrServer solrServer = new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
solrServer.deleteById("1234");
//提交
solrServer.commit();
}
@Test
public void deleteDocumentByQuery() throws Exception {
SolrServer solrServer = new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
solrServer.deleteByQuery("item_title:測試商品3");
solrServer.deleteByQuery("*:*");
solrServer.commit();
}
二.往索引庫循環寫數據
SolrServer solrServer=new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
try {
//1、先查詢所有商品數據
List<SearchItem> itemList = this.searchItemDao.getItemList();
//2、遍歷商品數據添加到索引庫
for (SearchItem searchItem : itemList) {
//創建文檔對象
SolrInputDocument document = new SolrInputDocument();
//向文檔中添加域
document.addField("id", searchItem.getId());
document.addField("item_title", searchItem.getTitle());
document.addField("item_sell_point", searchItem.getSell_point());
document.addField("item_price", searchItem.getPrice());
document.addField("item_image", searchItem.getImage());
document.addField("item_category_name", searchItem.getCategory_name());
document.addField("item_desc", searchItem.getItem_desc());
//把文檔寫入索引庫
solrServer.add(document);
}
//3、提交
solrServer.commit();
System.out.println("success");
a=1;
} catch (Exception e) {
e.printStackTrace();
}
三.出現錯誤:java異常 java.lang.NoClassDefFoundError: org/slf4j/LoggerFactory
原因:錯誤的原因是因為缺少slf4j日志組件jar包造成的,slf4j是一個開源的日志組件,和log4j類似,都是用來記錄日志的開源組件。
SLF4J,即簡單日志門面(Simple Logging Facade for Java),不是具體的日志解決方案,它只服務於各種各樣的日志系統。按照官方的說法,SLF4J是一個用於日志系統的簡單Facade,允許最終用戶在部署其應用時使用其所希望的日志系統。
實際上,SLF4J所提供的核心API是一些接口以及一個LoggerFactory的工廠類。從某種程度上,SLF4J有點類似JDBC,不過比JDBC更簡單,在JDBC中,你需要指定驅動程序,而在使用SLF4J的時候,不需要在代碼中或配置文件中指定你打算使用那個具體的日志系統。如同使用JDBC基本不用考慮具體數據庫一樣,SLF4J提供了統一的記錄日志的接口,只要按照其提供的方法記錄即可,最終日志的格式、記錄級別、輸出方式等通過具體日志系統的配置來實現,因此可以在應用中靈活切換日志系統。
四.解決方法:
解決
配置pom.xml
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-api -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.22</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-log4j12 -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.22</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-simple -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.22</version>
五.用solr進行結果查詢
進行結果查詢:
進行測試練習
import org.junit.jupiter.api.Test;
@Test
public void searchDocumet() throws Exception {
//創建一個SolrServer對象
SolrServer solrServer = new HttpSolrServer("http://192.168.0.128:8080/solr/collection1");
//創建一個SolrQuery對象
SolrQuery query = new SolrQuery();
//設置查詢條件、過濾條件、分頁條件、排序條件、高亮
//query.set("q", "*:*");
query.setQuery("手機");
//分頁條件
query.setStart(0);
query.setRows(10);
//設置默認搜索域
query.set("df", "item_keywords");
//設置高亮
query.setHighlight(true);
//高亮顯示的域
query.addHighlightField("item_title");
query.setHighlightSimplePre("<div>");
query.setHighlightSimplePost("</div>");
//執行查詢,得到一個Response對象
QueryResponse response = solrServer.query(query);
//取查詢結果
SolrDocumentList solrDocumentList = response.getResults();
//取查詢結果總記錄數
System.out.println("查詢結果總記錄數:" + solrDocumentList.getNumFound());
for (SolrDocument solrDocument : solrDocumentList) {
System.out.println(solrDocument.get("id"));
//取高亮顯示
Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
List<String> list = highlighting.get(solrDocument.get("id")).get("item_title");
String itemTitle = "";
if (list != null && list.size() >0) {
itemTitle = list.get(0);
} else {
itemTitle = (String) solrDocument.get("item_title");
}
System.out.println(itemTitle);
System.out.println(solrDocument.get("item_sell_point"));
System.out.println(solrDocument.get("item_price"));
System.out.println(solrDocument.get("item_image"));
System.out.println(solrDocument.get("item_category_name"));
System.out.println("=============================================");
}
}
寫dao層
寫service層
寫controller層
