|
@@ -229,11 +229,11 @@ def handle_node(receiver, head_data, data_source=None, resource_type=None):
|
|
|
|
|
|
# 创建数据资源与数据源的关系
|
|
|
if data_source_en_name:
|
|
|
- # 创建 isbelongto 关系
|
|
|
+ # 创建 originates_from 关系
|
|
|
rel_data_source_cypher = """
|
|
|
MATCH (a:data_resource), (b:data_source)
|
|
|
WHERE id(a) = $resource_id AND b.en_name = $ds_en_name
|
|
|
- MERGE (a)-[r:isbelongto]->(b)
|
|
|
+ MERGE (a)-[r:originates_from]->(b)
|
|
|
RETURN r
|
|
|
"""
|
|
|
rel_result = session.run(
|