如何在Neo4j的NoSQL數(shù)據(jù)存儲(chǔ)中持久化對(duì)象關(guān)系

原標(biāo)題：Spring認(rèn)證中國(guó)教育管理中心-了解如何在 Neo4j 的 NoSQL 數(shù)據(jù)存儲(chǔ)中持久化對(duì)象和關(guān)系。（Spring中國(guó)教育管理中心）

本指南將引導(dǎo)您完成使用Spring Data Neo4j構(gòu)建應(yīng)用程序的過程，該應(yīng)用程序在 Neo4j 中存儲(chǔ)數(shù)據(jù)并從中檢索數(shù)據(jù)，Neo4j是一個(gè)基于圖形的數(shù)據(jù)庫(kù)。

你將建造什么

您將使用 Neo4j 的NoSQL基于圖形的數(shù)據(jù)存儲(chǔ)來(lái)構(gòu)建嵌入式 Neo4j 服務(wù)器、存儲(chǔ)實(shí)體和關(guān)系以及開發(fā)查詢。

你需要什么

約15分鐘
最喜歡的文本編輯器或 IDE
JDK 1.8或更高版本
Gradle 4+或Maven 3.2+
您還可以將代碼直接導(dǎo)入 IDE：彈簧工具套件 (STS)IntelliJ IDEA

如何完成本指南

像大多數(shù) Spring入門指南一樣，您可以從頭開始并完成每個(gè)步驟，也可以繞過您已經(jīng)熟悉的基本設(shè)置步驟。無(wú)論哪種方式，您最終都會(huì)得到工作代碼。

要從頭開始，請(qǐng)繼續(xù)從 Spring Initializr 開始。

要跳過基礎(chǔ)知識(shí)，請(qǐng)執(zhí)行以下操作：

下載并解壓本指南的源代碼庫(kù)，或使用Git克隆它：git clone https://github.com/spring-guides/gs-accessing-data-neo4j.git
光盤進(jìn)入gs-accessing-data-neo4j/initial
跳轉(zhuǎn)到定義一個(gè)簡(jiǎn)單實(shí)體。

完成后，您可以對(duì)照中的代碼檢查結(jié)果
gs-accessing-data-neo4j/complete。

從 Spring Initializr 開始

您可以使用這個(gè)預(yù)先初始化的項(xiàng)目并單擊 Generate 下載 ZIP 文件。此項(xiàng)目配置為適合本教程中的示例。

手動(dòng)初始化項(xiàng)目：

導(dǎo)航到https://start.spring.io。該服務(wù)提取應(yīng)用程序所需的所有依賴項(xiàng)，并為您完成大部分設(shè)置。
選擇 Gradle 或 Maven 以及您要使用的語(yǔ)言。本指南假定您選擇了 Java。
單擊Dependencies并選擇Spring Data Neo4j。
單擊生成。
下載生成的 ZIP 文件，該文件是根據(jù)您的選擇配置的 Web 應(yīng)用程序的存檔。

如果您的 IDE 具有 Spring Initializr 集成，您可以從您的 IDE 完成此過程。

你也可以從 Github 上 fork 項(xiàng)目并在你的 IDE 或其他編輯器中打開它。

建立 Neo4j 服務(wù)器

在構(gòu)建此應(yīng)用程序之前，您需要設(shè)置 Neo4j 服務(wù)器。

Neo4j 有一個(gè)開源服務(wù)器，您可以免費(fèi)安裝。

在安裝了 Homebrew 的 Mac 上，運(yùn)行以下命令：

$釀造安裝neo4j

有關(guān)其他選項(xiàng)，請(qǐng)?jiān)L問
https://neo4j.com/download/community-edition/。

安裝后，通過運(yùn)行以下命令以默認(rèn)設(shè)置啟動(dòng)它：

$ neo4j 開始

您應(yīng)該會(huì)看到類似于以下內(nèi)容的輸出：

啟動(dòng) Neo4j。
啟動(dòng) neo4j (pid 96416)。默認(rèn)情況下，它位于 http://localhost:7474/
在服務(wù)器準(zhǔn)備好之前可能會(huì)有短暫的延遲。
有關(guān)當(dāng)前狀態(tài)，請(qǐng)參見 /usr/local/Cellar/neo4j/3.0.6/libexec/logs/neo4j.log。

默認(rèn)情況下，Neo4j 的用戶名和密碼為neo4jand neo4j。但是，它需要更改新的帳戶密碼。為此，請(qǐng)運(yùn)行以下命令：

curl -v -u neo4j:neo4j POST localhost:7474/user/neo4j/password -H "Content-type:application/json" -d "{"password":"secret"}"

這會(huì)將密碼從更改neo4j為secret?- 在生產(chǎn)中不要做的事情！完成該步驟后，您應(yīng)該準(zhǔn)備好運(yùn)行本指南的其余部分。

定義一個(gè)簡(jiǎn)單的實(shí)體

Neo4j 捕獲實(shí)體及其關(guān)系，這兩個(gè)方面同等重要。想象一下，您正在為一個(gè)系統(tǒng)建模，您在其中存儲(chǔ)每個(gè)人的記錄。但是，您還想跟蹤一個(gè)人的同事（teammates在本例中）。使用 Spring Data Neo4j，您可以使用一些簡(jiǎn)單的注釋來(lái)捕獲所有這些，如以下清單（in 中
src/main/java/com/example/accessingdataneo4j/Person.java）所示：

package com.example.accessingdataneo4j;

import java.util.Collections;
import java.util.HashSet;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;

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.GeneratedValue;

@Node
public class Person {

  @Id @GeneratedValue private Long id;

  private String name;

  private Person() {
    // Empty constructor required as of Neo4j API 2.0.5
  };

  public Person(String name) {
    this.name = name;
  }

  /**
   * Neo4j doesn't REALLY have bi-directional relationships. It just means when querying
   * to ignore the direction of the relationship.
   * https://dzone.com/articles/modelling-data-neo4j
   */
  @Relationship(type = "TEAMMATE")
  public Set teammates;

  public void worksWith(Person person) {
    if (teammates == null) {
      teammates = new HashSet<>();
    }
    teammates.add(person);
  }

  public String toString() {

    return this.name + "'s teammates => "
      + Optional.ofNullable(this.teammates).orElse(
          Collections.emptySet()).stream()
            .map(Person::getName)
            .collect(Collectors.toList());
  }

  public String getName() {
    return name;
  }

  public void setName(String name) {
    this.name = name;
  }
}

在這里，您有一個(gè)Person只有一個(gè)屬性的類：name.

該類Person用注釋@NodeEntity。Neo4j 存儲(chǔ)它時(shí)，會(huì)創(chuàng)建一個(gè)新節(jié)點(diǎn)。這個(gè)類也有一個(gè)id標(biāo)記@GraphId。Neo4j@GraphId在內(nèi)部使用來(lái)跟蹤數(shù)據(jù)。

下一個(gè)重要的部分是teammates. 它很簡(jiǎn)單Set，但被標(biāo)記為@Relationship。這意味著這個(gè)集合的每個(gè)成員都應(yīng)該作為一個(gè)單獨(dú)的Person節(jié)點(diǎn)存在。注意方向是如何設(shè)置的UNDIRECTED。這意味著當(dāng)您查詢TEAMMATE關(guān)系時(shí)，Spring Data Neo4j 會(huì)忽略關(guān)系的方向。

使用該worksWith()方法，您可以輕松地將人們聯(lián)系在一起。

最后，您有一個(gè)方便的toString()方法可以打印出該人的姓名和該人的同事。

創(chuàng)建簡(jiǎn)單查詢

Spring Data Neo4j 專注于在 Neo4j 中存儲(chǔ)數(shù)據(jù)。但它繼承了 Spring Data Commons 項(xiàng)目的功能，包括派生查詢的能力。本質(zhì)上，您不需要學(xué)習(xí) Neo4j 的查詢語(yǔ)言。相反，您可以編寫一些方法并讓查詢?yōu)槟帉憽?/span>

要了解其工作原理，請(qǐng)創(chuàng)建一個(gè)查詢Person節(jié)點(diǎn)的接口。以下清單 (in
src/main/java/com/example/accessingdataneo4j/PersonRepository.java) 顯示了這樣一個(gè)查詢：

package com.example.accessingdataneo4j;

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

public interface PersonRepository extends Neo4jRepository {

  Person findByName(String name);
  List findByTeammatesName(String name);
},>

PersonRepository擴(kuò)展Neo4jRepository接口并插入其操作的類型：Person. 該接口帶有許多操作，包括標(biāo)準(zhǔn)的 CRUD（創(chuàng)建、讀取、更新和刪除）操作。

但是您可以通過聲明它們的方法簽名來(lái)定義其他查詢。在這種情況下，您添加了findByName，它會(huì)查找類型節(jié)點(diǎn)Person并找到與上匹配的節(jié)點(diǎn)name。您還有findByTeammatesName，它會(huì)尋找一個(gè)Person節(jié)點(diǎn)，深入到teammates字段的每個(gè)條目，并根據(jù)隊(duì)友的name.

訪問 Neo4j 的權(quán)限

Neo4j 社區(qū)版需要憑據(jù)才能訪問它。您可以通過設(shè)置幾個(gè)屬性（在中
src/main/resources/application.properties）來(lái)配置這些憑據(jù)，如以下清單所示：

spring.neo4j.uri=bolt://localhost:7687
spring.data.neo4j.username=neo4j
spring.data.neo4j.password=secret

這包括默認(rèn)用戶名 ( neo4j) 和我們之前選擇的新設(shè)置的密碼 ( secret)。

不要將真實(shí)憑據(jù)存儲(chǔ)在您的源存儲(chǔ)庫(kù)中。相反，使用Spring Boot 的 property overrides在運(yùn)行時(shí)配置它們。

創(chuàng)建應(yīng)用程序類

Spring Initializr 為應(yīng)用程序創(chuàng)建一個(gè)簡(jiǎn)單的類。以下清單顯示了 Initializr 為本示例創(chuàng)建的類（在中
src/main/java/com/example/accessingdataneo4j/AccessingDataNeo4jApplication.java）：

package com.example.accessingdataneo4j;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class AccessingDataNeo4jApplication {

  public static void main(String[] args) {
    SpringApplication.run(AccessingDataNeo4jApplication.class, args);
  }

}

@SpringBootApplication是一個(gè)方便的注釋，它添加了以下所有內(nèi)容：

@Configuration: 將類標(biāo)記為應(yīng)用程序上下文的 bean 定義源。
@EnableAutoConfiguration：告訴 Spring Boot 根據(jù)類路徑設(shè)置、其他 bean 和各種屬性設(shè)置開始添加 bean。例如，如果spring-webmvc位于類路徑上，則此注釋將應(yīng)用程序標(biāo)記為 Web 應(yīng)用程序并激活關(guān)鍵行為，例如設(shè)置DispatcherServlet.
@ComponentScan: 告訴 Spring 在包中查找其他組件、配置和服務(wù)com/example，讓它找到控制器。

該main()方法使用 Spring Boot 的SpringApplication.run()方法來(lái)啟動(dòng)應(yīng)用程序。您是否注意到?jīng)]有一行 XML？也沒有web.xml文件。這個(gè) Web 應(yīng)用程序是 100% 純 Java，您不必處理任何管道或基礎(chǔ)設(shè)施的配置。

只要它們包含在@SpringBootApplication類的同一個(gè)包（或子包）中，Spring Boot 就會(huì)自動(dòng)處理這些存儲(chǔ)庫(kù)。為了更好地控制注冊(cè)過程，您可以使用@EnableNeo4jRepositories注釋。

默認(rèn)情況下，@EnableNeo4jRepositories掃描當(dāng)前包以查找擴(kuò)展 Spring Data 存儲(chǔ)庫(kù)接口之一的任何接口。basePackageClasses=MyRepository.class如果您的項(xiàng)目布局有多個(gè)項(xiàng)目并且找不到您的存儲(chǔ)庫(kù)，您可以使用它來(lái)安全地告訴 Spring Data Neo4j 按類型掃描不同的根包。

顯示記錄輸出。該服務(wù)應(yīng)在幾秒鐘內(nèi)啟動(dòng)并運(yùn)行。

PersonRepository現(xiàn)在自動(dòng)裝配您之前定義的實(shí)例。Spring Data Neo4j 動(dòng)態(tài)實(shí)現(xiàn)該接口并插入所需的查詢代碼以滿足接口的義務(wù)。

該main方法使用 Spring BootSpringApplication.run()啟動(dòng)應(yīng)用程序并調(diào)用CommandLineRunner構(gòu)建關(guān)系的方法。

在本例中，您將創(chuàng)建三個(gè)本地Person實(shí)例：Greg、Roy 和 Craig。最初，它們只存在于內(nèi)存中。請(qǐng)注意，沒有人是任何人的隊(duì)友（目前）。

起初，你找到 Greg，表明他與 Roy 和 Craig 合作，然后再次堅(jiān)持他。請(qǐng)記住，隊(duì)友關(guān)系被標(biāo)記為UNDIRECTED（即雙向）。這意味著 Roy 和 Craig 也已更新。

這就是為什么當(dāng)您需要更新 Roy 時(shí)。首先從 Neo4j 獲取該記錄至關(guān)重要。在將 Craig 添加到列表之前，您需要了解 Roy 隊(duì)友的最新狀態(tài)。

為什么沒有代碼可以獲取 Craig 并添加任何關(guān)系？因?yàn)槟阋呀?jīng)擁有了！格雷格早些時(shí)候?qū)⒖死赘駱?biāo)記為隊(duì)友，羅伊也是如此。這意味著無(wú)需再次更新 Craig 的關(guān)系。當(dāng)您遍歷每個(gè)團(tuán)隊(duì)成員并將他們的信息打印到控制臺(tái)時(shí)，您可以看到它。

最后，查看您向后看的其他查詢，回答“誰(shuí)與誰(shuí)一起工作？”的問題。

以下清單顯示了完成的
AccessingDataNeo4jApplication類 (at
src/main/java/com/example/accessingdataneo4j/AccessingDataNeo4jApplication.java)：

package com.example.accessingdataneo4j;

import java.util.Arrays;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.data.neo4j.repository.config.EnableNeo4jRepositories;

@SpringBootApplication
@EnableNeo4jRepositories
public class AccessingDataNeo4jApplication {

	private final static Logger log = LoggerFactory.getLogger(AccessingDataNeo4jApplication.class);

	public static void main(String[] args) throws Exception {
		SpringApplication.run(AccessingDataNeo4jApplication.class, args);
		System.exit(0);
	}

	@Bean
	CommandLineRunner demo(PersonRepository personRepository) {
		return args -> {

			personRepository.deleteAll();

			Person greg = new Person("Greg");
			Person roy = new Person("Roy");
			Person craig = new Person("Craig");

			List team = Arrays.asList(greg, roy, craig);

			log.info("Before linking up with Neo4j...");

			team.stream().forEach(person -> log.info("\t" + person.toString()));

			personRepository.save(greg);
			personRepository.save(roy);
			personRepository.save(craig);

			greg = personRepository.findByName(greg.getName());
			greg.worksWith(roy);
			greg.worksWith(craig);
			personRepository.save(greg);

			roy = personRepository.findByName(roy.getName());
			roy.worksWith(craig);
			// We already know that roy works with greg
			personRepository.save(roy);

			// We already know craig works with roy and greg

			log.info("Lookup each person by name...");
			team.stream().forEach(person -> log.info(
					"\t" + personRepository.findByName(person.getName()).toString()));

			List teammates = personRepository.findByTeammatesName(greg.getName());
			log.info("The following have Greg as a teammate...");
			teammates.stream().forEach(person -> log.info("\t" + person.getName()));
		};
	}

}

構(gòu)建一個(gè)可執(zhí)行的 JAR

您可以使用 Gradle 或 Maven 從命令行運(yùn)行應(yīng)用程序。您還可以構(gòu)建一個(gè)包含所有必要依賴項(xiàng)、類和資源的單個(gè)可執(zhí)行 JAR 文件并運(yùn)行它。構(gòu)建可執(zhí)行 jar 可以在整個(gè)開發(fā)生命周期、跨不同環(huán)境等中輕松地將服務(wù)作為應(yīng)用程序交付、版本化和部署。

如果您使用 Gradle，則可以使用./gradlew bootRun. 或者，您可以使用構(gòu)建 JAR 文件./gradlew build，然后運(yùn)行 ?JAR 文件，如下所示：

java -jar build/libs/gs-accessing-data-neo4j-0.1.0.jar

如果您使用 Maven，則可以使用./mvnw spring-boot:run. 或者，您可以使用構(gòu)建 JAR 文件，./mvnw clean package然后運(yùn)行該 JAR 文件，如下所示：

java -jar 目標(biāo)/gs-accessing-data-neo4j-0.1.0.jar

此處描述的步驟創(chuàng)建了一個(gè)可運(yùn)行的 JAR。您還可以構(gòu)建經(jīng)典的 WAR 文件。

您應(yīng)該會(huì)看到類似于以下列表的內(nèi)容（還有其他內(nèi)容，例如查詢）：

在與 Neo4j 連接之前...
	格雷格的隊(duì)友 => []
	羅伊的隊(duì)友 => []
	克雷格的隊(duì)友 => []

按姓名查找每個(gè)人...
	格雷格的隊(duì)友 => [羅伊，克雷格]
	羅伊的隊(duì)友 => [格雷格，克雷格]
	克雷格的隊(duì)友 => [羅伊，格雷格]

您可以從輸出中看到（最初）沒有人通過任何關(guān)系連接。然后，在您添加人員后，他們被捆綁在一起。最后，您可以看到根據(jù)隊(duì)友查找人員的便捷查詢。