之前的教程中我们讲述了如何在linux系统下构建起neo4j 服务器,但是没有试过用我们最常见的语言接口对服务器进行创建节点,关系等常规操作,今天我们将重点讲述如何使用py2neo进行数据库连接,节点 关系创建等操作;
首先讲述的是如何安装py2neo,这个是老生常谈
pip install py2neo --user
一般默认安装的是最新版本的,我测试的时候使用的是3.1.2版本的;
其次,我们来尝试下数据库连接方式,感谢万能的python社区,py2neo中的接口可以用简单、可靠来形容;
#################################################
# g是这个python中获取到的数据库句柄,后续可以通过这个g来
# 进行创建,查询,删除等各种操作;
#################################################
from py2neo import Graph,Node,Relationship
g = Graph(
host = "1.1.1.1", # neo4j 搭载服务器的ip地址,ifconfig可获取到
http_port = 7978, # neo4j 服务器监听的端口号
user = "neo4j", # 数据库user name,如果没有更改过,应该是neo4j
password = "******" # 自己设定的密码
)
- 为了更好的尝试py2neo的创建功能,我们需要在下面中编写几个样本例子,其中包括node,以及node之间的relationship。
def test_create_node():
global g
"""
g.delete_all()
tx = g.begin()
worker_1 = {"name":"allen","age":13,"company":"google inc"}
worker_2 = {"name":"john","age":24,"company":"microsoft inc"}
node_1 = Node("WORKER",**worker_1)
node_2 = Node("WORKER",**worker_2)
rel_1_2 = Relationship(node_1,"CO_WORKER",node_2)
tx.merge(node_1)
tx.merge(node_2)
tx.merge(rel_1_2)
tx.commit()
"""
g.delete_all()
tx = g.begin()
# in loop mode
worker_list = [
{"name":"allen","age":13,"company":"google inc"},
{"name":"john","age":24,"company":"microsoft inc"}
]
for worker in worker_list:
node = Node("WORKER",**worker)
tx.merge(node)
node1 = Node(name="allen")
node2 = Node(name="john")
rel = Relationship(node1,"CO_WORKER",node2)
tx.merge(rel)
tx.commit()
- g.delete_all()将会删除数据库中所有的节点和关系,g.begin()是一定要放在执行代码的前面的,作者在上述的脚本中使用了两种模式,一种是顺序添加,就是被注释掉的那块,这样做是为了体会流程,一种是用循环方式添加,工程中可以将节点放到文件中,使用循环方式添加,高效,快捷;在创建节点的时候建议使用 tx.merge,这个相当于create if not exist,很多事情不用自己操心,最后提交tx.commit(),将所有的东西都会push到远端的neo4j服务器上,最后我们可以在neo4j的html界面上,输入 以下命令,前端中就会显示刚才创建的节点和关系:
MATCH p=()-[r:CO_WORKER]->() RETURN p LIMIT 25
- 更多教程,详见:neo4j 官网