java - 使用嵌入式数据库进行单元测试的 Graphaware TimeTree 程序

Question

更新:我在 neo4j timetree 源中找到了一些类似的测试，但使用了 GraphAwareIntegrationTest，它扩展了 ServerIntegrationTest。因此，我尝试使用以下命令创建 GraphDatabaseService Bean 进行测试，但仍然没有成功。我得到“没有为此数据库实例注册名为 ga.timetree.events.attach 的过程。”这不可能吗？

@Bean
  public GraphDatabaseService graphDatabaseService() {
    GraphDatabaseService gds = new TestGraphDatabaseFactory().newImpermanentDatabaseBuilder().newGraphDatabase();
    Procedures procedures = (Procedures)((GraphDatabaseFacade) gds).getDependencyResolver().resolveDependency(Procedures.class);
    try {
        ClassPathProcedureUtils.registerAllProceduresAndFunctions(procedures);
    }catch (Exception ex) {
        log.error("error", ex);
    }
    return gds;
}

======================

类似于this issue但我正在使用 Spring Boot 2、SDN5 和 neo4j 3.2.5、graphaware 和时间树。我有自动事件附件设置，并且我看到事件被保存到时间树中，但我无法使用使用 cypher 的过程调用进行查询。我收到错误:

Caused by: org.neo4j.ogm.exception.CypherException: Error executing Cypher; Code: Neo.ClientError.Procedure.ProcedureNotFound; Description: There is no procedure with the name `ga.timetree.range` registered for this database instance. Please ensure you've spelled the procedure name correctly and that the procedure is properly deployed.
at org.neo4j.ogm.drivers.embedded.request.EmbeddedRequest.executeRequest(EmbeddedRequest.java:176)

我没有看到链接问题中回答的 TimeTreeProcedures 类。嵌入式/单元测试仍然支持这吗？

另外，如果支持的话，我想使用 CustomRootTimeTree。任何帮助或指向我可以在过程调用中定义自定义根树 id 的密码的指针也将非常感激。感谢您的帮助!

测试:

    @Test
    public void testSingleTimeTree() {

        User user = new User("alper@alper.com", "alper", "alper");
        userRepository.save(user);
        Collection<User> found = userRepository.findByEmail("alper@alper.com");
        user = found.iterator().next();
        Workout workout = new Workout(new DateTime().plusMonths(2).getMillis());
        workoutRepository.save(workout);
        GraphUnit.printGraph(graphDb);
        Iterable<Workout> workouts = workoutRepository.findWorkouts();

        for(Workout workout1 : workouts) {
            log.info("workout: {}", workout1);
        }
    }

Repo(目前硬编码开始/结束):

    public interface WorkoutRepository extends Neo4jRepository<Workout, Long> {

        @Query("CALL ga.timetree.range({start: 1506826887000, end: 1512097287, create: false})")
        Iterable<Workout> findWorkouts();

    }

pom.xml:

  <parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
      <version>2.0.0.BUILD-SNAPSHOT</version>
      <relativePath/> <!-- lookup parent from repository -->
  </parent>

  <properties>
      <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
      <java.version>1.8</java.version>
      <spring-data-releasetrain.version>Kay-RELEASE</spring-data-releasetrain.version>
      <!--<neo4j-ogm.version>3.0.0</neo4j-ogm.version>-->
  </properties>

  <dependencyManagement>
      <dependencies>
          <dependency>
              <groupId>org.springframework.data</groupId>
              <artifactId>spring-data-releasetrain</artifactId>
              <version>${spring-data-releasetrain.version}</version>
              <scope>import</scope>
              <type>pom</type>
          </dependency>
      </dependencies>
  </dependencyManagement>

  <dependencies>
      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-data-neo4j</artifactId>
      </dependency>
      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-data-rest</artifactId>
      </dependency>
      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-web</artifactId>
      </dependency>
      <dependency>
          <groupId>org.neo4j</groupId>
          <artifactId>neo4j-ogm-embedded-driver</artifactId>
          <version>${neo4j-ogm.version}</version>
      </dependency>
      <dependency>
          <groupId>org.neo4j</groupId>
          <artifactId>neo4j</artifactId>
          <version>3.2.5</version>
          <scope>runtime</scope>
      </dependency>

      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-test</artifactId>
          <scope>test</scope>
      </dependency>

      <!-- added by me -->
      <dependency>
          <groupId>org.neo4j</groupId>
          <artifactId>neo4j-kernel</artifactId>
          <version>3.2.5</version>
          <type>test-jar</type>
      </dependency>
      <dependency>
          <groupId>com.graphaware.neo4j</groupId>
          <artifactId>graphaware-framework-embedded</artifactId>
          <version>3.2.5.51</version>
          <type>pom</type>
      </dependency>
      <dependency>
          <groupId>com.graphaware.neo4j</groupId>
          <artifactId>timetree</artifactId>
          <version>3.2.1.51.27</version>
      </dependency>
      <dependency>
          <groupId>org.neo4j</groupId>
          <artifactId>neo4j-graphdb-api</artifactId>
          <version>3.2.5</version>
      </dependency>
      <dependency>
          <groupId>org.neo4j</groupId>
          <artifactId>neo4j-io</artifactId>
          <version>3.2.5</version>
          <type>test-jar</type>
      </dependency>
      <dependency>
          <groupId>com.graphaware.neo4j</groupId>
          <artifactId>tests</artifactId>
          <version>3.2.5.51</version>
      </dependency>
  </dependencies>

Answer 1

通过调试 Neo4j 源代码，我终于让它正常工作了。测试和使用过程的测试位于 https://github.com/graphaware/neo4j-timetree ，它使用 ClassPathProcedureUtils 类从 target/classes 目录加载类。它查找 @Procedure 注释并处理这些类，并且过程变得可用。如果不修改它以从 jar 以及目标/类加载类，我可以让它工作的唯一方法(尽管是一个 hack)是将 Neo4j-timetree 项目的目标/类输出复制到我的项目目标/类输出目录中。

更新:我还可以通过直接使用以下命令注册所需的过程来使其工作:

@Bean
public GraphDatabaseService graphDatabaseService() {
    GraphDatabaseService gds = new TestGraphDatabaseFactory().newImpermanentDatabaseBuilder().newGraphDatabase();
    try {
        ClassPathProcedureUtils.registerAllProceduresAndFunctions(procedures);
        Procedures procedures = ((GraphDatabaseFacade)gds).getDependencyResolver().resolveDependency(Procedures.class);
        procedures.registerProcedure(TimedEventsProcedure.class);
        procedures.registerProcedure(TimeTreeProcedure.class);
        procedures.registerFunction(TimedEventsProcedure.class);
        procedures.registerFunction(TimeTreeProcedure.class);
      }catch (Exception ex) {
        log.error("error", ex);
      }
      return gds;
}