pennate 发表于 2017-12-19 11:17:23

9.solr学习速成之group

package com.liucheng.solr;  

import java.io.IOException;  

import java.util.List;  

import org.apache.solr.client.solrj.SolrQuery;  

import org.apache.solr.client.solrj.SolrServerException;  

import org.apache.solr.client.solrj.impl.HttpSolrClient;  

import org.apache.solr.client.solrj.response.Group;  

import org.apache.solr.client.solrj.response.GroupCommand;  

import org.apache.solr.client.solrj.response.GroupResponse;  

import org.apache.solr.client.solrj.response.QueryResponse;  

import org.apache.solr.common.params.GroupParams;  

public>public static void searchByGroup(){  

  HttpSolrClient server
= solrServer.getServer();  

  SolrQuery query
= new SolrQuery("brand_s:海尔儿");  

  query.setParam(GroupParams.GROUP,
true);//表示查询时使用group机制  

  query.setParam(GroupParams.GROUP_FIELD, "brand_s");//设置group查询针对的域
  

  //设置每个组最多返回记录数,可用于数据采集,若只需要数量,可设置为0
  

  query.setParam(GroupParams.GROUP_LIMIT, "5");
  

  //设置返回的行数
  

  query.setRows(10);
  

  try {
  

  QueryResponse queryResponse = server.query(query);
  

  if(queryResponse!=null){
  

  GroupResponse groupResponse = queryResponse.getGroupResponse();
  

  if(groupResponse != null){
  

  List<GroupCommand> groupList = groupResponse.getValues();
  

  for(GroupCommand groupCommand : groupList){
  

  List<Group> groups = groupCommand.getValues();
  

  for(Group group : groups){
  

  System.out.println(group.getResult().get(0).getFieldValue("subMajor_s"));
  

  System.out.println("group查询。。。"+group.getGroupValue()+"数量为:"
  

  + group.getResult().getNumFound());
  }
  }
  }
  

  }
  

  } catch (SolrServerException e) {
  

  e.printStackTrace();
  

  } catch (IOException e) {
  

  e.printStackTrace();
  }
  }
  public static void main(String[] args) {
  

  searchByGroup();
  }
  
}
页: [1]
查看完整版本: 9.solr学习速成之group