mconnection.class

Ir para a documentação deste ficheiro.

<?php
 
class MConnection
{
    var $db; // database object
    var $id; // the connection identifier
    var $traceback = array(); // a list of connection errors
    var $affectedrows;
    
    var $_miolo;     // MIOLO object
 
    function __construct($db)
    {
        $this->db = $db;
        $this->_miolo = $this->db->_miolo;
        $this->_miolo->Uses('database/' . $db->system . '/mquery.class');
    }
 
    // Virtual methods - to be implemented by the specific drivers
 
    public function _connect($dbhost, $LoginDB, $LoginUID, $LoginPWD, $persistent = true, $port='')
    {
    }
 
    public function _close()
    {
    }
 
    public function _error()
    {
    }
 
    public function _execute($sql)
    {
    }
 
    public function _createquery()
    {
    }
 
    public function _createproc()
    {
    }
 
    public function _chartotimestamp($timestamp)
    {
    }
 
    public function _chartodate($date)
    {
    }
 
    public function _timestamptochar($timestamp)
    {
    }
 
    public function _datetochar($date)
    {
    }
 
    // opens a connection to the specified data source
    function Open($dbhost, $LoginDB, $LoginUID, $LoginPWD, $persistent = true, $parameters = NULL, $port=NULL)
    {
        if ($this->id)
        {
            $this->Close();
        }
        $this->_connect($dbhost, $LoginDB, $LoginUID, $LoginPWD, $persistent, $parameters, $port);
        if (!$this->id)
        {
            $this->traceback[] = "Unable to estabilish DataBase Conection to host: $dbhost, DB: $LoginDB";
        }
        return $this->id;
    }
 
    function Close()
    {
        if ($this->id)
        {
            $this->_close($this->id);
            $this->id = 0;
        }
    }
 
    function GetError()
    {
        if (!$this->id)
        {
            $err = _M("No valid Database connection estabilished.");
        }
        elseif ($this->traceback)
        {
            $err .= "<br>" . implode("<br>", $this->traceback);
        }
        return $err;
    }
 
    function GetErrors()
    {
        return $this->traceback;
    }
 
    function GetErrorCount()
    {
        return count($this->traceback);
    }
 
    function CheckError()
    {
        if (empty($this->traceback))
        {
            return;
        }
        $n = count($this->traceback);
        if ($n > 0)
        {
            $msg = "";
            for ($i = 0; $i < $n; $i++)
            {
                $msg .= $this->traceback[$i] . "<br>";
            }
        }
        if ($msg != '')
        {
            throw new EDatabaseException($this->db->conf, $msg);
        }
    }
 
    function Execute($sql)
    {
        $this->_miolo->LogSQL($sql, false, $this->db->conf);
 
        if (!($success = $this->_execute($sql)))
        {
            throw new EDatabaseExecException($this->GetError());
        }
 
        return $success;
    }
 
    function Parse($sql)
    {
        $this->_miolo->LogSQL( _M('Parse: ') . $sql->command, false, $this->db->conf);
        $sql->stmt = $this->_parse($sql->command);
    }
 
    function Bind($sql)
    {
        if ($binds = $sql->parameters)
        {
            foreach ($binds as $ph => $pv)
            {
                $this->_bind($sql->stmt, $ph, $pv);
            }
        }
    }
 
    function getQuery($sql, $maxrows = null, $offset = null)
    {
        $this->_miolo->Assert($this->id, $this->GetErrors());
        try
        {
            $query = $this->_createquery();
            $query->SetConnection($this);
            $query->SetSQL($sql);
            if ($sql->bind)
            {
                if (!$sql->stmt)
                {
                    $this->Parse($sql);
                }
 
                $this->Bind($sql);
            }
 
            $query->Open($maxrows, $offset, $sql->stmt);
        }
        catch( Exception $e )
        {
            throw $e;
        }
 
        return $query;
    }
 
    function getQueryCommand($sqlCommand, $maxrows = null, $offset = null)
    {
        $this->_miolo->Assert($this->id, $this->GetErrors());
        $query = $this->_createquery();
        $query->SetConnection($this);
        $query->SetSQLCommand($sqlCommand);
        $query->Open($maxrows, $offset);
        return $query;
    }
 
    function ExecProc($sql, $aParams = null)
    {
        $this->_miolo->Assert($this->id, $this->GetErrors());
        $q = $this->_createproc();
        $q->conn = &$this;
        if ($sql != "")
        {
            $q->ExecProc($sql, $aParams);
        }
        return ($q->result ? $q->result : (!$q->error));
    }
}
?>