python连接neo4j|极客教程

python连接neo4j

简介

Neo4j是一个面向图形数据库的开源项目，能够处理大量的连接数据。通过Python连接Neo4j可以方便地对图形数据库进行操作，进行数据的增删改查等操作。

安装Neo4j

首先，我们需要安装Neo4j数据库。可以去官网下载最新的安装包：Neo4j官网

安装完成后，启动Neo4j数据库，并在浏览器中打开http://localhost:7474/，即可进入Neo4j的管理界面。

安装py2neo

py2neo是一个Python库，用于连接Neo4j数据库并进行操作。可以通过pip来安装py2neo：

pip install py2neo

安装完成后，就可以在Python中使用py2neo来连接Neo4j数据库了。

连接Neo4j数据库

要连接到Neo4j数据库，需要知道数据库的地址、用户名和密码。通常情况下，默认地址为bolt://localhost:7687/，用户名和密码可以在Neo4j的管理界面中进行设置。

下面是一个连接到Neo4j数据库的示例代码：

from py2neo import Graph, Node, Relationship

graph = Graph("bolt://localhost:7687/", auth=("neo4j", "password"))

在这个示例中，我们使用了py2neo库中的Graph类，传入Neo4j数据库的地址、用户名和密码来连接到数据库。

创建节点和关系

连接到Neo4j数据库后，我们可以创建节点和关系。节点表示图中的实体，关系表示实体之间的联系。

下面是一个创建节点和关系的示例代码：

# 创建节点
alice = Node("Person", name="Alice")
bob = Node("Person", name="Bob")

# 创建关系
works_with = Relationship(alice, "WORKS_WITH", bob)

# 将节点和关系添加到图中
graph.create(alice | bob | works_with)

在这个示例中，我们创建了两个节点alice和bob，类型为Person，并创建了一个关系works_with表示alice和bob之间有工作联系。

使用graph.create()方法将节点和关系添加到Neo4j数据库中。

查询数据

使用Cypher语言可以方便地对Neo4j数据库进行查询操作。以下是一些常见的查询示例：

查询所有节点和关系

result = graph.run("MATCH (n) RETURN n")
for record in result:
    print(record)

查询指定类型的节点

result = graph.run("MATCH (p:Person) RETURN p")
for record in result:
    print(record)

查询指定节点的关系

result = graph.run("MATCH (p1)-[r]->(p2) WHERE p1.name='Alice' RETURN r")
for record in result:
    print(record)

通过Cypher语言，我们可以灵活地查询到我们需要的数据。

更新数据

更新Neo4j数据库中的数据也是很简单的，可以通过Cypher语言来执行UPDATE语句。

下面是一个更新节点属性的示例代码：

graph.run("MATCH (p:Person) WHERE p.name='Alice' SET p.age=30")

在这个示例中，我们更新了Person节点中名为Alice的节点的age属性为30。

删除数据

删除Neo4j数据库中的数据也是很容易的，可以通过Cypher语言来执行DELETE语句。

下面是一个删除节点的示例代码：

graph.run("MATCH (p:Person) WHERE p.name='Alice' DELETE p")

在这个示例中，我们删除了Person节点中名为Alice的节点。

关闭连接

在操作完成后，记得关闭和释放连接资源。

graph.close()

完整示例代码

下面是一个完整的Python连接Neo4j数据库的示例代码：

from py2neo import Graph, Node, Relationship

graph = Graph("bolt://localhost:7687/", auth=("neo4j", "password"))

# 创建节点
alice = Node("Person", name="Alice")
bob = Node("Person", name="Bob")

# 创建关系
works_with = Relationship(alice, "WORKS_WITH", bob)

# 将节点和关系添加到图中
graph.create(alice | bob | works_with)

# 查询所有节点和关系
result = graph.run("MATCH (n) RETURN n")
for record in result:
    print(record)

# 更新节点属性
graph.run("MATCH (p:Person) WHERE p.name='Alice' SET p.age=30")

# 删除节点
graph.run("MATCH (p:Person) WHERE p.name='Alice' DELETE p")

# 关闭连接
graph.close()