<?php
/***********************************\
Fabrizio Parrella
updated on: 09/20/2004 - v.1.0 - initial release
updated on: 09/21/2004 - v.1.1 - added fetch_object
updated on: 09/22/2004 - v.1.2 - change the show/hide errors system
updated on: 09/22/2004 - v.1.2.1 - added the $debug variable
updated on: 10/06/2004 - v.1.2.2 - added the total_time variable to keep track of the time that is needed to run the queries
updated on: 01/04/2005 - v.1.3 - added transactions
updated on: 07/29/2005 - v.1.4 - added the possibility to substitute text in the query
updated on: 08/08/2005 - v.1.4.1 - added mysql_escape_string
updated on: 10/13/2005 - v.1.5 - added the possibility to have the query ALWAYS cache (when it is a select)
updated on: 10/13/2005 - v.1.5.1 - added some extra error checking
updated on: 11/01/2005 - v.1.5.2 - if in a query is set SQL_NO_CACHE, the select will not force the SQL_CACHE
updated on: 11/08/2005 - v.1.5.3 - added a function catled dbug to print or not the debug information
updated on: 12/27/2005 - v.1.6 - adapted to work withPHP4 and PHP5 w/o error messages (E_STRICTS, OR E_WARNING, OR E_NOTE)
updated on: 12/29/2005 - v.1.6.1 - added mysql_num_fields, mysql_fetch_field, and mysql_fetch_row
updated on: 02/04/2006 - v.1.6.2 - added trigger_error when mysql generate an error, this will allow the programmer to manage the error in a better way
updated on: 02/20/2006 - v.1.6.3 - fixed the variable: db_accesses to be internal and not global
updated on: 02/27/2006 - v.1.6.4 - fixed the email to send the whole current page and not only the script name
updated on: 06/25/2006 - v.1.7 - changed function "query" and "query_first", added a second parameter: $record_type
added functions:
mysql_data_seek: if the second parameter is not passed, will position on a random record
set_default_result_type: will change the default $result_type for the query function
updated on: 07/04/2006 - v.1.8 - added close function to close a mysql connection
updated on: 07/21/2006 - v.1.9 - added connect_first_use parameter, to allow the class to connect only when it is used the first time
this will avoid connection to the database when there are not queries executed
fabrizio@nldesign.com
this class is one of the many classes to access the MYSQL database.
this class will send an email evrytime that there is an error with some query, in this way
will be simpler to monitor the site and to see if there is any kind of problem
with MYSQL/query
\***********************************/
if(phpversion()>=5){
require_once realpath(dirname(__FILE__).'/php5x/'.basename(__FILE__));
}else{
require_once realpath(dirname(__FILE__).'/php4x/'.basename(__FILE__));
}
class db_bibivu extends db_bibivu_vars{
function db_bibivu(){
$this->substitute['what'] = '';
$this->substitute['with'] = '';
// $this->default_result_type = MYSQL_ASSOC;
// $this->default_result_type = MYSQL_NUM;
$this->default_result_type = MYSQL_BOTH; //mysql default
}
function set_default_result_type($result_type){
if(
$result_type == MYSQL_ASSOC ||
$result_type == MYSQL_NUM ||
$result_type == MYSQL_BOTH
){
$this->default_result_type = $result_type;
}
}
function substitute($what, $with){
$this->substitute['what'] = $what;
$this->substitute['with'] = $with;
}
function connect($persistant = false, $first_use = false) {
$this->persistant = $persistant;
if($this->connect_first_use==0 || $first_use){
$time1=$this->getmicrotime();
if ( 0 == $this->link_id ) {
if($persistant){
$this->link_id=@mysql_pconnect($this->server,$this->user,$this->password,true);
} else {
$this->link_id=@mysql_connect($this->server,$this->user,$this->password,true);
}
if (!$this->link_id) {
$this->print_error('Link-ID == false, connect failed');
}elseif ($this->database!='') {
$this->select_db($this->database);
}
}
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
}
}
function pconnect() {
$this->connect(true);
}
function is_connected(){
return (bool)$this->link_id;
}
function geterrdesc() {
$this->error=mysql_error();
return $this->error;
}
function geterrno() {
$this->errno=mysql_errno();
return $this->errno;
}
function select_db($database='') {
if ($database!='') {
$this->database=$database;
}
if(!mysql_select_db($this->database)) {
$this->print_error('Impossible to open the database '.$this->database);
}
}
function query($query_string) {
if(!$this->is_connected() && $this->connect_first_use==1){
//first connection, I try to connect
$this->connect($this->persistant,true);
}
if($this->link_id){
$time1=$this->getmicrotime();
$this->db_accesses++;
$query_string = trim($query_string);
if($this->substitute['what'] != '' && $this->substitute['with'] != ''){
$query_string = str_replace($this->substitute['what'],$this->substitute['with'],$query_string);
}
if($this->SQL_CACHE==1){
if(strtoupper(substr($query_string,0,6)) == 'SELECT' && !preg_match('/^SELECT[\s+]SQL_NO_CACHE/i', $query_string)){
$query_string = preg_replace('/^SELECT[\s+]SQL_CACHE/i','SELECT ',$query_string);
$query_string = preg_replace('/^SELECT[\s+]/i','SELECT SQL_CACHE ',$query_string);
}
}
$this->dbug('<font size="1">'.$this->db_accesses.' - DATABASE ACCESS<br/>'.$query_string);
$this->query_id = mysql_query($query_string,$this->link_id);
$this->write_log($query_string); //save the query log
$time2=$this->getmicrotime();
$this->dbug('('.($time2-$time1).')</font><br />');
$this->total_time += $time2-$time1;
if (!$this->query_id) {
$this->print_error('QUERY SQL not valid: '.$query_string);
if($this->in_trans){
$this->rollback_transaction();
}
}
return $this->query_id;
} else {
return false;
}
}
function query_first($query_string, $result_type=NULL) {
if($this->query($query_string)!=false){ //call the query function
$returnarray=$this->fetch_array($this->query_id, $result_type);
$this->free_result($this->query_id);
return $returnarray;
} else {
return false;
}
}
function data_seek($query_id=-1,$pos=-1){
$time1=$this->getmicrotime();
if ($query_id!=-1) {
$this->query_id=$query_id;
}
if($this->query_id){
if($this->num_rows($this->query_id)>0){
if($pos==-1){
//a random position
$pos = rand(1,$this->num_rows($this->query_id))-1;
}
$return = mysql_data_seek($this->query_id,$pos);
} else {
$return = false;
}
}else{
$return = false;
}
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $return;
}
function fetch_array($query_id=-1, $result_type=NULL) {
$time1=$this->getmicrotime();
if ($query_id!=-1) {
$this->query_id=$query_id;
}
if($result_type==NULL) $result_type = $this->default_result_type;
if($this->query_id){
$this->record = mysql_fetch_array($this->query_id, $result_type);
}else{
$this->record = false;
}
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $this->record;
}
function fetch_object($query_id=-1) {
$time1=$this->getmicrotime();
/*
thanks to:
Thomas Bruhin - mailto:thomas@mediasonics.ch
Media Sonics - http://www.mediasonics.ch
*/
if ($query_id!=-1) {
$this->query_id=$query_id;
}
if($this->query_id){
$this->record = mysql_fetch_object($this->query_id);
}else{
$this->record = false;
}
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $this->record;
}
function fetch_row($query_id=-1) {
$time1=$this->getmicrotime();
if ($query_id!=-1) {
$this->query_id=$query_id;
}
if($this->query_id){
$this->record = mysql_fetch_row($this->query_id);
}else{
$this->record = false;
}
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $this->record;
}
function fetch_field($query_id=-1, $field_offset=0) {
$time1=$this->getmicrotime();
if ($query_id!=-1) {
$this->query_id=$query_id;
}
if($this->query_id){
$this->record = mysql_fetch_field($this->query_id, $field_offset);
}else{
$this->record = false;
}
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $this->record;
}
function num_fields($query_id=-1) {
$time1=$this->getmicrotime();
if ($query_id!=-1) {
$this->query_id=$query_id;
}
if($this->query_id){
$this->record = mysql_num_fields($this->query_id);
}else{
$this->record = 0;
}
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $this->record;
}
function start_transaction($query = 'START TRANSACTION;'){
$this->query('SET AUTOCOMMIT=0;');
$this->query($query);
$this->in_trans = true;
}
function rollback_transaction($query = 'ROLLBACK;'){
if($this->in_trans){
$this->query($query);
$this->query('SET AUTOCOMMIT=1;');
$this->in_trans = false;
}
}
function commit_transaction($query = 'COMMIT;'){
if($this->in_trans){
$this->query($query);
$this->query('SET AUTOCOMMIT=1;');
$this->in_trans = false;
}
}
function free_result($query_id=-1) {
$time1=$this->getmicrotime();
if ($query_id!=-1) {
$this->query_id=$query_id;
}
$return = mysql_free_result($this->query_id);
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $return;
}
function num_rows($query_id=-1) {
$time1=$this->getmicrotime();
if ($query_id!=-1) {
$this->query_id=$query_id;
}
$return = mysql_num_rows($this->query_id);
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $return;
}
function affected_rows() {
$time1=$this->getmicrotime();
if($this->link_id){
$return = mysql_affected_rows($this->link_id);
}
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $return;
}
function insert_id() {
$time1=$this->getmicrotime();
if($this->link_id){
$return = mysql_insert_id($this->link_id);
}
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $return;
}
function real_escape_string($string) {
$time1=$this->getmicrotime();
if(!$this->is_connected() && $this->connect_first_use==1){
//first connection, I try to connect
$this->connect($this->persistant,true);
}
if($string!='' && $this->link_id){
$return = mysql_real_escape_string($string,$this->link_id);
} else {
$return =$string;
}
// $return = mysql_real_escape_string($string);
$time2=$this->getmicrotime();
$this->total_time += $time2-$time1;
return $return;
}
function escape_string($string) {
//alias for escape_string($string)
return $this->real_escape_string($string);
}
function print_error($msg) {
// need to add a session variable to send the errr message to the email
// only once per session or every 15 minutes
if($this->link_id){
$this->errdesc=mysql_error($this->link_id);
$this->errno=mysql_errno($this->link_id);
} else {
//no connection, just gettin the last error from Mysql
$this->errdesc=mysql_error();
$this->errno=mysql_errno();
}
if(!isset($_SESSION[$this->appname][$this->errno]) || ($_SESSION[$this->appname][$this->errno]+(60*15))>time()){
$_SESSION[$this->appname][$this->errno] = time();
$messagehtml ='Error in the DB in '.$this->appname.': '.$msg.'<br />';
$messagehtml.='error mySQL : '.$this->errdesc.'<br />';
$messagehtml.='error number mySQL : '.$this->errno.'<br />';
$messagehtml.='Date : '.date('d.m.Y @ H:i').'<br />';
$messagehtml.='Page : http'.(isset($_SERVER['HTTPS'])?'s':'').'://'.(isset($_SERVER['SERVER_NAME'])?$_SERVER['SERVER_NAME']:'').(isset($_SERVER['REQUEST_URI'])?$_SERVER['REQUEST_URI']:'').'<br />';
$messagehtml.='Referrer : '.(isset($_SERVER['HTTP_REFERER'])?$_SERVER['HTTP_REFERER']:'').'<br />';
$messagehtml.='USER IP : '.$_SERVER['REMOTE_ADDR'].'<br />';
$message ='Error in the DB in '.$this->appname.': '.$msg."\n";
$message .='error mySQL : '.$this->errdesc."\n";
$message .='error number mySQL : '.$this->errno."\n";
$message .='Date : '.date('d.m.Y @ H:i')."\n";
$message .='Page : http'.(isset($_SERVER['HTTPS'])?'s':'').'://'.(isset($_SERVER['SERVER_NAME'])?$_SERVER['SERVER_NAME']:'').(isset($_SERVER['REQUEST_URI'])?$_SERVER['REQUEST_URI']:'')."\n";
$message .='Referrer : '.(isset($_SERVER['HTTP_REFERER'])?$_SERVER['HTTP_REFERER']:'')."\n";
$message .='USER IP : '.$_SERVER['REMOTE_ADDR']."\n";
if($this->show_error==1){
echo $messagehtml;
}elseif($this->show_error==0){
echo '<center><h1>ERROR !!</h1><br />an e-mail has been sent to the staff<br />we are sorry for this problem</center>';
echo "\n<!-- ".$message." -->\n";
}
$admin_email = $this->admin_email;
$headers = '';
$headers .= 'From: "web Site" <'.$admin_email.'>'."\n";
$headers .= 'Reply-To: "database" <'.$admin_email.'>'."\n";
$headers .= 'X-Sender: <$admin_email>'."\n";
$headers .= 'X-Mailer: PHP/'.phpversion()."\n"; //mailer
$headers .= 'X-Priority: 3'."\n"; //1 UrgentMessage, 3 Normal
if($admin_email!=''){
mail($admin_email, '[website]->Error DB',$message,$headers);
}
if($this->die_error==1){
die();
}elseif($this->trigger_error==1){
trigger_error('MYSQL ERROR!!('.$this->errno.')'.$this->errdesc, E_USER_ERROR);
$this->link_id = false;
}
}
}
function write_log($testo){
//salvo il log delle query che vengono eseguite su un file
if ($this->log==1){
if ($this->filelog=='') $this->filelog=date('Y-m-d').'.txt';
$testo = trim($testo);
if ((substr($testo,0,6)=='INSERT' || substr($testo,0,6)=='UPDATE' || substr($testo,0,6)=='DELETE' || substr($testo,0,7)=='REPLACE')){
$fp = fopen($this->filelog, 'a');
if ($fp){
$testo=str_replace("\n","\\n",$testo);
$testo=str_replace("\r","\\r",$testo);
fputs ($fp, $testo."\n");
fclose($fp);
}
}
}
}
function dbug($text){
if($this->debug==1){
echo $text;
}
$this->write_log('# dbug: '.$text);
}
function getmicrotime(){
static $var_controllo = 0;
static $tempo1;
if ($var_controllo == 0) {
list($usec, $sec) = explode(' ', microtime());
$tempo1 = (float)$usec + (float)$sec;
$var_controllo = 1;
} elseif ($var_controllo == 1) {
list($usec, $sec) = explode(' ', microtime());
$tempo2 = (float)$usec + (float)$sec;
$tempo_esecuzione = $tempo2 - $tempo1;
return $tempo_esecuzione;
}
}
function close(){
if($this->link_id){
return mysql_client_encoding($this->link_id);
}
}
}
?>
|
Download
