# 导入Neo4j驱动程序
from neo4j import GraphDatabase
# 定义一个类来处理与Neo4j数据库的交互
class Neo4jConnection:
def __init__(self, uri, user, password):
self.driver = GraphDatabase.driver(uri, auth=(user, password))
def close(self):
self.driver.close()
# 创建节点和关系的示例方法
def create_node_and_relationship(self):
with self.driver.session() as session:
# 创建两个节点并建立关系
result = session.run(
"""
MERGE (a:Person {name: $name1})
MERGE (b:Person {name: $name2})
MERGE (a)-[r:FRIEND]->(b)
RETURN a.name, b.name, type(r)
""",
name1="Alice", name2="Bob"
)
for record in result:
print(record)
# 使用示例
if __name__ == "__main__":
# 连接到本地Neo4j实例
conn = Neo4jConnection("bolt://localhost:7687", "neo4j", "password")
# 创建节点和关系
conn.create_node_and_relationship()
# 关闭连接
conn.close()
neo4j
库中的GraphDatabase
类来连接和操作Neo4j数据库。Neo4jConnection
类:封装了与Neo4j数据库的连接逻辑,包括初始化、关闭连接以及创建节点和关系的方法。Person
节点,并建立它们之间的FRIEND
关系。Neo4jConnection
对象,调用方法创建节点和关系,并最终关闭连接。这段代码展示了如何使用Python与Neo4j数据库进行交互,创建节点和关系,并执行简单的查询。
下一篇:python转字符串
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站