Привет всем, Вилли здесь. В прошлый раз я говорил вам, что я создаю Skybase CMDB с использованием Neo4j и Spring Data Neo4j , и я был рад получить много положительных отзывов об этом. Я показал немного кода, но не так много. В этом посте я покажу вам, как я создаю элемент конфигурации человека (CI) в Skybase, используя Spring Data Neo4j.
Требования к лицу CI
Мы начнем с простого создания КИ человека. Полезно иметь людей в CMDB по разным причинам: они позволяют вам определять детализированные элементы управления доступом (например, Джим может развертывать такие-то приложения в среде разработки; Эрик может развертывать все, что он хочет, где угодно и т. Д.) .); они позволяют вам определять группы, которые будут получать уведомления о критических событиях и инцидентах; и т.п.
Наш сотрудник CI будет иметь имя пользователя, имя и фамилию, некоторые номера телефонов, адрес электронной почты, менеджера, прямые отчеты и, наконец, проекты, над которыми он работает. Нам нужно иметь возможность отображать людей в виде списка, отображать конкретного человека в подробном представлении, позволять пользователям создавать, редактировать и удалять людей и так далее. Вот, например, как будет выглядеть представление списка, по крайней мере сейчас:
А вот как будет выглядеть наше представление деталей:
Отношения между человеком и проектом имеют связанную роль. Эти отношения также являются основой для списка соавторов: два человека являются соавторами, если есть хотя бы один проект, членами которого они являются.
Наших простых требований должно быть достаточно, чтобы показать, каково это — писать код Spring Data Neo4j.
Создание сущностей Person и ProjectMembership
Сначала мы создадим Человека. Я подавил аннотации валидации и JAXB, поскольку они не имеют отношения к нашим текущим целям:
package org.skydingo.skybase.model;
import java.util.Set;
import org.neo4j.graphdb.Direction;
import org.skydingo.skybase.model.relationship.ProjectMembership;
import org.springframework.data.neo4j.annotation.*;
import org.springframework.data.neo4j.support.index.IndexType;
@NodeEntity
public class Person implements Comparable<Person> {
@GraphId private Long id;
@Indexed(indexType = IndexType.FULLTEXT, indexName = "searchByUsername")
private String username;
private String firstName, lastName, title, workPhone, mobilePhone, email;
@RelatedTo(type = "REPORTS_TO")
private Person manager;
@RelatedTo(type = "REPORTS_TO", direction = Direction.INCOMING)
private Set<Person> directReports;
@RelatedToVia(type = "MEMBER_OF")
private Set<ProjectMembership> memberships;
public Long getId() { return id; }
public void setId(Long id) { this.id = id; }
public String getUsername() { return username; }
public void setUsername(String username) { this.username = username; }
... other accessor methods ...
public Person getManager() { return manager; }
public void setManager(Person manager) { this.manager = manager; }
public Set<Person> getDirectReports() { return directReports; }
public void setDirectReports(Set<Person> directReports) {
this.directReports = directReports;
}
public Iterable<ProjectMembership> getMemberships() { return memberships; }
public ProjectMembership memberOf(Project project, String role) {
ProjectMembership membership = new ProjectMembership(this, project, role);
memberships.add(membership);
return membership;
}
... equals(), hashCode(), compareTo() ...
}
Есть много аннотаций, которые мы используем, чтобы создать структуру. Начнем с узлов и их свойств. Затем мы рассмотрим простые отношения между узлами. Затем мы рассмотрим так называемые сущности отношений, которые в основном являются причудливыми отношениями. Во-первых, вот абстрактное представление нашей модели предметной области:
Теперь давайте посмотрим на некоторые детали.
Узлы и их свойства. Когда у нас есть объект на основе узла, сначала мы аннотируем его аннотацией @NodeEntity. Большинство простых свойств узлов (т. Е. Свойств, которые не являются связями с другими узлами) подойдут для поездки. Обратите внимание, что мне не нужно было комментировать firstName, lastName, email и т. Д. Spring Data Neo4j будет обрабатывать отображение там автоматически.
Однако есть несколько исключений. Во-первых, я добавил @GraphId в свое свойство id. Это говорит Spring Data Neo4j, что это идентификатор, который мы можем использовать для поиска. Другая — аннотация @Indexed, которая (неожиданно) создает индекс для рассматриваемого свойства. Это полезно, когда вам нужна альтернатива поиску по идентификатору.
Теперь посмотрим на отношения. Говоря в широком смысле, существуют простые отношения и более сложные отношения. Начнем с простых.
Простые отношения. На низком уровне Neo4j является базой данных графа, поэтому мы можем говорить о графе в теоретических терминах графа, таких как узлы, ребра, направленные ребра, DAG и все такое. Но здесь мы используем графики для моделирования предметной области, поэтому мы интерпретируем понятия низкоуровневых графов в терминах понятий моделирования предметной области более высокого уровня. Язык, который использует Spring Data Neo4j, — это «сущность узла» для узлов и «связь» для ребер.
Наш Person CI имеет простые отношения, называемые REPORTS_TO, которые связывают людей, чтобы мы могли моделировать иерархии отчетов. Person имеет два поля для этих отношений: manager и directReports. Это противоположные сайты с одинаковыми отношениями. Мы используем @RelatedTo (type = «REPORTS_TO») для аннотирования этих полей. У аннотации также есть элемент direction, значением по умолчанию которого является Direction.OUTGOING, что означает, что этот узел является хвостовым краем. Вот почему мы явно указываем direction = Direction.INCOMING для поля directReports.
Как это выглядит в базе данных? Неоклипс раскрывает все. Вот несколько примеров отношений отчетности (щелкните изображение, чтобы увеличить его):
(Немного в стороне: есть аннотация @Fetch — мы увидим ее чуть позже — которая говорит Spring Data Neo4j о необходимости загружать связанный объект. По какой-то причине мне не нужно использовать его для отношений менеджера и прямых отчетов, и я не уверен почему. Если кто-то знает, я был бы признателен за объяснение.)
Отношения сущностей. Помимо отношений REPORTS_TO между людьми, нам важны отношения MEMBER_OF между людьми и проектами. Это более интересно, чем отношение REPORTS_TO, потому что MEMBER_OF имеет ассоциированное свойство — роль — это аналогично добавлению столбца в таблицу ссылок в СУБД, как я упоминал в своем ответе Бригу в предыдущем посте. Метод Person.memberOf () предоставляет удобный способ назначить человека проекту, используя специальную «сущность отношения» ProjectMembership. Вот код:
package org.skydingo.skybase.model.relationship;
import org.skydingo.skybase.model.Person;
import org.skydingo.skybase.model.Project;
import org.springframework.data.neo4j.annotation.*;
@RelationshipEntity(type = "MEMBER_OF")
public class ProjectMembership {
@GraphId private Long id;
@Fetch @StartNode private Person person;
@Fetch @EndNode private Project project;
private String role;
public ProjectMembership() { }
public ProjectMembership(Person person, Project project, String role) {
this.person = person;
this.project = project;
this.role = role;
}
public Person getPerson() { return person; }
public void setPerson(Person person) { this.person = person; }
public Project getProject() { return project; }
public void setProject(Project project) { this.project = project; }
public String getRole() { return role; }
public void setRole(String role) { this.role = role; }
... equals(), hashCode(), toString() ...
}
ProjectMembership, как Person, является сущностью, но это сущность отношений. Мы используем @RelationshipEntity (type = «MEMBER_OF»), чтобы пометить это как объект отношения, и, как и в случае с Person, мы используем @GraphId для свойства id. Аннотации @StartNode и @EndNode указывают хвостовую часть и голову соответственно. @Fetch говорит Spring Data Neo4j загружать узлы с нетерпением. По умолчанию Spring Data Neo4j не очень загружает отношения, поскольку рискует загрузить весь график в память.
Создайте PersonRepository
Вот наш интерфейс PersonRepository:
package org.skydingo.skybase.repository;
import java.util.Set;
import org.skydingo.skybase.model.Person;
import org.skydingo.skybase.model.Project;
import org.springframework.data.neo4j.annotation.Query;
import org.springframework.data.neo4j.repository.GraphRepository;
public interface PersonRepository extends GraphRepository<Person> {
Person findByUsername(String username);
@Query("start project=node({0}) match project<--person return person")
Set<Person> findByProject(Project project);
@Query(
"start person=node({0}) " +
"match person-[:MEMBER_OF]->project<-[:MEMBER_OF]-collaborator " +
"return collaborator")
Set<Person> findCollaborators(Person person);
}
В последнем посте я отметил, что все, что нам нужно сделать, это расширить интерфейс GraphRepository; Spring Data генерирует реализацию автоматически.
Для findByUsername () Spring Data может выяснить, для чего предназначен запрос. Для двух других запросов мы используем @Query и язык запросов Cypher, чтобы указать желаемый набор результатов. {0} в запросах относится к параметру метода поиска. В запросе findCollaborators () мы используем [: MEMBER_OF], чтобы указать, каким отношениям мы хотим следовать. Они возвращают наборы вместо Iterables для устранения дубликатов.
Создать веб-контроллер
Мы не будем здесь описывать весь контроллер, но рассмотрим некоторые типичные методы. Предположим, что мы ввели PersonRepository в контроллер.
Создание человека. Чтобы создать человека, мы можем использовать следующее:
@RequestMapping(value = "", method = RequestMethod.POST)
public String createPerson(Model model, @ModelAttribute Person person) {
personRepo.save(person);
return "redirect:/people?a=created";
}
Еще раз, мы игнорируем проверку. Все, что нам нужно сделать, это вызвать метод save () в хранилище. Вот так обновления тоже работают.
Нахождение всех людей. Далее, вот как мы можем получить всех людей:
@RequestMapping(value = "", method = RequestMethod.GET)
public String getPersonList(Model model) {
Iterable<Person> personIt = personRepo.findAll();
List<Person> people =
new ArrayList<Person>(IteratorUtil.asCollection(personIt));
Collections.sort(people);
model.addAttribute(people);
return "personList";
}
Нам нужно проделать некоторую работу, чтобы получить Iterable, который PersonRepository.findAll () возвращает в нужный нам формат. IteratorUtil, который поставляется с Neo4j (org.neo4j.helpers.collection.IteratorUtil), помогает здесь.
Нахождение одного человека. Здесь мы хотим отобразить личные данные, которые мы создали выше. Как и в случае с findAll (), мы должны сделать некоторые массажи самостоятельно:
@RequestMapping(value = "/{username}", method = RequestMethod.GET)
public String getPersonDetails(@PathVariable String username, Model model) {
Person person = personRepo.findByUsername(username);
List<ProjectMembership> memberships =
CollectionsUtil.asList(person.getMemberships());
List<Person> directReports =
CollectionsUtil.asList(person.getDirectReports());
List<Person> collaborators =
CollectionsUtil.asList(personRepo.findCollaborators(person));
Collections.sort(directReports);
Collections.sort(collaborators);
model.addAttribute(person);
model.addAttribute("memberships", memberships);
model.addAttribute("directReports", directReports);
model.addAttribute("collaborators", collaborators);
return "personDetails";
}
Если вы хотите увидеть JSP, зайдите на сайт Skybase GitHub .
Настройте приложение
Наконец, вот мой файл beans-service.xml:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:neo4j="http://www.springframework.org/schema/data/neo4j"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/data/neo4j
http://www.springframework.org/schema/data/neo4j/spring-neo4j-2.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
<context:property-placeholder
location="classpath:/spring/environment.properties" />
<context:annotation-config />
<context:component-scan base-package="org.skydingo.skybase.service" />
<tx:annotation-driven mode="proxy" />
<neo4j:config storeDirectory="${graphDb.dir}" />
<neo4j:repositories base-package="org.skydingo.skybase.repository" />
</beans>
Neo4j имеет базовую модель сопоставления на основе POJO и усовершенствованную модель сопоставления на основе AspectJ. В этой записи блога мы использовали базовый подход, основанный на POJO, поэтому нам не нужно включать конфигурацию, связанную с AspectJ, например <context: spring-configure />.
Там у вас есть это — Person CI при поддержке Neo4j. Удачного кодирования!