4

我将我的节点表示为域实体。我想通过 REST 接口公开我的节点，使用 GET 按 id 查询，POST 保存节点及其相关节点，PUT 更新节点及其相关节点。GET 工作得很好，但我有一个关于 POST 和 PUT 案例的实施问题。让我来说明这个问题，因为代码通常比文字说的更多。

在此示例中，有两种相关的节点类型表示为域实体。一个协作可以有多个标签，一个标签可以属于多个协作。所以我们有一个多对多的关系。它们都共享相同的基类 NodeBacked，它基本上用作底层节点的包装器。

节点支持

abstract class NodeBacked {

    private Node node;

    public NodeBacked(final Node node) {
        this.node = node;
    }

    public Long getId() {
        return this.node.getId();
    }

    @Override
    public int hashCode() {
        return this.node.hashCode();
    }   

    @JsonIgnore
    public Node getNode() {
        return this.node;
    }

}

合作

public class Collaboration extends NodeBacked {

    public Collaboration(final Node node) {
        super(node);
    }

    // Leaving out some properties for clearness

    @JsonProperty(NAME_JSON)
    public String getName() {
        return (String) getNode().getProperty(NAME);
    }   

    @JsonProperty(TAGS_JSON)
    public Iterable<Tag> getTags() {
        return new IterableWrapper<Tag, Path>(Traversal.description().breadthFirst()
                .relationships(Relationships.HAS, Direction.OUTGOING).uniqueness(Uniqueness.NODE_GLOBAL)
                .evaluator(Evaluators.atDepth(1)).evaluator(Evaluators.excludeStartPosition()).traverse(getNode())) 

{
            @Override
            protected Tag underlyingObjectToObject(final Path path) {
                return new Tag(path.endNode());
            }
        };
    }

    public void setName(final String name) {
        final Index<Node> index = getNode().getGraphDatabase().index().forNodes(Indexes.NAMES);
        getNode().setProperty(NAME, name);
        if (StringUtils.isNotEmpty(getName())) {
            index.remove(getNode(), NAME, name);
        }
        index.add(getNode(), NAME, name);
    }

    public void addTag(final Tag tag) {
        if (!Traversal.description().breadthFirst().relationships(Relationships.HAS, Direction.OUTGOING)
                .uniqueness(Uniqueness.NODE_GLOBAL).evaluator(Evaluators.atDepth(1))
                .evaluator(Evaluators.excludeStartPosition())
                .evaluator(Evaluators.includeWhereEndNodeIs(tag.getNode())).traverse(getNode()).iterator().hasNext

()) {
            getNode().createRelationshipTo(tag.getNode(), Relationships.HAS);
        }
    }

    @Override
    public boolean equals(final Object o) {
        return o instanceof Collaboration && getNode().equals(((Collaboration) o).getNode());
    }

}

标签

public class Tag extends NodeBacked {

    public Tag(final Node node) {
        super(node);
    }

    @JsonProperty(NAME_JSON)
    public String getName() {
        return (String) getNode().getProperty(NAME);
    }

    public void setName(final String name) {
        final Index<Node> index = getNode().getGraphDatabase().index().forNodes(Indexes.NAMES);
        getNode().setProperty(NAME, name);
        if (StringUtils.isNotEmpty(getName())) {
            index.remove(getNode(), NAME, name);
        }
        index.add(getNode(), NAME, name);
    }

    @JsonProperty(COLLABORATIONS_JSON)
    @JsonSerialize(using = SimpleCollaborationSerializer.class)
    private Iterable<Collaboration> getCollaborations(int depth) {
        return new IterableWrapper<Collaboration, Path>(Traversal.description().breadthFirst()
                .relationships(Relationships.HAS, Direction.INCOMING).uniqueness(Uniqueness.NODE_GLOBAL)
                .evaluator(Evaluators.atDepth(1)).evaluator(Evaluators.excludeStartPosition()).traverse(getNode())) 

{
            @Override
            protected Collaboration underlyingObjectToObject(final Path path) {
                return new Collaboration(path.endNode());
            }
        };
    }

    @Override
    public boolean equals(final Object o) {
        return o instanceof Tag && getNode().equals(((Tag) o).getNode());
    }

}

我将通过 REST (Spring 3.2) 公开协作，如下所示。MappingJackson2HttpMessageConverter用于将 POJO转换为 JSON，反之亦然。

@Controller
@RequestMapping(value = CollaborationController.CONTEXT_PATH)
public class CollaborationController {

    public static final String CONTEXT_PATH = "/collaborations";

    @Autowired
    private GraphDatabaseService db;

    @Transactional
    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
    public @ResponseBody Collaboration getCollaboration(final @PathVariable Long id) {
        // should use a service layer but doing this for clearness
        return new Collaboration(db.getNodeById(id));
    }   

}

这很好用。getter 查询节点的属性并返回一个像样的 JSON 字符串。一个示例 JSON 字符串GET /collaborations/1：

{
  "name" : "Dummy Collaboration",
  "tags" : [ {
    "name" : "test",
    "id" : 3
  }, {
    "name" : "dummy",
    "id" : 2
  } ],
  "id" : 1
}

那么，有什么问题呢？想象一个带有 JSON 主体的 POST 请求，如下所示：

{
  "name" : "Second collaboration",
  "tags" : [ {
    "name" : "tagged"
  } ]
}

CollaborationController 有以下方法来处理 POST 请求：

@Transactional
    @RequestMapping(method = RequestMethod.POST, headers = JSON_CONTENT_TYPE)
    public @ResponseBody ResponseEntity<Collaboration> persist(final @RequestBody Collaboration collaboration, 
            final UriComponentsBuilder builder) {
        final Collaboration collab = new Collaboration(db.createNode(Labels.COLLAB));
        // Problem!!
        collab.setName(collaboration.getName());        

        final HttpHeaders headers = new HttpHeaders();
        headers.setLocation(builder.path(CONTEXT_PATH + "/{id}").buildAndExpand(collab.getId()).toUri());
        return new ResponseEntity<Collaboration>(collab, headers, HttpStatus.CREATED);
    }

该行collab.setName(collaboration.getName());不起作用，因为协作类不包含它自己的属性，并且使用直接查询底层节点的 getter。在这种情况下，没有任何可用的节点，因为协作应该由 Jackson2 使用 Spring 的 MappingJackson2HttpMessageConverter 从 JSON 转换为 POJO。没有任何属性，所以没有什么要设置的......

我正在寻找解决这个问题的最干净的解决方案，但还没有找到。我可以使用 POJO（或 VO 或 ...）作为 persist 方法的传入参数，但这并不是真正可维护的。更改属性需要更新 Collaboration 类以及 CollaborationVO（POJO）类。

欢迎提出建议！Spring Data Neo4j 主要解决了所有这些问题，但我对它的性能并不满意。这就是我尝试另一种方法的确切原因。

我希望这个解释足够清楚。谢谢你陪我！

使用的框架：

  • Spring 3.2.3.RELEASE
  • Neo4j 2.0.0-M3（嵌入式）
  • 杰克逊 2.2.2
4

1 回答 1

1

你说：

I could use a POJO (or VO or ...) as incoming parameter for the persist method, 
but that's not really maintainable.

但我看不出有什么办法——虽然我同意这看起来很丑，而且应该有更好的办法；但是，我还没有看到一个。

未讨论的方法的一个方面是它向客户端公开了底层数据库实现。当然，它被序列化为 JSON，但这会阻止客户端将“协作（或标签）”对象放在一起吗？[您的客户端可能是 javascript 客户端，因此这不是问题，但这并不能阻止其他一些假设的客户端构建您的对象之一。] 如果该客户端调用 getCollaborations()（或 getTags()）会发生什么方法？对我来说，这是两害相权之害。

我会将您现有的域实体更改为 ECollaboration/ETag 之类的东西，然后为 Collaboration/Tag 创建纯 POJO。E 类知道 POJO 是可以的，但反之则不行。因此，E 类也都可以实现一个接口，其方法如下：“convert()”和“valueOf()”，以在 API 类和域类之间进行转换。实际上，这些方法也有助于一点点的可维护性——当某些事情发生变化时，您可以很容易地看到对另一个对象的影响。

于 2013-07-02T13:12:45.177 回答