国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

Python同步數據庫的數據到Neo4J

2019-11-14 16:59:43
字體:
來源:轉載
供稿:網友

寫了主要是步驟,如果疑問,請咨詢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):

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


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 新疆| 上饶县| 射阳县| 长白| 宜兰县| 安塞县| 河池市| 江山市| 高台县| 阿瓦提县| 合川市| 祁阳县| 南涧| 岐山县| 阳江市| 临沂市| 收藏| 波密县| 莲花县| 东乌珠穆沁旗| 新密市| 延边| 积石山| 大连市| 图片| 房山区| 五河县| 新野县| 东阿县| 克山县| 海阳市| 德格县| 福贡县| 合江县| 横峰县| 米林县| 定南县| 英德市| 宾阳县| 云林县| 隆德县|