py2neo中使用参数执行Cypher查询的正确方法

Cypher查询的参数机制仅支持传递值类参数（比如节点属性值、查询阈值这类数据内容），不支持传递标签名、属性名、CSV字段名这类语法结构标识符。你之前尝试用Cypher参数传递节点标签、属性名、CSV列名的写法不符合语法规范，因此触发语法报错。

动态的标识符部分（节点标签、属性名、CSV列名）直接通过Python的字符串格式化拼接生成查询语句，因为这些参数都是你内部可控的配置项，不会有注入风险（如果要进一步安全加固，可以增加标签/属性白名单校验）。

正确代码示例 #

# node_from/node_to: 列表 [节点类型, 匹配属性名, CSV对应列名]
def link_nodes_from_csv(graph, node_from, node_to, rel_label_col):
    # 用Python f-string拼接动态标识符部分
    query = f"""
            LOAD CSV WITH HEADERS FROM "https://drive.google.com/uc?id=id&export=download" AS line 
            FIELDTERMINATOR '\t'
                MATCH (n:{node_from[0]}) WHERE n.{node_from[1]} = line.{node_from[2]}
                MATCH (m:{node_to[0]}) WHERE m.{node_to[1]} = line.{node_to[2]}
                CALL apoc.create.relationship(m, line.{rel_label_col}, {{}}, n) YIELD rel
                REMOVE rel.noOp
            """
    result = graph.run(query)
    nodes = [n for n in result]
    print(nodes)

注意事项 #

• 代码中apoc.create.relationship里的空 map 要写成{{}}，这是因为f-string里{}是特殊字符，要输出字面量{}需要双重转义。
• 如果你的参数可能来自外部输入，需要提前加白名单校验，比如先定义允许的节点标签列表、属性名列表，拼接前检查传入的node_from[0]等参数是否在白名单内，避免Cypher注入风险。

内容的提问来源于stack exchange，提问作者Dimiftb