我正在尝试使用 Neo4J 上的触发器在 CSV 中记录节点或关系被删除时的详细信息。在尝试了不同的触发查询后,我发现尝试将已删除关系的详细信息直接写入 csv 是行不通的,但是创建一个虚拟节点来记录关系详细信息,然后将 v-node 写入 csv 可以。我使用的查询是这样的:
call apoc.trigger.add("deletingRels","UNWIND {deletedRelationships} as del WITH del call apoc.create.vNode(['Record'], {startUUID:startNode(del).uuid, endUUID:endNode(del).uuid, relType:type(del)}) YIELD node as r WITH r, collect(r) as rs,'D:/export/reldeltest.cql' as filename call apoc.when(size(rs) > 0,'call apoc.export.csv.data(rs,[],filename,{quotes:false,useTypes:false}) YIELD rows RETURN rows','',{rs:rs,filename:filename}) YIELD value RETURN value",{phase:"before"})
运行查询:
match (t:Test {name:"test 12"})-[r]->(s:Test {name:"test 7"}) delete r return t,s
删除关系 r 并令人满意地产生以下 csv:
"_id","_labels","startUUID","relType","endUUID","_start","_end","_type"
"-4",":Record","f8ccb190-fd43-11e7-866b-40b034e34b1f","testR","ad45c410-fd24-11e7-90a4-40b034e34b1f",,,
删除节点的类似触发器是:
call apoc.trigger.add("deletingNodes", "UNWIND {deletedNodes} as del WITH del call apoc.create.vNode(['Record'], {uuid:del.uuid, nodeLabels:labels(del)}) YIELD node as r WITH r, collect(r) as rs,'D:/export/nodedeltest.cql' as filename call apoc.when(size(rs) > 0,'call apoc.export.csv.data(rs,[],filename,{quotes:false,useTypes:false}) YIELD rows RETURN rows','',{rs:rs,filename:filename}) YIELD value RETURN value", {phase:"before"})
运行查询以删除节点会导致 Neo4J 浏览器中出现以下错误消息:
Neo.ClientError.Transaction.TransactionHookFailed
控制台中的错误日志开始:
WARN Error executing trigger deletingNodes in phase before Node with id 1364 has been dele
ted in this transaction
org.neo4j.graphdb.QueryExecutionException: Node with id 1364 has been deleted in this transaction
at org.neo4j.kernel.impl.query.QueryExecutionKernelException.asUserException(QueryExecutionKernelException.java:
35).
运行查询以匹配该节点表明它仍然存在。
我在 Windows 上运行 Neo4J 3.3.1 的压缩版本,并在控制台中安装了 apoc 3.3.1 插件。
有人可以帮忙吗?