from neo4j import GraphDatabase driver = GraphDatabase.driver("bolt://localhost:7687", auth=("neo4j", "password"))
with driver.session() as session:result = session.run("MATCH (n:User) RETURN n.name LIMIT 10")print([record["n.name"] for record in result])# 关闭驱动
driver.close()
2. 全功能ORM(py2neo)
特点
支持节点/关系对象化操作,内置子图事务管理
集成GIS空间数据处理(WKT格式与Neo4j Spatial插件兼容)
提供GraphQL转换工具,一键生成API端点
代码示例
from py2neo import Graph, Node graph = Graph("bolt://localhost:7687", auth=("neo4j", "password"))
user = Node("User", name="Alice", age=30)
graph.create(user) # 自动提交事务
3. 领域驱动设计框架(neomodel-odm)
特点
类Django的声明式模型定义,支持DDD模式(聚合根、值对象)
自动生成数据库迁移脚本,兼容CI/CD流水线
内置事件溯源(Event Sourcing)和CQRS模式支持
代码示例
from neomodel_odm import StructuredNode, StringProperty class Product(StructuredNode):sku = StringProperty(unique_index=True)name = StringProperty(required=True)# 自动创建唯一约束并持久化
Product(sku="P-2025", name="Quantum Laptop").save()
4. 异步高性能驱动(asyncneo4j)
特点
专为微服务设计,支持万级并发连接
内置连接池自动扩缩容与故障转移机制
优化Bolt协议二进制编码,降低网络开销30%
代码示例
from asyncneo4j import Neo4jClient client = Neo4jClient("bolt://cluster-node:7687", pool_size=20)
async with client.transaction() as tx:await tx.execute("CREATE (:Log {level: $level})", level="INFO")