使用solrj进行查询操作
?
Solrj是Solr官方提供的基于Java的Solr客户端，提供完善的Solr操作API。
?
以好友为例。首先定义SpaceFriend实体Bean，用来直接处理Solr返回信息：
?
import org.apache.solr.client.solrj.beans.Field;
?
public class SpaceFriend {
? ? @Field("Id")
? ? int id;
?
? ? @Field("WebNickname")
? ? String webNickname;
?
? ? @Field("portrait")
? ? String Portrait;
?
? ? @Field("Gender")
? ? int gender;
?
? ? @Field("Age")
? ? int age;
?
? ? @Field("IsAgePublic")
? ? boolean isAgePublic;
?
? ? @Field("Horoscope")
? ? int horoscope;
?
? ? @Field("marriage")
? ? int marriage;
?
? ? @Field("FriendType")
? ? String[] friendType;
?
? ? @Field("CityNow")
? ? String cityNow;
?
? ? @Field("isCityPublic")
? ? boolean isCityPublic;
}
?
为了方便写了一个junit测试：
?
import java.util.List;
?
import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
?
import org.apache.solr.client.solrj.*;
import org.apache.solr.client.solrj.SolrQuery.ORDER;
import org.apache.solr.client.solrj.impl.BinaryRequestWriter;
import org.apache.solr.client.solrj.impl.CommonsHttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
?
public class SolrJTest {
? ? //多线程共享
? ? static CommonsHttpSolrServer server;
?
? ? @BeforeClass
? ? public static void beforeClassClass() throws Exception {
? ? ? ? server = new CommonsHttpSolrServer(
? ? ? ? ? ? ? ? "http://localhost:8088/solr");
? ? ? ? server.setSoTimeout(1000);
? ? ? ? server.setConnectionTimeout(100);
? ? ? ? server.setDefaultMaxConnectionsPerHost(100);
? ? ? ? server.setMaxTotalConnections(100);
? ? ? ? server.setFollowRedirects(false);
? ? ? ? server.setAllowCompression(true);
? ? ? ? server.setMaxRetries(1);
?
? ? ? ? //提升性能采用流输出方式
? ? ? ? server.setRequestWriter(new BinaryRequestWriter());
? ? }
?
? ? @AfterClass
? ? public static void tearDownAfterClass() throws Exception {
? ? }
?
? ? /**
? ? ?* @throws java.lang.Exception
? ? ?*/
? ? @Before
? ? public void setUp() throws Exception {
?
? ? }
?
? ? /**
? ? ?* @throws java.lang.Exception
? ? ?*/
? ? @After
? ? public void tearDown() throws Exception {
? ? }
?
? ? @Test
? ? public void QueryTest() throws SolrServerException {
? ? ? ? SolrQuery query = new SolrQuery();
?
? ? ? ? //主查询
? ? ? ? query.setQuery("*:*");
?
? ? ? ? //采用过滤器查询可以提高性能
?
? ? ? ? query.addFilterQuery("Searchable:1");
? ? ? ? query.addFilterQuery("SpaceAccessPrivate:1");
?
? ? ? ? //区间查询
? ? ? ? query.addFilterQuery("Age:[* TO 50]");
? ? ? ? query.addFilterQuery("FriendType:1");
?
? ? ? ? //添加排序
? ? ? ? query.addSortField("Score", ORDER.desc);
?
? ? ? ? //分页返回结果
? ? ? ? query.setStart(0);
? ? ? ? query.setRows(10);
?
? ? ? ? QueryResponse rsp = server.query(query);
? ? ? ? List<SpaceFriend> beans = rsp.getBeans(SpaceFriend.class);
?
? ? ? ? //输出符合条件的结果数
? ? ? ? System.out.println("NumFound: " + rsp.getResults().getNumFound());
?
? ? ? ? //输出结果
? ? ? ? for (int i = 0; i < beans.size(); i++) {
? ? ? ? ? ? SpaceFriend friend = beans.get(i);
?
? ? ? ? ? ? System.out.println("SpaceFriend " + i);
? ? ? ? ? ? System.out.println("Id " + friend.id);
? ? ? ? ? ? System.out.println("WebNickname:" + friend.webNickname);
? ? ? ? }
? ? }
}
