File Source for MySQLDatabaseHost.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();
}
/**
*
*/
require_once( CLASSPATH."settings.inc.php" );
/**
*
*/
require_once( CLASSPATH."databases/ABSTDatabaseHost.class.php" );
/**
*
*/
include_once( CLASSPATH."databases/mysql/MySQLDatabase.class.php" );
/**
*
*/
include_once( CLASSPATH."filesystem/Files.class.php" );
/**
*
*/
include_once( CLASSPATH."filesystem/FilesystemToolkit.class.php" );
/**
*
*/
include_once( CLASSPATH."communication/FTPHost.class.php" );
/**
* @package databases
* @subpackage mysql
*
* @version 0.2.0
* @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 MySQLDatabaseHost extends ABSTDatabaseHost
{
/**
* This reference of a FTP object is for the use that dumps should save on the
* server via FTP, cause of SAFE MODE restriction.
*
* @access private
* @var FTPHost $ftp
*/
var $ftp = null;
/**
* Stores whether a persistant connection should be use.
*
* @access private
* @var FTPHost $ftp
*/
var $bool_persistant_connection = false;
/**
* Constructor
*
* @version 1.1
* @since 0.1.0
* @author Daniel PlÃ¼cken <daniel@debakel.net>
* @access public
* @param string $host*
* @param string $user*
* @param string $password*
* @param string $port*
* @return MySQLDatabaseHost
*/
function MySQLDatabaseHost(
$host = "localhost",
$user = "",
$password = "",
$port = 3306
)
{
parent::__constructor(
$host,
$user,
$password,
$port
);
}
/**
* Sets whether a persistant connection should be use.
*
* @version 1.0
* @since 0.2.0
* @author Daniel PlÃ¼cken <daniel@debakel.net>
* @access public
* @param boolean $boolean
* @return void
*/
function setPersistantConnection( $boolean = true )
{
if ( is_bool( $boolean ) )
$this->bool_persistant_connection = $boolean;
}
/**
* Adds a databasetable's reference to this object of a database.
*
* @version 1.3
* @since 0.1.0
* @author Daniel PlÃ¼cken <daniel@debakel.net>
* @access public
* @param object $dbt_obj
* @return void
*/
function addDB( &$db_obj )
{
parent::addDB( $db_obj );
if( GENERATEMYSQLSYSTEMERRORLOGS )
{
$db_obj->query(
"CREATE TABLE IF NOT EXISTS __admin_mysql_errorlogs ( "
."id INT(10) UNSIGNED NOT NULL auto_increment, "
."script_name VARCHAR(255) DEFAULT NULL, "
."time_first DATETIME NOT NULL, "
."time_last DATETIME NOT NULL, "
."active TINYINT(1) UNSIGNED NOT NULL DEFAULT '1', "
."mysql_query TEXT, "
."mysql_error TEXT, "
."mysql_errno INT(5) UNSIGNED NOT NULL DEFAULT '0', "
."comment TEXT, "
."PRIMARY KEY ( `id` ) "
.") TYPE = MyISAM;", true
);
}
}
/**
* Sets the references to objects of databases to the attribute $this -> db.
*
* @version 1.1
* @since 0.1.3
* @author Daniel PlÃ¼cken <daniel@debakel.net>
* @access public
* @param string $regExp Makes sure that only databases were stored, which
* names matching the given regular expression.
* @param string $regExp2 Makes sure that only tables of a Database were
* stored, which names matching the given regular
* expression.
* @param boolean $resTab Cause whether the tables of the researched
* databases should be research too.
* @param boolean $resFld Cause whether the tables's fields of the
* researched tables should be research too.
* @return void
*/
function researchDatabases(
$regExp = "",
$regExp2 = "",
$resTab = true,
$resFld = false
)
{
if( !$this->is_connected )
$this->connect();
if( $this->is_connected )
{
$db_list = mysql_list_dbs( $this->resID );
unset( $this->db );
$i = 0;
$cnt = mysql_num_rows( $db_list );
while( $i < $cnt )
{
$tmp_name = mysql_db_name( $db_list, $i );
if( empty( $regExp ) )
{
$this->db[$i] = new MySQLDatabase( $tmp_name, $this );
if(
$resTab
|| !empty( $regExp2 )
)
$this->db[$i]->researchTables( $regExp2, $resFld );
}
else
if( preg_match( $regExp, $tmp_name ) )
{
$t = count( $this->db );
$this->db[$t] = new MySQLDatabase( $tmp_name, $this );
if(
$resTab
|| !empty( $regExp2 )
)
$this->db[$t]->researchTables( $regExp2, $resFld );
}
$i++;
}
}
}
/**
* Dumps this Databasehost. If this object has stored ftp data the dump method
* "PHP" will be used and the dumps will be stored on the ftp server which is
* stated in the ftp data. Otherwise you can use two different methods to
* store the created dumps depending on the value of the constant
* "MYSQL_DUMP_KIND", which can be modified in the file "settings.inc.php".
* You can use the fast "MYSQLDUMP" method, if your hosting allows to use the
* function exec() and you have quoted the right path to mysqldump in the
* constant "PATH2MYSQLDUMP", also changeable in the file "settings.inc.php",
* or you can use the method "PHP". The method "PHP" do not need an external
* program but is slower than the method "MYSQLDUMP".
*
*
* @version 1.2
* @since 0.1.4
* @author Daniel PlÃ¼cken <daniel@debakel.net>
* @access public
* @param string $target
* @param string $regExp Makes sure that only databases were stored,
* which names matching the given regular
* expression.
* @param string $regExp2 Makes sure that only tables of a Database
* were stored, which names matching the given
* regular expression.
* @param boolean $full_inserts
* @param boolean $drop_order
* @return boolean
*/
function dump(
$target = "./__dumps",
$regExp = "",
$regExp2 = "",
$full_inserts = false,
$drop_order = false
)
{
$this->researchDatabases( $regExp, $regExp2 );
if (
!function_exists( "is_a" )
&& get_class( $this->ftp ) == "ftphost"
|| function_exists( "is_a" )
&& is_a( $this->ftp, "FTPHost" )
)
{
$tmp_arr = FilesystemToolkit
::separatePathAndFile( $_SERVER["SCRIPT_NAME"] );
if (
empty ( $tmp_arr[0] )
|| strpos( $target, "/" ) === 0
)
$ftp_path = $target;
else
$ftp_path = "/".FilesystemToolkit
::getPurePathFromTo( $tmp_arr[0], $target );
if ( $this->ftp->file_exists( $target ) )
$this->ftp->rename( $ftp_path, $ftp_path."_".date( "Y-m-d_H:i" ) );
if ( !$this->ftp->file_exists( $target ) )
$this->ftp->mkdir( $ftp_path, 0777 );
for ( $i = 0; $i < count( $this->db ); $i++ )
{
if ( !$this->ftp->file_exists( $target."/".$this->db[$i]->name ) )
$this->ftp->mkdir( $ftp_path."/".$this->db[$i]->name, 0777 );
for ( $k = 0; $k < count( $this->db[$i]->dbt ); $k++ )
{
echo $this->db[$i]->dbt[$k]->getLastQuery()."<br />\r\n";
$this->ftp->saveFile(
$ftp_path."/".$this->db[$i]->name."/"
.$this->db[$i]->dbt[$k]->name.".sql",
$this->db[$i]->dbt[$k]->getDump(
"",
$full_inserts,
$drop_order
)
);
}
}
}
else
{
if( !is_dir( $target ) )
mkdir( $target, 0777 );
$old = @umask( 0 );
@chmod( $target, 0777 );
@umask( $old );
for( $i = 0; $i < count( $this->db ); $i++ )
{
if( !is_dir( $target."/".$this->db[$i]->name ) )
mkdir( $target."/".$this->db[$i]->name, 0777 );
$old = @umask( 0 );
@chmod( $target."/".$this->db[$i]->name, 0777 );
@umask( $old );
echo "<b>Database</b> ".$this->db[$i]->name."<br />\r\n";
if( strtoupper( MYSQL_DUMP_KIND ) == "MYSQLDUMP" )
for( $k = 0; $k < count( $this->db[$i]->dbt ); $k++ )
{
$tmp_data_order = $this->db[$i]->name." "
.$this->db[$i]->dbt[$k]->name." > "
.$target."/".$this->db[$i]->name."/"
.$this->db[$i]->dbt[$k]->name.".sql";
$tmp_exec = FilesystemToolkit::getCleanPath( PATH2MYSQLDUMP )
."/mysqldump "
.(
$drop_order
? "--add-drop-table "
: ""
)
."--host=".$this->name." "
."--password=".$this->password." "
."--user=".$this->user." "
."--port=".$this->port." "
#."--lines-terminated-by=\\r\\n "
.$tmp_data_order;
exec( $tmp_exec );
echo $tmp_data_order;
echo "<br />\r\n";
}
else
for( $k = 0; $k < count( $this->db[$i]->dbt ); $k++ )
{
$f = new Files(
$target."/".$this->db[$i]->name."/"
.$this->db[$i]->dbt[$k]->name.".sql"
);
$f->setContent(
$this->db[$i]->dbt[$k]->getDump(
"",
$full_inserts,
$drop_order
)
);
echo $this->db[$i]->dbt[$k]->getLastQuery()."<br />\r\n";
$f->save();
$old = @umask( 0 );
@chmod(
$target."/".$this->db[$i]->name."/"
.$this->db[$i]->dbt[$k]->name.".sql",
0777
);
@umask( $old );
}
}
}
}
/**
* Researches a whole folder to import dumped data from it.
*
* @version 1.0
* @since 0.1.9
* @author Daniel PlÃ¼cken <daniel@debakel.net>
* @access public
* @param string $source The source folder
* @param string $regExpFolder Makes sure that only folder will be
* imported, which names matching the given
* regular expression.
* @param string $regExpFiles Makes sure that only files will be imported,
* which names matching the given regular
* expression.
* @return boolean
*/
function importDump(
$source = "./__dumps",
$regExpFolder = "",
$regExpFiles = ""
)
{
$tmp_arr = FilesystemToolkit::loadFolderContent(
$source, "^ &$", $regExpFolder
);
$this->researchDatabases();
for ( $i = 0; $i < count( $tmp_arr ); $i++ )
if ( $tmp_arr[$i]["is_dir"] )
for ( $k = 0; $k < count( $this->db ); $k++ )
if ( $this->db[$k]->name == $tmp_arr[$i]["name"] )
$this->db[$k]->importDump(
$source."/".$tmp_arr[$i]["name"],
$regExpFiles
);
}
/**
* Adds ftp data to this object. This can be useful for writing dumps if the
* sever has SAFE MODE restrictions.
*
* @version 1.0
* @since 0.1.7
* @author Daniel PlÃ¼cken <daniel@debakel.net>
* @access public
* @param string $host
* @param string $user
* @param string $password
* @param string $port
* @return void
*/
function addFTPData(
$host,
$user,
$password,
$port = 21
)
{ $this->ftp = new FTPHost( $host, $user, $password, $port ); }
/**
* Opens a connection to the database server.
*
* @version 1.1
* @since 0.1.0
* @author Daniel PlÃ¼cken <daniel@debakel.net>
* @access public
* @param boolean $boolean_persitant
* @return boolean
*/
function connect( $boolean_persitant = false )
{
if(
(
$boolean_persitant
|| $this->bool_persistant_connection
)
&& $this->resID = @mysql_pconnect(
$this->name.":".$this->port,
$this->user,
$this->password
)
)
{
$this->is_connected = true;
return true;
}
else
if(
$this->resID = @mysql_connect(
$this->name.":".$this->port,
$this->user,
$this->password
)
)
{
$this->is_connected = true;
return true;
}
$this->is_connected = false;
return false;
}
/**
* Closes the current connection to the database server.
*
* @version 1.0
* @since 0.1.0
* @author Daniel PlÃ¼cken <daniel@debakel.net>
* @access public
*/
function disconnect()
{
if ( mysql_close() )
$this->is_connected = false;
}
} // End of class MySQLDatabase
?>

Source for file MySQLDatabaseHost.class.php