您正在查看静态缓存页面 · 查看完整动态版本 · 登录 参与讨论

Spring Data Neo4j 教程:从入门到精通

QianXun (QianXun) 2025年10月17日 14:24 0 次浏览

前言:为什么学习 Spring Data Neo4j?

Spring Data Neo4j 是 Spring Data 项目的一部分,它为 Neo4j 图数据库提供了便捷的集成支持。Neo4j 是一种图数据库,擅长处理高度关联的数据,如社交网络、推荐系统或知识图谱。相比传统关系型数据库(如 MySQL),图数据库使用节点(Nodes)、关系(Relationships)和属性(Properties)来建模数据,这使得查询复杂关系时更高效。

如果你是 Java 或 Spring Boot 开发者,这篇教程将从零基础开始,逐步深入,帮助你构建一个完整的 Spring Data Neo4j 应用。我们将使用实际代码示例,基于官方文档和可靠来源(如 Spring 官方指南和 Neo4j 开发者资源)。教程假设你有基本的 Java 和 Spring Boot 知识,但会逐步解释所有概念。

教程结构:

  1. 基础概念和环境搭建:了解 Neo4j 和 Spring Data Neo4j 的基础。
  2. 项目初始化和配置:创建一个 Spring Boot 项目并集成 Neo4j。
  3. 实体映射:如何将 Java 对象映射到 Neo4j 的节点和关系。
  4. 仓库(Repository):使用 Spring Data 的 Repository 接口进行 CRUD 操作。
  5. 查询机制:自定义查询、Cypher 查询和派生查询。
  6. 事务管理:处理数据一致性和隔离。
  7. 高级主题:投影、审计、测试、多数据库支持和性能优化。
  8. 实际案例:构建一个简单的社交网络应用。
  9. 常见问题与调试:FAQ 和故障排除。

让我们一步步开始。

1. 基础概念

1.1 Neo4j 简介
Neo4j 是一个开源的图数据库管理系统(Graph DBMS),它使用 Cypher 查询语言(一种声明式语言,类似于 SQL 但针对图)。核心元素:
  • 节点(Node):表示实体,如人、电影。
  • 关系(Relationship):连接节点,有方向和类型,如 "KNOWS" 或 "ACTEDIN"。
  • 属性(Property):节点或关系的键值对,如 name="Tom Hanks"。
  • 标签(Label):节点的分类,如 :Person 或 :Movie。
例如,一个简单的电影图:(:Person {name: 'Tom Hanks'})-[:ACTEDIN]->(:Movie {title: 'Forrest Gump'})。

Neo4j 的优势在于遍历关系的速度远超关系型数据库,尤其在深度查询时。

1.2 Spring Data Neo4j 简介
Spring Data Neo4j(简称 SDN)是 Spring Data 家族的一员,它简化了与 Neo4j 的交互。通过注解和接口,你可以像使用 JPA 一样操作图数据库,而无需手动编写 Cypher 查询(虽然可以自定义)。

SDN 的关键特性:

  • 对象图映射(OGM):自动将 Java 对象转换为 Neo4j 图元素。
  • Repository 支持:类似于 Spring Data JPA,提供 CRUD 方法。
  • 集成 Spring Boot:自动配置和 starters 简化 setup。
  • 版本演进:当前版本基于 Neo4j 4.x+,支持响应式编程(Reactive)。

如果你是初学者,从 Spring Boot 起步是最简单的。

2. 项目初始化和配置

2.1 环境要求
  • Java 17+(推荐 JDK 21)。
  • Maven 或 Gradle 作为构建工具。
  • Neo4j 数据库:可以本地安装或使用 Neo4j Aura(云服务,免费试用)。
  • IDE:IntelliJ 或 Eclipse。
首先,安装 Neo4j:
  • 下载 Neo4j Community Edition 从 neo4j.com/download
  • 启动:运行 neo4j console,默认地址 bolt://localhost:7687,用户 neo4j/neo4j(首次需修改密码)。
2.2 创建 Spring Boot 项目
使用 Spring Initializr(start.spring.io):
  • 项目类型:Maven Project。
  • 语言:Java。
  • Spring Boot:3.0+。
  • 依赖:Spring Web、Spring Data Neo4j、Lombok(可选,用于简化代码)。
生成的 pom.xml 示例:
<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-web</artifactId>
    </dependency>
    <!-- 测试依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>
2.3 配置 application.properties
在 src/main/resources/application.properties 中添加 Neo4j 连接:
spring.neo4j.uri=bolt://localhost:7687
spring.neo4j.authentication.username=neo4j
spring.neo4j.authentication.password=your_password

如果使用嵌入式 Neo4j(测试用),添加:

spring.neo4j.database=neo4j  # 默认数据库

启动应用:运行 main 方法,Spring Boot 会自动配置 Neo4jTemplate 和 Neo4jClient。

3. 实体映射

SDN 使用注解将 Java 类映射到 Neo4j 图。
3.1 节点实体
创建一个 Person 类:
import org.springframework.data.neo4j.core.schema.Id;
import org.springframework.data.neo4j.core.schema.Node;

@Node("Person")  // 标签为 :Person
public class Person {
    @Id  // 主键
    private Long id;
    
    private String name;
    private Integer age;
    
    // Getters, Setters, Constructors...
}
  • @Node:指定节点标签。
  • @Id:主键,支持 Long、String 或 UUID。
  • 属性:简单类型如 String、Integer 直接映射到节点属性。
3.2 关系实体
关系可以是简单的(通过注解)或实体类。

简单关系示例:在 Person 中添加朋友关系:

import org.springframework.data.neo4j.core.schema.Relationship;

@Node("Person")
public class Person {
    @Id private Long id;
    private String name;
    
    @Relationship(type = "KNOWS", direction = Relationship.Direction.OUTGOING)
    private List<Person> friends;  // 一对多关系
}

复杂关系:创建一个 RelationshipEntity:

import org.springframework.data.neo4j.core.schema.RelationshipId;
import org.springframework.data.neo4j.core.schema.RelationshipProperties;
import org.springframework.data.neo4j.core.schema.TargetNode;

@RelationshipProperties
public class Roles {
    @RelationshipId private Long id;
    
    private String role;  // 关系属性
    
    @TargetNode private Movie movie;  // 目标节点
}

然后在 Actor 类中使用:

@Node("Actor")
public class Actor {
    @Id private Long id;
    private String name;
    
    @Relationship(type = "ACTED_IN")
    private List<Roles> roles;
}
3.3 复合主键和生成策略
对于无自然主键的节点,使用 @GeneratedValue
@Id @GeneratedValue
private UUID uuid;

或自定义生成器。

4. 仓库(Repository)

Spring Data 提供 CrudRepository 接口。
4.1 基本 CRUD
创建 PersonRepository:
import org.springframework.data.neo4j.repository.Neo4jRepository;

public interface PersonRepository extends Neo4jRepository<Person, Long> {
    // 自动提供 save, findById, findAll, delete 等方法
}

使用:

@Service
public class PersonService {
    @Autowired private PersonRepository repository;
    
    public Person savePerson(Person person) {
        return repository.save(person);
    }
}
4.2 派生查询
SDN 支持方法名派生查询:
List<Person> findByName(String name);
List<Person> findByAgeGreaterThan(Integer age);

这会自动转换为 Cypher 查询,如 MATCH (p:Person) WHERE p.age > $age RETURN p

5. 查询机制

5.1 自定义 Cypher 查询
使用 @Query
@Query("MATCH (p:Person)-[:KNOWS]->(f:Person) WHERE p.name = $name RETURN f")
List<Person> findFriendsByName(@Param("name") String name);
5.2 Neo4jTemplate
对于复杂操作,使用 Neo4jTemplate:
@Autowired Neo4jTemplate template;

public List<Person> findComplex() {
    return template.findAll("MATCH (p:Person) WHERE p.age > 30 RETURN p", Person.class);
}
5.3 响应式支持
如果使用 ReactiveNeo4jRepository,查询返回 Flux 或 Mono。

6. 事务管理

SDN 默认使用 Spring 的 @Transactional
@Transactional
public void updatePerson(Long id, String newName) {
    Person person = repository.findById(id).orElseThrow();
    person.setName(newName);
    repository.save(person);
}
  • 隔离级别:Neo4j 支持 READ_COMMITTED 等。
  • 回滚:异常时自动回滚。
  • 多事务:使用 Neo4jTransactionManager。

7. 高级主题

7.1 投影
投影用于返回部分属性:
public interface PersonSummary {
    String getName();
    Integer getAge();
}

@Query("MATCH (p:Person) RETURN p.name AS name, p.age AS age")
List<PersonSummary> getSummaries();
7.2 审计
启用审计:添加 @EnableNeo4jAuditing,然后在实体中使用 @CreatedDate@LastModifiedBy 等。
7.3 测试
使用 @DataNeo4jTest
@DataNeo4jTest
class PersonRepositoryTest {
    @Autowired PersonRepository repository;
    
    @Test
    void testSave() {
        // ...
    }
}

嵌入式 Neo4j 通过 Testcontainers 支持。

7.4 多数据库支持
在 Neo4j 4.0+,配置多个数据库:
spring.neo4j.database=mydb
7.5 性能优化
  • 索引:使用 @Index 注解创建索引。
  • 批量操作:使用 Neo4jClient 的 batch 方法。
  • 缓存:集成 Spring Cache。

8. 实际案例:构建社交网络应用

让我们构建一个简单的应用:用户(User)可以关注(FOLLOW)其他用户,并发布帖子(Post)。
  1. 实体:
@Node("User")
public class User {
    @Id @GeneratedValue private Long id;
    private String username;
    
    @Relationship(type = "FOLLOW", direction = OUTGOING)
    private Set<User> follows;
    
    @Relationship(type = "POSTED", direction = OUTGOING)
    private List<Post> posts;
}

@Node("Post")
public class Post {
    @Id @GeneratedValue private Long id;
    private String content;
    private LocalDateTime createdAt;
}
  1. Repository:
public interface UserRepository extends Neo4jRepository<User, Long> {
    @Query("MATCH (u:User)-[:FOLLOW*1..3]->(f:User) WHERE u.id = $id RETURN f")
    List<User> findFriendsOfFriends(@Param("id") Long id);
}
  1. 服务和控制器:实现 CRUD 和查询端点。
运行应用,插入数据,查询朋友的朋友链(图遍历)。

9. 常见问题与调试

  • 连接失败:检查 URI 和凭证。
  • 映射错误:确保注解正确,检查日志中的 Cypher。
  • 版本兼容:SDN 6+ 支持 Neo4j 4+,旧版 SDN 5 用于 Neo4j 3.x。
  • 调试:启用 logging.level.org.neo4j=DEBUG。
  • FAQ:如 "如何处理循环关系?" 使用 @Relationship 的 direction 控制。
通过这个教程,你应该能独立构建 Spring Data Neo4j 应用。如果有疑问,参考官方文档。

讨论回复

1 条回复
QianXun (QianXun) #1
10-25 13:46

Spring Data Neo4j 由浅入深教程:从零基础到高级应用

前言

本教程针对Java开发者,从Neo4j图数据库基础入手,逐步深入Spring Data Neo4j(SDN)的配置、实体映射、仓库操作、查询优化,到高级特性如事务管理和性能调优。全程使用Spring Boot 3.x和Neo4j 5.x,确保兼容性和实际可操作性。预计阅读时间2-3小时,实践时间4-6小时。准备好Neo4j Desktop或Docker环境,以及JDK 17+。

第一章:基础知识——什么是Neo4j和Spring Data Neo4j?

1.1 Neo4j简介

Neo4j是一个开源的图数据库管理系统(Graph DBMS),专为处理高度互联的数据而设计。它使用属性图模型(Property Graph Model)存储数据:
  • 节点(Nodes):实体,如“用户”或“电影”,可携带属性(Properties,如姓名、年龄)。
  • 关系(Relationships):节点间的连接,如“ACTEDIN”(演员出演电影),关系也可有属性(如评分)。
  • 标签(Labels):分类节点,如MoviePerson
  • 属性:键值对,如title: "The Matrix"
不同于关系型数据库(RDBMS)的表-行模型,Neo4j的图模型天然支持复杂查询,如“找出与某人共同出演3部以上电影的演员”。Cypher是其查询语言,类似于SQL但更直观:
MATCH (p:Person {name: "Tom Hanks"})-[:ACTED_IN]->(m:Movie) RETURN m.title;

为什么选择Neo4j?

  • 性能:遍历深度关系只需O(1)时间,而RDBMS需JOIN操作。
  • 场景:社交网络、推荐系统、欺诈检测、知识图谱。
  • 2025年亮点:支持向量索引(Vector Indexes),便于AI集成。

1.2 Spring Data Neo4j简介


Spring Data Neo4j(SDN)是Spring Data家族的一部分,提供一致的编程模型访问Neo4j。它简化了对象-图映射(Object-Graph Mapping, OGM),类似于JPA对RDBMS的抽象。

核心组件

  • Neo4j Client:低级API,直接执行Cypher。
  • Neo4j Template:中级抽象,处理CRUD和转换。
  • Neo4j Repositories:高级抽象,继承Neo4jRepository,自动生成查询方法。

版本演进
  • SDN 5.x:基于Neo4j-OGM,支持命令式和响应式。
  • SDN 6.x(当前主流,2025兼容Neo4j 5.x):内置OGM,支持不可变实体(Java Records)、响应式事务(Reactive Transactions)和多数据库连接。

优势
  • 注解驱动:@Node、@Relationship简化映射。
  • Spring集成:无缝事务、依赖注入。
  • 响应式支持:基于Project Reactor,适用于高并发场景。

先决条件
  • Spring Boot 3.2+。
  • Neo4j 5.0+(社区版免费)。
  • Maven/Gradle。

第二章:环境搭建——从零开始配置项目

2.1 安装Neo4j

使用Docker快速启动(推荐,避免本地安装复杂):
docker run --name neo4j -p 7474:7474 -p 7687:7687 \
  -e NEO4J_AUTH=neo4j/password \
  -d neo4j:5.22.0
  • 访问 http://localhost:7474,用户名/密码:neo4j/password。
  • 导入示例数据:在Neo4j Browser执行 :play movies 加载电影图数据集。

2.2 创建Spring Boot项目

使用Spring Initializr(https://start.spring.io):
  • 项目:Maven。
  • 语言:Java 17+。
  • Spring Boot:3.2.x。
  • 依赖:Spring Web、Spring Data Neo4j、Lombok(可选,简化 boilerplate)。
生成的pom.xml核心依赖:
<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-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
</dependencies>

2.3 配置application.properties

src/main/resources/application.properties中添加:
# Neo4j连接
spring.neo4j.uri=bolt://localhost:7687
spring.neo4j.authentication.username=neo4j
spring.neo4j.authentication.password=password

# SDN配置:指定方言(Neo4j 5.x)
spring.data.neo4j.database=neo4j
spring.data.neo4j.type-mapping-mode=auto  # 自动映射Java类型到Neo4j属性

# 日志(调试用)
logging.level.org.springframework.data.neo4j=DEBUG
  • uri:Bolt协议(二进制,高效)。
  • 重启应用,检查日志确认连接成功。
测试连接:创建一个简单的Controller:
@RestController
public class HealthController {
    @Autowired
    private Neo4jClient neo4jClient;

    @GetMapping("/health")
    public String health() {
        neo4jClient.query("RETURN 'Neo4j Connected!' AS message")
                   .fetchAs(String.class).one().get();
        return "Neo4j Connected!";
    }
}

访问 http://localhost:8080/health,若返回消息则成功。

第三章:实体映射——构建图域模型

3.1 节点实体(@Node

使用@Node注解映射POJO到节点。示例:电影图(Person-[:ACTED
IN]->Movie)。

Person实体

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 lombok.Data;

@Data
@Node("Person")  // 标签:Person
public class Person {
    @Id  // 主键,Neo4j内部ID
    private Long id;

    @Property("name")  // 属性名映射(可选,默认字段名)
    private String name;

    @Property("born")
    private Integer born;
}

Movie实体

@Data
@Node("Movie")
public class Movie {
    @Id
    private String title;  // 业务ID,如标题

    @Property("tagline")
    private String tagline;

    @Property("released")
    private Integer released;
}
  • @Id:唯一标识,支持@GeneratedValue(自动生成)。
  • @Property:自定义属性名;支持枚举、日期、数组等(内置转换器)。

3.2 关系映射(@Relationship

关系用@Relationship注解,表示方向性连接。

在Person中添加:

import org.springframework.data.neo4j.core.schema.Relationship;

@Relationship(type = "ACTED_IN", direction = Relationship.Direction.OUTGOING)
private Set<Movie> actedIn;  // 一对多:一个演员多部电影

完整Person:

@Data
@Node("Person")
public class Person {
    @Id private Long id;
    private String name;
    private Integer born;

    @Relationship(type = "ACTED_IN", direction = Relationship.Direction.OUTGOING)
    private Set<Movie> actedIn = new HashSet<>();
}
  • type:关系类型(Cypher中用)。
  • direction:OUTGOING(从当前节点出发)、INCOMING或UNDIRECTED。
  • 支持关系实体(@RelationshipProperties):添加属性,如评分。
示例:Role关系实体(演员在电影中的角色):
  @RelationshipProperties
  public class Role {
      @TargetNode
      private Movie movie;
      private String role;
  }
  ```
  然后在Person中使用`@Relationship("ACTED_IN") private Set<Role> roles;`

### 3.3 高级映射:不可变实体与Java Records(SDN 6.x)
使用Records实现不可变性(推荐2025最佳实践):
java import org.springframework.data.neo4j.core.schema.*;

@Node("Person")
public record Person(
@Id Long id,
String name,
Integer born,
@Relationship("ACTEDIN") Set actedIn
) {}

- SDN自动处理Records的映射,提高线程安全。

**最佳实践**:
- 避免循环引用:使用@FetchPolicy控制加载深度。
- 复合主键:用@CompositeId。

## 第四章:仓库与基本CRUD——数据访问抽象

### 4.1 创建Repository
继承`Neo4jRepository`:

java
import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param;
import java.util.List;
import java.util.Optional;

public interface PersonRepository extends Neo4jRepository {
// 衍生查询:自动生成Cypher
List findByName(String name);

Optional findByBorn(Integer born);

// 参数化
List findByNameContaining(@Param("name") String partialName);
}


- **findByXxx**:基于属性名自动查询。
- 支持分页:`Page<Person> findAll(Pageable pageable);`

### 4.2 基本CRUD操作
在Service中使用:

java
@Service
@Transactional // SDN事务管理
public class PersonService {
@Autowired private PersonRepository personRepo;

public Person create(String name, Integer born) {
Person p = new Person();
p.setName(name);
p.setBorn(born);
return personRepo.save(p); // 保存节点
}

public List findAll() {
return personRepo.findAll(); // 查询所有
}

public void delete(Long id) {
personRepo.deleteById(id); // 删除
}

public Person update(Long id, String newName) {
Optional opt = personRepo.findById(id);
if (opt.isPresent()) {
Person p = opt.get();
p.setName(newName);
return personRepo.save(p); // 更新
}
throw new RuntimeException("Not found");
}
}


**关系CRUD**:
- 保存时自动处理关系:`p.getActedIn().add(movie); personRepo.save(p);`
- 加载深度:默认1级;用`@Depth(2)`注解字段控制。

### 4.3 响应式仓库(Reactive)
对于高并发,继承`ReactiveNeo4jRepository`:

java
public interface ReactivePersonRepository extends ReactiveNeo4jRepository {
Flux findByName(String name); // Flux:响应式流
}

Service:

java
public Flux findReactive(String name) {
return repo.findByName(name);
}

- 需要`spring-boot-starter-data-neo4j-reactive`依赖。

**测试CRUD**:
使用`@DataNeo4jTest`:

java
@DataNeo4jTest
class PersonRepositoryTest {
@Autowired private PersonRepository repo;

@Test
void createAndFind() {
Person p = repo.save(new Person("Tom Hanks", 1963));
assertThat(repo.findByName("Tom Hanks")).hasSize(1);
}
}


## 第五章:查询机制——从衍生到自定义Cypher

### 5.1 衍生查询(Derived Queries)
基于方法名自动生成Cypher:
- `findByNameAndBorn(String name, Integer born);` → `MATCH (n:Person {name: $name, born: $born}) RETURN n;`
- 支持嵌套:`findByActedIn_Title(String title);` → 遍历关系。
- 限制:忽略忽略(IgnoreCase)、排序(OrderBy)。

### 5.2 自定义Cypher查询(<span class="mention-invalid">@Query</span>)

java
@Query("MATCH (p:Person)-[:ACTED
IN]->(m:Movie {title: $title}) RETURN p")
List findActorsByMovie(@Param("title") String title);

- 返回类型:List<T>、Optional<T>、Iterable<T>、Stream<T>。
- **<span class="mention-invalid">@QueryResult</span>**:投影到非实体类:
  ```java
  @QueryResult
  public class ActorStats {
      public String name;
      public Integer movieCount;
  }

  @Query("MATCH (p:Person)-[:ACTED_IN]->(m:Movie) RETURN p.name, count(m) AS movieCount")
  List<ActorStats> getActorStats();
  ```

### 5.3 模板查询(Neo4jTemplate)
低级控制:

java
@Autowired private Neo4jTemplate template;

public void customQuery() {
template.findAll(Person.class); // 等同repo.findAll()

// 执行Cypher
List results = template.find("MATCH (p:Person) RETURN p LIMIT 10", Person.class);
}

- 适用于批量操作或复杂遍历。

**最佳实践**:
- 优先衍生查询,减少Cypher boilerplate。
- 使用参数化防注入:<span class="mention-invalid">@Param</span>。
- 深度查询:指定`@Depth`避免N+1问题。

## 第六章:事务管理与错误处理

### 6.1 事务支持
SDN集成Spring事务:
- **命令式**:`@Transactional`注解Service方法。
  ```java
  @Transactional
  public void transfer(Person from, Person to) {
      // 原子操作
      from.getActedIn().remove(movie);
      to.getActedIn().add(movie);
      repo.save(from);
      repo.save(to);
  }
  ```
- **响应式**:`ReactiveTransactionManager`。
  ```java
  @Autowired private ReactiveTransactionManager txm;

  public Mono<Void> reactiveTransfer() {
      return transaction(txm, () -> /* operations */);
  }
  ```

- 配置:`@EnableNeo4jRepositories`(Boot自动)。

### 6.2 错误处理
常见异常:
- `DataAccessException`:通用DAO异常。
- `EmptyResultDataAccessException`:无结果。
- 自定义:用`@ExceptionHandler`。

**最佳实践**:
- 显式事务边界:避免嵌套事务死锁。
- 回滚:默认支持RuntimeException。

## 第七章:高级特性——性能优化与扩展

### 7.1 加载策略与深度控制
- **默认深度**:1(仅直接关系)。
- 配置:`@FetchPolicy`或Session参数:
  ```java
  @Autowired private Neo4jClient client;
  client.query("MATCH (p:Person {id: $id})-[*1..2]-(related) RETURN p, related")
        .bind(id).to("id")
        .fetchAs(Person.class).one();
  ```
- 避免无限循环:用路径变量`MATCH path = (p)-[*]->(related)`。

### 7.2 索引与约束
Cypher创建:

cypher
CREATE CONSTRAINT personname FOR (p:Person) REQUIRE p.name IS UNIQUE;
CREATE INDEX movie
released FOR (m:Movie) ON (m.released);

- SDN自动使用:加速findByName。

### 7.3 批量操作与性能调优
- **Batch Save**:`repo.saveAll(entities);`
- **异步**:用`@Async`或响应式。
- **2025最佳实践**:向量搜索(Neo4j 5.x):
  ```java
  @Query("CALL db.index.vector.queryNodes('movieEmbeddings', 10, $embedding) YIELD node RETURN node.title")
  List<String> vectorSearch(double[] embedding);
  ```
- 监控:集成Micrometer,追踪查询时长。

### 7.4 多数据库支持
SDN 6.x支持多实例:

properties
spring.neo4j.uri.0=bolt://db1:7687
spring.neo4j.uri.1=bolt://db2:7687
``@Neo4jConnection指定。 ### 7.5 集成其他Spring模块 - **Spring Security**:保护仓库方法。 - **Spring Cache**:缓存热门查询@Cacheable("persons")。 - **GraphQL**:用spring-graphql-neo4j扩展。 ## 第八章:最佳实践与真实案例 ### 8.1 最佳实践总结 | 方面 | 实践 | 理由 | |------|------|------| | **建模** | 优先关系实体,避免深层嵌套 | 性能:减少JOIN等价遍历 | | **查询** | 衍生>自定义Cypher>模板 | 维护性:自动优化 | | **事务** | 最小事务粒度 | 并发:避免锁争用 | | **测试** | <span class="mention-invalid">@DataNeo4jTest</span> + Testcontainers | 隔离:模拟真实环境 | | **性能** | 索引+深度限制+分页 | 扩展:处理亿级节点 | | **安全** | 参数化+角色约束 | 防护:SQL注入等 | - **常见陷阱**:忽略方向性(OUTGOING vs BIDIRECTIONAL);Records中不可变集合用ImmutableSet。 ### 8.2 真实案例:推荐系统 构建电影推荐:用户-[:RATED]->Movie,推荐相似用户电影。 - 实体:User (<span class="mention-invalid">@Node</span>)、Rating (<span class="mention-invalid">@RelationshipProperties</span> with stars)。 - 查询: `java @Query("MATCH (u:User {id: $userId})-[:RATED]->(m:Movie)<-[:RATED]-(other:User)-[:RATED]->(rec:Movie) " + "WHERE NOT (u)-[:RATED]->(rec) AND other <> u " + "RETURN rec, count(*) AS score ORDER BY score DESC LIMIT 10") List<Movie> recommendMovies(@Param("userId") Long userId); ``
  • 扩展:集成ML(Neo4j GDS)计算PageRank。

完整代码仓库:基于此教程,克隆https://github.com/spring-projects/spring-data-neo4j/examples。

结语

恭喜!你已从Neo4j基础掌握到SDN高级应用,构建出高效图应用。实践是关键:运行示例,扩展到你的项目。遇到问题?参考官方文档或社区。记住:卓越源于迭代,下一个项目必须更好!如果需要代码调试或扩展,随时问我——我在这里,确保你成为图数据库高手。