Comment puis-je mettre en œuvre commit/rollback pour MySQL en PHP?

Eh bien en fait j'ai ce script qui prend du temps pour s'exécuter et, occasionnellement, des temps et des feuilles semi-complète de données flottant autour de ma base de données. (Oui, je sais que dans un monde parfait, je voudrais corriger ce QUE, au lieu de la mise en œuvre de validations et les restaurations, mais je suis contraint de ne pas le faire)

Voici mon code de base (abrutir pour des raisons de simplicité):

$database = new PDO("mysql:host=host;dbname=mysql_db","username","password");

while (notDone())
{
    $add_row = $database->prepare("INSERT INTO table (columns) VALUES (?)");
    $add_row->execute(array('values'));

    //PROCESSING STUFF THAT TAKES A LONG TIME GOES HERE
}

$database = null;

Donc mon problème est que si que si l'ensemble du processus à l'intérieur de cette boucle while n'est pas complète, alors je ne veux pas la ligne insérée à y rester. Je pense que d'une certaine façon, je pouvais utiliser les commits/restaurations au début et à la fin de la boucle while pour ce faire, mais ne savent pas comment.

OriginalL'auteur Andrew G. Johnson | 2008-11-30

  1. 10

    Prendre un coup d'oeil à ce tutoriel sur les transactions avec des AOP.

    Sont essentiellement constituées au long de l'exécution de code dans:

    $dbh->beginTransaction();
...
$dbh->commit();

    Et selon cette AOP de document de la page:

    "Lorsque le script se termine, ou lorsqu'une connexion est sur le point d'être fermé, si vous avez une excellente opération, PDO automatiquement de rouler de nouveau. "

    Si vous perdez de l'opération qui a été en attente lorsque le script a expiré.

    Mais vraiment, vous devriez repenser cette sorte qu'il ne dépend pas de la scriipt de rester en vie.

    Merci, je n'ai pas encore essayé mais je pense que c'est exactement ce que je cherche

    OriginalL'auteur Brian C. Lane

  2. 1

    Vous avez besoin pour utiliser InnoDB des tableaux pour les transactions ensuite utiliser une bibliothèque comme PDO ou MySQLi qui les prend en charge.

    OriginalL'auteur Coder2000

  3. 1
    try
{
    $mysqli->autocommit(FALSE);
    $mysqli->query("insert into tblbook (id,cid,book) values('','3','book3.1')");
    echo $q_ins=$mysqli->affected_rows."<br>";
    $mysqli->query("update tblbook set book='book3' where cid='3'");
    echo $q_upd=$mysqli->affected_rows."<br>";
    $mysqli->commit();
}
catch(PDOException $e)
{
    $mysqli->rollback();
    echo $sql . '<br />' . $e->getMessage();
}

    OriginalL'auteur Neelesh

  4. -1
    <?php
//This may help someone....This code commit the transactions
//only if both queries insert and update successfully runs

$mysqli=new mysqli("localhost","user_name","password","db_name");

if(mysqli_connect_errno())
{
    echo "Connection failed: ".mysqli_connect_error();
}
else
{
    $mysqli->autocommit(FALSE);
    $mysqli->query("insert into tblbook (id,cid,book) values('','3','book3.1')");
    echo $q_ins=$mysqli->affected_rows."<br>";
    $mysqli->query("update tblbook set book='book3' where cid='3'");
    echo $q_upd=$mysqli->affected_rows."<br>";

    if($q_ins==1 && $q_upd==1)
    {
        $mysqli->commit();
        echo "Commit<br>";
    }
    else
    {
        $mysqli->rollback();
        echo "Rollback<br>";
    }
}
?>

    OriginalL'auteur