Neo4j - 为每个节点返回多组行

Question

我有 1000 个员工节点，它们属于 7 个部门。我试图让财务部门的每个员工按降序发送给其他员工的前 10 条消息。我还想要他向其发送消息的员工部门。我正在根据这两个问题中给出的答案使用以下查询： return top n results for each query in Neo4j 和Getting top n records for each group in neo4j, 但我得到的结果是每个员工发送给每个部门其他员工的前 10 条消息（每个员工总共有 70 条消息）。我想要包括所有部门的结果，而不是每个部门的 10 个结果。

我使用的查询是：

MATCH(e:Employee{div:'finance'}),(b:Employee)
OPTIONAL MATCH (e)-[r:Message]->(b)
WITH e.name as em, b.division_name as bm,coalesce(r.NUMBER_OF_MESSAGES,0) 
as msg 
ORDER BY msg DESC 
WITH collect(msg) AS bts, em, bm
UNWIND bts[0..10] AS r
RETURN em, bm, r

我应该对此查询进行哪些更改？在此先感谢

Answer 1

Ram，我认为使用 APOC Procedure apoc.cypher.run 是一个不错的选择。通过此过程，您将能够为在财务部门工作的每个员工运行“子查询”。请安装 APOC 程序并尝试一下：

MATCH(e:Employee{div:'finance'})
CALL apoc.cypher.run('
    WITH {e} AS e
    OPTIONAL MATCH (e)-[r:ACTED_IN]->(b:Employee)
    RETURN e.name, b.division_name, coalesce(r.NUMBER_OF_MESSAGES,0) as messages
    ORDER BY messages DESC
    LIMIT 10',
{e:e}) YIELD value
return value

注意：记得根据 Neo4j 的版本安装 APOC 程序。见this link。