SolrGroup分组查询

场景描述&＃xff1a;

        普通查询时&＃xff0c;查询的结果中&＃xff0c;个人信息有很多重复的&＃xff0c;按照业务需求需要将重复的个人信息隐藏&＃xff0c;所以使用分组查询&＃xff0c;如果想查看隐藏的部分&＃xff0c;则在具体分组中继续使用分页的查询。

分组查询&＃xff1a;

JAVA部分代码&＃xff1a;

1. ...
2. // 创建solrQuery对象
3. SolrQuery query &＃61; new SolrQuery();
4. query.set("q", "*:*" );
5. /*分组*/
6. //是否分组
7. query.setParam("group", true);
8. //分组的字段&＃xff0c;不可以是多值字段
9. query.setParam("group.field", "PAT_ID");
10. //分组中每个组的上限数量&＃xff0c;默认为1
11. query.setParam("group.limit","2");
12. //分布式模式使用分组&＃xff0c;并返回分组数量
13. query.setParam("group.ngroups","true");
14. // 设置start&＃xff0c;开始的组
15. query.setStart(0);
16. // 设置rows&＃xff0c;返回多少组
17. query.setRows(10);
18. // 执行搜索&＃xff0c;返回response对象
19. QueryResponse rq &＃61; cloudSolrClient.query(query);
20. // 从response中获取想要的结果&＃xff0c;因为结构与正常搜索的结构不一致&＃xff0c;所以取数据时与普通搜索获取数据不一样
21. GroupResponse groupResponse &＃61; rq.getGroupResponse();
22. List<GroupCommand> groupCommandList &＃61; groupResponse.getValues();
23. SolrDocumentList solrDocumentList &＃61; new SolrDocumentList();
24. long count &＃61; 0;
25. long groupNum&＃61;0;
26. // 判断是否为空
27. if(groupCommandList!&＃61;null && groupCommandList.size()>0){
28. // 匹配出的结果总数
29. count &＃61; groupCommandList.get(0).getMatches();
30. // 分组总数
31. groupNum &＃61; groupCommandList.get(0).getNGroups();
32. List<Group> groupList&＃61;groupCommandList.get(0).getValues();
33. // 遍历返回的每个分组
34. for(Group group:groupList){
35. // 若为普通搜索的结果则只有一条&＃xff1b;若为分组详情则只有一组&＃xff0c;将一组全部放入
36. for(SolrDocument solrDocument:group.getResult()){
37. // 将分组中的数放入最后一个参数
38. solrDocument.addField("numFound",group.getResult().getNumFound());
39. // 每个分组只取第一个
40. solrDocumentList.add(solrDocument);
41. }
42. }
43. }
44. ...

        查询结果在solrDocumentList中&＃xff0c;处理成什么格式可以自己设置&＃xff1b;groupNum为分组的组数&＃xff0c;count为所有匹配的文档数&＃xff08;不分组的匹配数&＃xff09;&＃xff1b;

Solr管理页面查询的结构如下&＃xff1a;

分组中的分页&＃xff1a;

JAVA部分代码&＃xff1a;

1. //分组中的偏移量&＃xff0c;相当于普通搜索中的start
2. query.setParam("group.offset",String.valueOf(map.get("groupOffset")));
3. //分组中每个组的上限数量&＃xff0c;相当于普通搜索中的每页数量rows&＃xff0c;默认为1
4. query.setParam("group.limit",String.valueOf(map.get("groupLimit")));

        配合这两个条件&＃xff0c;进行分组中的分页。

1. 结果分组功能在分布式模式下不能完全起作用。
2. 如果计划在分布式模式下使用Solr的分组功能&＃xff0c;并需要得到精确的分组数量&＃xff08;由group.ngroups&＃61;true参数返回&＃xff09;。
3. 如果没有按照计划那样&＃xff0c;将数据按照分组的字段分割到各个分片上&＃xff0c;那返回的分组数量仅仅是一个上限值。解决办法是
4. 自定义散列&＃xff0c;就是设置一个id让指定的一组文档分发到同一个分片上&＃xff0c;这样做最大的问题是会造成集群里分片的不均衡。

地址&＃xff1a;https://blog.csdn.net/jiangchao858/article/details/63256048