数据分析之图算法: 基于Spark和Neo4j

36

｜

第

4

章

4.1.2

　将数据导入

Neo4j

下面介绍如何将数据导入

Neo4j

，首先加载节点：

WITH

"https://github.com/neo4j-graph-analytics/book/raw/master/data"

AS

base

WITH

base + "transport-nodes.csv"

AS

uri

LOAD CSV

WITH

HEADERS FROM uri

AS

row

MERGE (place:Place {id:row.id})

SET

place.latitude = toFloat(row.latitude),

place.longitude = toFloat(row.latitude),

place.population = toInteger(row.population)

然后加载关系：

WITH

"https://github.com/neo4j-graph-analytics/book/raw/master/data/"

AS

base

WITH

base + "transport-relationships.csv"

AS

uri

LOAD CSV

WITH

HEADERS FROM uri

AS

row

MATCH

(origin:Place {id: row.src})

MATCH

(destination:Place {id: row.dst})

MERGE (origin)-[:EROAD {distance: toInteger(row.cost)}]->(destination) ...