摘要：目的用于社交關(guān)系的管理和維護(hù)社交關(guān)系是一種網(wǎng)狀的關(guān)系圖難于維護(hù)這樣的數(shù)據(jù)安裝和配置需要滿足下面幾個(gè)條件安裝插件安裝驅(qū)動(dòng)安裝插件設(shè)置一下環(huán)境變量安裝插件和驅(qū)動(dòng)把復(fù)制到安裝目錄中的子目錄下重啟如何使用使用存儲(chǔ)過(guò)程加載驅(qū)動(dòng)執(zhí)行查詢

目的: 用于社交關(guān)系的管理和維護(hù). 社交關(guān)系是一種網(wǎng)狀的關(guān)系圖, RDBMS難于維護(hù)這樣的數(shù)據(jù).

需要滿足下面幾個(gè)條件

安裝 neo4j-apoc-procedures插件

安裝 MySQL JDBC驅(qū)動(dòng): https://dev.mysql.com/get/Dow...

安裝 APOC插件

設(shè)置一下環(huán)境變量

NEO4J_INSTALL_PATH=/path/to/neo4j

安裝插件和JDBC驅(qū)動(dòng)
把mysql-connector-java-8.0.11.jar復(fù)制到Neo4j安裝目錄中的plugins子目錄下.

cp mysql-connector-java-8.0.11.jar $NEO4J_INSTALL_PATH/plugins

重啟Neo4j

使用 apoc.load.driver 存儲(chǔ)過(guò)程加載驅(qū)動(dòng)

call apoc.load.driver("com.mysql.jdbc.Driver")

執(zhí)行MySQL查詢, 并在Neo4j創(chuàng)建節(jié)點(diǎn)(頂點(diǎn))和關(guān)系(邊)

CALL apoc.load.jdbc(
  "jdbc:mysql://localhost/db?user=root&password=root&useUnicode=true&characterEncoding=utf8",
  "select * from users_copy"
) YIELD row
CREATE (n:User {uuid: row.uuid, user_id: row.user_id, name: row.name})

說(shuō)明: 調(diào)用 apoc.load.jdbc 存儲(chǔ)過(guò)程連接到MySQL服務(wù)器, 數(shù)據(jù)庫(kù)名稱為 db, 用戶名和密碼都為 root, 連接到數(shù)據(jù)庫(kù)后執(zhí)行查詢 select * from users, 針對(duì)結(jié)果集的每一行, 產(chǎn)生一個(gè) user 變量. 針對(duì)每個(gè) user 變量, 執(zhí)行 Cypher 語(yǔ)句: CREATE (n:User {name: user.name}) 把 User 節(jié)點(diǎn)插入到 Neo4j 中

如果出現(xiàn)如下錯(cuò)誤:

No suitable driver found for jdbc:mysql://localhost:3306/db?user=root&password=root

需要檢查:

是否正確安裝了APOC插件

JDBC驅(qū)動(dòng)是否安裝到了正確的位置

是不是沒(méi)有重啟Neo4j服務(wù)器.

Neo4j 支持各種類型的數(shù)據(jù)源, 包括數(shù)據(jù)庫(kù), JSON, ElasticSearch, XML等. 參考APOC User Guide 的 Data Integration 章節(jié).

How do I use Cypher to connect to a RDBMS using JDBC
https://neo4j-contrib.github....