SpringBoot整合neo4j使用詳解
一、Spring Data Neo4j
和很多其他的中間件類似,都提供了類似jpa的方式與springboot進行集成,比如大家熟悉的springdata-jpa,操作es的jpa,操作mongo的jpa等,而 Neo4j也提供了與springboot整合的jpa方式,即Spring Data Neo4j,接下來就來演示springboot中如何集成和使用Spring Data Neo4j。
二、環(huán)境準備
提前搭建neo4j服務;
springboot版本,2.3.5;
提前準備一個springboot的工程;
三、整合步驟
按照下面的步驟進行操作
3.1 導入必須的maven依賴
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.8.15</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>${boot-web.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-neo4j</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>${lomok.version}</version>
</dependency>
</dependencies>3.2 添加配置文件
更多的配置參考官網,下面給出的是基本的連續(xù)配置。
server.port=8088 spring.data.neo4j.uri= bolt://IP:7687 spring.data.neo4j.username=neo4j spring.data.neo4j.password=neo4j
3.3 自定義節(jié)點與實體類映射
比如在本次演示案例中,有兩個節(jié)點操作對象,分別為Person和PersonRelation,兩者之間具有一定的關系,然后通過程序對其完成相關的crud操作。
自定義Person類
@Data
@Builder
@NodeEntity("person")
public class Person implements Serializable {
@Id
@GeneratedValue
private Long id;
@Property("name")
private String name;
}PersonRelation類
@Data
@NoArgsConstructor
@RelationshipEntity(type = "徒弟")
public class PersonRelation implements Serializable {
@Id
@GeneratedValue
private Long id;
@StartNode
private Person parent;
@EndNode
private Person child;
@Property
private String relation;
public PersonRelation(Person parent, Person child, String relation) {
this.parent = parent;
this.child = child;
this.relation = relation;
}
}3.4 自定義jpa
分別自定義兩個操作節(jié)點對象的Repository,繼承Neo4jRepository接口,使用jpa開發(fā)過的同學對此應該不陌生。
PersonRepository
public interface PersonRepository extends Neo4jRepository<Person,Long> {
/**
* 查詢某個節(jié)點的所有子節(jié)點
* @param pId
* @return
*/
@Query("Match (p:person) -[*]->(s:person) where id(p)={0} return s")
List<Person> findChildList(Long pId);
@Query("Match (p:person {name:{0}}) -[*]->(s:person) return s")
List<Person> findChildList(String name);
/**
* 查詢當前節(jié)點的父節(jié)點
* @param name
* @return
*/
@Query("Match (p:person) -[*]->(s:person {name:{0}}) return p")
List<Person> findParentList(String name);
List<Person> findByName(String name);
}PersonRelationRepository
public interface PersonRelationRepository extends Neo4jRepository<PersonRelation,Long> {
}四、整合測試
下面編寫單元測試對上面的代碼進行效果測試
4.1 保存Person以及關系數(shù)據
import com.congge.entity.Person;
import com.congge.entity.PersonRelation;
import com.congge.repository.PersonRelationRepository;
import com.congge.repository.PersonRepository;
import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
@SpringBootTest
@RunWith(SpringRunner.class)
public class PersonTest {
@Autowired
private PersonRepository personRepository;
@Autowired
private PersonRelationRepository personRelationRepository;
@Test
public void testSave() {
Person person = Person.builder().name("唐僧").build();
Person person2 = Person.builder().name("孫悟空").build();
Person person3 = Person.builder().name("豬八戒").build();
Person person4 = Person.builder().name("沙僧").build();
Person person5 = Person.builder().name("白龍馬").build();
List<Person> personList = new ArrayList<>(Arrays.asList(
person, person2, person3, person4, person5));
personRepository.saveAll(personList);
System.out.println("person 數(shù)據保存成功");
PersonRelation personRelation = new PersonRelation(person, person2, "徒弟");
PersonRelation personRelation2 = new PersonRelation(person, person3, "徒弟");
PersonRelation personRelation3 = new PersonRelation(person, person4, "徒弟");
PersonRelation personRelation4 = new PersonRelation(person, person5, "徒弟");
List<PersonRelation> personRelationList = new ArrayList<>(Arrays.asList(
personRelation, personRelation2, personRelation3,
personRelation4
));
// 保存關系數(shù)據
personRelationRepository.saveAll(personRelationList);
System.out.println("person 關系數(shù)據保存成功");
}
}運行上面的代碼

執(zhí)行成功后,可以去web界面上檢查剛剛保存的數(shù)據

4.2 查詢數(shù)據
@Test
public void testDelete(){
// 刪除所有person節(jié)點
personRepository.deleteAll();
// 刪除所有personRelation關系數(shù)據
personRelationRepository.deleteAll();
//根據id刪除
personRepository.deleteById(0l);
}
/**
* 查詢所有
*/
@Test
public void testFindAll() {
Iterable<Person> allPerson = personRepository.findAll();
allPerson.forEach(item -> {
System.out.println(item.getId());
System.out.println(item.getName());
System.out.println();
});
}
/**
* 根據id查詢
*/
@Test
public void testFindById() {
Optional<Person> personOptional = personRepository.findById(0l);
if (personOptional.isPresent()) {
System.out.println(personOptional.get().getName());
}
}
/**
* 分頁查詢
*/
@Test
public void testPage() {
//設置分頁、排序條件,page從0開始
PageRequest pageRequest = PageRequest.of(1, 2, Sort.by(Sort.Order.desc("id")));
Page<Person> page = personRepository.findAll(pageRequest);
page.getContent().forEach(person -> {
System.out.println(person.getId() + ":" + person.getName());
});
}
@Test
public void testFindByName() {
List<Person> personList = personRepository.findByName("唐僧");
for(Person p : personList){
System.out.println(p.getName());
}
}如果jpa中常用的方法還不能滿足要求的話,可以嘗試自定義編寫語句進行實現(xiàn)。
4.3 JPA自定義方法規(guī)則
使用jpa中的規(guī)則,進行自定義查詢,下面總結了一些常用的jpa使用規(guī)則,可以利用這些API完成一些更高級的業(yè)務場景開發(fā)
| Keyword | Sample | Cypher snippet |
|---|---|---|
| After | findByLaunchDateAfter(Date date) | n.launchDate > date |
| Before | findByLaunchDateBefore(Date date) | n.launchDate < date |
| Containing (String) | findByNameContaining(String namePart) | n.name CONTAINS namePart |
| Containing (Collection) | findByEmailAddressesContains(Collection addresses) findByEmailAddressesContains(String address) | ANY(collectionFields IN [addresses] WHERE collectionFields in n.emailAddresses) ANY(collectionFields IN address WHERE collectionFields in n.emailAddresses) |
| In | findByNameIn(Iterable names) | n.name IN names |
| Between | findByScoreBetween(double min, double max) findByScoreBetween(Range range) | n.score >= min AND n.score <= max Depending on the Range definition n.score >= min AND n.score <= max or n.score > min AND n.score < max |
| StartingWith | findByNameStartingWith(String nameStart) | n.name STARTS WITH nameStart |
| EndingWith | findByNameEndingWith(String nameEnd) | n.name ENDS WITH nameEnd |
| Exists | findByNameExists() | EXISTS(n.name) |
| True | findByActivatedIsTrue() | n.activated = true |
| False | findByActivatedIsFalse() | NOT(n.activated = true) |
| Is | findByNameIs(String name) | n.name = name |
| NotNull | findByNameNotNull() | NOT(n.name IS NULL) |
| Null | findByNameNull() | n.name IS NULL |
| GreaterThan | findByScoreGreaterThan(double score) | n.score > score |
| GreaterThanEqual | findByScoreGreaterThanEqual(double score) | n.score >= score |
| LessThan | findByScoreLessThan(double score) | n.score < score |
| LessThanEqual | findByScoreLessThanEqual(double score) | n.score <= score |
| Like | findByNameLike(String name) | n.name =~ name |
| NotLike | findByNameNotLike(String name) | NOT(n.name =~ name) |
| Near | findByLocationNear(Distance distance, Point point) | distance( point(n),point({latitude:lat, longitude:lon}) ) < distance |
| Regex | findByNameRegex(String regex) | n.name =~ regex |
| And | findByNameAndDescription(String name, String description) | n.name = name AND n.description = description |
| Or | findByNameOrDescription(String name, String description) | n.name = name OR n.description = description (Cannot be used to OR nested properties) |
五、寫在文末
本文詳細總結了如何在springboot中集成與使用neo4j,并通過代碼演示了如何使用,更多的用法有興趣的同學還可以深入研究。
以上就是SpringBoot整合neo4j使用詳解的詳細內容,更多關于SpringBoot整合neo4j的資料請關注腳本之家其它相關文章!
相關文章
@RequiredArgsConstructor如何實現(xiàn)構造器注入
這篇文章主要介紹了@RequiredArgsConstructor如何實現(xiàn)構造器注入問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-09-09

