向solr索引库添加数据

一.

写一个测试用例：

向索引库添加文档（数据）

创建一个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

</dependency>

</dependency>

<artifactId>slf4j-simple</artifactId>

五.用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层