使用批处理时无法接收返回的数据库响应

Question

当我使用 tx.batch 时，我试图从数据库中获取响应。

谢谢。

• 1( 查询数据库以获取需要更新的预先存在的记录
• 2( 使用来自 1 的结果，对 db 进行另一次批处理调用以执行任一 创建或更新记录
• 3( 使用状态 200 回复我的 API，并创建记录，并且 记录已更新

批量调用确实有效，已验证的记录入或/并更新到数据库中。

 db.tx(t1 => {
    let queryCheck = [];
    reqData.forEach(obj => {
      for (let key in obj) {
        obj[key].resovledURLs.forEach(data => {
          queryCheck.push(
            t1.any(
              `SELECT * FROM testDB WHERE url='${key}' AND testurl='${data}';`
            )
          );
        });
      }
    });
    return t1
      .batch(queryCheck)
      .then(data => {
        return t1.tx(t2 => {
          let t2QueryBatch = [];
         // got rid of queryBatchOfEverything()
         // uses data from t1.batch(queryCheck) to make joinedArray
         let joinedArray = updateArray.concat(createArray);
          joinedArray.forEach(obj => {
            if (obj.queryType === "Update") {
              t2QueryBatch.push(
                t2.none(
                  `UPDATE testDB SET count = count + 1 WHERE url='${
                    obj.url
                  }' AND errorurl='${obj.testurl}';`
                )
              );
            } else {
              t2QueryBatch.push(
                t2.none(
                  `INSERT INTO testDB (url, testurl) VALUES ('${
                    obj.url
                  }', '${obj.testurl}');`
                )
              );
            }
          });
          return t2.batch(t2QueryBatch);
        });
      })
      .then(data => {
        console.log(data);
      });
  });

Answer 1

您的代码存在如此多的问题，因此无法就确切的问题提出建议。在进行任何进一步的诊断之前，您需要彻底修改代码。

代码中立即发现的问题...

问题1

你忘记queryBatchOfEverything链接到包含它的事务，即它应该是return queryBatchOfEverything...的，如果这是你的事务逻辑

问题2

您在db对象上打开嵌套事务，该事务无效，即您无法在另一个事务中创建独立的顶级事务。

您只能从父事务的上下文中创建子事务，也称为savepoint，即 t1.tx(t2 => {}) .

问题3

您忘记将嵌套事务的结果链接到父事务中，因此您手上又有一个松散的承诺。它需要return t1.tx(t2 => )

习题4

您在嵌套事务中使用方法 one，这意味着您希望只返回一行数据，而您的查询都不返回任何内容，即您应该在那里使用方法 none。这正是你问的问题。但是您需要修复其余部分才能使整体正常工作。

问题5

您不会将t2.batch链接到交易，从而创建另一个松散的承诺。应该是return t2.batch.

习题6

这不是问题，只是一些无用的代码：

let updateRecords = await t1.batch(queryCheck).then(data => {
    return data;
});

它与此完全相同：

let updateRecords = await t1.batch(queryCheck);