Python同步數據庫的數據到Neo4J

寫了主要是步驟，如果疑問，請咨詢QQ:5988628

Python版本采用2.7.X，默認的2.6.X后期會有問題，建議，一開始就升級Python。然后再安裝pip。

 

訪問數據庫

sqlalchemy + pyodbc，要是從linux訪問windows 上的MS Sql Server，還需要安裝freetds

 

訪問Neo4J的驅動采用 neo4j-rest-client

https://neo4j-rest-client.readthedocs.org/en/latest/info.html

 

以下是示例代碼：

#StatService.py
import urllib
import time
import sqlalchemy
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
from sqlalchemy import Column, Integer, String, Text, ForeignKey, Numeric, Unicode
from datetime import datetime

from neo4jrestclient.client import GraphDatabase

class StatService:

def __init(self):pass

def Run(self):
print 'Hello, World!'

quoted = urllib.quote_plus('DRIVER={FreeTDS};Server=xxx.meiyuetao.idc;Database=xxx;UID=xxx;PWD=xxx;TDS_Version=7.0;Port=1433;')
engine = sqlalchemy.create_engine('mssql+pyodbc:///?odbc_connect={0}'.format(quoted))

#讀取數據庫示例
connection = engine.connect()
result = connection.execute("select * from t_sys_config_parameter where code = 'RELATION_SYNC'")
for row in result:
print "value:", row['value']
connection.close()

#處理邏輯,數據映射等

#插入數據到Neo4J示例
gdb = GraphDatabase("http://localhost:7474/db/data/")
n = gdb.nodes.create(Name="Jason")
root = gdb.node[0]
root.relationships.create("Referral", n)

if __name__ == '__main__':
StatService().Run()

#End