CALL Procedure() Commands out of sync; you can't run this command now

[Javierc]

Buenas a todos,

Tengo un desarrollo que hace una llamada a dos procedimientos: de esta forma...

CALL procedimiento1 (var1, var2);
...
...
$variable = valor_campo_de_registro_de_procedimiento1
CALL procedimiento2 ($variable);
...
...

Si solo hay una llamada a un procedimiento no hay problema, o si en lugar de llamar a los procedimientos los cambio por las select funciona sin problema. Pero si lo hago como os he indicado obtengo este error:

Commands out of sync; you can't run this command now

Por lo que he mirado por internet parece que falta que se cierre la conexion cuando obtengo el primer conjunto de resultados. Pero no consigo dar con la forma de hacerlo. La unica manera de que me funcione es destruyendo el objeto de la conexion y volviendolo a crear antes de la segunda llamada .. pero esa forma no me parece la correcta.

El metodo que utilizo es el siguiente y lo que hace es volcar los resultados en un array :

Código PHP:

$resultado = mysqli_query($this->conexion, $sql);
                if (!$resultado) {
                    $this->error = mysqli_errno($this->conexion);
                } else {
                    if (mysqli_num_rows($resultado) == 0) {
                        return false;
                    } else {
                        $i = 0;
                        while ($row = mysqli_fetch_array($resultado, MYSQLI_ASSOC)) {
                            foreach ($row as $indice => $valor) {
                                $r["$indice"][$i] = $valor;
                            }
                            $i++;
                        }
                        mysqli_free_result($resultado);
                        return $r;
                    }
                }
 

Si alguien me puede echar una mano, muchas gracias.

[gnzsoloyo]

Posetea el bloque anterios, desde el principio, donde creas el contenido de $sql.

[Javierc]

Esta es la clase completa...

Código PHP:

class Mysql{
 
    private $host;
    private $usuario;
    private $password;
    private $basededatos;
    private $conexion;
    public $error;
 
    public function __construct($host, $usuario, $password, $basededatos)
    {
        $this->host = $host;
        $this->usuario = $usuario;
        $this->password = $password;
        $this->basededatos = $basededatos;
        if (!$this->_conect()) {
            $this->error = mysqli_connect_error();
            echo mysqli_connect_error();
        }
    }
 
    public function _conect()
    {
        $this->conexion = mysqli_connect($this->host, $this->usuario, $this->password, $this->basededatos);
        $this->conexion->query("SET NAMES utf8");
       $this->conexion->query("SET CHARACTER SET utf8");
        $this->conexion->set_charset('utf8');
        if ($this->conexion) mysqli_select_db($this->conexion, $this->basededatos);
        else {
            $this->error = mysqli_connect_error();
            return false;
        }
 
    }
 
    public function filtrar($valor)
    {
        $valor = stripcslashes($valor);
        $valor = ltrim($valor);
        $valor = rtrim($valor);
        return mysqli_real_escape_string($this->conexion, $valor);
    }
 
    public function charset()
    {
       return mysqli_character_set_name($this->conexion);
    }
    public function consulta($sql)
    {
       $tipo=explode(" ",$sql);
        $tipo_consulta = strtoupper($tipo[0]);
        switch ($tipo_consulta) {
            case 'CALL': 
            case 'SELECT':
            case 'DESCRI':
          case 'SHOW': // show tables
              $resultado = mysqli_query($this->conexion, $sql);
                if (!$resultado) {
                    $this->error = mysqli_errno($this->conexion);
                } else {
                    if (mysqli_num_rows($resultado) == 0) {
                        return false;
                    } else {
                        $i = 0;
                        while ($row = mysqli_fetch_array($resultado, MYSQLI_ASSOC)) {
                            foreach ($row as $indice => $valor) {
                                $r["$indice"][$i] = $valor;
                            }
                            $i++;
                        }
                        mysqli_free_result($resultado);
                        return $r;
                    }
                }
                break;
            case 'INSERT':
                $resultado = mysqli_query($this->conexion, $sql);
                if (!$resultado) {
                    $this->error = mysqli_errno($this->conexion);
                } else {
                    return mysqli_insert_id($this->conexion);
                }
                break;
            case 'DELETE':
            case 'UPDATE':
                $resultado = mysqli_query($this->conexion, $sql);
                if (!$resultado) {
                    $this->error = mysqli_errno($this->conexion);
                } else {
                    return mysqli_affected_rows($this->conexion);
                }
                break;
            default:
                $resultado = mysqli_query($this->conexion, $sql);
                if (!$resultado) {
                    $this->error = mysqli_errno($this->conexion);
                } else {
                    return mysqli_affected_rows($this->conexion);
                }
                break;
        }
    }
 
    public function __destruct()
    {
        @mysqli_close($this->conexion);
    }
}
 
?>
 

[gnzsoloyo]

Perdon, pero...
¿La consulta la recibes desde la pagina, de un form?

Eso es suicida, supongo que lo sabrás, ¿no?

En cualquier caso, el problema que hay que analizar es que tan bien construida esta la query, y como se incorpora su parametrización, cosa que en tu código no se ve. Sin eso, el error es imposible de diagnosticar y sólo podríamos hacer suposiciones.

[Javierc]

Hola, el parametro me llega por un $_REQUEST, pero ya me encargo de que no se pueda hacer sqlinjection.

La select del primer procedimiento puedes ser:

Select * from productos...

cuando obtengo el id_producto la segunda select

select * from inventario where id_producto = '".$id_producto."'

es decir...

Código PHP:

$a="CALL Producto()";
$haz=$db->consulta($a);
$hay=count($haz["id_productos"]);
for ($x=0;$x<$hay;$x++){
 $b="CALL Inevtario('".$haz["id_productos"][$x]."');
[B]AQUI SE PRODUCE EL ERROR[/B]
 $haz_b=$db->consulta($b);
 ....
 
}
 

Las select son correctas porque sustituyendo los Procedures por select funcionan correctamente.


GRacias.

[mortiprogramador]

Saludo.
Pues eso es porque se intenta realizar doble query,
y mysqli ocupa querys sin buffer para ello, en cuyo caso una de dos,
o usar mysqli_store_result o hacer el primer query, guardar en un array
los ids, y luego recorrerlos y ejecutar el segundo query
en dicho recorrido.

[Javierc]

Hola mortiprogramador, eso ya lo hago...

obtengo del primer procedure el array con todos los resultados, pero necesito destruir el objeto de la conexion y volver a crearlo para ejecutar el siguiente procedure, pero eso no me parece correcto..

¿no se podría hacer algo dentro de la clase, una vez que devuelve el array con los datos para que no se produzca el error y no tenga que destruir y volver a crear el objeto de la conexión?

gracias

[mortiprogramador]

Saludo
Pues revisando el tema a fondo, el asunto es por el llamado como tal
a los SP sin liberar recursos antes, así que se debe hacer uso de
mysqli_next_result enviando como parámetro la conexión
y mysqli_free_result enviando como parámetro el result de mysql_query.

En tu caso creo que podría ser en el else del default
de la función consultar de la clase Mysql.

Así incluso no habría necesidad de obtener los resultados para
luego tener que recorrerlos nuevamente, sino que en el mismo
ciclo de recorrido de los resultados se puede ejecutar los querys.

[Javierc]

En tu caso creo que podría ser en el else del default
de la función consultar de la clase Mysql.



de default del switch???, pero si no entra en el default.... o te refieres
a meter mysqli_free_result dentro del if (!$resultado) { .. <aqui> }

Gracias...

[mortiprogramador]

Iniciado por Javierc

En tu caso creo que podría ser en el else del default
de la función consultar de la clase Mysql.



de default del switch???, pero si no entra en el default.... o te refieres
a meter mysqli_free_result dentro del if (!$resultado) { .. <aqui> }

Gracias...

Saludo.
Me refería al else pero de ese if que mencionas,
sin embargo esto para CALL, habría que ver
como se comporta con los otros CASE (SELECT, DESCRI y SHOW) que
hacen uso de esta misma parte de código.