ReactiveNeo4jRepository保存时避免级联更新关联关系求助

使用组件 #

• Neo4jReactiveRepository
• Spring WebFlux
• Neo4j

操作流程 #

1. 创建节点B和C，建立B指向C的xyz关联关系
2. 通过neo4jReactiveRepository.save(new B(C))完成B和C的创建与关联
3. 尝试创建节点A，并建立A指向B的pqr关联，执行neo4jReactiveRepository.save(new A(B))
4. 期望最终数据关系：A->B->C（A与B为pqr关系，B与C为xyz关系）

问题描述 #

执行步骤3保存A时，Spring Data Neo4j会同时更新B与C的关联关系，导致原有关联被修改。需求是仅创建A节点及A与B的关联，不改动已存在的B-C关系。

已尝试方案 #

• 将B对象中的C设为null：会直接删除B与C的关联关系，不符合预期
• 手动编写Cypher查询：需分两步（创建A节点、创建A-B关联），操作繁琐

代码示例 #

Repository 接口 #

public interface DemoRepository extends ReactiveNeo4jRepository<A, String> {
}

Service 类 #

class DemoService{
    @Autowired
    DemoRepository demoRepository;

    public void saveObjectA(B b){
        demoRepository.save(new A(b));
    }
}

A 实体类 #

@Getter
@AllArgsConstructor
@NoArgsConstructor
@Builder(toBuilder = true)
@Node("A")
public class A {
    @Id
    private String id; // 补充ID字段，SDN需要标识节点
    @Relationship(type = "EXECUTES", direction = OUTGOING)
    private B b;

    public A(B b){
        this.b = b;
    }
}

B 实体类 #

@Getter
@AllArgsConstructor
@Builder(toBuilder = true)
@Node("B")
@ToString
@EqualsAndHashCode
public class B {
    @Id
    private String id; // 补充ID字段
    @Relationship(type = "SUPPORTS", direction = OUTGOING)
    private C c;
}

C 实体类 #

@Getter
@AllArgsConstructor
@Builder
@Node("C")
@EqualsAndHashCode
public class C {
    @Id
    private String id; // 补充ID字段
    private final String name;
}

解决方案 #

方案1：指定保存深度 #

利用ReactiveNeo4jRepository的重载save方法，指定保存深度为1，限制SDN仅处理A的直接关联节点，不递归处理B的关联：

class DemoService{
    @Autowired
    DemoRepository demoRepository;

    public Mono<A> saveObjectA(B b){
        // depth=1 表示仅处理A及直接关联的B，不处理B的关联C
        return demoRepository.save(new A(b), 1);
    }
}

方案2：仅传入关联节点的ID #

无需传入完整的B对象，仅创建包含B的ID的实例，SDN会识别为已存在节点，仅建立A-B关联：

class DemoService{
    @Autowired
    DemoRepository demoRepository;

    public Mono<A> saveObjectA(String bId){
        // 创建仅含ID的B实例
        B b = B.builder().id(bId).build();
        return demoRepository.save(new A(b));
    }
}

方案3：自定义Cypher查询 #

在Repository中编写自定义查询，一步完成A节点创建与A-B关联，完全控制数据操作：

public interface DemoRepository extends ReactiveNeo4jRepository<A, String> {
    @Query("CREATE (a:A)-[:EXECUTES]->(b:B {id: $bId}) RETURN a")
    Mono<A> createAAndLinkToB(@Param("bId") String bId);
}

// Service中调用
class DemoService{
    @Autowired
    DemoRepository demoRepository;

    public Mono<A> saveObjectA(String bId){
        return demoRepository.createAAndLinkToB(bId);
    }
}

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