如何测试 MySQL 事务？

Question

我有一个关于在事务中测试查询的问题。我使用 MySQL 事务已经有一段时间了，每次我这样做时，我都会使用类似的东西：

$doCommit = true;
$error = "";
mysql_query("BEGIN");

/* repeat this part with the different queries in the transaction
   this often involves updating of and inserting in multiple tables */
$query = "SELECT, UPDATE, INSERT, etc";
$result = mysql_query($query);
if(!$result){
    $error .= mysql_error() . " in " . $query . "<BR>";
    $doCommit = false;
}
/* end of repeating part */

if($doCommit){
    mysql_query("COMMIT");
} else {
    echo $error;
    mysql_query("ROLLBACK");
}

现在，经常发生我想测试我的事务，所以我将mysql_query("COMMIT"); 更改为mysql_query("ROLLBACK");，但我可以想象这不是测试这类东西的好方法。将每个表复制到 temp_table 并更新并插入这些表并在之后删除它们通常是不可行的（例如，因为表可能非常大）。当然，当代码投入生产时，相关的错误处理（而不仅仅是打印错误）就会到位。

做这样的事情最好的方法是什么？

Answer 1

首先，您的实现中有一个错误。如果查询出错，当前事务会自动回滚然后关闭。因此，当您继续执行查询时，它们将不在事务中（它们将被提交到数据库）。然后，当你执行Rollback 时，它会默默地失败。来自MySQL docs：

Rolling back can be a slow operation that may occur implicitly without the user 
having explicitly asked for it (for example, when an error occurs).

显式命令ROLLBACK 仅应在您在应用程序中确定需要回滚时使用（出于查询错误以外的原因）。例如，如果您从账户中扣除资金，如果您发现用户没有足够的资金来完成兑换，您会明确回滚...

就交易测试而言，我确实复制了数据库。我创建了一个新数据库并安装了一组“虚拟数据”。然后我使用自动化工具运行所有测试。该工具将实际提交事务并强制回滚，并检查在整个测试过程中是否保持预期的数据库状态。由于如果您对交易有未知的输入，则很难以编程方式从交易中了解最终状态，因此测试实时（甚至是从实时复制的）数据并不容易。您可以（并且应该）这样做，但不要依赖这些结果来确定您的系统是否正常工作。使用这些结果为自动化测试人员构建新的测试用例...

Answer 2

也许您可以重构您的第一个示例并使用一些 DB 访问包装类？

在那个包装类中你可以有一个变量 $normalCommit = true; 以及设置 $normalCommit 变量的方法 SetCommitMode()。 你有一个方法 Commit() 提交 if($normalCommit == true) 甚至有一个变量 $failTransaction 调用 mysql_query("ROLLBACK");如果你愿意（这样你就可以通过/失败许多顺序测试）。

然后当你运行测试时，你可以在测试代码文件的某处设置： $myDBClass->SetCommitMode(false); 或者 $myDBClass->RollBackNextOperation(true); 在您希望失败的操作之前，它只会失败。这样，您正在测试的代码将不包含那些失败/提交检查，只有 DB 类将包含它们。

通常只有测试代码（特别是如果您进行单元测试）应该调用这些 SetCommitMode 和 RollBackNextOperation 方法，因此您不会不小心将这些调用留在生产代码中。

或者你可以将一些疯狂的数据传递给你的方法（如果你正在测试一个方法），比如要保存在 UNSIGNED 字段中的负变量，然后如果你的代码在这样的 SQL 之后没有提交，那么你的事务应该 100% 失败错误（但不应该）。

Answer 3

通常我使用类似的东西（我使用 pdo 作为我的例子）：

$db->beginTransaction();
try {
  $db->exec('INSERT/DELETE/UPDATE');
  $db->commit();
}
catch (PDOException $e) {
  $db->rollBack();
  // rethrow the error or
}

或者，如果您有自己的异常处理程序，请为您的 PDOExceptions 使用特殊子句，在哪里回滚执行。示例：

function my_exception_handler($exception) {
  if($exception instanceof PDOException) {
    // assuming you have a registry class
    Registry::get('database')->rollBack();
  }
}