Neo4J 中的幂等性检查

Question

有人知道如何根据现有数据插入到 Neo4J 中吗？这是数据摄取的一部分。

例如，neo4j 中已经有一个属性为updatedAt 的节点。每当接收到新的 pubsub 事件以摄取数据时，我需要检查传入数据和 neo4j 中现有节点的 updatedAt 属性，并决定需要丢弃哪些数据。

最后，neo4j 应该有一个具有最新updatedAt 值的节点。

除了Triggers，APOC还有什么办法吗？

请帮忙。我对 Neo4j 真的很陌生。谢谢

Answer 1

我认为您正在寻找的是 Cypher MERGE 查询，更准确地说是 MERGE 查询与 ON CREATE 和 ON MATCH。例如：

MERGE (n:TYPE_OF_NODE { id: 'ID_OF_NODE_TO_BE_FOUND' })
ON CREATE SET 
    n.createdAt = INPUT_DATE,
    .../* Set other attributes if needed */
ON MATCH SET n.updatedAt = 
    CASE WHEN n.updatedAt < INPUT_DATE THEN INPUT_DATE ELSE n.updatedAt END,
    ... /* Set other attributes if needed */
RETURN n

上面的查询检查是否存在给定类型 TYPE_OF_NODE 且 id 等于 ID_OF_NODE_TO_BE_FOUND 的节点。 INPUT_DATE 我的意思是某个日期与接收数据的事件一起接收。

1. 如果一个节点不存在，就会创建它并设置一些属性 （见ON CREATE SET）。
2. 如果它存在，那么它将被更新（参见 ON MATCH SET)。具体来说，updateAt 属性将设置为 后面的值，为此我使用了CASE 声明。