如何确认py2neo中graph.commit(tx)是否成功更新记录及异常处理

一、确认graph.commit(tx)是否已写入数据库 #

你遇到的cursor.summary()和cursor.stats()在commit前后无变化的情况，是因为这些属性仅反映单个查询执行后的即时状态，而事务提交是整体操作，不会回溯更新之前cursor的统计信息。要确认事务是否成功写入，可以通过以下方式：

• 直接查询验证：在commit后，执行查询检查预期变更是否存在，比如针对你的示例：

  result = graph.run("MATCH (p:Person {name: 'John'}) RETURN p")
  if result.data():
      print("事务已成功写入")
  else:
      print("未找到预期数据，写入可能失败")
  

• 利用事务提交返回值：graph.commit(tx)会返回TransactionResult对象，通过它的summary属性可获取事务级统计信息：

  commit_result = graph.commit(tx)
  # 查看全局写入统计，包含节点创建、属性设置等数据
  print(commit_result.summary().counters)
  

二、事务失败的监控方式 #

graph.commit(tx)在事务失败时会直接抛出异常，不会返回特定失败响应。常见异常类型包括：

• Neo4jError：数据库层面错误，比如约束违反、语法错误、权限不足等；
• TransactionError：事务本身错误，比如事务已关闭、超时等。

你需要用try-except块捕获异常处理失败场景，修改后的示例代码如下：

from py2neo import Graph, Neo4jError, TransactionError

def process_query(cursor):
    dummy_query = "CREATE (:Person {name: 'John'})"
    return dummy_query

graph = Graph(uri="*****")
tx = graph.begin()

try:
    cursor1 = tx.run("MATCH (n) RETURN n")
    query2 = process_query(cursor1)
    cursor2 = tx.run(query2)
    
    commit_result = graph.commit(tx)
    # 通过事务统计确认写入情况
    counters = commit_result.summary().counters
    if counters.nodes_created > 0:
        print("事务提交成功，已创建节点")
except (Neo4jError, TransactionError) as e:
    tx.rollback()
    print(f"事务失败：{str(e)}")

补充说明 #

事务提交成功后，所有事务内的变更会持久化到数据库；若提交时抛出异常，事务会自动回滚，所有变更不会生效。

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