SpringBoot整合neo4j使用详解

    <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>

server.port=8088
spring.data.neo4j.uri= bolt://IP:7687
spring.data.neo4j.username=neo4j
spring.data.neo4j.password=neo4j

@Data
@Builder
@NodeEntity("person")
public class Person implements Serializable {
    @Id
    @GeneratedValue
    private Long id;
    @Property("name")
    private String name;
}

@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;
    }
}

public interface PersonRepository extends Neo4jRepository<Person,Long> {
    /**
     * 查询某个节点的所有子节点
     * @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);
    /**
     * 查询当前节点的父节点
     * @param name
     * @return
     */
    @Query("Match (p:person) -[*]->(s:person {name:{0}}) return p")
    List<Person> findParentList(String name);
    List<Person> findByName(String name);
}

public interface PersonRelationRepository  extends Neo4jRepository<PersonRelation,Long> {
}

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 数据保存成功");
        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
        ));
        // 保存关系数据
        personRelationRepository.saveAll(personRelationList);
        System.out.println("person 关系数据保存成功");
    }
}

@Test
    public void testDelete(){
        // 删除所有person节点
        personRepository.deleteAll();
        // 删除所有personRelation关系数据
        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());
        }
    }