### 使用Python一次性创建多个Neo4j节点 在使用Python与Neo4j交互时，可以通过Cypher查询语言一次性创建多个节点。这通常涉及将数据传递到查询中，并利用参数化查询来优化性能和安全性。以下是一个详细的实现方法： #### 1. 安装必要的库 首先需要确保安装了`neo4j`库，该库用于与Neo4j数据库进行交互。 ```bash pip install neo4j ``` #### 2. 创建连接并执行批量插入 通过`neo4j.Driver`创建一个会话，并使用Cypher查询语言中的`UNWIND`语句来处理列表数据。以下是完整的代码示例： ```python from neo4j import GraphDatabase # 建立与Neo4j的连接 uri = "bolt://localhost:7687" # 替换为你的Neo4j URI user = "neo4j" # 替换为你的用户名 password = "password" # 替换为你的密码 driver = GraphDatabase.driver(uri, auth=(user, password)) # 定义要创建的节点数据 nodes_data = [ {"name": "Alice", "age": 30, "city": "New York"}, {"name": "Bob", "age": 25, "city": "Los Angeles"}, {"name": "Charlie", "age": 35, "city": "Chicago"} ] # Cypher查询：使用UNWIND批量创建节点 query = """ UNWIND $nodes AS node CREATE (n:Person {name: node.name, age: node.age, city: node.city}) RETURN n """ # 执行查询 def create_nodes(tx, nodes): result = tx.run(query, nodes=nodes) return [record["n"] for record in result] with driver.session() as session: created_nodes = session.write_transaction(create_nodes, nodes_data) # 输出创建的节点 for node in created_nodes: print(node) # 关闭驱动程序 driver.close() ``` #### 3. 解释代码逻辑 - **`UNWIND`**：此语句用于将列表展开为行，以便对每一行执行操作。它非常适合处理批量数据[^1]。 - **参数化查询**：通过将`nodes_data`作为参数传递给Cypher查询，可以避免SQL注入问题并提高性能。 - **事务管理**：`write_transaction`方法确保所有节点都在一个事务中创建，如果发生错误，则整个事务将被回滚。 #### 4. 验证结果 在Neo4j浏览器中运行以下查询以验证节点是否已成功创建： ```cypher MATCH (n:Person) RETURN n ``` #### 注意事项 - 确保Neo4j服务器正在运行，并且URI、用户名和密码正确无误[^2]。 - 如果节点具有关系或其他属性，可以在`CREATE`语句中扩展Cypher查询。 - 在实际应用中，可能需要对大规模数据进行分批插入以避免内存不足的问题。 ### 示例输出 假设上述代码成功执行，输出可能如下： ``` <node id="1" labels="['Person']" properties="{'name': 'Alice', 'age': 30, 'city': 'New York'}"> <node id="2" labels="['Person']" properties="{'name': 'Bob', 'age': 25, 'city': 'Los Angeles'}"> <node id="3" labels="['Person']" properties="{'name': 'Charlie', 'age': 35, 'city': 'Chicago'}"> ```