【学习笔记】Python 操作 Neo4j ——基础操作+CSV_neo4j,python,csv

准备：

环境：Windows11、Java 11、neo4j 4.0.1

Java11安装：官网下载JAVA的JDK11版本（下载、安装、配置环境变量）_java11-CSDN博客

neo4j （Windows）下载链接：（想下载哪个版本就直接改后面的版本号）

    Neo4j 4.0.x 需要 JDK 11。

    Neo4j 4.1.x、4.2.x 和 4.3.x 需要 JDK 11。

    Neo4j 4.4.x 及以后的版本需要 JDK 11 或 JDK 16。

https://dist.neo4j.org/neo4j-community-4.0.1-windows.zip

1、安装 py2neo：

      在pycharm命令行下输入 pip install py2neo

2、cmd命令行启动neo4j：

      neo4j console

3、基础操作：

from py2neo import Graph, Node, Relationship
 
graph=Graph('http://localhost:7474/', name='neo4j', password='你的密码')   #连接数据库并初始化
graph.delete_all()  #清空数据库
 
n1=Node('Imperial',name='皇帝')  #创建节点（标签，属性1，属性2...）
n2=Node('Imperial',name='皇后')
n3=Node('Imperial',name='公主')
 
n1['age']=22  #向n1节点添加一个属性
 
graph.create(n1)  #创建节点
graph.create(n2)
graph.create(n3)
 
r1=Relationship(n1, 'husband', n2)  #调用Relationship函数定义一段关系：n1是n2的丈夫
r1['count']=1  #为关系r1添加一个属性
r2=Relationship(n2, 'wife', n1)
r2['count']=1
r3=Relationship(n2, 'mother', n3)
 
graph.create(r1)  #创建关系
graph.create(r2)
graph.create(r3)
 
print(graph)  #打印图
print(n1)  #打印节点
print(r2)  #打印关系

4、导入csv文件创建数据库：

      excel另存为csv文件时要注意使用utf-8编码，若不是，可用记事本打开后另存为时修改

      基金数据下载：https://www.szse.cn/market/product/list/all/index.html

from py2neo import Graph, Node, Relationship
import pandas as pd
import csv
 
graph=Graph('http://localhost:7474/', name='neo4j', password='你的密码')  #连接数据库并初始化
graph.delete_all()  #清空数据库
 
with open ('E:\\Learning\\pythonFile\\neo4jStudy\\funds.csv','r', encoding='utf-8') as f:  #使用utf-8编码读取csv文件
    reader=csv.reader(f)
    data=list(reader) #存为list
 
print(data[1])
 
for i in range(1, len(data)):  #循环读取 list 创建结点和关系
    fund = Node('ETF fund', id=data[i][0], name=data[i][1], listing_date=data[i][4])  #基金节点
    investment_category = Node('investment category',name=data[i][3])  #投资类型节点
    custodian = Node('custodian', name=data[i][6])  #管理人节点
 
 
    relationship1 = Relationship(custodian, '管理', fund)  #关系
    relationship2 = Relationship(fund,'投资', investment_category)  #关系
 
    graph.create(fund)  #创建节点以及关系
    graph.create(relationship1)
    graph.create(relationship2)