Java 操作 Neo4J 就是这么简单！

前几天阿粉给大家扩展了关于 Neo4J 图谱数据库的内容，今天阿粉教给大家如何使用 Java 来操作 Neo4j 数据库。

使用 Java 操作 Neo4J

首先我们先使用原生的这种方式，导入 jar 包，然后：

public  class TestController {       public   static  void main(String[] args) {          Driver driver = GraphDatabase.driver( "bolt://localhost:7687" , AuthTokens.basic( "neo4j" ,  "Yinlidong1995." ));          Session session = driver.session();          session.run( "CREATE (n:Part {name: {name},title: {title}})" ,                  parameters(  "name" ,  "Arthur001" ,  "title" ,  "King001"  ));          StatementResult result = session.run(  "MATCH (a:Part) WHERE a.name = {name} "  +                           "RETURN a.name AS name, a.title AS title" ,                  parameters(  "name" ,  "Arthur001" ));          while (result.hasNext()) {              Record record = result. next ();              System. out .println( record.get(  "title"  ).asString() +  ""  + record.get(  "name"  ).asString() );          }          session. close ();          driver. close ();      }  } 

这是一种比较古老的方式，来实现的，而且还是需要些 CQL 语句来进行实现。但是胜在非常好理解，这个时候，我们需要再来看看图，看看在 Neo4J 中他是怎么展现的。

通过这个，我们至少证明我们成功连上了，并且创建也成功了。

这时候有细心的读者就会问，为啥我之前在 GraphDatabase.driver 的地方，连接的是

bolt://localhost:7687.

这是因为，你启动的Neo4J 是7474，也就是说，Neo4J 服务里面可不是这个来连接，

SpringBoot 整合 Neo4j

1.创建SpringBoot项目

常规的创建SpringBoot项目，

创建完成之后，习惯性的要改一下 SpringBoot 的版本号，最好别用最新的，因为阿粉亲身经历，使用最新版的，出现了错误你都不知道怎么出现的，就是这么神奇，你永远都发现不了的bug。

我们把版本号改成2.1.0，这样的话，我们在 pom 文件中加入依赖 jar

<dependency>   <groupId>org.springframework.boot</groupId>   <artifactId>spring-boot-starter-data-neo4j</artifactId>  </dependency>  <dependency>   <groupId>org.projectlombok</groupId>   <artifactId>lombok</artifactId>   <version>1.16.10</version>  </dependency> 

2.增加配置

spring:    data:      neo4j:        url: bolt://localhost:7687        username: neo4j         password : Yinlidong1995.    main:      allow-bean-definition-overriding:  true

3.Neo4JConfig

package com.example.neo4j.config;    import org.neo4j.driver.v1.AuthTokens;  import org.neo4j.driver.v1.Driver;  import org.neo4j.driver.v1.GraphDatabase;  import org.neo4j.driver.v1.Session;  import org.springframework.beans.factory.annotation.Value;  import org.springframework.context.annotation.Bean;  import org.springframework.context.annotation.Configuration;  import org.springframework.data.neo4j.repository.config.EnableNeo4jRepositories;  import org.springframework. transaction .annotation.EnableTransactionManagement;    @Configuration  @EnableNeo4jRepositories( "com.example.neo4j.repository" )  @EnableTransactionManagement  public  class Neo4jConfig {      @Value( "${spring.data.neo4j.url}" )      private String url;      @Value( "${spring.data.neo4j.username}" )      private String userName;      @Value( "${spring.data.neo4j.password}" )      private String  password ;        @Bean( name  =  "session" )       public  Session neo4jSession() {          Driver driver = GraphDatabase.driver(url, AuthTokens.basic(userName,  password ));           return  driver.session();      }  } 

4.编写实体类

package com.example.neo4j.entry;    import org.neo4j.ogm.annotation.*;    import java.util.HashSet;  import java.util. Set ;  @NodeEntity( "group" )  @Data  public  class GroupNode {      @Id      @GeneratedValue      private Long id;        /**       * 班级名称       */      @Property( name  =  "name" )      private String  name ;        /**       * 编号       */      private String num;        @Relationship(type =  "RelationEdge" )      private  Set <RelationEdge> sets = new HashSet<>();         public  void addRelation(StudentNode sonNode, String  name ) {          RelationEdge relationNode = new RelationEdge(this, sonNode,  name );          sets. add (relationNode);          sonNode.getSets(). add (relationNode);      }  } 

学生实体类：

package com.example.neo4j.entry;  import org.neo4j.ogm.annotation.GeneratedValue;  import org.neo4j.ogm.annotation.Id;  import org.neo4j.ogm.annotation.NodeEntity;  import org.neo4j.ogm.annotation.Relationship;    import java.util.HashSet;  import java.util. Set ;    /**   * 有点类似于Mysql中的 table  映射的对象类，mysql中叫做ORM，neo4j中叫做OGM [object graph mapping]   */  @NodeEntity( "student" )  @Data  public  class StudentNode {      @Id      @GeneratedValue      private Long id;        /**       * 学生名称       */      private String  name ;        /**       * 性别       */      private String sex;        @Relationship(type =  "RelationEdge" , direction =  "INCOMING" )      private  Set <RelationEdge> sets = new HashSet<>();       } 

package com.example.neo4j.entry;  import lombok.Data;  import org.neo4j.ogm.annotation.*;    @RelationshipEntity(type =  "RelationEdge" )  @Data  public  class RelationEdge {      @Id      @GeneratedValue      private Long id;        // 关系名      private String  name ;        @StartNode      private GroupNode groupNode;        @EndNode      private StudentNode studentNode;         public  RelationEdge(GroupNode parentNode, StudentNode sonNode, String  name ) {          this.groupNode = parentNode;          this.studentNode = sonNode;          this. name  =  name ;      }  } 

5.Repository接口

对应的学生接口：

package com.example.neo4j.repository;    import com.example.neo4j.entry.StudentNode;  import org.springframework.data.neo4j.repository.Neo4jRepository;    public  interface StudentRepository extends Neo4jRepository<StudentNode,Long> {  } 

对应的班级接口

package com.example.neo4j.repository;    import com.example.neo4j.entry.GroupNode;  import org.springframework.data.neo4j.repository.Neo4jRepository;    public  interface GroupRepository extends Neo4jRepository<GroupNode,Long> {  } 

最后完成编写我们的 Controller

package com.example.neo4j.controller;    import com.example.neo4j.entry.*;  import com.example.neo4j.repository.GroupRepository;  import com.example.neo4j.repository.StudentRepository;  import lombok.extern.slf4j.Slf4j;  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( "/node" )  @Slf4j  public  class GroupController {        @Autowired      private StudentRepository studentRepository;      @Autowired      private GroupRepository groupRepository;        @GetMapping(value =  "/create" )       public  void createNodeRelation() {          StudentNode studentNode1 = new StudentNode();          studentNode1.setName( "Alen" );          studentNode1.setSex( "男" );          StudentNode studentNode2 = new StudentNode();          studentNode2.setName( "Kai" );          studentNode2.setSex( "女" );          studentRepository.save(studentNode1);          studentRepository.save(studentNode2);            GroupNode groupNode = new GroupNode();          groupNode.setName( "火箭班" );          groupNode.setNum( "298" );          // 增加关系          groupNode.addRelation(studentNode1,  "includes" );          groupNode.addRelation(studentNode2,  "includes" );          groupRepository.save(groupNode);      }  } 

启动之后，访问http://localhost:8080/node/create

我们再去图谱数据库看看。

怎么样，使用Java 操作是不是也是非常简单的呢?这样的图谱数据库你会选择么?

原文链接：https://mp.weixin.qq测试数据/s/OnZ21ecRd5OUdq-wo37LwQ

查看更多关于Java 操作 Neo4J 就是这么简单！的详细内容...