Mysql e PHP – Abrindo uma transação (transaction)

Abrindo uma transação no banco de dados Mysql utilizando o PHP.

Obviamente, como primeiro passo você deverá se conectar ao banco desejado.

Utilize o código a seguir:

<?php

$server = 'localhost';
$user = 'root';
$pwd = '';
$db = 'mydb';

$mysqli = new mysqli($server, $user, $pwd, $db);

if (mysqli_connect_errno()) trigger_error(mysqli_connect_error());

Altere as variáveis utilizadas no construtor do mysqli com os seus dados.

“Abrindo” a transação

$mysqli->autocommit(FALSE);

$mysqli->query(" INSERT INTO test VALUES ('teste') ");
$mysqli->query(" INSERT INTO test VALUES ('teste') ");

$mysqli->commit();

Por padrão, toda a vez que a função “query” é executada o comando é enviado imediatamente para o Mysql.

Para evitar que isso aconteça, utilizados:

$mysqli->autocommit(FALSE);

Executamos os comandos desejados.

$mysqli->query(" INSERT INTO test VALUES ('teste') ");

Feito isso, realizamos o Commit:

$mysqli->commit();

Caso seja necessário, o comando de rollback:

$mysqli->rollback();

Exemplo completo

Utilizando de um bloco try/catch e statement podemos utilizar o rollback da forma correta.

No exemplo estou realizando alguns inserts, mais poderiam ser updates, selects, deletes, etc..

try {

    $mysqli->autocommit(false);

    $stmt = $mysqli->prepare("INSERT INTO `teste_0`(`col1`) VALUES (?)");
    $stmt->bind_param('ss',$val1);
    $stmt->execute();

    $stmt = $mysqli->prepare("INSERT INTO `teste_1`(`col1`) VALUES (?)");
    $stmt->bind_param('ss',$val2);
    $stmt->execute();

    $mysqli->commit();

} catch(Exception $e){
  
    $mysqli->rollback();

    throw new StorageException("Erro..");
}