关于Neo4j事务示例中success变量未动态更新的技术问询

问题描述 #

我在查阅Neo4j事务相关文档时看到了这段示例代码：

var tx = session.beginTransaction();
tx.run("MERGE (bob:Person {name : {nameParam} }) RETURN bob.name AS name", {nameParam: 'Bob'})
  .subscribe({
    onNext: function (record) {
      console.log(record.get('name'));
    },
    onCompleted: function () {
      session.close();
    },
    onError: function (error) {
      console.log(error);
    }
  });
//决定事务是否提交或回滚
var success = false;
if (success) {
  tx.commit()
    .subscribe({
      onCompleted: function () {
        // 此事务现已提交
      },
      onError: function (error) {
        console.log(error);
      }
    });
} else {
  //事务已回滚，数据库中不会创建任何内容
  console.log('rolled back');
  tx.rollback();
}

但这段代码里的success变量值始终没变，我想知道该如何判断事务是否执行成功，以及为什么success没有根据执行结果动态更新？

解答 #

咱们先拆解一下问题的核心：

1. 为什么success不会动态更新？

示例里的success = false是硬编码的固定值，完全没有和tx.run()的实际执行结果关联起来。而且tx.run()是异步操作，代码会先执行到if (success)判断，这时候查询可能还没完成，自然也不会去更新success的值。

2. 如何判断事务执行成功并动态处理提交/回滚？

Neo4j JavaScript驱动的操作是异步的，我们需要利用回调函数或者Promise/async-await来根据查询结果更新状态，再决定提交或回滚。这里有两种常见的处理方式：

方式一：利用回调函数关联执行结果

把success的赋值和提交/回滚逻辑放到tx.run()的回调里，只有当查询完成（或出错）时才去处理事务：

var tx = session.beginTransaction();
tx.run("MERGE (bob:Person {name : {nameParam} }) RETURN bob.name AS name", {nameParam: 'Bob'})
  .subscribe({
    onNext: function (record) {
      console.log(record.get('name'));
    },
    onCompleted: function () {
      // 查询执行成功，提交事务
      tx.commit()
        .subscribe({
          onCompleted: function () {
            console.log('事务已提交');
            session.close();
          },
          onError: function (error) {
            console.log('提交失败:', error);
            session.close();
          }
        });
    },
    onError: function (error) {
      // 查询执行出错，直接回滚事务
      console.log('查询出错，回滚事务:', error);
      tx.rollback();
      session.close();
    }
  });

方式二：用async/await简化异步逻辑

如果你的环境支持ES6+，推荐用async-await来写，代码更直观易读：

async function createPerson() {
  const session = driver.session(); // 假设driver已经初始化
  let tx;
  try {
    tx = session.beginTransaction();
    const result = await tx.run("MERGE (bob:Person {name : $nameParam }) RETURN bob.name AS name", {nameParam: 'Bob'});
    
    // 遍历结果（如果需要）
    result.records.forEach(record => {
      console.log(record.get('name'));
    });
    
    // 查询执行成功，提交事务
    await tx.commit();
    console.log('事务已提交');
  } catch (error) {
    // 任何出错的情况，回滚事务
    console.log('执行出错，回滚事务:', error);
    if (tx) await tx.rollback();
  } finally {
    // 无论成功失败，都关闭session
    await session.close();
  }
}

// 调用函数
createPerson();

关键要点

• 异步顺序：Neo4j的查询操作是非阻塞的，必须等待查询完成（通过回调或await）后，才能判断是否成功并处理事务。
• 错误处理：不仅要处理查询本身的错误，还要处理提交/回滚过程中可能出现的错误。
• 资源释放：记得在操作完成后关闭session，避免资源泄漏。

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