devbox
weixin_40725706
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Neo4j学习笔记(二) SpringMVC中使用Spring Data Neo4j_neo4j id 手工赋值 mvc

作者：weixin_40725706 | 2024-06-16 18:24:36

赞

踩

neo4j id 手工赋值 mvc

目录

一.pom.xml中添加spring-data-neo4j依赖

二.数据库连接配置文件neo4j.properties

三.日志打开Cypher的DEBUG信息,便于调试

四.JAVA代码

    4.1  Neo4jConfiguration.java为配置类

    4.2  Const.java为常量定义，这里列举了关系类型

    4.3  Neo4jEntity.java图实体基类，把图实体的ID属性放在基类

    4.4  RelActedInDTO.java为业务DTO根据输入输出设计自己定义

    4.5  Movie.java定义了电影节点和对应的关系

    4.6  Person.java定义了人节点和对应的关系

    4.7  RelActedIn.java定义了参演关系

    4.8  RelDirected.java定义了导演关系

    4.9  RelFollows.java定义了跟随关系

    4.10  RelReviewed.java定义了评介关系

    4.11  MovieRepository.java定义了电影为主的图数据访问方法

    4.12  PersonRepository.java定义了人为主的图数据访问方法

    4.13  MovieService.java定义了服务接口

    4.14  MovieServiceImpl.java定义了服务实现

    4.15  MovieController.java定义了控制器

五.测试

    5.1  取得指定电影的参演演员和角色

    5.2  为电影添加演员,如果电影或演员不存在会自动创建对应的节点

一.pom.xml中添加spring-data-neo4j依赖

  • 实验中使用独立的Neo4j服务器，采用bolt协议访问。如果是使用嵌入式neo4j或者使用http协议，需要添加其他依赖。
  • 5.3.4.RELEASE版本的spring-data-neo4j需要至少
         Neo4j 3.4以上
         Spring Framework 5.2.9.RELEASE以上

  1.         <!-- Neo4j -->
  2.         <dependency>
  3.             <groupId>org.springframework.data</groupId>
  4.             <artifactId>spring-data-neo4j</artifactId>
  5.             <version>5.3.4.RELEASE</version>
  6.         </dependency>

二.数据库连接配置文件neo4j.properties

  1. #
  2. URI=bolt://localhost:7687
  3. username=neo4j
  4. password=password
  5. #connection.pool.size=... #see Java driver doc
  6. #encryption.level=... #see Java driver doc
  7. #trust.strategy=... #see Java driver doc
  8. #trust.certificate.file=... #see Java driver doc
  9. #connection.liveness.check.timeout=... #see Java driver doc
  10. #verify.connection=... #see Java driver doc

三.日志打开Cypher的DEBUG信息,便于调试

  • SpringMVC的时候在log4j2.xml里的Loggers里添加

  1.         <Logger name="org.neo4j.ogm.drivers.bolt" level="DEBUG" additivity="false">
  2.             <AppenderRef ref="Console"/>
  3.         </Logger>

  • Springboot的时候只需要在application.properties里添加"logging.level.org.neo4j.ogm.drivers.bolt=DEBUG"

四.JAVA代码

   实验中采用Neo4j 4.0自带的Movie Graph为数据
   代码结构如下

    4.1  Neo4jConfiguration.java为配置类

      sessionFactory和transactionManager都改成了带neo4j开头的名字，可以在同一应用中有关系型数据库访问框架时并存使用。@EnableNeo4jRepositories的注解属性需要做相应的修改。

  1. package com.study.neo4j.config;
  2.  
  3. import org.neo4j.ogm.config.ClasspathConfigurationSource;
  4. import org.neo4j.ogm.config.ConfigurationSource;
  5. import org.neo4j.ogm.session.SessionFactory;
  6. import org.springframework.context.annotation.Bean;
  7. import org.springframework.context.annotation.Configuration;
  8. import org.springframework.data.neo4j.repository.config.EnableNeo4jRepositories;
  9. import org.springframework.data.neo4j.transaction.Neo4jTransactionManager;
  10. import org.springframework.transaction.annotation.EnableTransactionManagement;
  11.  
  12. @Configuration
  13. @EnableNeo4jRepositories(sessionFactoryRef = "neo4jSessionFactory", transactionManagerRef="neo4jTransactionManager", basePackages = "com.study.neo4j.dao")
  14. @EnableTransactionManagement
  15. public class Neo4jConfiguration {
  16. 	@Bean
  17.     public SessionFactory neo4jSessionFactory() {
  18.         // with domain entity base package(s)
  19.         return new SessionFactory(configuration(), "com.study.neo4j.bean");
  20.     }
  21.  
  22. 	@Bean
  23.     public org.neo4j.ogm.config.Configuration configuration() {
  24.         ConfigurationSource properties = new ClasspathConfigurationSource("neo4j.properties");
  25.         org.neo4j.ogm.config.Configuration configuration = new org.neo4j.ogm.config.Configuration.Builder(properties).build();
  26.         return configuration;
  27.     }
  28.  
  29. 	@Bean
  30.     public Neo4jTransactionManager neo4jTransactionManager() {
  31.         return new Neo4jTransactionManager(neo4jSessionFactory());
  32.     }
  33. }

    4.2  Const.java为常量定义，这里列举了关系类型

  1. package com.study.neo4j.bean;
  2.  
  3. public class Const {
  4. 	public static final String REL_TYPE_ACTEDIN = "ACTED_IN";
  5. 	public static final String REL_TYPE_DIRECTED = "DIRECTED";
  6. 	public static final String REL_TYPE_FOLLOWS = "FOLLOWS";
  7. 	public static final String REL_TYPE_PRODUCED = "PRODUCED";
  8. 	public static final String REL_TYPE_REVIEWED = "REVIEWED";
  9. 	public static final String REL_TYPE_WROTE = "WROTE";
  10. }

    4.3  Neo4jEntity.java图实体基类，把图实体的ID属性放在基类

  1. package com.study.neo4j.bean;
  2.  
  3. import org.neo4j.ogm.annotation.Id;
  4. import org.neo4j.ogm.annotation.GeneratedValue;
  5.  
  6. public abstract class Neo4jEntity {
  7. 	@Id
  8. 	@GeneratedValue
  9. 	protected Long id;
  10.  
  11. 	public Long getId() {
  12. 		return id;
  13. 	}
  14. 	public void setId(Long id) {
  15. 		this.id = id;
  16. 	}
  17. }

    4.4  RelActedInDTO.java为业务DTO根据输入输出设计自己定义

  1. package com.study.neo4j.bean;
  2.  
  3. import com.study.neo4j.bean.node.Movie;
  4. import com.study.neo4j.bean.node.Person;
  5. import com.study.neo4j.bean.rel.RelActedIn;
  6.  
  7. public class RelActedInDTO {
  8. 	private RelActedIn relActedIn;
  9. 	private Movie movie;
  10. 	private Person person;
  11. 	public RelActedIn getRelActedIn() {
  12. 		return relActedIn;
  13. 	}
  14. 	public void setRelActedIn(RelActedIn relActedIn) {
  15. 		this.relActedIn = relActedIn;
  16. 	}
  17. 	public Movie getMovie() {
  18. 		return movie;
  19. 	}
  20. 	public void setMovie(Movie movie) {
  21. 		this.movie = movie;
  22. 	}
  23. 	public Person getPerson() {
  24. 		return person;
  25. 	}
  26. 	public void setPerson(Person person) {
  27. 		this.person = person;
  28. 	}
  29. }

    4.5  Movie.java定义了电影节点和对应的关系

      三个关系类型都以电影节点为结束节点

  1. package com.study.neo4j.bean.node;
  2.  
  3. import java.util.List;
  4.  
  5. import org.neo4j.ogm.annotation.NodeEntity;
  6. import org.neo4j.ogm.annotation.Relationship;
  7.  
  8. import com.study.neo4j.bean.Const;
  9. import com.study.neo4j.bean.Neo4jEntity;
  10. import com.study.neo4j.bean.rel.RelDirected;
  11. import com.study.neo4j.bean.rel.RelReviewed;
  12. import com.study.neo4j.bean.rel.RelActedIn;
  13.  
  14. @NodeEntity
  15. public class Movie extends Neo4jEntity {
  16.  
  17.     private String title;
  18.     private String tagline;
  19.     private Integer released;
  20.     @Relationship(type = Const.REL_TYPE_ACTEDIN, direction=Relationship.INCOMING)
  21.     private List<RelActedIn> relActedIns;
  22.     @Relationship(type = Const.REL_TYPE_DIRECTED, direction=Relationship.INCOMING)
  23.     private List<RelDirected> relDirecteds;
  24.     @Relationship(type = Const.REL_TYPE_REVIEWED, direction=Relationship.INCOMING)
  25.     private List<RelReviewed> relRevieweds;
  26.  
  27. 	public String getTitle() {
  28. 		return title;
  29. 	}
  30. 	public void setTitle(String title) {
  31. 		this.title = title;
  32. 	}
  33. 	public String getTagline() {
  34. 		return tagline;
  35. 	}
  36. 	public void setTagline(String tagline) {
  37. 		this.tagline = tagline;
  38. 	}
  39. 	public Integer getReleased() {
  40. 		return released;
  41. 	}
  42. 	public void setReleased(Integer released) {
  43. 		this.released = released;
  44. 	}
  45. 	public List<RelActedIn> getRelActedIns() {
  46. 		return relActedIns;
  47. 	}
  48. 	public void setRelActedIns(List<RelActedIn> relActedIns) {
  49. 		this.relActedIns = relActedIns;
  50. 	}
  51.  
  52. 	public List<RelDirected> getRelDirecteds() {
  53. 		return relDirecteds;
  54. 	}
  55. 	public void setRelDirecteds(List<RelDirected> relDirecteds) {
  56. 		this.relDirecteds = relDirecteds;
  57. 	}
  58. 	public List<RelReviewed> getRelRevieweds() {
  59. 		return relRevieweds;
  60. 	}
  61. 	public void setRelRevieweds(List<RelReviewed> relReviewed) {
  62. 		this.relRevieweds = relReviewed;
  63. 	}
  64. 	@Override
  65. 	public String toString() {
  66. 		return "Movie [title=" + title + ", tagline=" + tagline + ", released=" + released + ", relActedIns="
  67. 				+ relActedIns + ", relDirecteds=" + relDirecteds + ", relReviewed=" + relRevieweds + ", id=" + id + "]";
  68. 	}
  69.  
  70. }

    4.6  Person.java定义了人节点和对应的关系

      三个关系类型以人节点为结束节点
      relFollows和relFollowsBy定义了同一种关系类型，对于单个节点来说又分为以本人为结束节点的关系和以本人为开始节点的关系

  1. package com.study.neo4j.bean.node;
  2.  
  3. import java.util.List;
  4.  
  5. import org.neo4j.ogm.annotation.NodeEntity;
  6. import org.neo4j.ogm.annotation.Relationship;
  7.  
  8. import com.study.neo4j.bean.Const;
  9. import com.study.neo4j.bean.Neo4jEntity;
  10. import com.study.neo4j.bean.rel.RelActedIn;
  11. import com.study.neo4j.bean.rel.RelDirected;
  12. import com.study.neo4j.bean.rel.RelFollows;
  13. import com.study.neo4j.bean.rel.RelReviewed;
  14.  
  15. @NodeEntity
  16. public class Person extends Neo4jEntity {
  17.     private String name;
  18.     private Integer born;
  19.     @Relationship(type = Const.REL_TYPE_ACTEDIN)
  20.     private List<RelActedIn> relActedIns;
  21.     @Relationship(type = Const.REL_TYPE_DIRECTED)
  22.     private List<RelDirected> relDirecteds;
  23.     @Relationship(type = Const.REL_TYPE_REVIEWED)
  24.     private List<RelReviewed> relRevieweds;
  25.     @Relationship(type = Const.REL_TYPE_FOLLOWS)
  26.     private List<RelFollows> relFollows;
  27.     @Relationship(type = Const.REL_TYPE_FOLLOWS, direction=Relationship.INCOMING)
  28.     private List<RelFollows> relFollowsBy;
  29.  
  30. 	public String getName() {
  31. 		return name;
  32. 	}
  33. 	public void setName(String name) {
  34. 		this.name = name;
  35. 	}
  36. 	public Integer getBorn() {
  37. 		return born;
  38. 	}
  39. 	public void setBorn(Integer born) {
  40. 		this.born = born;
  41. 	}
  42. 	public List<RelActedIn> getRelActedIns() {
  43. 		return relActedIns;
  44. 	}
  45. 	public void setRelActedIns(List<RelActedIn> relActedIns) {
  46. 		this.relActedIns = relActedIns;
  47. 	}
  48. 	public List<RelDirected> getRelDirecteds() {
  49. 		return relDirecteds;
  50. 	}
  51. 	public void setRelDirecteds(List<RelDirected> relDirecteds) {
  52. 		this.relDirecteds = relDirecteds;
  53. 	}
  54. 	public List<RelReviewed> getRelRevieweds() {
  55. 		return relRevieweds;
  56. 	}
  57. 	public void setRelRevieweds(List<RelReviewed> relRevieweds) {
  58. 		this.relRevieweds = relRevieweds;
  59. 	}
  60. 	public List<RelFollows> getRelFollows() {
  61. 		return relFollows;
  62. 	}
  63. 	public void setRelFollows(List<RelFollows> relFollows) {
  64. 		this.relFollows = relFollows;
  65. 	}
  66. 	public List<RelFollows> getRelFollowsBy() {
  67. 		return relFollowsBy;
  68. 	}
  69. 	public void setRelFollowsBy(List<RelFollows> relFollowsBy) {
  70. 		this.relFollowsBy = relFollowsBy;
  71. 	}
  72. 	@Override
  73. 	public String toString() {
  74. 		return "Person [name=" + name + ", born=" + born + ", relActedIns=" + relActedIns + ", relDirecteds="
  75. 				+ relDirecteds + ", relRevieweds=" + relRevieweds + ", relFollows=" + relFollows + ", relFollowsBy="
  76. 				+ relFollowsBy + ", id=" + id + "]";
  77. 	}
  78. }

    4.7  RelActedIn.java定义了参演关系

      分别使用@StartNode和@EndNode注解表示关系的开始节点和结束节点
      为了避免Json序列化时候的无限循环，使用@JsonIgnore注解取消对开始节点和结束节点的序列化，并在toString中不做开始节点和结束节点的toString

  1. package com.study.neo4j.bean.rel;
  2.  
  3. import java.util.List;
  4.  
  5. import org.neo4j.ogm.annotation.EndNode;
  6. import org.neo4j.ogm.annotation.Property;
  7. import org.neo4j.ogm.annotation.RelationshipEntity;
  8. import org.neo4j.ogm.annotation.StartNode;
  9.  
  10. import com.fasterxml.jackson.annotation.JsonIgnore;
  11. import com.study.neo4j.bean.Const;
  12. import com.study.neo4j.bean.Neo4jEntity;
  13. import com.study.neo4j.bean.node.Movie;
  14. import com.study.neo4j.bean.node.Person;
  15.  
  16. @RelationshipEntity(type = Const.REL_TYPE_ACTEDIN)
  17. public class RelActedIn extends Neo4jEntity {
  18. 	@Property
  19. 	private List<String> roles;
  20.  
  21. 	@StartNode
  22. 	@JsonIgnore
  23. 	private Person person;
  24. 	@EndNode
  25. 	@JsonIgnore
  26. 	private Movie movie;
  27.  
  28. 	public List<String> getRoles() {
  29. 		return roles;
  30. 	}
  31. 	public void setRoles(List<String> roles) {
  32. 		this.roles = roles;
  33. 	}
  34. 	public Person getPerson() {
  35. 		return person;
  36. 	}
  37. 	public void setPerson(Person person) {
  38. 		this.person = person;
  39. 	}
  40. 	public Movie getMovie() {
  41. 		return movie;
  42. 	}
  43. 	public void setMovie(Movie movie) {
  44. 		this.movie = movie;
  45. 	}
  46. 	@Override
  47. 	public String toString() {
  48. 		return "RelActedIn [roles=" + roles + ", person.id=" + person==null?null:person.getId() + ", movie.id=" + movie==null?null:movie.getId() + ", id=" + id + "]";
  49. 	}
  50. }

    4.8  RelDirected.java定义了导演关系

      分别使用@StartNode和@EndNode注解表示关系的开始节点和结束节点
      为了避免Json序列化时候的无限循环，使用@JsonIgnore注解取消对开始节点和结束节点的序列化，并在toString中不做开始节点和结束节点的toString

  1. package com.study.neo4j.bean.rel;
  2.  
  3. import org.neo4j.ogm.annotation.EndNode;
  4. import org.neo4j.ogm.annotation.RelationshipEntity;
  5. import org.neo4j.ogm.annotation.StartNode;
  6.  
  7. import com.fasterxml.jackson.annotation.JsonIgnore;
  8. import com.study.neo4j.bean.Const;
  9. import com.study.neo4j.bean.Neo4jEntity;
  10. import com.study.neo4j.bean.node.Movie;
  11. import com.study.neo4j.bean.node.Person;
  12.  
  13. @RelationshipEntity(type = Const.REL_TYPE_DIRECTED)
  14. public class RelDirected extends Neo4jEntity {
  15.  
  16. 	@StartNode
  17. 	@JsonIgnore
  18. 	private Person person;
  19. 	@EndNode
  20. 	@JsonIgnore
  21. 	private Movie movie;
  22.  
  23. 	public Person getPerson() {
  24. 		return person;
  25. 	}
  26. 	public void setPerson(Person person) {
  27. 		this.person = person;
  28. 	}
  29. 	public Movie getMovie() {
  30. 		return movie;
  31. 	}
  32. 	public void setMovie(Movie movie) {
  33. 		this.movie = movie;
  34. 	}
  35. 	@Override
  36. 	public String toString() {
  37. 		return "RelActedIn [person.id=" + person==null?null:person.getId() + ", movie.id=" + movie==null?null:movie.getId() + ", id=" + id + "]";
  38. 	}
  39. }

    4.9  RelFollows.java定义了跟随关系

      分别使用@StartNode和@EndNode注解表示关系的开始节点和结束节点
      为了避免Json序列化时候的无限循环，使用@JsonIgnore注解取消对开始节点和结束节点的序列化，并在toString中不做开始节点和结束节点的toString

  1. package com.study.neo4j.bean.rel;
  2.  
  3. import org.neo4j.ogm.annotation.EndNode;
  4. import org.neo4j.ogm.annotation.RelationshipEntity;
  5. import org.neo4j.ogm.annotation.StartNode;
  6.  
  7. import com.fasterxml.jackson.annotation.JsonIgnore;
  8. import com.study.neo4j.bean.Const;
  9. import com.study.neo4j.bean.Neo4jEntity;
  10. import com.study.neo4j.bean.node.Person;
  11.  
  12. @RelationshipEntity(type = Const.REL_TYPE_FOLLOWS)
  13. public class RelFollows extends Neo4jEntity {
  14.  
  15. 	@StartNode
  16. 	@JsonIgnore
  17. 	private Person person;
  18. 	@EndNode
  19. 	@JsonIgnore
  20. 	private Person followPerson;
  21.  
  22. 	public Person getPerson() {
  23. 		return person;
  24. 	}
  25. 	public void setPerson(Person person) {
  26. 		this.person = person;
  27. 	}
  28. 	public Person getFollowPerson() {
  29. 		return followPerson;
  30. 	}
  31. 	public void setMovie(Person followPerson) {
  32. 		this.followPerson = followPerson;
  33. 	}
  34. 	@Override
  35. 	public String toString() {
  36. 		return "RelActedIn [person.id=" + person==null?null:person.getId() + ", followPerson.id=" + followPerson==null?null:followPerson.getId() + ", id=" + id + "]";
  37. 	}
  38. }

    4.10  RelReviewed.java定义了评介关系

      分别使用@StartNode和@EndNode注解表示关系的开始节点和结束节点
      为了避免Json序列化时候的无限循环，使用@JsonIgnore注解取消对开始节点和结束节点的序列化，并在toString中不做开始节点和结束节点的toString

  1. package com.study.neo4j.bean.rel;
  2.  
  3. import org.neo4j.ogm.annotation.EndNode;
  4. import org.neo4j.ogm.annotation.RelationshipEntity;
  5. import org.neo4j.ogm.annotation.StartNode;
  6.  
  7. import com.fasterxml.jackson.annotation.JsonIgnore;
  8. import com.study.neo4j.bean.Const;
  9. import com.study.neo4j.bean.Neo4jEntity;
  10. import com.study.neo4j.bean.node.Movie;
  11. import com.study.neo4j.bean.node.Person;
  12.  
  13. @RelationshipEntity(type = Const.REL_TYPE_REVIEWED)
  14. public class RelReviewed extends Neo4jEntity {
  15.  
  16. 	private Integer rating;
  17. 	private String summary;
  18.  
  19. 	@StartNode
  20. 	@JsonIgnore
  21. 	private Person person;
  22. 	@EndNode
  23. 	@JsonIgnore
  24. 	private Movie movie;
  25.  
  26. 	public Integer getRating() {
  27. 		return rating;
  28. 	}
  29. 	public void setRating(Integer rating) {
  30. 		this.rating = rating;
  31. 	}
  32. 	public String getSummary() {
  33. 		return summary;
  34. 	}
  35. 	public void setSummary(String summary) {
  36. 		this.summary = summary;
  37. 	}
  38. 	public Person getPerson() {
  39. 		return person;
  40. 	}
  41. 	public void setPerson(Person person) {
  42. 		this.person = person;
  43. 	}
  44. 	public Movie getMovie() {
  45. 		return movie;
  46. 	}
  47. 	public void setMovie(Movie movie) {
  48. 		this.movie = movie;
  49. 	}
  50. 	@Override
  51. 	public String toString() {
  52. 		return "RelReviewed [rating=" + rating + ", summary=" + summary + ", person.id=" + person==null?null:person.getId() + ", movie.id=" + movie==null?null:movie.getId()
  53. 				+ ", id=" + id + "]";
  54. 	}
  55. }

    4.11  MovieRepository.java定义了电影为主的图数据访问方法

      findByTitle为自动生成型方法，函数的查询语句会根据方法名自动生成，这个功能很有意思，后面再另起一篇记载自动生成都可以有哪些要素。查询的默认深度为1，即查询本节点以及和本节点有直接关系的节点，查询的关系类型为Movie.java中定义的关系类型。可以使用@Depth注解直接改变当前方法的查询深度，也可以使用(@Depth int depth)定义为方法的一个参数，根据传入参数决定查询深度，0为只查询本节点不查询关系，-1为无限延申。
      其他函数为自定义查询，没有深度的问题，只返回自己Cypher写的return内容。
      查询可以返回分页数据，例如getActorsThatActInMovieFromTitle。
      如果要直接返回指定关系类型，需要Cypher里return (n1)-[r]->(n2)类似的路径。

  1. package com.study.neo4j.dao;
  2.  
  3. import java.util.List;
  4.  
  5. import org.springframework.data.domain.Page;
  6. import org.springframework.data.domain.PageRequest;
  7. import org.springframework.data.neo4j.annotation.Depth;
  8. import org.springframework.data.neo4j.annotation.Query;
  9. import org.springframework.data.neo4j.repository.Neo4jRepository;
  10.  
  11. import com.study.neo4j.bean.node.Movie;
  12. import com.study.neo4j.bean.node.Person;
  13. import com.study.neo4j.bean.rel.RelActedIn;
  14.  
  15. public interface MovieRepository extends Neo4jRepository<Movie,Long> {
  16.     // returns the node with id equal to idOfMovie parameter
  17.     @Query("MATCH (n) WHERE id(n)=$0 RETURN n")
  18.     Movie getMovieFromId(Integer idOfMovie);
  19.  
  20.     // returns the nodes which have a title according to the movieTitle parameter
  21.     @Query("MATCH (movie:Movie {title:$0}) RETURN movie")
  22.     Movie getMovieFromTitle(String movieTitle);
  23.  
  24.     //@Depth(value=2)
  25.     Movie findByTitle(String title);
  26.  
  27.     // returns a Page of Person that have a ACTED_IN relationship to the movie node with the title equal to movieTitle parameter.
  28.     @Query(value = "MATCH (movie:Movie {title:$0})<-[:ACTED_IN]-(actor) RETURN actor ORDER BY actor.name", countQuery= "MATCH (movie:Movie {title:$0})<-[:ACTED_IN]-(actor) RETURN count(actor)")
  29.     Page<Person> getActorsThatActInMovieFromTitle(String movieTitle, PageRequest page);
  30.  
  31.     // returns a Slice of Person that have a ACTED_IN relationship to the movie node with the title equal to movieTitle parameter.
  32.     @Query("MATCH p=(movie:Movie {title:$0})<-[relActedIn:ACTED_IN]-(actor) RETURN p")
  33.     List<RelActedIn> getActorsAndRolesThatActInMovieFromTitle(String movieTitle);
  34.  
  35.     // returns users who directed a movie
  36.     @Query("MATCH (movie:Movie {title:$0})<-[DIRECTED]-(user) RETURN user")
  37.     List<Person> getUsersWhoRatedMovieFromTitle(String movieTitle);
  38. }

    4.12  PersonRepository.java定义了人为主的图数据访问方法

  1. package com.study.neo4j.dao;
  2.  
  3. import org.springframework.data.neo4j.repository.Neo4jRepository;
  4.  
  5. import com.study.neo4j.bean.node.Person;
  6.  
  7. public interface PersonRepository extends Neo4jRepository<Person,Long> {
  8.     //@Depth(value=2)
  9. 	Person findByName(String name);
  10. }

    4.13  MovieService.java定义了服务接口

  1. package com.study.neo4j.service;
  2.  
  3. import java.util.List;
  4. import java.util.Map;
  5.  
  6. import com.study.neo4j.bean.RelActedInDTO;
  7. import com.study.neo4j.bean.node.Movie;
  8. import com.study.neo4j.bean.node.Person;
  9.  
  10. public interface MovieService {
  11.     public Iterable<Movie> findAll();
  12.     public Movie getMovie(String movieTitle);
  13. 	public List<Person> getActorsByMovieTitle(String movieTitle);
  14. 	public List<Person> getActorsAndRolesByMovieTitle(String movieTitle);
  15. 	public RelActedInDTO addActors(RelActedInDTO relActedInDTO);
  16. 	public Map<String, List<Person>> getPersonsByMovieTitle(String movieTitle);
  17. }

    4.14  MovieServiceImpl.java定义了服务实现

      @Transactional(value="neo4jTransactionManager")指定使用Neo4jConfiguration.java里定义的事务管理器。如果本应用中没有其他事务管理器可以去除括号里的内容
      Neo4jRepository.save()保存数据时，默认深度是-1，所有movie的属性、movie对应的关系、movie对应的人、人对应的关系......，会自动判断查询出来之后有没有发生变化，如果有变化，会自动更新。也可以手动指定保存时的深度,0为只保存movie的属性，不管对应的关系以及关系连接的节点，1为保存movie的属性、关系以及关系连接的节点的属性。

  1. package com.study.neo4j.service;
  2.  
  3. import java.util.ArrayList;
  4. import java.util.HashMap;
  5. import java.util.List;
  6. import java.util.Map;
  7.  
  8. import org.apache.commons.lang3.StringUtils;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.data.domain.Page;
  11. import org.springframework.data.domain.PageRequest;
  12. import org.springframework.stereotype.Service;
  13. import org.springframework.transaction.annotation.Transactional;
  14.  
  15. import com.study.neo4j.bean.RelActedInDTO;
  16. import com.study.neo4j.bean.node.Movie;
  17. import com.study.neo4j.bean.node.Person;
  18. import com.study.neo4j.bean.rel.RelActedIn;
  19. import com.study.neo4j.bean.rel.RelDirected;
  20. import com.study.neo4j.bean.rel.RelReviewed;
  21. import com.study.neo4j.dao.MovieRepository;
  22. import com.study.neo4j.dao.PersonRepository;
  23.  
  24. @Service("movieService")
  25. @Transactional(value="neo4jTransactionManager")
  26. public class MovieServiceImpl implements MovieService {
  27.  
  28. 	@Autowired
  29. 	private MovieRepository movieRepository;
  30. 	@Autowired
  31. 	private PersonRepository personRepository;
  32.  
  33. 	@Override
  34. 	public Iterable<Movie> findAll() {
  35. 		return movieRepository.findAll();
  36. 	}
  37.  
  38. 	@Override
  39. 	public Movie getMovie(String movieTitle) {
  40. 		return movieRepository.getMovieFromTitle(movieTitle);
  41. 	}
  42.  
  43. 	@Override
  44. 	public List<Person> getActorsByMovieTitle(String movieTitle) {
  45. 		PageRequest pageRequest = PageRequest.of(0, 3);
  46. 		Page<Person> person = movieRepository.getActorsThatActInMovieFromTitle(movieTitle, pageRequest);
  47. 		return person.toList();
  48. 	}
  49.  
  50. 	@Override
  51. 	public List<Person> getActorsAndRolesByMovieTitle(String movieTitle) {
  52. 		List<Person> listRet = new ArrayList<Person>();
  53. 		List<RelActedIn> list = movieRepository.getActorsAndRolesThatActInMovieFromTitle(movieTitle);
  54. 		for (RelActedIn relActedIn : list) {
  55. 			listRet.add(relActedIn.getPerson());
  56. 		}
  57. 		return listRet;
  58. 	}
  59.  
  60. 	@Override
  61. 	public RelActedInDTO addActors(RelActedInDTO relActedInDTO) {
  62. 		// 查找电影,没有就使用请求参数新建
  63. 		Movie movie = movieRepository.findByTitle(relActedInDTO.getMovie().getTitle());
  64. 		if (movie == null) {
  65. 			movie = relActedInDTO.getMovie();
  66. 			movie.setRelActedIns(new ArrayList<RelActedIn>(1));
  67. 		}
  68. 		// 查新人,没有就使用请求参数新建
  69. 		Person person = personRepository.findByName(relActedInDTO.getPerson().getName());
  70. 		if (person == null) {
  71. 			person = relActedInDTO.getPerson();
  72. 			person.setRelActedIns(new ArrayList<RelActedIn>(1));
  73. 		}
  74. 		RelActedIn relActedIn = null;
  75. 		// 查询是否已经参演
  76. 		for (RelActedIn relActedInTmp:movie.getRelActedIns()) {
  77. 			if (StringUtils.equals(person.getName(), relActedInTmp.getPerson().getName())) {
  78. 				relActedIn = relActedInTmp;
  79. 				break;
  80. 			}
  81. 		}
  82. 		if (relActedIn == null) {
  83. 			// 变更前没有参演,新建关系
  84. 			relActedIn = relActedInDTO.getRelActedIn();
  85. 			relActedIn.setMovie(movie);
  86. 			relActedIn.setPerson(person);
  87. 			movie.getRelActedIns().add(relActedIn);
  88. 			person.getRelActedIns().add(relActedIn);
  89. 		} else {
  90. 			// 改变参演角色列表
  91. 			relActedIn.setRoles(relActedInDTO.getRelActedIn().getRoles());
  92. 		}
  93. 		movieRepository.save(movie);
  94. 		// 设置返回值
  95. 		RelActedInDTO retRelActedInDTO = new RelActedInDTO();
  96. 		retRelActedInDTO.setMovie(movie);
  97. 		retRelActedInDTO.setPerson(person);
  98. 		retRelActedInDTO.setRelActedIn(relActedIn);
  99. 		return retRelActedInDTO;
  100. 	}
  101.  
  102. 	@Override
  103. 	public Map<String, List<Person>> getPersonsByMovieTitle(String movieTitle) {
  104. 		Movie movie = movieRepository.findByTitle(movieTitle);
  105. 		Map<String, List<Person>> retMap = new HashMap<String, List<Person>>();
  106. 		// 取得参演人员
  107. 		List<Person> list = new ArrayList<Person>();
  108. 		for (RelActedIn relActed : movie.getRelActedIns()) {
  109. 			list.add(relActed.getPerson());
  110. 		}
  111. 		retMap.put("actedIns", list);
  112. 		// 取得导演人员
  113. 		list = new ArrayList<Person>();
  114. 		for (RelDirected relDirected : movie.getRelDirecteds()) {
  115. 			list.add(relDirected.getPerson());
  116. 		}
  117. 		retMap.put("directeds", list);
  118. 		// 取得评介人员
  119. 		list = new ArrayList<Person>();
  120. 		for (RelReviewed relReviewed : movie.getRelRevieweds()) {
  121. 			list.add(relReviewed.getPerson());
  122. 		}
  123. 		retMap.put("revieweds", list);
  124. 		return retMap;
  125. 	}
  126.  
  127. }

    4.15  MovieController.java定义了控制器

  1. package com.study.neo4j.controller;
  2.  
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.web.bind.annotation.CrossOrigin;
  5. import org.springframework.web.bind.annotation.RequestBody;
  6. import org.springframework.web.bind.annotation.RequestMapping;
  7. import org.springframework.web.bind.annotation.RequestMethod;
  8. import org.springframework.web.bind.annotation.RestController;
  9.  
  10. import com.mvc.base.controller.BaseController;
  11. import com.study.neo4j.bean.RelActedInDTO;
  12. import com.study.neo4j.bean.node.Movie;
  13. import com.study.neo4j.service.MovieService;
  14. import com.util.RestResponse;
  15.  
  16. @CrossOrigin(origins = "*", allowCredentials = "true", allowedHeaders = "*", methods = {RequestMethod.GET, RequestMethod.POST})
  17. @RestController
  18. @RequestMapping("/movie")
  19. public class MovieController extends BaseController {
  20.     @Autowired
  21.     private MovieService movieService;
  22.  
  23.     /**
  24.      * 取得所有电影
  25.      *
  26.      * @return RestResponse
  27.      */
  28.     @RequestMapping(value = "/findAll")
  29.     public RestResponse findAll() {
  30.         return RestResponse.success(movieService.findAll());
  31.     }
  32.  
  33.     /**
  34.      * 通过电影名取得电影
  35.      *
  36.      * @return RestResponse
  37.      */
  38.     @RequestMapping(value = "/getMovieByTitle")
  39.     public RestResponse getMovieByTitle(@RequestBody Movie movie) {
  40.         return RestResponse.success(movieService.getMovie(movie.getTitle()));
  41.     }
  42.  
  43.     /**
  44.      * 通过电影名取得演员
  45.      *
  46.      * @return RestResponse
  47.      */
  48.     @RequestMapping(value = "/getActorsByMovieTitle")
  49.     public RestResponse getActorsByMovieTitle(@RequestBody Movie movie) {
  50.         return RestResponse.success(movieService.getActorsByMovieTitle(movie.getTitle()));
  51.     }
  52.  
  53.     /**
  54.      * 通过电影名取得演员(包含参演角色)
  55.      *
  56.      * @return RestResponse
  57.      */
  58.     @RequestMapping(value = "/getActorsAndRolesByMovieTitle")
  59.     public RestResponse getActorsAndRolesByMovieTitle(@RequestBody Movie movie) {
  60.         return RestResponse.success(movieService.getActorsAndRolesByMovieTitle(movie.getTitle()));
  61.     }
  62.  
  63.     /**
  64.      * 通过电影名取得相关人员和关系
  65.      *
  66.      * @return RestResponse
  67.      */
  68.     @RequestMapping(value = "/getPersonsByMovieTitle")
  69.     public RestResponse getPersonsByMovieTitle(@RequestBody Movie movie) {
  70.         return RestResponse.success(movieService.getPersonsByMovieTitle(movie.getTitle()));
  71.     }
  72.  
  73.     /**
  74.      * 为电影添加演员
  75.      *
  76.      * @return RestResponse
  77.      */
  78.     @RequestMapping(value = "/addActors")
  79.     public RestResponse addActors(@RequestBody RelActedInDTO relActedInDTO) {
  80.         return RestResponse.success(movieService.addActors(relActedInDTO));
  81.     }
  82. }

五.测试

    5.1  取得指定电影的参演演员和角色

        请求地址  /movie/getActorsAndRolesByMovieTitle
        请求Json内容：

{"title":"The Matrix"}

        返回内容：

  1. {
  2.     "code": 0,
  3.     "count": 0,
  4.     "data": [
  5.         {
  6.             "id": 8,
  7.             "name": "Emil Eifrem",
  8.             "born": 1978,
  9.             "relActedIns": [
  10.                 {
  11.                     "id": 7,
  12.                     "roles": [
  13.                         "Emil"
  14.                     ]
  15.                 }
  16.             ],
  17.             "relDirecteds": null,
  18.             "relRevieweds": null,
  19.             "relFollows": null,
  20.             "relFollowsBy": null
  21.         },
  22.         {
  23.             "id": 3,
  24.             "name": "Laurence Fishburne",
  25.             "born": 1961,
  26.             "relActedIns": [
  27.                 {
  28.                     "id": 2,
  29.                     "roles": [
  30.                         "Morpheus"
  31.                     ]
  32.                 }
  33.             ],
  34.             "relDirecteds": null,
  35.             "relRevieweds": null,
  36.             "relFollows": null,
  37.             "relFollowsBy": null
  38.         },
  39.         {
  40.             "id": 4,
  41.             "name": "Hugo Weaving",
  42.             "born": 1960,
  43.             "relActedIns": [
  44.                 {
  45.                     "id": 3,
  46.                     "roles": [
  47.                         "Agent Smith"
  48.                     ]
  49.                 }
  50.             ],
  51.             "relDirecteds": null,
  52.             "relRevieweds": null,
  53.             "relFollows": null,
  54.             "relFollowsBy": null
  55.         },
  56.         {
  57.             "id": 2,
  58.             "name": "Carrie-Anne Moss",
  59.             "born": 1967,
  60.             "relActedIns": [
  61.                 {
  62.                     "id": 1,
  63.                     "roles": [
  64.                         "Trinity"
  65.                     ]
  66.                 }
  67.             ],
  68.             "relDirecteds": null,
  69.             "relRevieweds": null,
  70.             "relFollows": null,
  71.             "relFollowsBy": null
  72.         },
  73.         {
  74.             "id": 1,
  75.             "name": "Keanu Reeves",
  76.             "born": 1964,
  77.             "relActedIns": [
  78.                 {
  79.                     "id": 0,
  80.                     "roles": [
  81.                         "Neo"
  82.                     ]
  83.                 }
  84.             ],
  85.             "relDirecteds": null,
  86.             "relRevieweds": null,
  87.             "relFollows": null,
  88.             "relFollowsBy": null
  89.         }
  90.     ],
  91.     "msg": "操作成功"
  92. }

    5.2  为电影添加演员,如果电影或演员不存在会自动创建对应的节点

        请求地址  /movie/addActors
        请求Json内容：

  1. {
  2.     "movie": {
  3.         "title": "这是一个新电影",
  4.         "tagline": "这是电影宣传词",
  5.         "released": 2020
  6.     },
  7.     "person": {
  8.         "name": "李四",
  9.         "born": 1986
  10.     },
  11.     "relActedIn": {
  12.         "roles": [
  13.             "大铃铛",
  14.             "路人乙",
  15.             "大坏蛋"
  16.         ]
  17.     }
  18. }

        返回内容：

  1. {
  2.     "code": 0,
  3.     "count": 0,
  4.     "data": {
  5.         "relActedIn": {
  6.             "id": 254,
  7.             "roles": [
  8.                 "大铃铛",
  9.                 "路人乙",
  10.                 "大坏蛋"
  11.             ]
  12.         },
  13.         "movie": {
  14.             "id": 172,
  15.             "title": "这是一个新电影",
  16.             "tagline": "这是电影宣传词",
  17.             "released": 2020,
  18.             "relActedIns": [
  19.                 {
  20.                     "id": 257,
  21.                     "roles": [
  22.                         "路人丙2"
  23.                     ]
  24.                 },
  25.                 {
  26.                     "id": 256,
  27.                     "roles": [
  28.                         "路人丙"
  29.                     ]
  30.                 },
  31.                 {
  32.                     "id": 253,
  33.                     "roles": [
  34.                         "小铃铛",
  35.                         "路人甲"
  36.                     ]
  37.                 },
  38.                 {
  39.                     "id": 254,
  40.                     "roles": [
  41.                         "大铃铛",
  42.                         "路人乙",
  43.                         "大坏蛋"
  44.                     ]
  45.                 }
  46.             ],
  47.             "relDirecteds": null,
  48.             "relRevieweds": null
  49.         },
  50.         "person": {
  51.             "id": 174,
  52.             "name": "李四",
  53.             "born": 1986,
  54.             "relActedIns": [
  55.                 {
  56.                     "id": 254,
  57.                     "roles": [
  58.                         "大铃铛",
  59.                         "路人乙",
  60.                         "大坏蛋"
  61.                     ]
  62.                 }
  63.             ],
  64.             "relDirecteds": null,
  65.             "relRevieweds": null,
  66.             "relFollows": null,
  67.             "relFollowsBy": null
  68.         }
  69.     },
  70.     "msg": "操作成功"
  71. }

        多次更改后的图：

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/weixin_40725706/article/detail/727757
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号