入门

我们为 SDN 提供了一个 Spring Boot starter。请通过您的依赖管理引入 starter 模块,并配置要使用的 bolt URL,例如 spring.neo4j.uri=bolt://localhost:7687。该 starter 假定服务器已禁用身份验证。由于 SDN starter 依赖于 Java Driver 的 starter,因此那里提到的所有配置事项也适用于此处。有关可用属性的参考,请使用您 IDE 在 spring.neo4j 命名空间下的自动完成功能。

SDN 支持

  • 众所周知且易于理解的命令式编程模型(与 Spring Data JDBC 或 JPA 非常相似)

  • 基于 Reactive Streams 的响应式编程,包括对响应式事务的完全支持。

所有这些都包含在同一个二进制文件中。响应式编程模型需要数据库端使用 4+ 版本的 Neo4j 服务器,另一端使用响应式 Spring。

准备数据库

对于此示例,我们使用 电影图,因为每个 Neo4j 实例都免费附带此图。

如果您没有运行中的数据库,但安装了 Docker,请运行

在 Docker 中启动本地 Neo4j 实例。
docker run --publish=7474:7474 --publish=7687:7687 -e 'NEO4J_AUTH=neo4j/secret' neo4j:5

您现在可以访问 http://localhost:7474。上述命令将服务器密码设置为 secret。请注意提示符中已准备好运行的命令 (:play movies)。执行该命令以用一些测试数据填充您的数据库。

创建一个新的 Spring Boot 项目

设置 Spring Boot 项目最简单的方法是使用 start.spring.io(此网站也集成在主要的 IDE 中,如果您不想使用网站的话)。

选择 "Spring Web Starter" 以获取创建基于 Spring 的 Web 应用程序所需的所有依赖。Spring Initializr 将为您创建一个有效的项目结构,其中包含所选构建工具的所有文件和设置。

使用 Maven

您可以对 Spring Initializer 发起 curl 请求来创建一个基本的 Maven 项目

使用 Spring Initializr 创建一个基本的 Maven 项目
curl https://start.spring.io/starter.tgz \
  -d dependencies=webflux,data-neo4j  \
  -d bootVersion=3.2.0 \
  -d baseDir=Neo4jSpringBootExample \
  -d name=Neo4j%20SpringBoot%20Example | tar -xzvf -

这将创建一个新文件夹 Neo4jSpringBootExample。由于此 starter 尚未添加到 initializer 中,您必须手动将以下依赖添加到您的 pom.xml

在 Maven 项目中包含 spring-data-neo4j-spring-boot-starter
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-data-neo4j</artifactId>
</dependency>

如果项目已存在,您也可以手动添加此依赖。

使用 Gradle

思路相同,只需生成一个 Gradle 项目即可

使用 Spring Initializr 创建一个基本的 Gradle 项目
curl https://start.spring.io/starter.tgz \
  -d dependencies=webflux,data-neo4j \
  -d type=gradle-project \
  -d bootVersion=3.2.0 \
  -d baseDir=Neo4jSpringBootExampleGradle \
  -d name=Neo4j%20SpringBoot%20Example | tar -xzvf -

Gradle 的依赖如下所示,必须添加到 build.gradle

在 Gradle 项目中包含 spring-data-neo4j-spring-boot-starter
dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-data-neo4j'
}

如果项目已存在,您也可以手动添加此依赖。

配置项目

现在在您喜欢的 IDE 中打开这些项目。找到 application.properties 并配置您的 Neo4j 凭据

spring.neo4j.uri=bolt://localhost:7687
spring.neo4j.authentication.username=neo4j
spring.neo4j.authentication.password=verysecret

这是连接到 Neo4j 实例所需的最低配置。

使用此 starter 时,无需添加任何驱动程序的程序化配置。SDN repository 将通过此 starter 自动启用。

配置 Neo4j Cypher-DSL

根据您运行应用程序所使用的 Neo4j 版本,建议配置 Neo4j Cypher-DSL 运行的方言。默认使用的方言是针对 Neo4j 的 LTS 版本 4.4。可以通过定义一个 Cypher-DSL Configuration bean 来更改此设置。

使 Cypher-DSL 使用 Neo4j 5 方言
@Bean
Configuration cypherDslConfiguration() {
	return Configuration.newConfig()
                .withDialect(Dialect.NEO4J_5).build();
}
尽管 Spring Data Neo4j 会尽力兼容 Neo4j 5 和默认方言的组合,但始终建议明确定义方言。例如,这将导致更优化的查询,并为较新的 Neo4j 版本利用 elementId()

在模块路径上运行

Spring Data Neo4j 可以在模块路径上运行。它的自动模块名称是 spring.data.neo4j。由于当前 Spring Data 构建设置的限制,它本身不提供模块。因此,它使用一个自动但稳定的模块名称。然而,它确实依赖于一个模块化的库(Cypher-DSL)。由于上述限制,我们无法在您的项目上表达对此库的需求,因为缺少 module-info.java

因此,您的项目要在模块路径上运行 Spring Data Neo4j 6.1+ 所需的最少 module-info.java 如下所示

一个旨在在模块路径上使用 Spring Data Neo4j 的项目中的 module-info.java
module your.module {

	requires org.neo4j.cypherdsl.core;

	requires spring.data.commons;
	requires spring.data.neo4j;

	opens your.domain to spring.core; (1)

	exports your.domain; (2)
}
1 Spring Data Neo4j 使用 Spring Data Commons 及其反射能力,因此您至少需要将您的域包开放给 spring.core
2 我们在此假设 your.domain 也包含 repositories:它们必须导出才能被 spring.beansspring.contextspring.data.commons 访问。如果您不想将它们导出到所有模块,可以将它们限制为这些模块。

创建您的域

我们的域层应完成两件事

  • 将您的图映射到对象

  • 提供对这些对象的访问

节点实体示例

SDN 完全支持不可修改的实体,适用于 Java 和 Kotlin 中的 data 类。因此,我们将重点关注这里的不可变实体,MovieEntity.java 展示了这样的实体。

SDN 支持 Neo4j Java Driver 支持的所有数据类型,请参阅章节“Cypher 类型系统”中的 将 Neo4j 类型映射到本机语言类型。未来的版本将支持额外的转换器。
MovieEntity.java
import java.util.ArrayList;
import java.util.List;

import org.springframework.data.neo4j.core.schema.Id;
import org.springframework.data.neo4j.core.schema.Node;
import org.springframework.data.neo4j.core.schema.Property;
import org.springframework.data.neo4j.core.schema.Relationship;
import org.springframework.data.neo4j.core.schema.Relationship.Direction;

@Node("Movie") (1)
public class MovieEntity {

	@Id (2)
	private final String title;

	@Property("tagline") (3)
	private final String description;

	@Relationship(type = "ACTED_IN", direction = Direction.INCOMING) (4)
	private List<Roles> actorsAndRoles = new ArrayList<>();

	@Relationship(type = "DIRECTED", direction = Direction.INCOMING)
	private List<PersonEntity> directors = new ArrayList<>();

	public MovieEntity(String title, String description) { (5)
		this.title = title;
		this.description = description;
	}

	// Getters omitted for brevity
}
1 @Node 用于将此类标记为托管实体。它还用于配置 Neo4j 标签。如果只使用简单的 @Node,标签默认为类名。
2 每个实体都必须有一个 ID。此处显示的 Movie 类使用属性 title 作为唯一的业务键。如果您没有这样的唯一键,可以使用 @Id@GeneratedValue 的组合来配置 SDN 使用 Neo4j 的内部 ID。我们还提供了 UUID 的生成器。
3 这展示了 @Property 作为一种方式,使得字段名称可以与图属性的名称不同。
4 这定义了与 PersonEntity 类型的类的关系以及关系类型 ACTED_IN
5 这是供您的应用程序代码使用的构造函数。

普遍的说法:使用内部生成 ID 的不可变实体有点矛盾,因为 SDN 需要一种方法来使用数据库生成的值设置字段。

如果您找不到好的业务键或不想使用 ID 生成器,下面是使用内部生成 ID 的相同实体,结合常规构造函数和所谓的 wither 方法,SDN 使用此方法

MovieEntity.java
import org.springframework.data.neo4j.core.schema.GeneratedValue;
import org.springframework.data.neo4j.core.schema.Id;
import org.springframework.data.neo4j.core.schema.Node;
import org.springframework.data.neo4j.core.schema.Property;

import org.springframework.data.annotation.PersistenceConstructor;

@Node("Movie")
public class MovieEntity {

	@Id @GeneratedValue
	private Long id;

	private final String title;

	@Property("tagline")
	private final String description;

	public MovieEntity(String title, String description) { (1)
		this.id = null;
		this.title = title;
		this.description = description;
	}

	public MovieEntity withId(Long id) { (2)
		if (this.id.equals(id)) {
			return this;
		} else {
			MovieEntity newObject = new MovieEntity(this.title, this.description);
			newObject.id = id;
			return newObject;
		}
	}
}
1 这是供您的应用程序代码使用的构造函数。它将 ID 设置为 null,因为包含内部 ID 的字段不应该被修改。
2 这是 id 属性的所谓 wither 方法。它创建一个新实体并相应地设置字段,而不修改原始实体,从而使其不可变。

当然,您可以使用 Kotlin 的数据类与 SDN 一起建模您的域。如果您想或需要完全使用 Java,Project Lombok 是另一种选择。

声明 Spring Data repository

您基本上有两种选择:您可以以存储无关的方式使用 SDN 并使您的领域特定 repository 扩展以下接口之一

  • org.springframework.data.repository.Repository

  • org.springframework.data.repository.CrudRepository

  • org.springframework.data.repository.reactive.ReactiveCrudRepository

  • org.springframework.data.repository.reactive.ReactiveSortingRepository

相应地选择命令式或响应式。

虽然技术上不禁止,但不建议在同一个应用程序中混合使用命令式和响应式数据库访问。我们不会为您提供此类场景的支持。

另一种选择是选择特定存储的实现并获得我们开箱即用的所有方法。这种方法的优点也是其最大的缺点:一旦公开,所有这些方法都将成为您 API 的一部分。大多数时候,移除某些内容比之后添加东西更困难。此外,使用特定于存储的方法会将您的存储泄露到您的域中。从性能角度来看,没有惩罚。

一个适用于上述任何电影实体的响应式 repository 如下所示

MovieRepository.java
import reactor.core.publisher.Mono;

import org.springframework.data.neo4j.repository.ReactiveNeo4jRepository;

public interface MovieRepository extends ReactiveNeo4jRepository<MovieEntity, String> {

	Mono<MovieEntity> findOneByTitle(String title);
}
响应式代码的测试使用 reactor.test.StepVerifier 完成。请参阅 Project Reactor 的相应文档或查看我们的示例代码。