2012-10-09 32 views
5

Todo lo que quiero saber es si puede usar mysqli's prepare, execute y rollback juntos?¿Puedes usar Mysqli para preparar, ejecutar y deshacer juntos?

$m = new mysqli($dbhost,$dbuser,$dbpassword,$dbname); 

$m->autocommit(FALSE); 
$stmt = $m->prepare("INSERT `table` (`name`,`gender`,`age`) VALUES (?,?,?)"); 
$stmt->bind_param("ssi", $name, $gender, $age); 
$query_ok = $stmt->execute(); 

$stmt = $m->prepare("INSERT `table` (`name`,`gender`,`age`) VALUES (?,?,?)"); 
$stmt->bind_param("ssi", $name, $gender, $age); 
if ($query_ok) {$query_ok = $stmt->execute();} 

if (!$query_ok) {$m->rollback();} else {$m->commit();} 

¿Se puede hacer esto? Supongamos que el código anterior tiene un bucle y o las variables obtienen datos nuevos en ellos.

+0

¿Has probado? –

+0

¿Qué te hace suponer que podrías o no podrías? –

+0

Lo he probado y no está claro en los resultados, por lo que estoy preguntando. La documentación de PHP no dice nada de ninguna manera si preparan, ejecutan y retrotraen trabajo juntos. ¿Alguien alguna vez lo intenta o lo pone a funcionar? –

Respuesta

0

La mejor manera de manejar esto es con excepciones (como siempre, maldito error PHP/advertencia). Simplemente porque nuestra llamada commit() también puede fallar. Tenga en cuenta que finally solo está disponible en las versiones PHP más nuevas.

<?php 

// Transform all errors to exceptions! 
mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT); 

try { 
    $connection = new \mysqli($dbhost, $dbuser, $dbpassword, $dbname); 
    $connection->autocommit(false); 

    $stmt = $connection->prepare("INSERT `table` (`name`, `gender`, `age`) VALUES (?, ?, ?)"); 
    $stmt->bind_param("ssi", $name, $gender, $age); 
    $stmt->execute(); 

    // We can simply reuse the prepared statement if it's the same query. 
    //$stmt = $connection->prepare("INSERT `table` (`name`, `gender`, `age`) VALUES (?, ?, ?)"); 

    // We can even reuse the bound parameters. 
    //$stmt->bind_param("ssi", $name, $gender, $age); 

    // Yet it would be better to write it like this: 
    /* 
    $stmt = $connection->prepare("INSERT `table` (`name`, `gender`, `age`) VALUES (?, ?, ?), (?, ?, ?)"); 
    $stmt->bind_param("ssissi", $name, $gender, $age, $name, $gender, $age); 
    */ 

    $stmt->execute(); 
    $stmt->commit(); 
} 
catch (\mysqli_sql_exception $exception) { 
    $connection->rollback(); 
    throw $exception; 
} 
finally { 
    isset($stmt) && $stmt->close(); 
    $connection->autocommit(true); 
}