python neo4j

gaohaikuo1

from py2neo import Graph, Node, Relationship
import pandas
db = Graph("bolt://localhost:7687", user="neo4j", password="gao6318866", name="neo4j") # 连接数据库


node_1 = Node('英雄',name = '张无忌')
node_2 = Node('英雄',name = '杨逍',武力值='100')
node_3 = Node('派别',name = '明教')

# 存入图数据库
db.create(node_1)
db.create(node_2)
db.create(node_3)
print(node_1)

gaohaikuo1

从excel读取文件，并提取其中几列作为节点和属性，并建立连接

import pandas as pd
from py2neo import Graph, Node, Relationship

# 读取Excel文件
#df = pd.read_excel('abc.csv',sheet_name=0,header = 0)
df = pd.read_csv("abc.csv",header = 2)
# 查看前几行数据
print(df[['姓名','业绩名称']].head(10))



db = Graph("bolt://localhost:7687", user="neo4j", password="gao6318866", name="neo4j") # 连接数据库


node_1 = Node('英雄',name = '张无忌')
node_2 = Node('英雄',name = '杨逍',武力值='100')
node_3 = Node('派别',name = '明教')

# 存入图数据库
db.create(node_1)
db.create(node_2)
db.create(node_3)
print(node_1)

gaohaikuo1

读取excel文件
import pandas as pd
from py2neo import Graph, Node, Relationship

# 读取Excel文件
#df = pd.read_excel('abc.csv',sheet_name=0,header = 0)
df = pd.read_csv("abc.csv",header = 2)
# 查看前几行数据
print(df[['姓名','业绩名称']].head(10))

gaohaikuo1

给已有节点添加属性
db = Graph("bolt://localhost:7687", user="neo4j", password="gao6318866", name="neo4j") # 连接数据库
node_matcher =  NodeMatcher(db);
node= node_matcher.match("英雄",name="杨逍").first()
node["email"] = "alice@example.com"
node["city"] = "New York"
db.push(node)

gaohaikuo1

读取excel并创建节点
import pandas as pd
from py2neo import Graph, Node, Relationship,NodeMatcher

def readExcel(file_name,dropna_col = ''):

    # 读取Excel文件
    #df = pd.read_excel('abc.csv',sheet_name=0,header = 0)
    df = pd.read_csv(file_name,header = 2)
    if dropna_col != '':
        df1 = df.dropna(subset = [dropna_col])
    # 查看前几行数据
    print(df1[['姓名','业绩名称']])
    return df1


df = readExcel(file_name = 'abc.csv',dropna_col = '姓名');
db = Graph("bolt://localhost:7687", user="neo4j", password="gao6318866", name="neo4j") # 连接数据库


def create_node_from_df(df,db,label,attributes):
    for index, row in df.iterrows():
        name = row['姓名']
        job_number = row['工号']
        node = Node("教师");
        for attr in attributes:
            node[attr] = row[attr]
        db.create(node)
create_node_from_df(df,db,label = '教师',attributes = ["姓名","工号"])