dbjames.class.php

Go to the documentation of this file.

<?
include_once("core/system/JSystem.class.php");

class DBJames
{

        // Variables $dbhost, $dbuser, $dbpasswd, $dbname
        var $dbhost;            
        var $dbuser;            
        var $dbpasswd;          
        var $dbname;            

        var $rs;                
        var $row;               
        var $numRows;           
        var $numFields;         
        var $dbConnection;      
        var $sql;               
        var $newID;             
        var $EOF;               
        
        var $msgDebug;          
        var $numErr;            
        var $desErr;            
        var $debug = true;      
        var $fileLog;           
        var $fileHdl;           



        function DBJames(){
                $this->dbhost = JSystem::GetConfig("DBHOST");
                $this->dbuser = JSystem::GetConfig("DBUSER");
                $this->dbpasswd = JSystem::GetConfig("DBPASSWD");
                $this->dbname = JSystem::GetConfig("DBNAME");
                $this->fileLog = JSystem::GetConfig("FLOG");

                $this->ConnectDatabase();
        }


        function ConnectDatabase(){

                $this->dbConnection = mysql_connect($this->dbhost,$this->dbuser,$this->dbpasswd);

                if(!$this->dbConnection && $this->debug){
                        $this->numErr = mysql_errno();
                        $this->desErr = mysql_error();
                        $this->msgDebug = "\nError nº ".$this->numErr; 
                        $this->msgDebug .= " al conectar con ";
                        $this->msgDebug .= $this->dbname; 
                        $this->msgDebug .=  "\nDescripción: ";
                        $this->msgDebug .= $this->desErr;                               
                        $this->msgDebug .= "\nFecha: " . date("d/m/Y - H:i:s");
                        $this->debug();
                }else{
                        $res = mysql_select_db($this->dbname,$this->dbConnection);
                }
        }


        function CloseDatabase(){
                if($this->dbConnection){
                        mysql_close($this->dbConnection);
                }
        }

        function Query($sql){
        
                if($this->dbConnection){
                        $this->sql = $sql;
                        $this->rs = mysql_query($this->sql, $this->dbConnection);

                        if (!$this->rs){
                                $msg = "Error al ejecutar query '".$sql."': ";
                                $msg .= mysql_errno().": ".mysql_error()."<br>\n";
                                $this->numRows = 0;
                                $this->EOF = true;
                                $this->msgDebug  = "Query:".$msg; 
                                $this->debug();
                                return;
                        }
                                                         
                        if($this->rs && mysql_num_rows($this->rs)){
                                $this->EOF = false;
                                $this->row = mysql_fetch_array($this->rs);
                                $this->numRows = mysql_num_rows($this->rs);
                                $this->numFields = mysql_num_fields($this->rs);
                        }else{
                                $this->numRows = 0;
                                $this->EOF = true;
                        }

                        $this->msgDebug  = "Query: [" . $sql . "] => "; 
                        $this->msgDebug .= "(". $this->numRows . ") fila/s";

                        $this->debug();
                }
        }
        


        function Execute($sql){
        
                if($this->dbConnection){   
                        $this->sql = $sql;
                        $this->rs = mysql_query($this->sql,$this->dbConnection);
                        $this->numRows = (mysql_affected_rows($this->dbConnection));
        
                        if($this->rs){
                                $this->EOF = false;
                        }else{
                                $this->EOF = true;               
                        }
        
                        $this->msgDebug  = "Execute: [" . $sql . "] => "; 
                        $this->msgDebug .= "(". $this->numRows . ") fila/s afectadas";
                        $this->debug();
                }
        
        }


        function SetInsertID(){
                if($this->dbConnection)
                        $this->newID = mysql_insert_id($this->dbConnection);
                else
                        $this->newID = false;
        }
        
                        
        function GetFieldName($col){
                return mysql_field_name($this->rs,$col);
        }               
                        


        function getValue($col){

                if(is_int($col))
                        return $this->row[$col];
                else
                        return $this->row[$col];

        }
           

        function Next(){

                if($this->rs && $this->dbConnection){

                          $this->row = mysql_fetch_array($this->rs);
                          if($this->row)
                                  $this->EOF = false;
                          else
                                  $this->EOF = true;

                 }
        }



        function First(){
                $this->Go(0);
        }
                        


        function Go($pos){

          // NOTA: Los resultados comienzan por la fila 0
                if(($this->rs) && ($pos <= $this->numRows) && ($pos >= 0)){
                        mysql_data_seek($this->rs,$pos);
                        $this->Next();
                }
        }

        function Debug(){
   
                $this->OpenFile();
                if($this->fileHdl){                             
                        $msg = "\n[".strftime("%D %T")."]";
                        $msg .= $this->msgDebug;
                        $msg .= "<hr>";
                        fwrite($this->fileHdl, $msg);
                        $this->CloseFile();
                }

        }
                

        function OpenFile()
        {
                $this->fileHdl = fopen($this->fileLog,'a');
        }
        


        function CloseFile()
        {
                if($this->fileHdl)
                        fclose($this->fileHdl);
        }               

}

// Fin clase DBJames

?>

---