Solr客户端自定义开发

吸毒的虫子

@Service
@Qualifier("searchService")
public class SearchService {
@Value("${solr.url}")
private String searchurl;
@Value("${solr.q.fields}")
private String qfields;
@Value("${solr.s.fields}")
private String sfields;
@Value("${solr.h.fields}")
private String hfields;
/**
* 分页查询Position
* @param key 关键字
* @param page 分页
* @param pagesize 分页大小
* @return 分页信息
*/
public PageInfo<Position> query(String key, int page, int pagesize) {
PageInfo<Position> ps = new PageInfo<Position>(page, pagesize);
SolrServer server = new HttpSolrServer(searchurl);
SolrQuery params = new SolrQuery();
params.setQuery(setQueryFields(key, qfields));
params.setStart(ps.getStart());
params.setRows(ps.getPagesize());
boolean ish = setHighlight(params,hfields);
setSortFields(params, sfields);
SolrDocumentList list = null;
//第一个Map的键是文档的ID，第二个Map的键是高亮显示的字段名
Map<String,Map<String,List<String>>> high= null;
try {
QueryResponse response = server.query(params);
list = response.getResults();
if(ish){
high = response.getHighlighting();
}
} catch (Exception e) {
e.printStackTrace();
}
if(ish){
}
ps.setItems(mappingVo(list,high,ish));
ps.setTotal((int) list.getNumFound());
return ps;
}
/**
* 设置高亮字段
* @param params SolrQuery对象
* @param hfields2 高亮字段，以逗号分隔
* @return 是否需要高亮
*/
private boolean setHighlight(SolrQuery params, String hfields2) {
if(StringUtils.hasText(hfields2)){
String[] arr = hfields2.split(",");
for (String s : arr) {
params.addHighlightField(s);
}
params.setHighlight(true);
params.setHighlightSimplePre("<font color='red'><em>");
params.setHighlightSimplePost("</em></font>");
return true;
}
return false;
}
/**
* 将查询结果返回映射为Position对象列表
* @param list 返回的document列表
* @param high 高亮信息
* @param ish 是否需要高亮
* @return Position对象列表
*/
private List<Position> mappingVo(SolrDocumentList list,Map<String,Map<String,List<String>>> high,boolean ish) {
List<Position> poses = new ArrayList<Position>();
for (SolrDocument doc : list) {
Position p = new Position();
p.setPid(doc.getFieldValue("CP_ID").toString());
if(ish && high.get(p.getPid()).containsKey("COMPANY_NAME")){
p.setCompany(high.get(p.getPid()).get(("COMPANY_NAME")).toString());
}else{
p.setCompany(doc.getFieldValue("COMPANY_NAME").toString());
}
p.setStamp((Date)doc.getFieldValue("ADD_AT"));
poses.add(p);
}
return poses;
}
/**
* 设置排序字段
* @param params SolrQuery对象
* @param sfields2 排序字段，都是按降序排
*/
private void setSortFields(SolrQuery params, String sfields2) {
String[] arr = sfields2.split(",");
for (String s : arr) {
params.addSortField(s, ORDER.desc);
}
}
/**
* 定义查询字段
* @param key 关键字
* @param qfields2 以，分隔的字段列表，以或条件
* @return
*/
private String setQueryFields(String key, String qfields2) {
StringBuilder sb = new StringBuilder();
String[] arr = qfields2.split(",");
for (String s : arr) {
sb.append(s).append(":").append(key).append(" OR ");
}
String q = sb.toString();
return q.substring(0, q.length() - 4);
}
}

另外在浏览器中清除所有的索引可以这样

http://localhost:8080/solr/update?stream.body=%3Cdelete%3E%3Cquery%3E*:*%3C/query%3E%3C/delete%3E&commit=true


<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.nbrc.gqh</groupId>
<artifactId>search</artifactId>
<packaging>war</packaging>
<version>1.0.0-SNAPSHOT</version>
<name>search Maven Webapp</name>
<url>http://maven.apache.org</url>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>3.2.1.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>3.2.1.RELEASE</version>
</dependency>
<dependency>
<groupId>org.apache.solr</groupId>
<artifactId>solr-solrj</artifactId>
<version>3.6.2</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<version>2.5</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>taglibs</groupId>
<artifactId>standard</artifactId>
<version>1.1.2</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jsp-api</artifactId>
<version>2.0</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.codehaus.jackson</groupId>
<artifactId>jackson-core-lgpl</artifactId>
<version>1.8.1</version>
</dependency>
<dependency>
<groupId> org.codehaus.jackson</groupId>
<artifactId>jackson-mapper-asl</artifactId>
<version>1.9.5</version>
</dependency>
<dependency>
<groupId>org.codehaus.jackson</groupId>
<artifactId>jackson-mapper-lgpl</artifactId>
<version>1.8.1</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpmime</artifactId>
<version>4.2.1</version>
</dependency>
</dependencies>
<build>
<finalName>search</finalName>
</build>
</project>