Neo4j OGM 的事务和关系实体映射问题

Question

使用的版本：spring-data-neo4j 4.2.0-BUILD-SNAPSHOT / neo4j-ogm 2.0.6-SNAPSHOT

我有正确获取关系实体的问题。

以下 fetch 调用不会返回一致的结果（在同一事务中执行）：

1. session.query("MATCH (:A)-[b:HAS_B]-(:C) RETURN count(b) as count") 返回 1
2. session.query("MATCH (:A)-[b:HAS_B]-(:C) RETURN b") 正确返回关系实体作为RelationshipModel对象
3. session.query(B.class, "MATCH (:A)-[b:HAS_B]-(:C) RETURN b") 返回空值！

重要说明：当所有操作（create、fetch）都在同一个事务中完成时，似乎没问题。

我已经能够实现一种解决方法，方法是使用 session.query(String, Map) 来查询关系实体并自己将其映射到我的 POJO。

@NodeEntity
public class A {
    public A () {}
    public A (String name) {
        this.name = name;
    }

    @GraphId
    private Long graphId;

    private String name;

    @Relationship(type="HAS_B", direction=Relationship.OUTGOING)
    private B b;
}

@RelationshipEntity(type="HAS_B")
public class B {
    public B () {}
    public B (String name, A a, C c) {
        this.name = name;
        this.a = a;
        this.c = c;
    }

    @GraphId
    private Long graphId;

    @StartNode
    private A a;

    @EndNode
    private C c;

    private String name;
}

@NodeEntity
public class C {
    public C () {}
    public C (String name) {
        this.name = name;
    }

    @GraphId
    private Long graphId;

    private String name;
}

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(loader=AnnotationConfigContextLoader.class, classes={MyTest.TestConfiguration.class})
public class MyTest {
    @Autowired
    private MyBean myBean;

    @Configuration
    @EnableAutoConfiguration
    @EnableTransactionManagement
    @EnableNeo4jRepositories("com.nagra.ml.sp.cpm.core.repositories")
    public static class TestConfiguration {
        @Bean
        public org.neo4j.ogm.config.Configuration configuration() {
            org.neo4j.ogm.config.Configuration config = new org.neo4j.ogm.config.Configuration();
            config.driverConfiguration().setDriverClassName("org.neo4j.ogm.drivers.embedded.driver.EmbeddedDriver");
            return config;
        }
        @Bean
        public SessionFactory sessionFactory() {
            return new SessionFactory(configuration(), "com.nagra.ml.sp.cpm.model");
        }
        @Bean
        public Neo4jTransactionManager transactionManager() {
            return new Neo4jTransactionManager(sessionFactory());
        }
        @Bean
        public MyBean myBean() {
            return new MyBean();
        }
    }

    @Test
    public void alwaysFails() {
        myBean.delete();
        myBean.create("1");
        try { Thread.sleep(2000); } catch (InterruptedException e) {} //useless
        myBean.check("1"); // FAILS HERE !
    }

    @Test
    public void ok() {
        myBean.delete();
        myBean.createAndCheck("2");
    }
}

@Transactional(propagation = Propagation.REQUIRED)
public class MyBean {

    @Autowired
    private Session neo4jSession;

    public void delete() {
        neo4jSession.query("MATCH (n) DETACH DELETE n", new HashMap<>());
    }

    public void create(String suffix) {
        C c = new C("c"+suffix);
        neo4jSession.save(c);
        A a = new A("a"+suffix);
        neo4jSession.save(a);
        B bRel = new B("b"+suffix, a, c);
        neo4jSession.save(bRel);
    }

    public void check(String suffix) {
        //neo4jSession.clear(); //Not working even with this
        Number countBRels = (Number) neo4jSession.query("MATCH (:A)-[b:HAS_B]-(:C) WHERE b.name = 'b"+suffix+"' RETURN count(b) as count", new HashMap<>()).iterator().next().get("count");
        assertEquals(1, countBRels.intValue()); // OK
        Iterable<B> bRels = neo4jSession.query(B.class, "MATCH (:A)-[b:HAS_B]-(:C) WHERE b.name = 'b"+suffix+"' RETURN b", new HashMap<>());
        boolean relationshipFound = bRels.iterator().hasNext();
        assertTrue(relationshipFound); // FAILS HERE !
    }

    public void createAndCheck(String suffix) {
        create(suffix);
        check(suffix);
    }
}

Answer 1

此查询session.query(B.class, "MATCH (:A)-[b:HAS_B]-(:C) RETURN b") 仅返回关系，但不返回开始节点或结束节点，因此 OGM 无法对其进行水合。您需要始终返回起始节点和结束节点以及 session.query(B.class, "MATCH (a:A)-[b:HAS_B]-(c:C) RETURN a,b,c") 之类的关系

当您在同一个事务中创建和获取数据时它似乎工作的原因是会话已经有a 和c 的缓存副本，因此b 可以通过缓存的开始和结束进行水合节点。

Answer 2

首先，请从 OGM 2.0.6-SNAPSHOT 升级到 2.1.0-SNAPSHOT。我注意到前者的一些异常行为可能是问题的一部分。

现在开始测试。这里有几件事值得研究。

• @DirtiesContext 的使用：您似乎没有触及上下文，如果您使用它来重置测试之间的上下文以便获得新的会话/事务，那么这是错误的方式。只需改用@Transactional。 Spring JUnit 运行器将以特殊方式处理此问题（请参阅下一点）。
• 意识到事务测试会自动回滚：Jasper 是对的。 Spring 集成测试将always roll back by default。如果您想确保您的 JUnit 测试提交 then you will have to @Commit it。 here 是一个关于如何设置测试的好例子。
• 了解 Spring Transaction 代理的工作原理。除了所有这些混乱之外，您还必须确保您不会简单地将事务方法调用到同一类中的事务方法并期望 Spring 的事务行为适用。快速写下为什么可以看到here。

如果你解决了这些问题，一切都会好起来的。