You can not select more than 25 topics Topics must start with a chinese character,a letter or number, can include dashes ('-') and can be up to 35 characters long.

README.md 8.6 kB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319
  1. # spring-boot-demo-neo4j
  2. > 此 demo 主要演示了 Spring Boot 如何集成Neo4j操作图数据库,实现一个校园人物关系网。
  3. ## 注意
  4. 作者编写本demo时,Neo4j 版本为 `3.5.0`,使用 docker 运行,下面是所有步骤:
  5. 1. 下载镜像:`docker pull neo4j:3.5.0`
  6. 2. 运行容器:`docker run -d -p 7474:7474 -p 7687:7687 --name neo4j-3.5.0 neo4j:3.5.0`
  7. 3. 停止容器:`docker stop neo4j-3.5.0`
  8. 4. 启动容器:`docker start neo4j-3.5.0`
  9. 5. 浏览器 http://localhost:7474/ 访问 neo4j 管理后台,初始账号/密码 neo4j/neo4j,会要求修改初始化密码,我们修改为 neo4j/admin
  10. ## pom.xml
  11. ```xml
  12. <?xml version="1.0" encoding="UTF-8"?>
  13. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  14. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  15. <modelVersion>4.0.0</modelVersion>
  16. <artifactId>spring-boot-demo-neo4j</artifactId>
  17. <version>1.0.0-SNAPSHOT</version>
  18. <packaging>jar</packaging>
  19. <name>spring-boot-demo-neo4j</name>
  20. <description>Demo project for Spring Boot</description>
  21. <parent>
  22. <groupId>com.xkcoding</groupId>
  23. <artifactId>spring-boot-demo</artifactId>
  24. <version>1.0.0-SNAPSHOT</version>
  25. </parent>
  26. <properties>
  27. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  28. <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  29. <java.version>1.8</java.version>
  30. </properties>
  31. <dependencies>
  32. <dependency>
  33. <groupId>org.springframework.boot</groupId>
  34. <artifactId>spring-boot-starter-data-neo4j</artifactId>
  35. </dependency>
  36. <dependency>
  37. <groupId>org.springframework.boot</groupId>
  38. <artifactId>spring-boot-starter-web</artifactId>
  39. </dependency>
  40. <dependency>
  41. <groupId>org.springframework.boot</groupId>
  42. <artifactId>spring-boot-starter-test</artifactId>
  43. <scope>test</scope>
  44. </dependency>
  45. <dependency>
  46. <groupId>org.projectlombok</groupId>
  47. <artifactId>lombok</artifactId>
  48. <optional>true</optional>
  49. </dependency>
  50. <dependency>
  51. <groupId>cn.hutool</groupId>
  52. <artifactId>hutool-all</artifactId>
  53. </dependency>
  54. <dependency>
  55. <groupId>com.google.guava</groupId>
  56. <artifactId>guava</artifactId>
  57. </dependency>
  58. </dependencies>
  59. <build>
  60. <finalName>spring-boot-demo-neo4j</finalName>
  61. <plugins>
  62. <plugin>
  63. <groupId>org.springframework.boot</groupId>
  64. <artifactId>spring-boot-maven-plugin</artifactId>
  65. </plugin>
  66. </plugins>
  67. </build>
  68. </project>
  69. ```
  70. ## application.yml
  71. ```yaml
  72. spring:
  73. data:
  74. neo4j:
  75. uri: bolt://localhost
  76. username: neo4j
  77. password: admin
  78. open-in-view: false
  79. ```
  80. ## CustomIdStrategy.java
  81. ```java
  82. /**
  83. * <p>
  84. * 自定义主键策略
  85. * </p>
  86. *
  87. * @author yangkai.shen
  88. * @date Created in 2018-12-24 14:40
  89. */
  90. public class CustomIdStrategy implements IdStrategy {
  91. @Override
  92. public Object generateId(Object o) {
  93. return IdUtil.fastUUID();
  94. }
  95. }
  96. ```
  97. ## 部分Model代码
  98. ### Student.java
  99. ```java
  100. /**
  101. * <p>
  102. * 学生节点
  103. * </p>
  104. *
  105. * @author yangkai.shen
  106. * @date Created in 2018-12-24 14:38
  107. */
  108. @Data
  109. @NoArgsConstructor
  110. @RequiredArgsConstructor(staticName = "of")
  111. @AllArgsConstructor
  112. @Builder
  113. @NodeEntity
  114. public class Student {
  115. /**
  116. * 主键,自定义主键策略,使用UUID生成
  117. */
  118. @Id
  119. @GeneratedValue(strategy = CustomIdStrategy.class)
  120. private String id;
  121. /**
  122. * 学生姓名
  123. */
  124. @NonNull
  125. private String name;
  126. /**
  127. * 学生选的所有课程
  128. */
  129. @Relationship(NeoConsts.R_LESSON_OF_STUDENT)
  130. @NonNull
  131. private List<Lesson> lessons;
  132. /**
  133. * 学生所在班级
  134. */
  135. @Relationship(NeoConsts.R_STUDENT_OF_CLASS)
  136. @NonNull
  137. private Class clazz;
  138. }
  139. ```
  140. ## 部分Repository代码
  141. ### StudentRepository.java
  142. ```java
  143. /**
  144. * <p>
  145. * 学生节点Repository
  146. * </p>
  147. *
  148. * @author yangkai.shen
  149. * @date Created in 2018-12-24 15:05
  150. */
  151. public interface StudentRepository extends Neo4jRepository<Student, String> {
  152. /**
  153. * 根据名称查找学生
  154. *
  155. * @param name 姓名
  156. * @param depth 深度
  157. * @return 学生信息
  158. */
  159. Optional<Student> findByName(String name, @Depth int depth);
  160. /**
  161. * 根据班级查询班级人数
  162. *
  163. * @param className 班级名称
  164. * @return 班级人数
  165. */
  166. @Query("MATCH (s:Student)-[r:R_STUDENT_OF_CLASS]->(c:Class{name:{className}}) return count(s)")
  167. Long countByClassName(@Param("className") String className);
  168. /**
  169. * 查询满足 (学生)-[选课关系]-(课程)-[选课关系]-(学生) 关系的 同学
  170. *
  171. * @return 返回同学关系
  172. */
  173. @Query("match (s:Student)-[:R_LESSON_OF_STUDENT]->(l:Lesson)<-[:R_LESSON_OF_STUDENT]-(:Student) with l.name as lessonName,collect(distinct s) as students return lessonName,students")
  174. List<ClassmateInfoGroupByLesson> findByClassmateGroupByLesson();
  175. /**
  176. * 查询师生关系,(学生)-[班级学生关系]-(班级)-[班主任关系]-(教师)
  177. *
  178. * @return 返回师生关系
  179. */
  180. @Query("match (s:Student)-[:R_STUDENT_OF_CLASS]->(:Class)-[:R_BOSS_OF_CLASS]->(t:Teacher) with t.name as teacherName,collect(distinct s) as students return teacherName,students")
  181. List<TeacherStudent> findTeacherStudentByClass();
  182. /**
  183. * 查询师生关系,(学生)-[选课关系]-(课程)-[任教老师关系]-(教师)
  184. *
  185. * @return 返回师生关系
  186. */
  187. @Query("match ((s:Student)-[:R_LESSON_OF_STUDENT]->(:Lesson)-[:R_TEACHER_OF_LESSON]->(t:Teacher))with t.name as teacherName,collect(distinct s) as students return teacherName,students")
  188. List<TeacherStudent> findTeacherStudentByLesson();
  189. }
  190. ```
  191. ## Neo4jTest.java
  192. ```java
  193. /**
  194. * <p>
  195. * 测试Neo4j
  196. * </p>
  197. *
  198. * @author yangkai.shen
  199. * @date Created in 2018-12-24 15:17
  200. */
  201. @Slf4j
  202. public class Neo4jTest extends SpringBootDemoNeo4jApplicationTests {
  203. @Autowired
  204. private NeoService neoService;
  205. /**
  206. * 测试保存
  207. */
  208. @Test
  209. public void testSave() {
  210. neoService.initData();
  211. }
  212. /**
  213. * 测试删除
  214. */
  215. @Test
  216. public void testDelete() {
  217. neoService.delete();
  218. }
  219. /**
  220. * 测试查询 鸣人 学了哪些课程
  221. */
  222. @Test
  223. public void testFindLessonsByStudent() {
  224. // 深度为1,则课程的任教老师的属性为null
  225. // 深度为2,则会把课程的任教老师的属性赋值
  226. List<Lesson> lessons = neoService.findLessonsFromStudent("漩涡鸣人", 2);
  227. lessons.forEach(lesson -> log.info("【lesson】= {}", JSONUtil.toJsonStr(lesson)));
  228. }
  229. /**
  230. * 测试查询班级人数
  231. */
  232. @Test
  233. public void testCountStudent() {
  234. Long all = neoService.studentCount(null);
  235. log.info("【全校人数】= {}", all);
  236. Long seven = neoService.studentCount("第七班");
  237. log.info("【第七班人数】= {}", seven);
  238. }
  239. /**
  240. * 测试根据课程查询同学关系
  241. */
  242. @Test
  243. public void testFindClassmates() {
  244. Map<String, List<Student>> classmates = neoService.findClassmatesGroupByLesson();
  245. classmates.forEach((k, v) -> log.info("因为一起上了【{}】这门课,成为同学关系的有:{}", k, JSONUtil.toJsonStr(v.stream()
  246. .map(Student::getName)
  247. .collect(Collectors.toList()))));
  248. }
  249. /**
  250. * 查询所有师生关系,包括班主任/学生,任课老师/学生
  251. */
  252. @Test
  253. public void testFindTeacherStudent() {
  254. Map<String, Set<Student>> teacherStudent = neoService.findTeacherStudent();
  255. teacherStudent.forEach((k, v) -> log.info("【{}】教的学生有 {}", k, JSONUtil.toJsonStr(v.stream()
  256. .map(Student::getName)
  257. .collect(Collectors.toList()))));
  258. }
  259. }
  260. ```
  261. ## 截图
  262. 运行测试类之后,可以通过访问 http://localhost:7474 ,查看neo里所有节点和关系
  263. ![image-20181225150513101](http://static.xkcoding.com/spring-boot-demo/neo4j/063605.jpg)
  264. ## 参考
  265. - spring-data-neo4j 官方文档:https://docs.spring.io/spring-data/neo4j/docs/5.1.2.RELEASE/reference/html/
  266. - neo4j 官方文档:https://neo4j.com/docs/getting-started/3.5/