如何在Memgraph Python客户端中实现节点的创建/更新（含标签与属性）

Memgraph完全支持Cypher的MERGE语法，这正是你要的Upsert功能核心。下面直接给可落地的Python实现方案：

核心逻辑：利用Cypher的MERGE + ON CREATE/ON MATCH #

Cypher的MERGE会尝试匹配指定模式的节点，如果不存在就创建它；配合ON CREATE和ON MATCH子句，可以分别定义创建时的属性设置和匹配到现有节点时的属性更新逻辑。

举个例子：假设你要操作的是User标签的节点，用user_id作为唯一标识来判断节点是否存在，不存在则创建带user_id、name、email的节点，存在则更新name和email属性。

Python代码实现 #

这里用官方推荐的mgclient客户端（先确保已经安装：pip install mgclient）：

import mgclient

def upsert_user_node(user_id, name, email):
    # 建立与Memgraph的连接
    connection = mgclient.connect(host='127.0.0.1', port=7687)
    cursor = connection.cursor()

    # 构造Cypher Upsert语句
    cypher_query = """
        MERGE (u:User {user_id: $user_id})
        ON CREATE SET u.name = $name, u.email = $email
        ON MATCH SET u.name = $name, u.email = $email
        RETURN u
    """

    # 参数化执行查询（避免Cypher注入，同时更高效）
    cursor.execute(cypher_query, {"user_id": user_id, "name": name, "email": email})
    
    # 获取执行结果（可选，返回操作后的节点）
    result = cursor.fetchone()
    print(f"操作后的节点: {result}")

    # 关闭连接
    connection.commit()
    cursor.close()
    connection.close()

# 测试调用
upsert_user_node(1, "Alice", "alice@example.com")
upsert_user_node(1, "Alice Smith", "alice.smith@example.com")  # 这行会更新现有节点

关键细节说明 #

• 唯一标识的选择：MERGE里的{user_id: $user_id}是判断节点是否存在的依据，必须选业务上唯一的属性（比如用户ID、商品SKU等），否则会创建重复节点。
• 属性更新逻辑：ON CREATE里的属性是创建节点时要设置的，ON MATCH里是匹配到节点时要更新的，两者可以不一样（比如创建时设置created_at，更新时只更新updated_at和其他业务属性）。
• 参数化查询：一定要用参数占位符（$xxx）而不是字符串拼接，防止Cypher注入，同时Memgraph会缓存参数化查询的执行计划，提升性能。
• 批量Upsert：如果要批量处理多个节点，可以用UNWIND配合MERGE，示例：

def bulk_upsert_users(users):
    connection = mgclient.connect(host='127.0.0.1', port=7687)
    cursor = connection.cursor()

    cypher_query = """
        UNWIND $users AS user
        MERGE (u:User {user_id: user.user_id})
        ON CREATE SET u.name = user.name, u.email = user.email, u.created_at = timestamp()
        ON MATCH SET u.name = user.name, u.email = user.email, u.updated_at = timestamp()
        RETURN u
    """

    cursor.execute(cypher_query, {"users": users})
    connection.commit()
    cursor.close()
    connection.close()

# 批量数据示例
user_list = [
    {"user_id": 2, "name": "Bob", "email": "bob@example.com"},
    {"user_id": 3, "name": "Charlie", "email": "charlie@example.com"},
    {"user_id": 2, "name": "Bob Brown", "email": "bob.brown@example.com"}
]
bulk_upsert_users(user_list)

注意事项 #

• 确保Memgraph服务正在运行，且Python客户端能正常连接（检查host、port、认证信息，如果有密码的话要在connect里加password参数）。
• 如果你的节点有多个标签或者更复杂的匹配条件，直接修改MERGE里的模式即可，比如MERGE (u:User:VIP {user_id: $user_id})。

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