<?php
/**
* Fichero IgepPersistencia. Contiene la clase del mismo nombre.
*
* @version	$Id: IgepPersistencia.php,v 1.30 2006-05-31 12:40:16 afelixf Exp $
* @author David: <pascual_dav@gva.es> 
* @author Keka: <bermejo_mjo@gva.es>
* @author Vero: <navarro_ver@gva.es>
* @author Raquel: <borjabad_raq@gva.es> 
* @author Toni: <felix_ant@gva.es>
* @package	igep
*/


/**
* Definición del nombre del fichero actual
*/
define("NOMBRE_FICHERO","IgepPersistencia.php");

/**
* 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:
* <ul>
* <li><b>str_tabla</b> - Contiene el nombre de la tabla a la que hace referencia.</li>
* <li><b>obj_conexion</b> - El objeto conexión por el que se ha accedido a la tabla</li>
* <li><b>$obj_errorBD</b> - Referencia al objeto de error global</li>
* </ul>
*
* @version	$Id: IgepPersistencia.php,v 1.30 2006-05-31 12:40:16 afelixf Exp $
* @author David: <pascual_dav@gva.es> 
* @author Keka: <bermejo_mjo@gva.es>
* @author Vero: <navarro_ver@gva.es>
* @author Raquel: <borjabad_raq@gva.es> 
* @author Toni: <felix_ant@gva.es>
* @package	igep
*/
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;
  	
  /**
  * Constructor
  *
  * @access	public
  * @param	object	$obj_conexion
  * @param	string	$str_tabla
  */
  function IgepPersistencia($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;		
	}

	/**
	* Retorna el nombre de la tabla a la que hace referencia.
	*
	* @access	public
	* @return	string
	*/	
	function getTabla() {
		return $this->str_tabla;
	}
	
	/**
	* Dada una matriz de datos realiza los INSERTs en la tabla.
	* El parámetro que recibe es un array de tuplas. Cada tupla
	* debe ser un array asociativo del modo ["campo"]=>"valor".
	*
	* @access	public
	* @param	matriz	$m_datos
	*/		
  function insertar($m_datos){
    //Debug:Indicamos que ejecutamos la consulta
    IgepDebug::setDebug(DEBUG_IGEP,'IgepPersistencia: Ejecutamos INSERT');
    			 	 	
    foreach ($m_datos as $v_filaDatos) {	 			 		 	
      $res = $this->obj_conexion->autoExecute($this->str_tabla, $v_filaDatos, DB_AUTOQUERY_INSERT);
      if (DB::isError($res))	 		 								
    	 $this->obj_errorBD->setError('IGEP-1',NOMBRE_FICHERO,'Insertar',$res);    									    			
    }	 		 		 		 		 	
	}
	 
  /**
  * 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
  */				
  function borrar($v_filaDatos){		
    foreach($v_filaDatos as $prop => $val) {			
      if ($str_condicion!='') 
        $str_condicion.=' AND '; 
      $str_condicion.=$prop;
      //Escapamos los carácteres especiales			
      $val = str_replace("'","''",$val);
      $val = str_replace("\\","\\\\",$val);
      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);
    
    $res = $this->obj_conexion->query($consulta);					
    if (DB::isError($res))	 		 
      $this->obj_errorBD->setError("IGEP-2",NOMBRE_FICHERO,"borrar",$res,$consulta);
    else {
      //Comprobamos si existe error de concurrencia.
      if ($this->obj_conexion->affectedRows()==0)
        $this->obj_errorBD->setError('IGEP-4',NOMBRE_FICHERO,'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
  */					
  function actualizar($v_filaDatos,$v_filaDatosAntiguos){		
    foreach($v_filaDatos as $prop => $val) {					
      if($v_filaDatosAntiguos[$prop]!=$val){
        if ($str_set!='')  
          $str_set.=' ,';
        $str_set.=$prop;
        //Escapamos los carácteres especiales
        $val = str_replace("'","''",$val);
        $val = str_replace("\\","\\\\",$val);						
        if (gettype($val)=="string") { 
          if($val!="")
            $str_set.="='".$val."'";
          else
            $str_set.="= null";
        }
        else { 				
          if($val!="")
            $str_set.="=".$val;
          else
            $str_set.="= null";
        }
      }//Fin del if que comprueba si los datos son actualizados
    }//FIN foreach												
    foreach($v_filaDatosAntiguos as $prop => $val) {					
      if ($str_condicion!='') 
        $str_condicion.=' AND ';
      $str_condicion.=$prop;
      //Escapamos los carácteres especiales
      $val = str_replace("'","''",$val);
      $val = str_replace("\\","\\\\",$val);
      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);
      $res =  $this->obj_conexion->simpleQuery($consulta);				
      if (DB::isError($res))	 		 
        $this->obj_errorBD->setError('IGEP-3',NOMBRE_FICHERO,'actualizar',$res,$consulta);
      else {
        //Comprobamos si existe error de concurrencia.
        if ($this->obj_conexion->affectedRows()==0)  						
          $this->obj_errorBD->setError('IGEP-4',NOMBRE_FICHERO,'actualizar','','Error de Concurrencia: '.$consulta); 						 						 					
      }
    }//if de condición no vacia 		 		
  }//FIN de actualizar
}//FIN clase IgepPersistencia
?>