Mysql Transacciones

[vpalestino]

Hola:
Tengo unas funciones para hacer transacciones de mysql atraves del php. Solo que despues de la llamada a la primera funcion, el Id.Resorce que me habia devuelto mysql se pierde y se me hace muy raro ya que el paso del id de conexion si se pasa por el paso de parametros.Me queda la duda si en verdad se pueden realizar las transacciones de mysql con el php atraves de funciones( ya he hecho transacciones con postgres y es facil), ya que he buscado por la web y nada claro he encontrado. bueno saludos.


function query($sql){
$this->result = mysql_query($sql,$this->conn);
echo "<br><br>con:".$this->conn."<br>sql:$sql<br>res:".$this->result."<br>";
if($this->result){
echo "#Hecho#<br>";
return 0;
}
else{
echo "#NO_hecho#<br>";
return -1;
}
}

function commit(){

$this->result = mysql_query("COMMIT",$this->conn);
if($this->result){
mysql_close($this->conn);echo "comit";return $res;
}
else{
echo "no commit";return -1;
}
}

function rollback(){
$res = mysql_query("ROLLBACK",$this->conn);
if($res){
mysql_close($this->conn);
return $res;
}
else{
mysql_close($this->conn);
return -1;
}
}

[BrujoNic]

Trasladado de BD a PHP. Favor no poner código de programación en BD.

Función de la sección de Base de Datos

[AlvaroG]

Hola vpalestino,

Primero que nada, MySQL no soporta transacciones en las tablas MyISAM, así que asegurate de no estar usando tablas de ese tipo.

Segundo, para siguientes ocasiones, poné el código entre etiquetas [ php] y [ /php], así queda formateado y con coloreado de sintaxis.

Veo que la función commit() devuelve un valor no inicializado, en la función no existe la variable $res, que es lo que estás devolviendo.

Código PHP:

  function commit(){ 
    $this->result = mysql_query("COMMIT",$this->conn); 
 
    if ($this->result) { 
        mysql_close($this->conn); 
        echo "comit"; 
        return $res; // <- ¿dónde está definida? 
    } 
 
    else { 
        echo "no commit"; 
        return -1; 
    } 
}  
   

No veo otros errores, pero si ese no es el problema deberías explicar la lógica detrás de ese código, cómo estás usándolo.


Saludos.

[vpalestino]

Gracias por los comentarios, fue un error de dedo. Bueno ya soluciones mi problema a continuacion pongo en codigo:

<?php
class MySQLDB
{
private $connection; // The MySQL database connection

/* Class constructor */
function MySQLDB(){
/* Make connection to database */
$this->connection = mysql_connect(DB_SERVER, DB_USER, DB_PASS) or die(mysql_error());
mysql_select_db(DB_NAME, $this->connection) or die(mysql_error());
}

/* Transactions functions */

function begin(){
$null = mysql_query("START TRANSACTION", $this->connection);
return mysql_query("BEGIN", $this->connection);
}

function commit(){
return mysql_query("COMMIT", $this->connection);
}

function rollback(){
return mysql_query("ROLLBACK", $this->connection);
}

function transaction($q_array){
$retval = 1;

$this->begin();

foreach($q_array as $qa){
$result = mysql_query($qa['query'], $this->connection);
if(mysql_affected_rows() == 0){ $retval = 0; }
}

if($retval == 0){
$this->rollback();
return false;
}else{
$this->commit();
return true;
}
}

};

/* Create database connection object */
$database = new MySQLDB;

// then from anywhere else simply put the transaction queries in an array or arrays like this:

function function(){
global $database;

$q = array (
array("query" => "UPDATE table WHERE something = 'something'"),
array("query" => "UPDATE table WHERE something_else = 'something_else'"),
array("query" => "DELETE FROM table WHERE something_else2 = 'something_else2'"),
);

$database->transaction($q);

}

?>


Saludos