* @author Keka: * @author Vero: * @author Raquel: * @author Toni: * @package gvHIDRA */ /** * IgepPersistencia es una clase que corresponde a un manejador de tabla de BD de una * conexión dada. Permite realizar las operaciones básicas de actualización * sobre dicha tabla (inserción, borrado y modificación de tuplas). * * Consta de las siguientes propiedades: *

*
• str_tabla - Contiene el nombre de la tabla a la que hace referencia.
*
• obj_conexion - El objeto conexión por el que se ha accedido a la tabla
*
• $obj_errorBD - Referencia al objeto de error global
*

* * @version $Id: IgepPersistencia.php,v 1.39 2008-06-09 15:23:13 afelixf Exp $ * @author David: * @author Keka: * @author Vero: * @author Raquel: * @author Toni: * @package gvHIDRA */ class IgepPersistencia { /** * tabla a modificar * * @var string str_tabla */ var $str_tabla; /** * objeto conexion * * @var object obj_conexion */ var $obj_conexion; /** * variable de error * * @var object obj_errorNegocio */ var $obj_errorBD; private $is_pdo = FALSE; /** * Constructor * * @access public * @param object $obj_conexion * @param string $str_tabla */ public function __construct ($obj_conexion, $str_tabla) { //Instanciamos la clase global $g_error; $this->obj_errorBD =& $g_error; $this->obj_conexion = $obj_conexion; $this->str_tabla = $str_tabla; (get_class($obj_conexion)=='PDO') ? $this->is_pdo=TRUE : $this->is_pdo=FALSE; } public function __sleep() { if ( $this->is_pdo ) { unset($this->obj_conexion); $this->obj_conexion = null; } return array_keys(get_object_vars($this)); } /** * Retorna el nombre de la tabla a la que hace referencia. * * @access public * @return string */ public function getTabla() { return $this->str_tabla; } /** * Dada una matriz asociativa de datos realiza los INSERTs en la tabla * asociada al objeto. * * @access public * @param array $m_datos Matriz de vectores asociativos por nombres de columna / valor */ public function insertar($m_datos) { $query = ''; $numFilas = count($m_datos); if ($numFilas<1) { IgepDebug::setDebug(DEBUG_IGEP, 'IgepPersistencia: Se ha intentado ejecutar INSERT con una matriz de datos vacía.'); return; } //Para cada dato $numInsercion = 0; foreach ($m_datos as $v_filaDatos) { $numInsercion++; $query = 'INSERT INTO '.$this->str_tabla; $queryKeys =' ('; $queryValues =' VALUES ('; foreach ($v_filaDatos as $colName=>$value) { $queryKeys.= $colName.', '; if ( $value=='' || is_null($value) ) $queryValues.= 'null, '; else $queryValues.= "'$value', "; }//Fin for columnas $queryKeys = substr_replace ($queryKeys, ') ', -2, 2); $queryValues = substr_replace ($queryValues, ') ', -2, 2); $query .=$queryKeys.$queryValues; //Debug:Indicamos que ejecutamos la consulta IgepDebug::setDebug(DEBUG_IGEP,"IgepPersistencia: Ejecutamos INSERT ($numInsercion de $numFilas)"); try { $res = $this->obj_conexion->exec($query); } catch (Exception $e) { //Excepciones PDO $this->obj_errorBD->setError('IGEP-1', 'IgepPersistencia.php', "'Insertar ($numInsercion de $numFilas)", $e->getMessage()); return; } //Tratamiento de errores if ((!$this->is_pdo AND PEAR::isError($res)) OR ($this->is_pdo AND $res===FALSE)) { $this->obj_errorBD->setError('IGEP-1', 'IgepPersistencia.php', "'Insertar ($numInsercion de $numFilas)", $res); return; } }//Fin for filas }//Fin insertar /** * Dada una tupla o fila de la tabla realiza el DELETE. La * tupla debe ser un array asociativo del modo ["campo"] * =>"valor". Esta función recibe la fila a borrar porque * realiza una comprobación de consistencia (se borra la * tupla siempre y cuando alguien no la haya modificado). * * @access public * @param array $v_filaDatos */ public function borrar($v_filaDatos) { $str_condicion=''; foreach($v_filaDatos as $prop => $val) { if ($str_condicion!='') $str_condicion.=' AND '; $str_condicion.=$prop; if (gettype($val)=="string") { if($val!="") $str_condicion.="='".$val."'"; else $str_condicion.=" is null"; } else { if($val!="") $str_condicion.="=".$val; else $str_condicion.=" is null"; } }//FIN foreach // Se monta la query con los datos obtenidos $consulta = "DELETE FROM ".$this->str_tabla. " WHERE " .$str_condicion; //Debug:Indicamos que ejecutamos la consulta IgepDebug::setDebug(DEBUG_IGEP,'IgepPersistencia: Borrado - '.$consulta); try { $res = $this->obj_conexion->exec($consulta); } catch (Exception $e) { //Excepciones PDO $this->obj_errorBD->setError("IGEP-2",'IgepPersistencia.php',"borrar",$e->getMessage(),$consulta); return; } //Tratamiento de errores if ((!$this->is_pdo AND PEAR::isError($res)) OR ($this->is_pdo AND $res===FALSE)) $this->obj_errorBD->setError("IGEP-2",'IgepPersistencia.php',"borrar",$res,$consulta); else { //Comprobamos si existe error de concurrencia. if ($res==0) $this->obj_errorBD->setError('IGEP-4','IgepPersistencia.php','borrar','','Error de Concurrencia: '.$consulta); } }// Fin de borrar /** * Dada una tupla o fila de la tabla realiza el UPDATE. Recibe * dos parámetros; uno es la tupla con los nuevos datos y otro es * la tupla con los datos que fueron visualizados.Esto se debe a * que realiza una comprobación de consistencia (se actuliza la * tupla siempre y cuando alguien no la haya modificado). Los dos * parámetros son arrays asociativos de la forma ["campo"]=>"valor". * * @access public * @param array $m_datos */ public function actualizar($v_filaDatos, $v_filaDatosAntiguos) { $str_set = ''; foreach($v_filaDatos as $prop => $val) { if($v_filaDatosAntiguos[$prop]!=$val || empty($v_filaDatosAntiguos[$prop])) { if ($str_set!='') $str_set.=' ,'; $str_set.=$prop; if (gettype($val)=="string") { if($val!="") $str_set.="='".$val."'"; else $str_set.="= null"; } else { if($val!="") $str_set.="=".$val; else $str_set.="= null"; } } }//FIN foreach $str_condicion = ''; foreach($v_filaDatosAntiguos as $prop => $val) { if ($str_condicion!='') $str_condicion.=' AND '; $str_condicion.=$prop; if (gettype($val)=='string') { if($val!='') $str_condicion.="='".$val."'"; else $str_condicion.=' is null'; } else { if($val!='') $str_condicion.='='.$val; else $str_condicion.=' is null'; } }//FIN foreach // Ejecutamos la sentencia de Actualización if ($str_condicion!='' AND $str_set!='') { $consulta = "UPDATE $this->str_tabla SET ".$str_set.' WHERE '.$str_condicion; //Debug:Indicamos que ejecutamos la consulta IgepDebug::setDebug(DEBUG_IGEP,'IgepPersistencia: Actualización - '.$consulta); try { $res = $this->obj_conexion->exec($consulta); } catch (Exception $e) { //Excepciones de PDO $this->obj_errorBD->setError('IGEP-3','IgepPersistencia.php','actualizar',$e->getMessage(), $consulta); return; } //Errores de pear o pdo if ((!$this->is_pdo AND PEAR::isError($res)) OR ($this->is_pdo AND $res===FALSE)) $this->obj_errorBD->setError('IGEP-3','IgepPersistencia.php','actualizar',$res, $consulta); else { //Comprobamos si existe error de concurrencia. if ($res==0) $this->obj_errorBD->setError('IGEP-4','IgepPersistencia.php','actualizar','','Error de Concurrencia: '.$consulta); } }//if de condición no vacia }//FIN de actualizar }//FIN clase IgepPersistencia ?>