如何使用回滚功能处理 100 多个 mysql 查询？答案

【问题标题】：How to Process more than 100 mysql query with rollback feature?如何使用回滚功能处理 100 多个 mysql 查询？
【发布时间】：2013-07-15 19:46:23
【问题描述】：

目前我正在开发一个系统，在该系统中我必须触发 100 个相互依赖的查询，例如，

在我的脚本中（目前正在执行），

$query1 = mysql_query("INSERT_QUERY_STRING");
if(!$query) {
    die('error'.mysql_error());
}

//this loop can be turn more than 100 times

while(CONDITION) {
    //query generated here
    $query2 = mysql_query("UPDATE_QUERY_STRING");
    $query3 = mysql_query("UPDATE_QUERY_STRING");
    $query4 = mysql_query("UPDATE_QUERY_STRING");
    $query5 = mysql_query("UPDATE_QUERY_STRING");

    if(!$query2 || !$query3 || !$query4 || !$query5) {
        die('error '.mysql_error());
    }
}

$query6 = mysql_query("UPDATE_QUERY_STRING");
if(!$query6) {
    die('error '.mysql_error());
}

忽略语法错误，这只是一个逻辑

问题是，由于所有查询都是相互依赖的，如果一个失败，那么之前发生的所有更改都应该被撤销。我知道一种使用 MYSQL 事务、提交和回滚的解决方案。这是我想出来的（计划这样做），

$processes = array();

$processes[] = "INSERT_QUERY_STRING"; //query1

//this loop can be turn more than 100 times

while(CONDITION) {
    //query generated here
    $processes[] = "UPDATE_QUERY_STRING"; //looping queries
}

$processes[] = "UPDATE_QUERY_STRING" //last query

mysql_query("SET AUTOCOMMIT=0");
mysql_query("START TRANSACTION");    
$error = false;
for($i=0;$i < count($processes) ; $i++)
{
    $q = mysql_query($processes[$i]);
    if(!$q) {
        $error = true;
        break;
    }
}

if($error == false) {
    mysql_query("COMMIT");
}
else {
    mysql_query("ROLLBACK");
}

我的解决方案是好/最好的吗？有没有其他可能的解决方案可以更快更有效地做同样的事情？谢谢。

【问题讨论】：

您演示了 mysql，但正如您所说，它只是逻辑，好吧，实际上 PDO 提供了这个功能，您可以看到 Transactions and auto-commit
PDO 仅检查驱动程序级别的事务功能。如果某些运行时条件意味着事务不可用，如果数据库服务器接受启动事务的请求，PDO::beginTransaction() 仍将返回 TRUE 而不会出错。

标签： php mysql transactions commit rollback

【解决方案1】：

我认为在游览代码中使用 try/catch 会更好：

$processes = array();

$processes[] = "INSERT_QUERY_STRING"; //query1

//this loop can be turn more than 100 times

while(CONDITION) {
    //query generated here
    $processes[] = "UPDATE_QUERY_STRING"; //looping queries
}

$processes[] = "UPDATE_QUERY_STRING"; //last query

mysql_query("SET AUTOCOMMIT=0");
mysql_query("START TRANSACTION");  

$count_processes = count($processes);

for($i=0; $i < $count_processes; $i++)
{
    try {
        $q = mysql_query($processes[$i]);
        if (!$q) throw new Exception(mysql_error());
    }
    catch (Exception $e) {
        mysql_query("ROLLBACK");
        break;
    }
}

mysql_query("COMMIT");
mysql_query("SET AUTOCOMMIT=1");

使用 try/catch 更好，因为您可以控制代码和错误:)

【讨论】：

另外我建议阅读 PDO：phpro.org/tutorials/Introduction-to-PHP-PDO.html net.tutsplus.com/tutorials/php/…

【解决方案2】：

交易绝对是最好的方式。我将插入查询放在 try-catch 语句中以涵盖不可预测的情况并使用 foreach 遍历 $processes

【讨论】：

好的。谢谢 :) 使用 foreach 的优势？