springboot+neo4j

@DataNeo4jTest是一个Spring Boot测试片。测试切片为使用 Neo4j 进行测试提供了所有必要的基础设施：事务管理器、客户端、模板和声明的存储库（其命令式或反应式变体，具体取决于是否存在反应式依赖项）。测试片已包含在内@ExtendWith(SpringExtension.class)，因此它可以与 JUnit 5 (JUnit Jupiter) 自动运行。

@DataNeo4jTest默认情况下提供命令式和反应式基础设施，并且还添加了隐式基础设施@Transactional。 @Transactional然而，在 Spring 测试中，始终意味着命令式事务，因为声明式事务需要方法的返回类型来决定是否需要命令式事务PlatformTransactionManager或反应式事务。ReactiveTransactionManager

要断言反应式存储库或服务的正确事务行为，您需要将 注入TransactionalOperator 到测试中或将域逻辑包装在使用带注释的方法的服务中，该方法公开返回类型，使基础设施可以选择正确的事务管理器。

测试切片不会引入嵌入式数据库或任何其他连接设置。您可以自行决定是否使用适当的连接。

我们推荐以下两个选项之一：使用Neo4j Testcontainers 模块 或 Neo4j 测试工具。虽然 Testcontainers 是一个众所周知的项目，拥有许多不同服务的模块，但 Neo4j 测试工具却相当陌生。它是一个嵌入式实例，在测试存储过程时特别有用，如测试基于 Neo4j 的 Java 应用程序中所述。然而，测试工具也可用于测试应用程序。由于它在与您的应用程序相同的 JVM 内启动数据库，因此性能和计时可能与您的生产设置不同。

为了您的方便，我们提供了三种可能的场景：Neo4j 测试工具 3.5 和 4.0 以及 Testcontainers Neo4j。我们为 3.5 和 4.0 提供了不同的示例，因为测试工具在这些版本之间发生了变化。此外，4.0 需要 JDK 11。

19. @DataNeo4jTest使用 Neo4j 测试工具 3.5

<dependency>
    <groupId>org.neo4j.test</groupId>
    <artifactId>neo4j-harness</artifactId>
    <version>3.5.23</version>
    <scope>test</scope>
</dependency>

import static org.assertj.core.api.Assertions.assertThat;
 
import java.util.Optional;
 
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import org.neo4j.harness.ServerControls;
import org.neo4j.harness.TestServerBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.data.neo4j.DataNeo4jTest;
import org.springframework.data.neo4j.core.Neo4jClient;
import org.springframework.test.context.DynamicPropertyRegistry;
import org.springframework.test.context.DynamicPropertySource;
 
@DataNeo4jTest
class MovieRepositoryTest {
 
	private static ServerControls embeddedDatabaseServer;
 
	@BeforeAll
	static void initializeNeo4j() {
 
		embeddedDatabaseServer = TestServerBuilders.newInProcessBuilder() (1)
			.newServer();
	}
 
	@AfterAll
	static void stopNeo4j() {
 
		embeddedDatabaseServer.close(); (2)
	}
 
	@DynamicPropertySource  (3)
	static void neo4jProperties(DynamicPropertyRegistry registry) {
 
		registry.add("spring.neo4j.uri", embeddedDatabaseServer::boltURI);
		registry.add("spring.neo4j.authentication.username", () -> "neo4j");
		registry.add("spring.neo4j.authentication.password", () -> null);
	}
 
	@Test
	public void findSomethingShouldWork(@Autowired Neo4jClient client) {
 
		Optional<Long> result = client.query("MATCH (n) RETURN COUNT(n)")
			.fetchAs(Long.class)
			.one();
		assertThat(result).hasValue(0L);
	}
}
 

1.创建嵌入式 Neo4j 的入口点
2.这是一个 Spring Boot 注释，允许动态注册应用程序属性。我们覆盖相应的 Neo4j 设置。
3.所有测试后关闭 Neo4j。

20.@DataNeo4jTest使用 Neo4j 测试工具 4.x

<dependency>
    <groupId>org.neo4j.test</groupId>
    <artifactId>neo4j-harness</artifactId>
    <version>{neo4j-version}</version>
    <scope>test</scope>
    <exclusions>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-nop</artifactId>
        </exclusion>
    </exclusions>
</dependency>

Neo4j 4.x 企业版的依赖项可在com.neo4j.test:neo4j-harness-enterprise适当的存储库配置下获得。

import static org.assertj.core.api.Assertions.assertThat;
 
import java.util.Optional;
 
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import org.neo4j.harness.Neo4j;
import org.neo4j.harness.Neo4jBuilders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.data.neo4j.DataNeo4jTest;
import org.springframework.data.neo4j.core.Neo4jClient;
import org.springframework.test.context.DynamicPropertyRegistry;
import org.springframework.test.context.DynamicPropertySource;
 
@DataNeo4jTest
class MovieRepositoryTest {
 
	private static Neo4j embeddedDatabaseServer;
 
	@BeforeAll
	static void initializeNeo4j() {
 
		embeddedDatabaseServer = Neo4jBuilders.newInProcessBuilder() (1)
			.withDisabledServer() (2)
			.build();
	}
 
	@DynamicPropertySource (3)
	static void neo4jProperties(DynamicPropertyRegistry registry) {
 
		registry.add("spring.neo4j.uri", embeddedDatabaseServer::boltURI);
		registry.add("spring.neo4j.authentication.username", () -> "neo4j");
		registry.add("spring.neo4j.authentication.password", () -> null);
	}
 
	@AfterAll
	static void stopNeo4j() {
 
		embeddedDatabaseServer.close(); (4)
	}
 
	@Test
	public void findSomethingShouldWork(@Autowired Neo4jClient client) {
 
		Optional<Long> result = client.query("MATCH (n) RETURN COUNT(n)")
			.fetchAs(Long.class)
			.one();
		assertThat(result).hasValue(0L);
	}
}
 

1.创建嵌入式 Neo4j 的入口点
2.禁用不需要的 Neo4j HTTP 服务器
3.这是一个 Spring Boot 注释，允许动态注册应用程序属性。我们覆盖相应的 Neo4j 设置。
4.所有测试后关闭 Neo4j。