Spring Boot 整合 Neo4j的过程详解

目录

• ​​1. Neo4j 简介​​
• ​​Neo4j 的核心概念​​
• 2. 环境准备​​
• ​​2.1 安装 Neo4j​​
• ​​方式 1：本地安装（docker 方式）
• ​​方式 2：云服务（Neo4j Aura）​​
• ​​2.2 创建 Spring Boot 项目​​
• 3. Spring Boot 整合 Neo4j​​
• ​​3.1 添加 Neo4j 依赖​​
• 3.2 配置 Neo4j 连接​​
• 3.3 创建 Neo4j 实体类​​
• ​​示例：定义Person节点​
• 3.4 创建 Neo4j Repository​​
• 3.5 创建 Service 层​
• 3.6 创建 Controller 层​
• 4. 测试 Neo4j 操作​​
• ​​4.1 启动 Spring Boot 项目​​
• ​​4.2 使用 Postman 测试​​
• ​​(1) 新增 Person​
• (2) 查询所有 Person​
• ​​(3) 按名字查询​
• (4) 删除 Person​
• 5. 进阶：定义关系（Relationship）​​
• ​​5.1 定义Movie节点​
• 5.2 定义关系​​
• 6. 总结​​

        Neo4j 是一个高性能的 ​​图数据库​​，适用于存储和查询 ​​节点（Node）​​ 和 ​​关系（Relationship）​​ 的数据。本教程将带你从零开始，在 ​​Spring Boot​​ 项目中整合 ​​Neo4j​​，并实现基本的 ​​CRUD​​ 操作。

​​1. Neo4j 简介​​

Neo4j 是一个 ​​原生图数据库​​，采用 ​​属性图模型​​，数据由 ​​节点（Node）​​ 和 ​​关系（Relationship）​​ 组成，每个节点和关系都可以有 ​​属性（Property）​​。

​​Neo4j 的核心概念​​

2. 环境准备​​

​​2.1 安装 Neo4j​​

​​方式 1：本地安装（Docker 方式）

docker run \
    --name neo4j \
    -p 7474:7474 -p 7687:7687 \
    -e NEO4J_AUTH=neo4j/123456 \
    neo4j:5.12.0

• ​​7474​​：Neo4j Web 管理界面端口
• ​​7687​​：Neo4j 数据库端口（Bolt 协议）
• ​​NEO4J_AUTH=neo4j/123456​​：默认用户名 neo4j，密码 123456

访问 ​​Neo4j Web 界面​​：http://localhost:7474

​​方式 2：云服务（Neo4javascriptj Aura）​​

• 官网：https://neo4j.com/cloud/aura/
• 免费试用，无需本地安装。

​​2.2 创建 Spring Boot 项目​​

使用 ​​Spring Initializr​​ 创建项目：

• ​​依赖​​：
  • ​​Spring Web​​
  • ​​Spring Data Neo4j​​

https://i.imgur.com/xyz1234.png

3. Spring Boot 整合 Neo4j​​

​​3.1 添加 Neo4j 依赖​​

在 pom.XML&编程客栈nbsp;中添加：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot编程-starter-data-neo4j</artifactId>
</dependency>

3.2 配置 Neo4j 连接​​

在 application.yml 或 application.properties 中配置：

spring:
  data:
    neo4j:
      uri: bolt://localhost:7687  # Neo4j Bolt 协议地址
      username: neo4j             # 默认用户名
      password: 123456            # 默认密码

3.3 创建 Neo4j 实体类​​

Neo4j 的实体类使用 @Node 注解标记，类似于 JPA 的 @Entity。

​​示例：定义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;
@Node("Person")  // 定义节点标签为 "Person"
public class Person {
    @Id  // 主键
    private Long id;
    @Property("name")  // 属性名
    private String name;
    @Property("age")
    private Integer age;
    // 构造方法、Getter、Setter
    public Person() {}
    public Person(Long id, String name, Integer age) {
        this.id = id;
        this.name = name;
        this.age = age;
    }
    // Getter & Setter
    public Long getId() { return id; }
    public void setId(Long id) { this.id = id; }
    public String getName() { return name; }
    public void setName(String name) { this.name = name; }
    public Integer getAge() { return age; }
    public void setAge(Integer age) { this.age = age; }
}

3.4 创建 Neo4j Repository​​

类似于 JPA 的 JpaRepository，Neo4j 提供 Neo4jRepository 用于 CRUD 操作。

import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.stereotype.Repository;
@Repository
public interface PersonRepository extends Neo4jRepository<Person, Long> {
    // 可以自定义查询方法
    List<Person> findByName(String name);
}

3.5 创建 Service 层​

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import Java.util.List;
@Service
public class PersonService {
    @Autowired
    private PersonRepository personRepository;
    // 保存 Person
    public Person savePerson(Person person) {
        return personRepository.save(person);
    }
    // 查询所有 Person
    public List<Person> findAllPersons() {
        return personRepository.findAll();
    }
    // 按名字查询 Person
    public List<Person> findByName(String name) {
        return personRepository.findByName(name);
    }
    // 删除 Person
    public void deletePerson(Long id) {
        personRepository.deleteById(id);
    }
}

3.6 创建 Controller 层​

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
@RequestMapping("/api/persons")
public class PersonController {
    @Autowired
    private PersonService personService;
    // 新增 Person
    @PostMapping
    public Person addPerson(@RequestBody Person person) {
        return personService.savePerson(person);
    }
    // 查询所有 Person
    @GetMapping
    public List<Person> getAllPersons() {
        return personService.findAllPersons();
    }
    // 按名字查询 Person
    @GetMapping("/name/{name}")
    public List<Person> getPersonsByName(@PathVariable String name) {
        return personService.findByName(name);
    }
    // 删除 Person
    @DeleteMapping("/{id}")
    public void deletePerson(@PathVariable Long id) {
        personService.deletePerson(id);
    }
}

4. 测试 Neo4j 操作​​

​​4.1 启动 Spring Boot 项目​​

运行 SpringBootApplication 主类，访问：

• ​​Neo4j Web 界面​​：http://localhost:7474
• ​​API 接口​​：
  • POST /api/persons（新增 Person）
  • GET /api/persons（查询所有 Person）
  • GET /api/persons/name/{name}（按名字查询）
  • DELETE /api/persons/{id}（删除 Person）

​​4.2 使用 Postman 测试​​

​​(1) 新增 Person​

POST http://localhost:8080/api/persons
{
    "id": 1,
    "name": "Alice",
    "age": 25
}

(2) 查php询所有 Person​

GET http://localhost:8080/api/persons

​​(3) 按名字查询​

GET http://localhost:8080/api/persons/name/Alice

(4) 删除 Person​

DELETE http://localhost:8080/api/persons/1

5. 进阶：定义关系（Relationship）​​

Neo4j 不仅可以存储节点，还可以定义 ​​关系​​。例如，Person 和 Movie 之间可以有 ACTED_IN 关系。

​​5.1 定义Movie节点​

@Node("Movie")
public class Movie {
    @Id
    private Long id;
    @Property("title")
    private String title;
    // Getter & Setter
}

5.2 定义关系​​

使用 @Relationsjship 注解定义关系：

import org.springframework.data.neo4j.core.schema.Relationship;
@Node("Person")
public class Person {
    @Id
    private Long id;
    @Property("name")
    private String name;
    @Property("age")
    private Integer age;
    @Relationship(type = "ACTED_IN", direction = Relationship.Direction.OUTGOING)
    private List<Movie> movies;
    // Getter & Setter
}

6. 总结​​

到此这篇关于Spring Boot 整合 Neo4j的文章就介绍到这了,更多相关Spring Boot 整合 Neo4j内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)！