|
|
from Util import *
|
|
|
# 连接数据库
|
|
|
db = Graph("neo4j://10.10.21.20:7687", auth=("neo4j", "DsideaL4r5t6y7u"))
|
|
|
# 清空
|
|
|
clear(db)
|
|
|
|
|
|
# 创建节点
|
|
|
node_1 = Node("英雄", name="张无忌")
|
|
|
node_2 = Node("英雄", name="杨逍", power=100)
|
|
|
node_3 = Node("派别", name="明教")
|
|
|
|
|
|
# 创建关系
|
|
|
relations = [
|
|
|
(node_1, '教主', node_2),
|
|
|
(node_3, '统领', node_1), # 修正原代码可能的逻辑关系
|
|
|
(node_2, '师出', node_3)
|
|
|
]
|
|
|
|
|
|
# 构建子图并提交
|
|
|
subgraph = Subgraph(
|
|
|
nodes=[node_1, node_2, node_3],
|
|
|
relationships=[Relationship(r[0], r[1], r[2]) for r in relations]
|
|
|
)
|
|
|
db.create(subgraph)
|
|
|
|
|
|
from py2neo import Path
|
|
|
# 建一个路径：比如按照该路径查询，或者遍历的结果保存为路径
|
|
|
node_4, node_5, node_6 = Node(name='阿大'), Node(name='阿二'), Node(name='阿三')
|
|
|
path_1 = Path(node_4, '小弟', node_5, Relationship(node_6, "小弟", node_5), node_6)
|
|
|
db.create(path_1)
|
|
|
|
|
|
print(path_1)
|
|
|
|
|
|
# 创建一个子图，并通过子图的方式更新数据库
|
|
|
node_7 = Node('英雄', name='张翠山')
|
|
|
node_8 = Node('英雄', name='殷素素')
|
|
|
node_9 = Node('英雄', name='狮王')
|
|
|
|
|
|
relationship7 = Relationship(node_1, '生父', node_7)
|
|
|
relationship8 = Relationship(node_1, '生母', node_8)
|
|
|
relationship9 = Relationship(node_1, '义父', node_9)
|
|
|
subgraph_1 = Subgraph(nodes=[node_7, node_8, node_9], relationships=[relationship7, relationship8, relationship9])
|
|
|
db.create(subgraph_1)
|
|
|
|
|
|
|
|
|
# 创建一个新的事务
|
|
|
transaction_1 = db.begin()#事务开始
|
|
|
|
|
|
# 创建一个新node
|
|
|
node_10 = Node('武当',name = '张三丰')
|
|
|
transaction_1.create(node_10)
|
|
|
# 创建两个关系：张无忌→（师公）→张三丰 张翠山→（妻子）→殷素素
|
|
|
relationship_10 = Relationship(node_1,'师公',node_10)
|
|
|
relationship_11 = Relationship(node_7,'妻子',node_8)
|
|
|
|
|
|
transaction_1.create(relationship_10)
|
|
|
transaction_1.create(relationship_11)
|
|
|
|
|
|
transaction_1.commit()#事务提交
|
|
|
|
|
|
from py2neo import RelationshipMatcher
|
|
|
|
|
|
# 查询某条关系
|
|
|
relation = RelationshipMatcher(db)
|
|
|
|
|
|
# None表示any node哦！不是表示空
|
|
|
print('=' * 10, 'hate关系查询结果', '=' * 10)
|
|
|
x = relation.match(nodes=None, r_type='hate')
|
|
|
for x_ in x:
|
|
|
print(x_)
|
|
|
|
|
|
# 为了便于查询更多类容，使用事务的方法新增一些关系和节点
|
|
|
transaction_2 = db.begin()
|
|
|
|
|
|
node_100 = Node('巾帼', name='赵敏')
|
|
|
re_100 = Relationship(node_1, 'Love', node_100)
|
|
|
|
|
|
node_101 = Node('巾帼', name='周芷若')
|
|
|
re_101 = Relationship(node_1, 'knows', node_101)
|
|
|
re_101_ = Relationship(node_101, 'hate', node_100)
|
|
|
|
|
|
node_102 = Node('巾帼', name='小昭')
|
|
|
re_102 = Relationship(node_1, 'konws', node_102)
|
|
|
|
|
|
node_103 = Node('巾帼', name='蛛儿')
|
|
|
re_103 = Relationship(node_103, 'Love', node_1)
|
|
|
|
|
|
transaction_2.create(node_100)
|
|
|
transaction_2.create(re_100)
|
|
|
transaction_2.create(node_101)
|
|
|
transaction_2.create(re_101)
|
|
|
transaction_2.create(re_101_)
|
|
|
transaction_2.create(node_102)
|
|
|
transaction_2.create(re_102)
|
|
|
transaction_2.create(node_103)
|
|
|
transaction_2.create(re_103)
|
|
|
|
|
|
transaction_2.commit()
|
|
|
# 增加俩关系
|
|
|
re1_1 = Relationship(node_101, '情敌', node_102)
|
|
|
re1_2 = Relationship(node_102, '情敌', node_103)
|
|
|
db.create(re1_1)
|
|
|
db.create(re1_2)
|
|
|
|
|
|
# 情敌查询结果
|
|
|
print('=' * 10, 'hate关系查询结果', '=' * 10)
|
|
|
x = relation.match(nodes=None, r_type='情敌')
|
|
|
for x_ in x:
|
|
|
print(x_)
|
|
|
|
