. * * For more information, contact Colosa Inc, 2566 Le Jeune Rd., * Coral Gables, FL, 33134, USA, or email info@colosa.com. * */ /** * * @package gulliver.system * */ require_once("DB.php"); define('DB_ERROR_NO_SHOW_AND_CONTINUE', 0); define('DB_ERROR_SHOW_AND_STOP', 1); define('DB_ERROR_SHOW_AND_CONTINUE', 2); define('DB_ERROR_SHOWALL_AND_STOP', 3); define('DB_ERROR_SHOWALL_AND_CONTINUE', 4); /** * DBConnection class definition * It is useful to stablish a connection * * @package gulliver.system * @author Fernando Ontiveros Lira * @copyright (C) 2002 by Colosa Development Team. */ class DBConnection { public $db; public $db_error; public $errorLevel; public $type; /** * *************************************************************** * /* Error types: * /* -1 Fatal error ( clase no instanced ) * /* -2 Syntax error ( session missing, query malformed, etc ) * /* -3 warning ( when the engine build a dangerous query, i.e delete without where clause ) * /* * /* Error level: * /* 0 don't display any error information and continue. * /* 1 display small box with error information and die. * /* 2 display small box with error information and continue * /* 3 display complete error information and die. * /* 4 display complete error information and continue. * /* * /* Error Structure * /* int error code * /* string error message * /* string error detailed message * /* * /* In all cases, the error will be saved in the apache log file * /* * /* */ /** * Starts DB connection with default values * * @author Fernando Ontiveros Lira * @access public * @param const $strServer Host Name * @param const $strUser User Name * @param const $strPwd Password * @param const $strDB Database Name * @param string $type Connection Type * @param integer $strPort Used Port * @param string $errorLevel Error values posibles are: * @return string * */ public function __construct($strServer = DB_HOST, $strUser = DB_USER, $strPwd = DB_PASS, $strDB = DB_NAME, $type = DB_ADAPTER, $strPort = 0, $errorLevel = 2) { $this->errorLevel = $errorLevel; if ($type == null) { $type = 'mysql'; } $this->type = $type; //print "

---

$type $strServer, $strUser, $strPwd, $strDB

---

"; switch ($type) { case 'mysql': $dsn = "mysql://$strUser:$strPwd@$strServer/$strDB"; break; case 'pgsql': //$dsn = "pgsql://postgres@$strServer/$strDB"; $prt = ($strPort == 0 || $strPort == 5432 ? '' : ":$strPort"); $dsn = "pgsql://$strUser:$strPwd@$strServer$prt/$strDB"; break; case 'odbc': $dsn = "odbc://$strUser:$strPwd@$strServer/$strDB"; break; case 'mssql': $strServer = substr($strServer, 0, strpos($strServer, ':')); $prt = ($strPort == 0 || $strPort == 1433 ? '' : ":$strPort"); $dsn = "mssql://$strUser:$strPwd@$strServer$prt/$strDB"; ///--) $dsn = "mssql://$strUser:$strPwd@$strServer/$strDB"; break; case 'oracle': $dsn = "oci8://$strUser:$strPwd@$strServer/$strDB"; break; default: $dsn = "mysql://$strUser:$strPwd@$strServer/$strDB"; break; } $this->db_error = null; if ($type === 'myxml') { $this->db = XMLDB::connect($strServer); } else { $this->db = DB::connect($dsn); } if (DB::isError($this->db)) { $this->db_error = $this->db; $this->db = null; $this->logError($this->db_error); } } /** * Close Connection and Generate Log Message * * @author Fernando Ontiveros Lira * @access public * @return void */ public function Reset() { if ($this->db) { $this->db->disconnect(); } $this->db = null; } /** * Disconnect from Data base * * @author Fernando Ontiveros Lira * @access public * @return void */ public function Free() { $this->Reset(); } /** * Close Connection * * @author Fernando Ontiveros Lira * @access public * @return void */ public function Close() { $this->Reset(); } /** * log Errors * * @author Fernando Ontiveros Lira * @access public * @param db_error $obj * @param string $errorLevel * @return void */ public function logError($obj, $errorLevel = null) { global $_SESSION; global $_SERVER; $filter = new InputFilter(); $_SERVER = $filter->xssFilterHard($_SERVER); $_SESSION = $filter->xssFilterHard($_SESSION); if (is_null($errorLevel)) { if (isset($this->errorLevel)) { $errorLevel = $this->errorLevel; } else { $errorLevel = DB_ERROR_SHOWALL_AND_STOP; //for fatal errors the default is 3, show detailed and die. } } if ($errorLevel == DB_ERROR_SHOW_AND_STOP || $errorLevel == DB_ERROR_SHOW_AND_CONTINUE || $errorLevel == DB_ERROR_SHOWALL_AND_STOP || $errorLevel == DB_ERROR_SHOWALL_AND_CONTINUE) { print ""; print ""; if ($errorLevel == DB_ERROR_SHOWALL_AND_STOP || $errorLevel == DB_ERROR_SHOWALL_AND_CONTINUE) { print ""; } print "

" . $obj->code . ' ' . $obj->message . "

" . $obj->userinfo . "

"; } if (defined('DB_ERROR_BACKTRACE') && DB_ERROR_BACKTRACE) { print "

"; print((htmlentities(DBConnection::traceError()))) ; print "

"; } //G::setErrorHandler ( ); //G::customErrorLog( 'DB_Error', $obj->code . ' ' . $obj->message . '-' . $obj->userinfo, '', '' ); if ($errorLevel == DB_ERROR_SHOW_AND_STOP || $errorLevel == DB_ERROR_SHOWALL_AND_STOP) { die(); //stop } } /** * Get the trace of the current execution (debug_backtrace). * * @author David Callizaya * @param string $tts * @param string $limit * @return string */ public function traceError($tts = 2, $limit = -1) { $trace = debug_backtrace(); $out = ''; foreach ($trace as $step) { if ($tts > 0) { $tts --; } else { $out .= '[' . basename($step['file']) . ': ' . $step['line'] . '] : ' . $step['function'] . '(' . DBConnection::printArgs($step['args']) . ")\n"; $limit --; if ($limit === 0) { return $out; } } } return $out; } /** * Print the arguments of a function * * @author David Callizaya * @param string $args * @return string */ public function printArgs($args) { $out = ''; if (is_array($args)) { foreach ($args as $arg) { if ($out !== '') { $out .= ' ,'; } if (is_string($arg)) { $out .= "'" . ($arg) . "'"; } elseif (is_array($arg)) { $out .= print_r($arg, 1); } elseif (is_object($arg)) { $out .= get_class($arg); // print_r ( $arg ,1 ); } elseif (! isset($arg)) { $out .= 'NULL'; } else { $out .= sprintf("%s", $arg); } } } else { if (! isset($args)) { $out = 'NULL'; } else { $out = print_r($args, 1); } } return $out; } /** * Gets last autoincrement value inserted * * @author Fernando Ontiveros Lira * @access public * @return void */ public function GetLastID() { if (PEAR_DATABASE === 'mysql') { $lastId = mysqli_insert_id($this->db); } else { $dberror = PEAR::raiseError(null, DB_ERROR_FEATURE_NOT_AVAILABLE, null, 'null', "getLastID with " . PEAR_DATABASE . ' database.', 'G_Error', true); DBconnection::logError($dberror, DB_ERROR_SHOWALL_AND_STOP); //this error will stop the execution, until we add this feature!! $lastId = $dberror; } return $lastId; } }