前几天阿粉给大家扩展了关于 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 操作是不是也是非常简单的呢？这样的图谱数据库你会选择么？