1.Spring Data 简介
Spring Data 是 Spring 的顶级项目。里面包含了 N 多个二级子项目，每个子项目对应一种技术或工具。其目的为了让数据访问更加简单，更加方便的和 Spring 进行整合
Spring Data 项目如果单独使用是还需要配置 XML 配置文件的，当和 Spring Boot 整合后使用起来非常方便。spring-boot-starter-data-xx 就是对应的启动器
2.实现步骤
2.1 添加依赖
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-solr</artifactId>
</dependency>
</dependencies>
2.2 编写配置文件
spring:
data:
solr:
host: http://192.168.9.132:8080/solr
# zk-host: 192.168.9.132:2181,192.168.9.132:2182,192.168.9.132:2183
core:collection1
2.3 编写测试类
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = MyApplication.class)
public class MyTest {
@Autowired
private SolrTemplate solrTemplate;
public void testInsert(){
SolrInputDocument doc = new SolrInputDocument();
doc.setField("id","002");
doc.setField("item_title","这是一个手机3");
UpdateResponse ur = solrTemplate.saveBean("collection1", doc);
if(ur.getStatus()==0){
System.out.println("成功");
}else{
System.out.println("失败");
}
solrTemplate.commit("collection1");
}
public void testDelete(){
UpdateResponse ur = solrTemplate.deleteByIds("collection1", "change.me");
if(ur.getStatus()==0){
System.out.println("成功");
}else{
System.out.println("失败");
}
solrTemplate.commit("collection1");
}
public void query(){
SimpleQuery query = new SimpleQuery();
Criteria c = new Criteria("item_keywords");
c.is("手机");
query.addCriteria(c);
query.setOffset(1L);
query.setRows(1);
ScoredPage<DemoPojo> sp = solrTemplate.queryForPage("collection1", query, DemoPojo.class);
System.out.println(sp.getContent());
}
@Test
public void queryHL(){
List<DemoPojo> listResult = new ArrayList<>();
SimpleHighlightQuery query = new SimpleHighlightQuery();
//设置查询条件
Criteria c = new Criteria("item_keywords");
c.is("手机");
query.addCriteria(c);
//分页
query.setOffset(0L);
query.setRows(10);
//排序
Sort sort = new Sort(Sort.Direction.DESC,"id");
query.addSort(sort);
//高亮设置
HighlightOptions hlo = new HighlightOptions();
hlo.addField("item_title item_sell_point");
hlo.setSimplePrefix("<span style='color:red;'>");
hlo.setSimplePostfix("</span>");
query.setHighlightOptions(hlo);
HighlightPage<DemoPojo> hl = solrTemplate.queryForHighlightPage("collection1", query, DemoPojo.class);
// System.out.println(hl.getContent());
List<HighlightEntry<DemoPojo>> highlighted = hl.getHighlighted();
for(HighlightEntry<DemoPojo> hle : highlighted){
List<HighlightEntry.Highlight> list = hle.getHighlights();
DemoPojo dp = hle.getEntity();
for (HighlightEntry.Highlight h : list){
//一个对象里面可能多个属性是高亮属性
if(h.getField().getName().equals("item_title")){
dp.setItem_title( h.getSnipplets().get(0));
}
}
listResult.add(dp);
}
System.out.println(listResult);
}
}