File Source for MySQLDatabase.class.php

<?php
/*
if( !extension_loaded( 'mysql' ) )
dl( 'mysql.so' );
*/
/**
* For including this file you have to define the constant "CLASSPATH".
* Because every include in the framework depends on the CLASSPATH definition.
* The CLASSPATH means the relative path to the folder that contains the
* framework GilliGan.
*
* @package databases
* @subpackage mysql
*/
if( !defined( "CLASSPATH" ) )
{
echo "<h3>You have to define the constant CLASSPATH!</h3>\r\n";
echo "Example: define( 'CLASSPATH', '../path/to/classes/' );\r\n";
exit();
}
if( defined( "LANG" ) )
/**
* Including language specific messages.
*/
include( CLASSPATH."core/lang_spec_values/".LANG.".inc.php" );
else
{
echo "<h3>You have to define the constant LANG!</h3>\r\n";
echo "Example for german: define( 'LANG', 'de' );\r\n";
exit();
}
/**
* Loading global settings for GilliGan.
*/
require_once( CLASSPATH."settings.inc.php" );
/**
*
*/
include_once( CLASSPATH."core/PlainTextFormatter.class.php" );
/**
* Loading the parent class.
*/
require_once( CLASSPATH."databases/Database.class.php" );
/**
*
*/
include_once( CLASSPATH."databases/mysql/MySQLDatabaseTable.class.php" );
/**
*
*/
include_once( CLASSPATH."filesystem/Files.class.php" );
/**
*
*/
include_once( CLASSPATH."filesystem/FilesystemToolkit.class.php" );
/**
*
*/
$GLOBALS["GilliGan_MySQL_QueryLog"] = "";
/**
* @package databases
* @subpackage mysql
*
* @version 0.2.02
* @author Daniel Plücken <daniel@debakel.net>
* @license http://www.gnu.org/copyleft/lesser.html
* GNU Lesser General Public License
* @copyright Copyright (C) 2004 Daniel Plücken <daniel@debakel.net>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General
* Public License along with this library; if not, write to the
* Free Software Foundation, Inc., 59 Temple Place, Suite 330,
* Boston, MA 02111-1307 USA
*/
class MySQLDatabase extends Database
{
/**
* Constructor
*
* @access public
* @version 1.21
* @since 0.1.0
*
* @param string $name
* @param object $parent
*
* @return MySQLDatabase
*/
function MySQLDatabase( $name, $parent = "" )
{
if( !empty( $name ) )
{
$this->name = $name;
if(
!function_exists( "is_a" )
&& get_class( $parent ) == "mysqldatabasehost"
|| function_exists( "is_a" )
&& is_a( $parent, "MySQLDatabaseHost" )
)
$parent->addDB( $this );
}
else
if(
defined( "DEBUG" )
|| SCRIPTDEBUGGING
)
{
echo "<pre>\r\n";
echo "<h3>You have to give a name to this database!</h3>";
echo "Use following Syntax:\r\n\r\n";
echo " \x24db = new MySQLDatabase( \x24name, $parent = \"\" );\r\n\r\n";
echo "BACKTRACE DEBUG:\r\n";
$debugArr = debug_backtrace();
if ( DEBUG_COMPLETE_BACKTRACES )
print_r( $debugArr );
else
print_r( $debugArr[count($debugArr)-1] );
echo "</pre>\r\n";
}
}
/**
* Sets the references to objects of database-tables to the attribute
* $this->dbt.
*
* @access public
* @version 1.11
* @since 0.1.0
*
* @param string $regExp Makes sure that only database-tables were stored,
* which names matching the given regular expression.
* @param boolean $resFld Cause whether the tables's fields should be
* research too.
*
* @return void
*/
function researchTables( $regExp = "", $resFld = false )
{
if( $this->probeConnection() )
{
$dbt_list = mysql_list_tables( $this->name, $this->getResourceID() );
unset( $this->db );
$i = 0;
$t = 0;
$cnt = mysql_num_rows( $dbt_list );
while( $i < $cnt )
{
$tmp_name = mysql_db_name( $dbt_list, $i );
if( empty( $regExp ) )
{
$this->dbt[$i] = new MySQLDatabaseTable( $tmp_name );
$this->dbt[$i]->setParent( $this );
if( $resFld )
$this->dbt[$i]->researchFields();
}
else
if( preg_match( $regExp, $tmp_name ) )
{
$this->dbt[$t] = new MySQLDatabaseTable( $tmp_name );
$this->dbt[$t]->setParent( $this );
if( $resFld )
$this->dbt[$t]->researchFields();
$t++;
}
$i++;
}
}
}
/**
* Dumps this Database.
*
* @access public
* @version 1.1
* @since 0.1.1
*
* @param string $target
* @param string $regExp Makes sure that only database-tables were stored,
* which names matching the given regular expression.
*
* @return boolean
*/
function dump( $target = "./__dumps", $regExp = "" )
{
$this->researchTables( $regExp = "", $regExp2 = "" );
if( !is_dir( $target ) )
mkdir( $target, 0777 );
$old = @umask( 0 );
@chmod( $target, 0777 );
@umask( $old );
if( !is_dir( $target."/".$this->name ) )
mkdir( $target."/".$this->name, 0777 );
$old = @umask( 0 );
@chmod( $target."/".$this->name, 0777 );
@umask( $old );
echo "Database ".$this->name." \r\n";
for( $i = 0; $i < count( $this->dbt ); $i++ )
{
$f = new Files(
$target."/".$this->name."/"
.$this->dbt[$i]->name.".sql"
);
$f->setContent( $this->dbt[$i]->getDump() );
echo $this->dbt[$i]->getLastQuery()." \r\n";
$f->save();
$old = @umask( 0 );
@chmod(
$target."/".$this->name."/"
.$this->dbt[$i]->name.".sql",
0777
);
@umask( $old );
}
}
/**
* Imports Dumps from given source to this database.
*
* @access public
* @version 1.1
* @since 0.1.1
*
* @param string $source
* @param string $regExp Makes sure that only files will be imported,
* which names matching the given regular expression.
*
* @return boolean
*/
function importDump( $source = "./__dumps", $regExp = "" )
{
$tmp_arr = FilesystemToolkit::loadFolderContent( $source, $regExp, "^ &$" );
$source = FilesystemToolkit::getCleanPath( $source );
if( strtoupper( MYSQL_IMPORT_KIND ) == "MYSQL" )
for( $i = 0; $i < count( $tmp_arr ); $i++ )
{
$tmp_data_order = "-e \"source ".$source."/".$tmp_arr[$i]["name"]."\" "
.$this->name;
$tmp_exec = FilesystemToolkit::getCleanPath( PATH2MYSQL )
."/mysql ".$tmp_data_order;
echo $tmp_exec." ";
exec( $tmp_exec );
}
else
for( $i = 0; $i < count( $tmp_arr ); $i++ )
{
$tmp_f = new Files( $source."/".$tmp_arr[$i]["name"] );
$str_tmp = &$tmp_f->getContent();
$this->import( $str_tmp );
unset( $tmp_f );
}
}
/**
* Researches a whole folder to import dumped data from it.
*
* @access public
* @version 1.5
* @since 0.1.7
*
* @param string $source The source resource of the MySQL-Dump.
*
* @return boolean
*/
function importSingleDump( $source = "http://www.test.de/getMySQLTable.php" )
{
if ( $f = fopen( $source, 'r' ) )
{
$str_rest = "";
while ( !feof( $f ) )
{
$data = $str_rest.fgets( $f );
$pos = 0;
$query = "";
while (
(
$pos_new = Strings::pregpos(
$data,
"!;\s+(?:INSERT|REPLACE|UPDATE|DROP|CREATE) !is",
$pos
)
) !== false
)
{
$length = $pos_new - $pos;
$tok = trim( substr( $data ,$pos, $length ) );
$query .= $tok;
if (
!empty( $query )
// Check whether the last tok ends with a html entity or
// unicode.
&& preg_match( "!&(?:[a-z0-9]{2,9}|#\d{1,5})$!i", $query )
)
$query .= ";\r\n";
else
if ( !preg_match( "!&(?:[a-z0-9]{2,9}|#\d{1,5})$!i", $query ) )
{
$this->query( $query );
$query = "";
}
$pos = $pos_new + 3;
}
$str_rest = substr( $data ,$pos );
ob_flush();
flush();
}
fclose( $f );
}
$str_rest = trim( $str_rest );
if ( !empty( $str_rest ) )
$this->query( $str_rest );
}
// * - %databasetable% -> The name of the database in which an error occurs.
/**
* This function parses pseudo variables in a text on SQL-errors.
*
* - %database% -> The name of this database.
* - %query% -> The query which was tried to execute.
*
* @static
* @access public
* @version 1.0
* @since 0.1.5
*
* @param string $database
* @param string $query
* @param string $text
*
* @return string
*/
function __parse_vars( $database, $query, $text )
{
$out = preg_replace( "!\%database\%!i", $database, $text );
$out = preg_replace( "!\%query\%!i", $query, $out );
// $out = preg_replace( "!\%databasetable\%!i", $databasetable, $out );
return $out;
}
/**
* Will query this database.
*
* @access public
* @version 1.6
* @since 0.1.0
*
* @param string $sqlOrder
* @param boolean $no_logs
*
* @return boolean
*/
function query( $sqlOrder, $no_logs = false )
{
static $int_query_cnt = 1;
if ( MYSQLDEBUGGING )
{ $query_microtime_begin = time() + microtime(); }
if ( $this->probeConnection() )
{
$result = mysql_db_query(
$this->name, $sqlOrder,
$this->getResourceID()
);
}
if ( MYSQLDEBUGGING )
{
$query_microtime = time() + microtime() - $query_microtime_begin;
$GLOBALS["GilliGan_MySQL_QueryLog"] .= "\r\n<!--\r\nQuery "
.$int_query_cnt.":\r\n"
."------\r\n"
.PlainTextFormatter::formatSQL(
str_replace(
"-->",
"--[ADDED TO AVOID CLOSING OF EMBRACING COMMENT]>",
$sqlOrder
)
)
."\r\n------------------------------------------\r\n"
."Execution Time: "
.$query_microtime
." Seconds"
."\r\n------------------------------------------\r\n"
."-->";
$GLOBALS["GilliGan_MySQL_QueryExecutionTime"] += $query_microtime;
$int_query_cnt++;
}
$this->last_query = $sqlOrder;
$err = mysql_error( $this->getResourceID() );
$errno = mysql_errno( $this->getResourceID() );
if ( !$result )
{
if (
!empty( $this->parent->error_callback )
&& function_exists( $this->parent->error_callback )
&& in_array(
$errno,
array(
// no connection
2013,
// Access denied for user
1045,
// no such database
1049
)
)
)
{
$tmp_name = $this->parent->error_callback;
$tmp_name( $errno, $err );
}
else
if (
!empty( $this->error_callback )
&& function_exists( $this->error_callback )
)
{
$tmp_name = $this->error_callback;
$tmp_name( $errno, $err );
}
else
{
if (
!$no_logs
&& GENERATEMYSQLSYSTEMERRORLOGS
)
{
$res = $this->query(
"SELECT * "
."FROM __admin_mysql_errorlogs "
."WHERE script_name = '".$_SERVER["SCRIPT_NAME"]."' "
."AND mysql_errno = '".$errno."' "
."AND active = '1'",
true
);
$cnt = mysql_num_rows( $res );
if( $cnt > 0 )
$this->query(
"UPDATE __admin_mysql_errorlogs "
."SET mysql_error = '".str_replace( "'","\'", $err )."', "
."mysql_errno = '".$errno."', "
."mysql_query = '".str_replace( "'","\'", $sqlOrder )."', "
."time_last = NOW() "
."WHERE script_name = '".$_SERVER["SCRIPT_NAME"]."'", true
);
else
{
$this->query(
"INSERT INTO __admin_mysql_errorlogs "
."SET mysql_error = '".str_replace( "'","\'", $err )."', "
."mysql_errno = '".$errno."', "
."mysql_query = '".str_replace( "'","\'", $sqlOrder )."', "
."time_first = NOW(), "
."script_name = '".$_SERVER["SCRIPT_NAME"]."'", true
);
mail(
ADMINEMAIL,
$GLOBALS["email_subject"]["sqlerror"],
MySQLDatabase::__parse_vars(
$this->name,
$sqlOrder,
$GLOBALS["email_body"]["sqlerror"]
),
"From: \"info@".str_replace(
"www.", "",
$_SERVER["HTTP_HOST"]
)."\" "
."< info@".str_replace(
"www.", "",
$_SERVER["HTTP_HOST"]
)." >\r\n"
."Reply-To: \"noreply\" <>\r\n"
);
}
/*
$res_arr = mysql_fetch_assoc( $res )
if( empty( $res_arr["active"] ) )
mail( );
*/
}
if (
defined( "DEBUG" )
|| MYSQLDEBUGGING
)
{
if ( function_exists( "debug_backtrace" ) )
{
echo "<pre>\r\n";
echo "An error occurs!\r\n";
echo "BACKTRACE DEBUG:\r\n";
$debugArr = debug_backtrace();
if ( DEBUG_COMPLETE_BACKTRACES )
print_r( $debugArr );
else
print_r( $debugArr[count($debugArr)-1] );
echo "</pre>\r\n";
echo " \r\n";
}
echo "ISO-Occurrance-Date: "
.date( "Y-m-d H:i:s" )." \r\n";
echo "MySQL says: \r\n";
echo $err." \r\n";
echo "Your query is: \r\n";
die( "<pre>".PlainTextFormatter::formatSQL( $sqlOrder )."</pre>" );
}
}
}
return $result;
}
/**
* Imports a given SQL-string into this Database.
*
* @access public
* @version 1.0
* @since 0.1.43
*
* @param string $str_dump The dump to import.
*
* @return boolean
*/
function import( $str_dump )
{
$tmp_look_ahead = "(?="
."("
."INSERT\s+INTO"
."|REPLACE\s+INTO"
."|UPDATE"
."|CREATE\s+TABLE"
."|DROP\s+TABLE"
.")"
.")";
$tmp_reg_exp = "(\s*+|--[^\r\n]*+)*{$tmp_look_ahead}";
$str_dump = preg_replace( "!^{$tmp_reg_exp}!is", "", $str_dump );
$order_arr = preg_split( "!;{$tmp_reg_exp}!is", $str_dump );
foreach ( $order_arr as $str_query )
$this->query( $str_query );
}
/**
* Probes whether there is a connection to the databasehost, if not it will
* attempt to connect to the host.
*
* @access public
* @version 1.21
* @since 0.1.1
*
* @return boolean
*/
function probeConnection()
{
if(
function_exists( "debug_backtrace" )
&& (
!function_exists( "is_a" )
&& get_class( $this->parent ) != "mysqldatabasehost"
|| function_exists( "is_a" )
&& !is_a( $this->parent, "MySQLDatabaseHost" )
)
&& (
defined( "DEBUG" )
|| MYSQLDEBUGGING
)
)
{
$debugArr = debug_backtrace();
echo "There is no valid parent-object for the database named "
."\"".$this->name."\". \r\n"
."Please add this database-object to a databasehost-object before "
."you make a call such as on line "
.$debugArr[count($debugArr)-1]["line"]." in file \""
.$debugArr[count($debugArr)-1]["file"]."\"."
." \r\n";
echo "BACKTRACE DEBUG: \r\n";
echo "<pre>\r\n";
if ( DEBUG_COMPLETE_BACKTRACES )
print_r( $debugArr );
else
print_r( $debugArr[count($debugArr)-1] );
echo "</pre>\r\n";
exit();
}
else
if( !$this->parent->is_connected )
$this->parent->connect();
if( $this->parent->is_connected )
return true;
else
return false;
}
} // END of class MySQLDatabase
?>

Source for file MySQLDatabase.class.php