Estoy complementando una clase para operaciones CRUD
hacia mysql
. Estoy realizando un método para ejecutar sentencias insert
, update
y delete
. Este es el código:
public function ejecutarSQL($sql,$parametrosSQL=array(),$tipos=null){
if( $this->conexion){
$parametros =array();
if(count($parametrosSQL)>=1){
foreach($parametrosSQL as $key => $value) {
$parametros[] = utf8_decode($value);
}
}
if (!($sentencia = $this->conexion->prepare($sql))) {
$msg="Falló la preparación: (" . $this->conexion->errno . ") " . $this->conexion->error;
}
# bind parameters for markers
# but this is not dynamic enough...
//$stmt->bind_param("s", $parameter);
//tipos:
//i => entero
//d => double,float
//s => string
//b => blob
if($parametros&&$tipos){
$bind_names[] = $tipos;
$arraytipos=str_split($tipos);
for ($i=0; $i<count($parametros);$i++){
if($arraytipos[$i]=='b'){
$bind_name = 'bind' . $i;
$null=NULL;
$$bind_name=$null;
$byteToSend = 1024;//this should equals the max_allowed_packet variable in your mysql config (usually in my.cnf config file)
$j=0;
while ($contentToSend = substr($parametros[$i], $j, $byteToSend)) {
$sentencia->send_long_data($i, $contentToSend);
$j+=$byteToSend;
}
$file=$parametros[$i];
$bind_names[] = &$file;
}else{
$bind_name = 'bind' . $i;
$$bind_name = $this->conexion->real_escape_string($parametros[$i]);
$bind_names[] = &$$bind_name;
}
}
$return = call_user_func_array(array($sentencia,'bind_param'),$bind_names);
}
if(!$sentencia->execute()){
$msg= "Falló la ejecución: (" . $this->conexion->errno . ") " . $this->conexion->error;
}else{
$nowRows=$sentencia->affected_rows;
if($nowRows>=1){
$result = $this->conexion->query("SELECT LAST_INSERT_ID() as ID;");
while ($fila = $result->fetch_assoc()) {
$datos_pr[] = $fila;
}
if ($datos_pr[0]["ID"] == null){
$datos = "Registro exitoso";
}else{
$datos=$datos_pr[0];
}
$datos_pr=null;
$bandera=true;
}else{
$bandera=false;
$msg = "Ocurrio un problema en la sentencia SQL y/o no se afectaron registros";
$nowRows=0;
}
}
}
}
He probado este código con inserts
, updates
y deletes
y funciona correctamente. El problema viene cuando intento guardar un archivo en un campo blob
, ya que el insert
se realiza correctamente, pero al revisar el campo blob
en mysql
esta vacío y no recibo ninguna tipo de error. La forma en que llamo a la función es esta:
$this->conexion=new Conexion("conexiones.properties");
$archivo=file_get_contents("C:/archivo.pdf");
$query="INSERT INTO movie_prueba(title,year,raiting,image) VALUES (?,now(),?,?);";
$parametros=array('texto7',20, $archivo);
$res=$this->conexion->ejecutarSQL($query,$parametros,"sib" );
var_dump($res);
He debuggeado el código y todo parece estar bien, incluso el ciclo while
send_long_data
para el guardado del archivo se ejecuta bien, por lo que no entiendo que es lo que falla. Me he basado en esta respuesta y en esta otra.
Como veo que al debuggear el código se ejecuta aparentemente como debe, comienzo a pensar que el problema debe ser alguna configuración de php
, de mysql
o incluso del driver mysqli
, pero lo desconozco. Espero me puedan apoyar.
ACTUALIZACIÓN:
Después de mucho debuggear encontré que en el objeto $sentencia
si aparece un error. El error aparece al ejecutar $sentencia->send_long_data($i, $contentToSend);
La variable con el error tiene esto:
[[0] => [[errno] => 2014, [sqlstate] => HY000, [error] => Commands out of sync; you can't run this command now]]
aunque ya lo busque sigo sin entender porque aparece, ya que he encontrado que aparece al tratar de ejecutar dos instrucciones al mismo tiempo, pero yo solo ejecuto una.