国产探花免费观看_亚洲丰满少妇自慰呻吟_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


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 衢州市| 青冈县| 莒南县| 银川市| 泽库县| 吉木萨尔县| 连南| 慈溪市| 博爱县| 凉山| 宁夏| 马山县| 绥江县| 喀喇| 黔西县| 凤翔县| 临夏市| 柘城县| 绥中县| 岐山县| 临潭县| 鸡东县| 安宁市| 钟祥市| 财经| 卓资县| 长沙市| 且末县| 黑山县| 云和县| 潜山县| 铜鼓县| 峡江县| 杭锦旗| 科技| 新郑市| 伽师县| 尉氏县| 洛扎县| 兴隆县| 喀什市|