solr开发从查询结果集中获取对象数据

踏雪寻梅

　　solrJ从查询结果集中获取对象数据.

方案一:自定义转换方式



    /**
*
* SolrDocument与实体类转换 [测试通过]
*
* @author pudongping
*
* @param document
*                     SolrDocument对象
* @param clzz   
*                     泛型类
* @return
*/
public static  T solrDocument2Entity(SolrDocument document, Class clzz) {
if (null != document) {
try {
Object obj = clzz.newInstance();
Method m = null;
Class fieldType = null;
for (String fieldName : document.getFieldNames()) {                        
//需要说明的是返回的结果集中的FieldNames()比类属性多
Field[] filedArrays = clzz.getDeclaredFields();                        //获取类中所有属性
for (Field f : filedArrays) {   
//如果实体属性名和查询返回集中的字段名一致,填充对应的set方法
if(f.getName().equals(fieldName)){
//获取到的属性名
//private java.lang.String com.test.model.Article.id
f = clzz.getDeclaredField(fieldName);   
//属性类型
//private java.lang.String com.test.model.Article.id
fieldType = f.getType();   
//构造set方法名  setId
String dynamicSetMethod = dynamicMethodName(f.getName(), "set");
//获取方法
//public void com.test.model.Article.setId(java.lang.String)
m = clzz.getMethod(dynamicSetMethod, fieldType);
//获取到的值
LOG.info(f.getName() + "-->" + dynamicSetMethod+ "=" + fieldType.cast(document.getFieldValue(fieldName)));
// 如果是 int, float等基本类型，则需要转型
if (fieldType.equals(Integer.TYPE)) {
fieldType = Integer.class;
} else if (fieldType.equals(Float.TYPE)) {
fieldType = Float.class;
} else if (fieldType.equals(Double.TYPE)) {
fieldType = Double.class;
} else if (fieldType.equals(Boolean.TYPE)) {
fieldType = Boolean.class;
} else if (fieldType.equals(Short.TYPE)) {
fieldType = Short.class;
} else if (fieldType.equals(Long.TYPE)) {
fieldType = Long.class;
} else if(fieldType.equals(String.class)){
fieldType = String.class;
}else if(fieldType.equals(Collection.class)){
fieldType = Collection.class;
}
m.invoke(obj, fieldType.cast(document.getFieldValue(fieldName)));
}
}
}
return clzz.cast(obj);
} catch (ClassCastException e) {
LOG.error("请检查schema.xml中的各个field的数据类型与PO类的是否一致.",e);
e.printStackTrace();
} catch (SecurityException e) {
e.printStackTrace();
} catch (NoSuchMethodException e) {
LOG.error("请检查PO类中的field对应的各个setter和getter是否存在.",e);
e.printStackTrace();
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
} catch (InstantiationException e) {
e.printStackTrace();
} catch (NoSuchFieldException e) {
LOG.error("请检查schema中的field是否不存在于PO类中.", e);
e.printStackTrace();
}
}
LOG.warn("solrDocument is null.");
return null;
}

/**
* 批量转换, 将solrDocumentList转换为实体类 List [测试通过]
*
* @author pudongping
*
* @param documents   
*                         solrDocumentList对象
* @param clzz            
*                         泛型类
*
* @return List
*
*/
public static List solrDocument2Entity(SolrDocumentList documents, Class clzz) {
if (null != documents && documents.size() > 0) {
List lists = new ArrayList();
for (SolrDocument sd : documents) {
Object obj = solrDocument2Entity(sd, clzz);
if (null!=obj) {
lists.add(clzz.cast(obj));
}
}
return lists;
}
LOG.warn("即将要转换的solrDocumentList为null或者size为0.");
return null;
}

　　需要说明的是反射里边的那个双重循环
　　要转换的单个SolrDocument内容如下



SolrDocument{id=2d3f7323-b212-4fae-8d69-d7fcffb0c731, title=[萧萧衷曲无处诉；为伊故，乐所苦。, 锦色芳华，岂堪人虚度？欲寄相思情万缕，捎不到，君心处。], author=柳梦璃, author_s=柳梦璃, _version_=1463433353865723904}
　　而我们定义的实体类



public class Article implements Serializable{
private static final long serialVersionUID = 4017316764889231758L;
private String id;
private List title;   
private String author;   
// getter and setter
}
　　SolrDocument中的fieldName个数比类的属性多,所以我们需要循环去判断.

　　方案二: 基于注解的内置获取方式
　　Javabean基于注解配置



package com.test.model;
import java.io.Serializable;
import java.util.List;
import org.apache.commons.lang.builder.ToStringBuilder;
import org.apache.solr.client.solrj.beans.Field;
public class Article implements Serializable{
/**
*
*/
private static final long serialVersionUID = 4017316764889231758L;
@Field("id")
private String id;
@Field("title")
private List title;   
@Field
private String author;            //@Field无参数时,匹配当前字段
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getAuthor() {
return author;
}
public void setAuthor(String author) {
this.author = author;
}
public List getTitle() {
return title;
}
public void setTitle(List title) {
this.title = title;
}
@Override
public String toString() {
return ToStringBuilder.reflectionToString(this);
}
}
　　查询结果集的两种转换方式



   
/**
* 根据关键字查询 [测试通过 - 使用 solr内部转换机制]
* @param
* @param server    solr客户端
* @param keyword    搜索关键字
* @param pageNum    当前页码
* @param pageSize    每页显示的大小
* @param clzz        对象类型
* @return
*/
public static Page queryBean(SolrServer server,String keyword,int pageNum,int pageSize, Class clzz){
SolrQuery query = new SolrQuery();
query.setQuery(keyword);
query.setStart((pageNum-1)*pageSize);
query.setRows(pageSize);
QueryResponse response = null;
try {
response = server.query(query);
} catch (SolrServerException e) {
e.printStackTrace();
return null;
}
//查询到的记录总数
long totalRow = Long.valueOf(response.getResults().getNumFound()).intValue();
//查询结果集
List items = response.getBeans(clzz);
//填充page对象
return new Page(pageNum, pageSize, totalRow, items);
}
/**
* 根据关键字查询 [测试通过 - 使用 solr内部转换机制]
* @param
* @param server    solr客户端
* @param keyword    搜索关键字
* @param pageNum    当前页码
* @param pageSize    每页显示的大小
* @param clzz        对象类型
* @return
*/
public static Page queryBinderBean(SolrServer server,String keyword,int pageNum,int pageSize, Class clzz){
SolrQuery query = new SolrQuery();
query.setQuery(keyword);
query.setStart((pageNum-1)*pageSize);
query.setRows(pageSize);
QueryResponse response = null;
try {
response = server.query(query);
} catch (SolrServerException e) {
e.printStackTrace();
return null;
}
//查询结果集
SolrDocumentList documents = response.getResults();
//使用DocumentObjectBinder获取
List items = server.getBinder().getBeans(clzz,documents);
//查询到的记录总数
long totalRow = Long.valueOf(response.getResults().getNumFound()).intValue();
//填充page对象
return new Page(pageNum, pageSize, totalRow, items);
}
　　Junit测试



    @Test
public void pageQueryBinder(){
Page page = SolrEngineHandler.queryBinderBean(server, "柳梦璃", 1, 10, Article.class);
System.out.println(page);
}
@Test
public void pageQueryBean(){
Page page = SolrEngineHandler.queryBean(server, "苏若年", 1, 10, Article.class);
System.out.println(page);
}
　　转载请注明出处:[http://www.iyunv.com/dennisit/p/3621728.html]