开发者社区> 一只会飞的鱼儿> 正文

springboot + neo4j 图形数据库 整合(本地)

简介: springboot + neo4j 图形数据库 整合(本地): 一、Windows环境中安装neo4j 1、安装jdk,配置jdk环境变量(此处不讲解jdk的安装配置教程) 2、下载neo4,neo4j社区下载 [下载地址](https://neo4j.
+关注继续查看

springboot + neo4j 图形数据库 整合(本地):
一、Windows环境中安装neo4j

1、安装jdk,配置jdk环境变量(此处不讲解jdk的安装配置教程)

2、下载neo4,neo4j社区下载 [下载地址](https://neo4j.com/download-center/)
  3.3.5版本
  链接:https://pan.baidu.com/s/1dfDfGYN1WEvj91F2MrYdxQ 
  提取码:1jqb 
  
  解压到指定目录

3、配置neo4j环境变量
  主目录设置为变量:

image

  编辑path变量,在path变量值的最后输入:
  %NEO4J_HOME%\bin

  (Neo4j支持三种网络协议(Protocol),分别是Bolt,HTTP和HTTPS,默认的连接器配置有三种,为了使用这三个端口,需要在        
  Windows防火墙中创建Inbound Rules,允许通过端口7687,7474和7473访问本机。)

4、启动neo4j
  进入neo4j的安装目录,启用DOS命令行窗口,输入neo4j.bat console命令:

image

   访问:http://localhost:7474/

image

   默认的host是bolt://localhost:7687,默认的用户是neo4j,默认的密码是:neo4j,第一次成功connect到Neo4j服务器之后,需要重置密码。

以上本地安装配置结束!

二、创建springboot项目 整合neo4j

使用gradle搭建,build.gradle配置如下:
1、springboot 相关jar包:
ext {
    springBootVersion = '2.0.2.RELEASE'
}
repositories {
    maven { url 'http://maven.aliyun.com/nexus/content/groups/public/' }
    jcenter()
}
dependencies {
    classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
}
}

apply plugin: 'java'
apply plugin: 'idea'
apply plugin: 'eclipse'
apply plugin: 'org.springframework.boot'
apply plugin: 'io.spring.dependency-management'

compileJava.options.encoding = 'UTF-8'

group = 'com.hbkj'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = 1.8
archivesBaseName = "lobby-match"


repositories {
maven { url 'http://maven.aliyun.com/nexus/content/groups/public/' }
jcenter()
}

dependencies {
compile 'org.springframework.boot:spring-boot-starter-web'
testCompile 'org.springframework.boot:spring-boot-starter-test'
compile group: 'io.netty', name: 'netty-all', version: '4.1.15.Final'
testCompile group: 'junit', name: 'junit', version: '4.12'
}

2、neo4j 相关jar包

  compile group: 'org.springframework.boot', name: 'spring-boot-starter-data-neo4j', version: '2.0.5.RELEASE'
  compile group: 'org.neo4j', name: 'neo4j-ogm-embedded-driver', version: '2.0.5'
  compile group: 'org.neo4j', name: 'neo4j-ogm-http-driver', version: '2.0.5'
  
  //lombok
  compileOnly group: 'org.projectlombok', name: 'lombok', version: '1.18.0'

3、配置application.yml

server:
  port: 8888

spring:
  data:
neo4j:
  uri: bolt://localhost:7687
  username: neo4j
  password: 123456

4、创建实体类


import lombok.Data;
import org.neo4j.ogm.annotation.GeneratedValue;
import org.neo4j.ogm.annotation.Id;
import org.neo4j.ogm.annotation.Index;
import org.neo4j.ogm.annotation.NodeEntity;

@Data
@NodeEntity
public class Student {
  @Id
  @GeneratedValue
  private Long id;

  @Index
  private long userId;
  private String name;
  private long age;

}

5、创建节点处理类 Cypher(注解方式编写sql)


import com.luzz.domain.bean.Student;
import org.springframework.data.neo4j.annotation.Query;
import org.springframework.data.neo4j.repository.Neo4jRepository;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;

import java.util.List;

/**
 * 节点处理类
 */
@Repository
public interface StudentRepository extends Neo4jRepository<Student, Long> {
  /**
   * 创建节点
   * @param userId
   * @param name
   * @param age
   */
  @Query("create (:Student {userId:{userId},name:{name},age:{age}})")
  void createNode(@Param("userId") long userId, @Param("name") String name, @Param("age") long age);

  /**
   * 查询所有节点
   * @return
   */
  @Query("match (n:Student) return n;")
  List<Student> getAllStudentNode();

  /**
   * 查询所有节点的所有关系
   * @return
   */
  @Query("match (a:Student)-[*1..]->(b:Student)return a,b;")
  List<Student> getAllStudentNodeRelation();

  /**
   * 创建2节点的关系 上下关系
   * @param superUserId
   * @param lowerUserId
   * @param time
   * @return
   */
  @Query("match (a:Student),(b:ResellerRelation) where a.userId = {superUserId} and b.userId = {lowerUserId} create (a) - [r:RESELLER_ACTED_IN{since:{time}}] -> (b) return a,b;")
  List<Student> addStudentNodeReseller(@Param("superUserId") long superUserId, @Param("lowerUserId") long lowerUserId, @Param("time") long time);
  /**
   * 根据id查询单个节点
   * @param userId
   * @return
   */
  @Query("match (n:Student) where n.userId ={userId} return n")
  Student findByUserId(@Param("userId") long userId);

  /**
   * 根据userId查询节点直属 2级关系
   * @param userId
   * @return
   */
  @Query("match (a:Student)-[*1..1]->(b:Student) where a.userId = {userId} return a,b")
  List<Student> findAllDirectlyByUserId(@Param("userId") long userId);

  /**
   * 根据userId 查询该节点的所有关系
   * @param userId
   * @return
   */
  @Query("match (a:Student)-[*1..]->(b:Student) where a.userId = {userId} return a,b")
  List<Student> findAllStudentByUserId(@Param("userId") long userId);

  /**
   * 根据userId 修改节点 属性
   * @param userId
   * @param name
   * @return
   */
  @Query("match (n:Student) where n.userId = {userId} set n.name ={name} return n")
  Student updateStudentNode(@Param("userId") long userId, @Param("name") long name);


  /**
   * 删除节点关系
   * @param superUserId
   * @param lowerUserId
   */
  @Query("match (n1:Student),(n2:Student) where n1.userId={superUserId} AND n2.userId={lowerUserId} optional match (n1)-[r]-(n2) delete r;")
  void deleteStudentNodeRelation(@Param("superUserId") long superUserId, @Param("lowerUserId") long lowerUserId);
}

可继承Neo4jRepository,可不继承,Neo4jRepository方法如下:

可使用save方法来根据对象创建节点
image

6、创建业务层StudentService StudentServiceImpl
StudentService.java


import com.luzz.domain.bean.Student;

import java.util.List;

public interface StudentService {
  void createNode(Student student);
  /**
   * 查询所有节点
   * @return
   */
  List<Student> getAllStudentNode();

  /**
   * 查询所有节点的所有关系
   * @return
   */
  List<Student> getAllStudentNodeRelation();

  /**
   * 创建2节点的关系 上下关系
   * @param superUserId
   * @param lowerUserId
   * @param time
   * @return
   */
  List<Student> addStudentNodeReseller(long superUserId, long lowerUserId, long time);
  /**
   * 根据id查询单个节点
   * @param userId
   * @return
   */
  Student findByUserId(long userId);

  /**
   * 根据userId查询节点直属 2级关系
   * @param userId
   * @return
   */
  List<Student> findAllDirectlyByUserId(long userId);

  /**
   * 根据userId 查询该节点的所有关系
   * @param userId
   * @return
   */
  List<Student> findAllStudentByUserId(long userId);

  /**
   * 根据userId 修改节点 属性
   * @param userId
   * @param name
   * @return
   */
  Student updateStudentNode(long userId, long name);


  /**
   * 删除节点关系
   * @param superUserId
   * @param lowerUserId
   */
  void deleteStudentNodeRelation(long superUserId, long lowerUserId);
}

StudentServiceImpl.java


import com.luzz.domain.bean.Student;
import com.luzz.domain.service.StudentRepository;
import com.luzz.domain.service.StudentService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;
@Service
public class StudentServiceImpl implements StudentService {
    @Autowired
    StudentRepository repository;

    @Override
    public void createNode(Student student) {
        repository.save(student);
    }

    @Override
    public List<Student> getAllStudentNode() {
        return null;
    }

    @Override
    public List<Student> getAllStudentNodeRelation() {
        return null;
    }

    @Override
    public List<Student> addStudentNodeReseller(long superUserId, long lowerUserId, long time) {
        return null;
    }

    @Override
    public Student findByUserId(long userId) {
        return repository.findByUserId(userId);
    }

    @Override
    public List<Student> findAllDirectlyByUserId(long userId) {
        return null;
    }

    @Override
    public List<Student> findAllStudentByUserId(long userId) {
        return null;
    }

    @Override
    public Student updateStudentNode(long userId, long name) {
        return null;
    }

    @Override
    public void deleteStudentNodeRelation(long superUserId, long lowerUserId) {

    }
}

7、测试Controller


import com.luzz.domain.bean.Student;
import com.luzz.domain.service.StudentService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/studentRelation")
public class TestController {
  @Autowired
  StudentService service;

  @GetMapping("/test")
  public String test() {
      //创建节点
      Student student = new Student();
      student.setUserId(100005);
      student.setName("李七");
      student.setAge(23);
      service.createNode(student);

      Student st = service.findByUserId(100005);
      System.out.println("查询结果:" + st);
      return st.toString();
  }
}

8、执行结果
image
image
image

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,阿里云优惠总结大概有三种登录方式: 登录到ECS云服务器控制台 在ECS云服务器控制台用户可以更改密码、更换系.
29209 0
Android保存多张图片到本地
目录介绍 01.实际开发保存图片遇到的问题 02.直接用http请求图片并保存本地 03.用glide下载图片保存本地 04.如何实现连续保存多张图片 05.关于其他介绍 好消息 博客笔记大汇总【16年3月到至今】,包括Java基础及深入知识点,Android技术博客,Python学习笔记等.
1070 0
SpringBoot-11-之从本地到线上
一、本地:[注]现在对于已经有了服务器和域名(已备案)的你,可以继续阅读 1.打包项目为jar 打包项目 2.备份数据库 备份数据库:mysqldump -uroot -p密码 toly>toly.
842 0
WinForm 加载本地图片
方式一: /// &lt;summary&gt; /// 从程序集中加载图片 /// &lt;/summary&gt; /// &lt;param name="imagePathName"&gt;图片路径(该图片必须是嵌入的资源)&lt;/param&gt; /// &lt;returns&gt;Bitmap 格式图片&
1140 0
百度地图JavaScript API本地搜索的结果面板
body, html{width: 100%;height: 100%; margin:0;font-family:"微软雅黑";} #l-map{height:300px;width:100%;} #r-result{w...
1122 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
20725 0
Neo4j数据库简介
作为世界先进的图数据库,Neo4j成为了时下许多互联网公司的首选。Neo4j是基于java开发的开源图数据库,也是一种NoSQL数据库。Neo4j在保证对数据关系的良好刻画的同时,还支持传统关系型数据的ACID特性,并且在存储效率,集群支持以及失效备援等等方面都有着不错的表现。近来因为实验室的项目的关系,对Neo4j有了一定的了解。同时,我也对其设计思想和架构都产生了很大的兴趣,所以写
2129 0
+关注
一只会飞的鱼儿
生活应该是体现在自己对技术的追求和对源码的执着之上!
4
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载