如何将SQL递归层次关系表转换为Neo4j？

Question

我有一个2递归字段PersonID和FollowPersonID的表，存储所有人之间的关系（人1跟随人2，人2跟随人1），我想提取并创建neo4J相关的网络。是否有捷径可寻？

Answer 1

该表格（我称之为“Follows”）可以变成两个Person节点之间的关系FOLLOWS。

你应该可以使用一些APOC procedures for loading using JDBC来帮助你做到这一点。

下面是一个例子：

CALL apoc.load.driver("com.mysql.jdbc.Driver") 
CALL apoc.load.jdbc("jdbc:mysql://localhost:3306/mydb?user=root", "Follows") YIELD row 
MATCH (p1:Person {id: row.PersonId}), (p2:Person {id: row.FollowPersonId}) 
MERGE (p1)-[:FOLLOWS]->(p2); 

如果该表是大的（或者有很多Person节点），这也将是有意义的首先创建一个索引（或唯一约束）上Person(id)到加快导入：

CREATE INDEX ON :Person(id); 

如果创建索引，这种形式的查询应确保使用索引（见this other answer一些更多细节）：

CALL apoc.load.driver("com.mysql.jdbc.Driver") 
CALL apoc.load.jdbc("jdbc:mysql://localhost:3306/mydb?user=root", "Follows") YIELD row 
WITH row.PersonId AS id1, row.FollowPersonId AS id2 
MATCH (p1:Person {id: id1}), (p2:Person {id: id2}) 
USING INDEX p1:Person(id) 
USING INDEX p2:Person(id) 
MERGE (p1)-[:FOLLOWS]->(p2); 

Answer 2

如果您正在寻找各种方法来连接到数据库，那么你可以使用APOC与以下步骤

CALL apoc.load.driver('your_jdbc_driver'); 
CALL apoc.load.jdbc(url, 'SELECT PersonID, FollowPersonID FROM PersonFollow;') 

连接和检索数据，例如，然后你就可以创建所有的节点和关系，如果你使用MERGE。例如像这样：

CREATE CONSTRAINT ON (p:Person) ASSERT p.PersonID IS UNIQUE; 

with "your_jdbc_url" as url 
CALL apoc.load.jdbc(url, 'SELECT PersonID, FollowPersonID 
FROM PersonFollow;') YIELD row 
MERGE (p:Person {PersonID:row.PersonID}) 
MERGE (f:Person {PersonID:row.FollowPersonID}) 
CREATE (p)-[:FOLLOWS]->(f) 

MERGE允许有也执行不同的操作创建和匹配，所以它可以设置其他属性值，根据节点的存在，或者如果它是一个新的节点