使用Neo4J Java Bolt Driver查询时COLLECT结果出现重复条目问题

问题原因 #

当Cypher查询同时关联多个一对多关系（比如Game关联Expansions和Categories）时，会产生笛卡尔积（2个Expansions × 2个Categories = 4行结果）。Neo4J浏览器会自动对结果做聚合展示，但Java Bolt Driver会返回所有原始行，直接收集就会导致集合出现重复数据。

方法一：调整Cypher查询（推荐） #

通过聚合查询从源头避免笛卡尔积，直接返回去重后的集合：

方案1：使用COLLECT(DISTINCT)聚合 #

将查询改为一次性收集所有关联节点，用DISTINCT确保去重：

MATCH (g:Game)
OPTIONAL MATCH (g)-[:HAS_EXPANSION]->(e:Expansions)
OPTIONAL MATCH (g)-[:BELONGS_TO]->(c:Categories)
RETURN g, COLLECT(DISTINCT e) AS expansions, COLLECT(DISTINCT c) AS categories

这样查询只会返回1行结果，expansions和categories集合直接包含2条不重复的数据。

方案2：分阶段聚合（避免笛卡尔积） #

先收集其中一类关联节点，再关联另一类，彻底避免笛卡尔积产生：

MATCH (g:Game)-[:HAS_EXPANSION]->(e:Expansions)
WITH g, COLLECT(e) AS expansions
MATCH (g)-[:BELONGS_TO]->(c:Categories)
RETURN g, expansions, COLLECT(c) AS categories

此方法先聚合得到Game对应的Expansions集合，再关联Categories并聚合，最终返回的集合无重复。

方法二：Java代码层面去重 #

如果无法修改查询，可在代码中用集合自动去重：

1. 确保你的Expansions和Categories实体类正确重写equals()和hashCode()方法（以节点ID或唯一属性作为判断依据）。
2. 使用HashSet收集数据自动去重，再转为List：

// 处理Expansions集合
Set<Expansions> expansionsSet = new HashSet<>();
while (result.hasNext()) {
    Record record = result.next();
    Node eNode = record.get("e").asNode();
    Expansions expansion = // 自行实现Node到实体的转换
    expansionsSet.add(expansion);
}
List<Expansions> expansions = new ArrayList<>(expansionsSet);

// Categories集合同理
Set<Categories> categoriesSet = new HashSet<>();
while (result.hasNext()) {
    Record record = result.next();
    Node cNode = record.get("c").asNode();
    Categories category = // 自行实现Node到实体的转换
    categoriesSet.add(category);
}
List<Categories> categories = new ArrayList<>(categoriesSet);

内容的提问来源于stack exchange，提问作者Gregg