Spring Boot整合neo4j

Neo4jRepository已经经过多层封装，包含了实现了crud基本功能外，再集成了分页功能，之后提炼了常用查询的方法，提高了代码复用性。

4、创建Neo4jConfig配置

package io.fredia.femicro.graph.config;
​
import org.springframework.context.annotation.Configuration;
import org.springframework.data.neo4j.repository.config.EnableNeo4jRepositories;
import org.springframework.transaction.annotation.EnableTransactionManagement;
​
@Configuration
@EnableNeo4jRepositories(basePackages = "com.example.demo.repository")
@EnableTransactionManagement // 激活隐式事务
public class Neo4jConfig {
}

注解解析：@Configuration： springboot声明配置类，一般为单例模式@EnableNeo4jRepositories： Neo4j扫描Repositories所在包，可以理解为mybatis扫描mapper包@EnableTransactionManagement： Neo4j完整的支持ACID，所以此处开启事务功能。

5、编写Service类

@Service
public class DeptService {
​
    @Autowired
    private DeptRepository deptRepository;
​
    public Iterable saveAll(List depts) {
        return deptRepository.saveAll(depts);
    }
​
    public void deleteById(Long id) {
        deptRepository.deleteById(id);
    }
​
    public void deleteAll() {
        deptRepository.deleteAll();
    }
​
    public List findByTitle(String title) {
        return deptRepository.findByTitle(title);
    }
}

6、编写Controller类

@RestController
public class TestController {
​
    @Autowired
    private DeptService deptService;
​
    @Autowired
    private RelationShipService relationShipService;
​
    /**
     * CEO
     *    -设计部
     *        - 设计1组
     *        - 设计2组
     *    -技术部
     *        - 前端技术部
     *        - 后端技术部
     *        - 测试技术部
     */
    @GetMapping("/create")
    public void create(){
        Dept CEO = Dept.builder().deptName("CEO").build();
        Dept dept1 = Dept.builder().deptName("设计部").build();
        Dept dept11 = Dept.builder().deptName("设计1组").build();
        Dept dept12 = Dept.builder().deptName("设计2组").build();
​
        Dept dept2 = Dept.builder().deptName("技术部").build();
        Dept dept21 = Dept.builder().deptName("前端技术部").build();
        Dept dept22 = Dept.builder().deptName("后端技术部").build();
        Dept dept23 = Dept.builder().deptName("测试技术部").build();
        List depts = new ArrayList(Arrays.asList(CEO,dept1,dept11,dept12,dept2,dept21,dept22,dept23));
        deptService.saveAll(depts);
​
        RelationShip relationShip1 = RelationShip.builder().parent(CEO).child(dept1).build();
        RelationShip relationShip2 = RelationShip.builder().parent(CEO).child(dept2).build();
        RelationShip relationShip3 = RelationShip.builder().parent(dept1).child(dept11).build();
        RelationShip relationShip4 = RelationShip.builder().parent(dept1).child(dept12).build();
        RelationShip relationShip5 = RelationShip.builder().parent(dept2).child(dept21).build();
        RelationShip relationShip6 = RelationShip.builder().parent(dept2).child(dept22).build();
        RelationShip relationShip7 = RelationShip.builder().parent(dept2).child(dept23).build();
        List relationShips = new ArrayList(Arrays.asList(relationShip1,relationShip2,relationShip3,relationShip4,relationShip5
                ,relationShip6,relationShip7));
        relationShipService.saveAll(relationShips);
    }
​
    @GetMapping("getById")
    public RelationShip getById(Long id){
        Optional byId = relationShipService.findById(id);
        return byId.orElse(null);
    }
​
    @GetMapping("deleteRelationShip")
    public void deleteRelationShip(Long id){
        relationShipService.deleteById(id);
    }
​
    @GetMapping("deleteDept")
    public void deleteDept(Long id){
        deptService.deleteById(id);
    }
​
    @GetMapping("deleteAll")
    public void deleteAll(){
        deptService.deleteAll();
        relationShipService.deleteAll();
    }
    @GetMapping("getByTitle")
    public List getByTitle(@RequestParam("title") String title){
        return deptService.findByTitle(title);
    }
}

测试结果

启动项目 访问本地地址：实现新增功能

http://localhost:8088/create

登录本机的Neo4j ：localhost：7474

查看Neo4j 数据库内容：

访问本地地址：通过Cypher语句实现查询功能

http://localhost:8088/getByTitle?title=技术

控制台打印日志：

查看Neo4j 数据库内容：