neo4j与mysql数据库_Neo4j: 迁移MySQL的数据到Neo4j
目的: 用于社交關系的管理和維護. 社交關系是一種網狀的關系圖, RDBMS難于維護這樣的數據.
安裝和配置
需要滿足下面幾個條件
安裝 neo4j-apoc-procedures插件
安裝 APOC插件
設置一下環境變量
NEO4J_INSTALL_PATH=/path/to/neo4j
安裝插件和JDBC驅動
把mysql-connector-java-8.0.11.jar復制到Neo4j安裝目錄中的plugins子目錄下.
cp mysql-connector-java-8.0.11.jar $NEO4J_INSTALL_PATH/plugins
重啟Neo4j
如何使用
使用 apoc.load.driver 存儲過程加載驅動
call apoc.load.driver('com.mysql.jdbc.Driver')
執行MySQL查詢, 并在Neo4j創建節點(頂點)和關系(邊)
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})
說明: 調用 apoc.load.jdbc 存儲過程連接到MySQL服務器, 數據庫名稱為 db, 用戶名和密碼都為 root, 連接到數據庫后執行查詢 select * from users, 針對結果集的每一行, 產生一個 user 變量. 針對每個 user 變量, 執行 Cypher 語句: CREATE (n:User {name: user.name}) 把 User 節點插入到 Neo4j 中
錯誤處理
如果出現如下錯誤:
No suitable driver found for jdbc:mysql://localhost:3306/db?user=root&password=root
需要檢查:
是否正確安裝了APOC插件
JDBC驅動是否安裝到了正確的位置
是不是沒有重啟Neo4j服務器.
參考資料
Neo4j 支持各種類型的數據源, 包括數據庫, JSON, ElasticSearch, XML等. 參考APOC User Guide 的 Data Integration 章節.
總結
以上是生活随笔為你收集整理的neo4j与mysql数据库_Neo4j: 迁移MySQL的数据到Neo4j的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 记录一次众测平台邀请码获取
- 下一篇: python数据处理常用函数_panda