Neo4j

Neo4j — це графова база даних NoSQL з відкритим вихідним кодом, яка використовує повнофункціональну модель даних вузлів, пов'язаних повноправними відносинами, що краще підходить для пов'язаних великих даних, ніж традиційні підходи з використанням РСУБД. Spring Boot передбачає кілька допоміжних засобів для роботи з Neo4j, включно зі "стартером" spring-boot-starter-data-neo4j.

Підключення до бази даних Neo4j

Щоб отримати доступ до сервера Neo4j, можна впровадити автоконфігурований org.neo4j.driver.Driver. За замовчуванням екземпляр намагатиметься підключитися до сервера Neo4j за адресою localhost:7687, використовуючи протокол Bolt. У наступному прикладі показано, як впровадити Driver для Neo4j, який дасть доступ, окрім іншого, до Session:

import org.neo4j.driver.Driver; import org.neo4j.driver.Session; import org.neo4j.driver.Values; import org.springframework.stereotype.Component; @Component public class MyBean { private final Driver driver; public MyBean(Driver driver) { this.driver = driver; }  // ...  public String someMethod(String message) { try (Session session = this.driver.session()) { return session.writeTransaction((transaction) -> transaction .run("CREATE (a:Greeting) SET a.message = $message RETURN a.message + ', від node ' + id(a)", Values.parameters("message", message)) .single().get(0).asString()); } } } 

import org.neo4j.driver.Driver import org.neo4j.driver.Transaction import org.neo4j.driver.Values import org.springframework.stereotype.Component @Component class MyBean(private val driver: Driver) {  // ...  fun someMethod(message: String?): String { driver.session().use { session -> return@someMethod session.writeTransaction { transaction: Transaction -> transaction.run( "CREATE (a:Greeting) SET a.message = \$message RETURN a.message + ', від node ' + id(a)", Values.parameters("message", message) ).single()[0].asString() } } } } 

Можна додати різні аспекти драйвера до конфігурації за допомогою властивостей spring.neo4j.*. У наступному прикладі показано, як налаштувати URI-ідентифікатор і облікові дані:

spring.neo4j.uri=bolt://my-server:7687
spring.neo4j.authentication.username=neo4j
spring.neo4j.authentication.password=secret

spring:
  neo4j:
    uri: "bolt://my-server:7687"
    authentication:
      username: "neo4j"
      password: "secret"

Автоконфігурований Driver створюється за допомогою ConfigBuilder. Для більш тонкого налаштування конфігурації оголоси один або кілька бінів ConfigBuilderCustomizer. Кожен з них буде викликатись по порядку через ConfigBuilder, який використовується для створення Driver.

Репозиторії Spring Data Neo4j

Spring Data містить засоби підтримки репозиторіїв для Neo4j.

Spring Data Neo4j має спільну з Spring Data JPA інфраструктуру, як і багато інших модулів Spring Data. Можна взяти приклад для JPA з попереднього розділу та визначити City як @Node для Spring Data Neo4j, а не @Entity для JPA, при цьому абстракція сховища працюватиме так само, як показано в наступному прикладі:

import java.util.Optional; import org.springframework.data.neo4j.repository.Neo4jRepository; public interface CityRepository extends Neo4jRepository<City, Long> { Optional<City> findOneByNameAndState(String name, String state); } 

import org.springframework.data.neo4j.repository.Neo4jRepository import java.util.Optional interface CityRepository : Neo4jRepository<City?, Long?> { fun findOneByNameAndState(name: String?, state: String?): Optional<City?>? } 

"Стартер" spring-boot-starter-data-neo4j активує підтримку репозиторіїв, а також управління транзакціями. Spring Boot підтримує як класичні, так і реактивні репозиторії Neo4j через біни Neo4jTemplate або ReactiveNeo4jTemplate. Якщо Project Reactor доступний у classpath, реактивний стиль також автоматично конфігурується.

Можна налаштувати розташування, в яких буде здійснюватися пошук репозиторіїв та сутностей, використовуючи анотацію @EnableNeo4jRepositories та @EntityScan відповідно на біні, позначеному анотацією @Configuration.

import org.neo4j.driver.Driver; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.neo4j.core.ReactiveDatabaseSelectionProvider; import org.springframework.data.neo4j.core.transaction.ReactiveNeo4jTransactionManager; @Configuration(proxyBeanMethods = false) public class MyNeo4jConfiguration { @Bean public ReactiveNeo4jTransactionManager reactiveTransactionManager(Driver driver, ReactiveDatabaseSelectionProvider databaseNameProvider) { return new ReactiveNeo4jTransactionManager(driver, databaseNameProvider); } } 

import org.neo4j.driver.Driver import org.springframework.context.annotation.Bean import org.springframework.context.annotation.Configuration import org.springframework.data.neo4j.core.ReactiveDatabaseSelectionProvider import org.springframework.data.neo4j.core.transaction.ReactiveNeo4jTransactionManager @Configuration(proxyBeanMethods = false) class MyNeo4jConfiguration { @Bean fun reactiveTransactionManager(driver: Driver, databaseNameProvider: ReactiveDatabaseSelectionProvider): ReactiveNeo4jTransactionManager { return ReactiveNeo4jTransactionManager(driver, databaseNameProvider) } }