简短的问题:
我正在寻找一种方法(java)来拦截对 Solr 的查询并注入我的业务逻辑提供的一些额外的过滤参数。我应该使用什么结构?
语境:
首先,我要坦白一点:对于 Solr,我是个菜鸟。对我来说,设置一个服务器,定义一个模式,编写一个功能性索引管理器,然后实际看到服务器返回正确的结果 - 完全符合预期! ——这本身就已经是一个很大的成就了。耶我!
然而,我目前正在从事一个需要更多一点的企业项目。粗略地说,solr 实例将被数千个用户通过同一个 requestHandler 进行查询,即返回的文档会根据用户的权限级别自动进行过滤。例如,如果用户 A 和超级用户 B 都尝试了完全相同的搜索参数(甚至是完全相同的 url),则用户 B 将获取用户 A 的所有文件,然后获取更多文件。为了实现这一点,文档已经使用必要的权限级别信息进行了索引。
好吧,考虑到这一点,并利用 Solr 为新手开发人员提供的大量文档,我尝试提出一个简单的自定义 requestHandler,它重写了 handleRequest 函数,以便在 SolrQueryRequest 中注入必要的额外参数。一切都很好——除了我在 QueryResponse 中从来没有看到任何差异,服务器粗鲁地忽略了我的小操作。在网上搜索了几天后,没有太多关于天气的提示,这是否是最好的方法,最后决定出来打扰一下 StackOverflow 的好人。
简而言之,我的问题是:
预先感谢,非常抱歉这么长的帖子!
UPDATE
经过大量阅读 API,特别是多次试验和错误后,我成功获得了一个实用的解决方案。然而我仍然无法理解 Solr 的大部分内部结构,因此仍然希望得到一些启发。随意砸吧,我还是很清楚自己的菜鸟的。
解决方案的相关部分是这个函数,它是由重写的句柄 RequestBody 调用的:
private void SearchDocumentsTypeII(SolrDocumentList results,
SolrIndexSearcher searcher, String q,
UserPermissions up, int ndocs, SolrQueryRequest req,
Map<String, SchemaField> fields, Set<Integer> alreadyFound)
throws IOException, ParseException {
BooleanQuery bq = new BooleanQuery();
String permLvl = "PermissionLevel:" + up.getPermissionLevel();
QParser parser = QParser.getParser(permLvl, null, req);
bq.add(parser.getQuery(), Occur.MUST);
Filter filter = CachingWrapperFilter(new QueryWrapperFilter(bq));
QueryParser qp = new QueryParser(q, new StandardAnalyzer());
Query query = qp.parse(q);
append (results, searcher.search(
query, filter, 50).scoreDocs,
alreadyFound, fields, new HashMap<String,Object>(), 0,
searcher.getReader(), true);
}
基本上,搜索查询不会以任何方式修改,而是应用包含用户权限级别的过滤器。即便如此,为什么以下替代方案不起作用?当应用在标准 requestHandler 中时,搜索查询可以完美地工作,而在这种情况下,它根本不会命中任何文档。
private void SearchDocumentsTypeII(SolrDocumentList results,
SolrIndexSearcher searcher, String q,
UserPermissions up, int ndocs, SolrQueryRequest req,
Map<String, SchemaField> fields, Set<Integer> alreadyFound)
throws IOException, ParseException {
String qFiltered = q + " AND " + "PermissionLevel:" + up.getPermissionLevel();
QueryParser qp = new QueryParser(qFiltered, new StandardAnalyzer());
Query query = qp.parse(qFiltered);
append (results, searcher.search(
query, null, 50).scoreDocs,
alreadyFound, fields, new HashMap<String,Object>(), 0,
searcher.getReader(), true);
}