Synchronisation de 2 BDD MySQL en PHP

//Entrez ici les informations de votre base de données et le nom du fichier de sauvegarde.
$mysqlDatabaseName ='database';
$mysqlUserName ='xxxxxxxxxxxxxx';
$mysqlPassword ='xxxxxxxxxxxxxx';
$mysqlHostName ='adresse ip';
$mysqlExportPath ='fichier-export.sql';

//Veuillez ne pas modifier les points suivants
//Exportation de la base de données et résultat
$command='mysqldump --opt -h' .$mysqlHostName .' -u' .$mysqlUserName .' -p' .$mysqlPassword .' ' .$mysqlDatabaseName .' > ' .$mysqlExportPath;
exec($command,$output=array(),$worked);
switch($worked){
case 0:
echo 'La base de données <b>' .$mysqlDatabaseName .'</b> a été stockée avec succès dans le chemin suivant '.getcwd().'/' .$mysqlExportPath .'</b>';
break;
case 1:
echo 'Une erreur s est produite lors de l exportation de <b>' .$mysqlDatabaseName .'</b> vers'.getcwd().'/' .$mysqlExportPath .'</b>';
break;
case 2:
echo 'Une erreur d exportation s est produite, veuillez vérifier les informations suivantes : <br/><br/><table><tr><td>MySQL Database Name:</td><td><b>' .$mysqlDatabaseName .'</b></td></tr><tr><td>MySQL User Name:</td><td><b>' .$mysqlUserName .'</b></td></tr><tr><td>MySQL Password:</td><td><b>NOTSHOWN</b></td></tr><tr><td>MySQL Host Name:</td><td><b>' .$mysqlHostName .'</b></td></tr></table>';
break;
}

/**
* DatabaseExport is a tool to export database via PHP and store it via FTP
*
* Copyright (c) 2011 Tomas Pavlatka (http://tomas.pavlatka.cz)
*
* @package DatabaseExport
*/

header("content-type: text/plain; charset=utf-8");

// Require classes.
require_once 'classes/Database.php';

// Export params.
$params = array(
    'database' => array(
	    'db_host'       => 'localhost',
	    'db_name'       => 'db_name',
	    'db_user'       => 'root',
	    'db_password'   => '',
	    'db_charset'    => 'utf8'),
    'ftp' => array(
        'ftp_server'    => '',
        'ftp_username'  => '',
        'ftp_password'  => '',
        'ftp_folder'    => ''
    ),
    'export' => array(
        'export_folder' => './backups/',
        'export_zip'    => 'bzip2',
    )
);

// Export database..
$dbObj = new PTX_Database($params['database']);
$dbObj->connect();

$dbTables = array();
if($dbObj->mysqlListTables()) {
	while($table = $dbObj->mysqlFetchArray()){
		$dbTables[] = (string)$table[0];	
	}
}
$exportedData = $dbObj->dbExport($dbTables);
	
// Save a file.
$fileName = $params['database']['db_name'].'-'.date('YmdHis').'.sql';
$filePath = $params['export']['export_folder'].$fileName;

if($params['export']['export_zip'] == 'bzip2') {
    $fileName .= '.bz2';
    $filePath .= '.bz2';
	$bz = bzopen($filePath, "w");
    bzwrite($bz, $exportedData);
    bzclose($bz);
} else {
	$fopen = fopen($filePath,'w+');
	fwrite($fopen,$exportedData);
	fclose($fopen);	
}

// Copy to FTP.
$ftpConnect = ftp_connect($params['ftp']['ftp_server']);
$ftpLogin = ftp_login($ftpConnect, $params['ftp']['ftp_username'], $params['ftp']['ftp_password']);
if($ftpLogin) {
    // Upload a file
    $destination = $params['ftp']['ftp_folder'].$fileName;
    $upload = ftp_put($ftpConnect, $destination, $filePath, FTP_BINARY); 	
}
ftp_close($ftpConnect); 

/**
* DatabaseExport is a tool to export database via PHP and store it via FTP
*
* Copyright (c) 2011 Tomas Pavlatka (http://tomas.pavlatka.cz)
*
* @package DatabaseExport
*/

class PTX_Database {
	
	/*
	 * Holds actual connection.
	 */
	private $_dbConnect;
	
    /*
     * Private variable holding option for class.
     */
	private $_options = array(
		'db_host'       => '',
	    'db_name'       => '',
	    'db_user'       => '',
	    'db_password'   => '',
	    'db_charset'    => 'utf-8');

	private $_selectQuery;
	
	/**
	 * Construct.
	 * 
	 * constructor of the class
	 * @param array $options - parameters for class
	 */
	public function __construct(array $options = array()) {
		$this->_options = array_merge($this->_options,$options);
	}
	
	/**
	 * Connect.
	 * 
	 * connects to the database.
	 */
	public function connect(){
       
		if(!$this->_dbConnect = @mysql_connect($this->_options['db_host'],$this->_options['db_user'],$this->_options['db_password'])){
            exit('Unable to connect to database');
        }
        if(!@mysql_select_db($this->_options['db_name'], $this->_dbConnect)) {
            exit(sprintf('Unable to connect to database %s',$this->_options['db_name']));
        }
        
        // Set charset.
        mysql_query("SET CHARACTER SET ".$this->_options['db_charset']);
	}
	
	/**
	 * Export.
	 * 
	 * exports database into text
	 * @param array $tables - list of the table
	 * @return exported data
	 */
    public function dbExport(array $tables) {
        $exportData = null;
        
    	foreach($tables as $table) {
            $exportData .= $this->_createExportHeader($table);
            $exportData .= $this->_getExportData($table);
        }
        
        return $exportData;
    }
    
    /**
     * Mysql Fetch Array.
     * 
     * fetch array from database.
     */
    public function mysqlFetchArray(){
        return @mysql_fetch_array($this->_selectQuery);
    }
    
    /**
     * Mysql Fetch Assoc.
     * 
     * fetch array assoc from database.
     */
    public function mysqlFetchAssoc(){
        return @mysql_fetch_assoc($this->_selectQuery);
    }
	
    /**
     * Mysql List Tables.
     * 
     * mysql_query to find all tables in database.
     * @return true | false
     */
    public function mysqlListTables(){
        if(!$this->_selectQuery = @mysql_query("SHOW TABLES FROM ".$this->_options['db_name'],$this->_dbConnect)) {
            return false;
        } else {
            return true;	
        }
    }
    
    /**
     * Create export header (Private).
     * 
     * creates header for export
     * @param $table - name of a table
     * @return header
     */
    private function _createExportHeader($table) {
    	// Fields.
    	$fields = array();
    	$query = mysql_query("DESCRIBE `{$table}`",$this->_dbConnect);
        while($field = mysql_fetch_assoc($query)) {
              $fields[] = $field;
        }
        
        // Indexes.
        $indexes = array();
        $query = mysql_query("SHOW INDEXES FROM `{$table}`");
        while($index = mysql_fetch_assoc($query)) {
            if(isset($indexes[$index['Key_name']])) {
            	$indexes[$index['Key_name']][] = $index;
            } else {
            	$indexes[$index['Key_name']] = array($index);
            }
        }
        
        // Table status.
        $query = mysql_query("SHOW TABLE STATUS WHERE `Name` = '{$table}'");
        $status = mysql_fetch_assoc($query);
        
        // Table header.
        $header  = "DROP TABLE IF EXISTS `{$table}`;\n";
        $header .= "CREATE TABLE `{$table}` (\n";
        foreach($fields as $key => $values) {
        	$header .= "\t`".$values['Field']."` ".$values['Type'];
        	if($values['Null'] == 'NO') {
        		$header .= " not null";
        	} else {
        		$header .= " null";
        	}
        	
        	// TODO: What about MySQL constants ?
        	if(!empty($values['Default'])) {
        		if($values['Default'] == 'CURRENT_TIMESTAMP') {
        			$header .= " default ".$values['Default'];
        		} else {
                    $header .= " default '".$values['Default']."'";
        		}
        	}
        	if(!empty($values['Extra'])) {
        		$header .= " ".$values['Extra'];
        	}
        	
        	$header .= ",\n";
        }
        
        $countIndexes = count($indexes);
        $counter = 1;
        foreach($indexes as $indexKey => $indexValeus) {
        	if($indexKey == 'PRIMARY') {
        		$header .= "\tPRIMARY KEY (";
                    $keyString = null;
        		    foreach($indexValeus as $indKey => $indValues) {
                        $keyString .= "`".$indValues['Column_name']."`,";
                    }
                    $header .= substr($keyString,0,-1);
        	} else {
        		$header .= "\tKEY `".$indexKey."` (";
                    $keyString = null;
                    foreach($indexValeus as $indKey => $indValues) {
                    	
                        $keyString .= "`".$indValues['Column_name']."`";
                        
                        if(!empty($indValues['Sub_part'])) {
                        	$keyString .= ' ('.$indValues['Sub_part'].')';
                        }
                        $keyString .= ",";
                    }
                    $header .= substr($keyString,0,-1);
        	}
        	
        	if($counter++ < $countIndexes) {
        		$header .= "),\n";
        	} else {
        		$header .= ")\n";
        	}
        }
        
        $header .= ") ";
        
        // Additional information.
        $charsetExplode = explode('_',$status['Collation']);
        $status['Charset'] = (isset($charsetExplode[0])) ? $charsetExplode[0] : null;
        $additionalInfo = array('Engine' => 'ENGINE','Auto_increment' => 'AUTO_INCREMENT', 'Charset' => 'CHARSET', 'Collation'  => 'COLLATE');
        foreach($additionalInfo as $key => $name) {
        	if(isset($status[$key]) && !empty($status[$key])) {
        		$header .= $name .'='.$status[$key]." ";
        	} 
        }
        $header .= ";\n\n";
        
        return (string)$header;
    }

    /**
     * Get Export Data (Private).
     * 
     * exports records from database.
     * @param $table - name of a table
     * @return export of records
     */
    private function _getExportData($table) {
        $d = null;
        $data = mysql_query("SELECT * FROM `{$table}` WHERE 1", $this->_dbConnect);
        
        $counter = 1;
        $insertData = null;
        $rowCounter = mysql_num_rows($data);
        if($rowCounter > 0) {
	        while($row = mysql_fetch_assoc($data)) {
	        	if($counter == 1) {
	                $insertData .= "INSERT INTO `{$table}` ";
	                    $columns = array_keys($row);
	                    $columnNames = null;
	                    foreach($columns as $key => $column) {
	                    	$columnsNames .= "`{$column}`,";
	                    }
	                $insertData .= "(".substr($columnsNames,0,-1).") VALUES \n";
	            } 
	            
	            $insertData .= "(";
	            $rowData = null;
	            foreach($row as $column => $value) {
	                $rowData .= "'".mysql_escape_string($value)."',";
	            }
	            $insertData .= substr($rowData,0,-1);
	            
	            if($counter < $rowCounter) {
	                $insertData .= "),\n";
	            } else {
	            	$insertData .= ");\n\n";
	            }
	            
	            // Increase counter;
	            $counter++;
	        }
        }
        
        // Return data.
        return (string)$insertData;
    }
}