Datenbank über php Seite kopieren

<?php
class sync
{
	/*
	 * crAzywuLf lässt grüßen
	 */
	var $dbConnection = array("dbHost" => "localhost","dbUser" => "root","dbPass" => "","dbName" => "test");
	var $dbSyncConnection = array("dbHost" => "localhost","dbUser" => "root","dbPass" => "","dbName" => "test2");
	var $dbSyncTables = array("Tabelle1","Tabelle2","guestbook");
	/*
	 * Ab hier muss nichts mehr geändert werden
	 */
	var $dbActiveConnection = "";
	var $dbSyncTablesColumns = array();
	var $dbSyncTablesData = array();
	var $dbSyncTablesSQL = array();
	var $syncErros = "";

	function dbOpenConnection($arr)
	{
		$this->dbActiveConnection = mysql_connect($arr['dbHost'], $arr['dbUser'], $arr['dbPass']) or $this->syncErrors .= "Keine Verbindung zum Datenbankserver".print_r($arr)."
";
		mysql_select_db($arr['dbName']) or $this->syncErrors .= "Keine Verbindung zum Datenbank".$arr['dbName']."
";  
	}
	function dbCloseConnection()
	{
		mysql_close($this->dbActiveConnection);
	}
	function getTableColums($table)
	{
		$do = mysql_query("SHOW COLUMNS FROM $table");
		$fieldsArray = array();
		while($f = mysql_fetch_array($do))
		{
			array_push($fieldsArray,$f['Field']);
		}
		$this->dbSyncTablesColumns[$table] = $fieldsArray;	
	}
	function getTableInput($table)
	{
		$do = mysql_query("SELECT * FROM $table");
		$this->dbSyncTablesData[$table] = "";
		$this->dbSyncTablesData[$table] .= "INSERT INTO $table (".(implode(",",$this->dbSyncTablesColumns[$table])).") VALUES ";
		while($f = mysql_fetch_array($do))
		{
			if($f > 0)
			{
				$inputThere = true;
				$this->dbSyncTablesData[$table] .= "(";
				foreach($this->dbSyncTablesColumns[$table] as $column)
				{
					$this->dbSyncTablesData[$table] .= "'".mysql_real_escape_string($f[$column])."',";
				}
				$this->dbSyncTablesData[$table] = substr($this->dbSyncTablesData[$table],0,-1);
				$this->dbSyncTablesData[$table] .= "),";
			}
		}
		$this->dbSyncTablesData[$table] = substr($this->dbSyncTablesData[$table],0,-1);
		$this->dbSyncTablesData[$table] .= ";";
		if($inputThere !== true)
		{
			$this->dbSyncTablesData[$table] = "";			
		}
	}
	function getTableData($table)
	{
		$this->getTableColums($table);
		$this->getTableInput($table);
	}
	function getTableSQL()
	{
		foreach($this->dbSyncTables as $table)
		{
			$res = mysql_query("SHOW CREATE TABLE `$table`") or $this->syncErrors .= "Fehler beim erstellen von Table: ".$table."
";
			$f = mysql_fetch_array($res);

			$this->dbSyncTablesSQL[$table] = $f[1];
			$this->getTableData($table);
		}
	}
	function dropTables()
	{
		foreach($this->dbSyncTables as $table)
		{
			mysql_query("DROP TABLE ".$table) or $this->syncErrors .= "Fehler beim löschen von Table: ".$table."
";			
		}
	}
	function syncTables()
	{
		foreach($this->dbSyncTablesSQL as $table => $tableSQL)
		{
			mysql_query($tableSQL) or $this->syncErrors .= "Fehler beim synchronisieren von Table: 
<pre>".$tableSQL."</pre>
";	
		}
		foreach($this->dbSyncTables as $tab)
		{
			if($this->dbSyncTablesData[$tab] != "")
			{
				mysql_query($this->dbSyncTablesData[$tab]) or $this->syncErrors .= "Fehler beim synchronisieren von TabellenDaten: 
<pre>".$this->dbSyncTablesData[$tab]."</pre>".mysql_error()."
";
			}
		}
	}
}


$sync = new sync();
$sync->dbOpenConnection($sync->dbConnection);
$sync->getTableSQL();
$sync->dbCloseConnection($sync->dbActiveConnection);
$sync->dbOpenConnection($sync->dbSyncConnection);
$sync->dropTables();
$sync->syncTables();
$sync->dbCloseConnection($sync->dbActiveConnection);
echo $sync->syncErrors;


if($sync->syncErrors == "")
{
	echo "Database successfully synchronized";
}


?>