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.
mysqli
tiene sus lagunas en el manejo de datos blob, sobre todo si el archivo es muy grande, quizá necesites recurrir a esto, lee las explicaciones y los ejemplos. Si yo estuviera en tu lugar PDO para esto. El paso de parámetros dinámicos es mucho más simple que todo el spaghetti que hay que hacer en estos casos si se usamysqli
y por algo muy simple: PDO permite para un array de parámetros en elexecute
de las consultas preparadas y esto simplifica la vida, más aún en casos como este.send_long_data
, pero aún así no me funciona.max_allowed_packet
con esta consulta:SHOW VARIABLES LIKE 'max_allowed_packet';
para saber cómo debes dividir el blob.fopen
, no sé si eso influya, pero trata de usar el código como ellos lo indican, primero sólo y si funciona entonces lo incorporas a la clase.$sentencia->close();