<?php
$link1 = mysql_connect("source","source_user","source_password");
$link2 = mysql_connect("dest","dest_user","dest_password");

// Read all databases into memory 
$Result = mysql_query("show databases ",$link1);
$cnt = @mysql_num_rows($Result);
echo "cnt=$cnt\r\n";
while ($cnt)
{
        $cnt--;
        if (!($Row = @mysql_fetch_row($Result))) continue;

        $databases[] = $Row[0];
}
mysql_close($link1);

// Iterate through all databases, importing tables one by one
foreach ($databases as $dbname)
{

        if (Strcasecmp($dbname,'-C')==0 || empty($dbname) || Strcasecmp($dbname,'information_schema')==0 ||
         Strcasecmp($dbname,'mysql')==0)
        {
                continue;
        }

        echo "Importing $dbname:\r\n";
        flush();


	// Create database
        @mysql_query("create database `$dbname`",$link2);

	// Make sure we still have a connection
        do
        {
	@mysql_Close($link1);
	$link1 = mysql_connect("source","source_user","source_password");
        if (empty($link1)) sleep(1);
        } while (empty($link1));

	// Read all tables into memory
        $tables = array();
        $Result1 = @mysql_query("SHOW tables FROM $dbname", $link1);
        $cnt1 = @mysql_num_Rows($Result1);
        echo "$cnt1 tables.\r\n";
        while ($cnt1)
        {
                $cnt1--;
                if (!($Row1 = @mysql_Fetch_row($Result1))) continue;

                $tables[] = $Row1[0];
        }

	// Close connection
        @mysql_close($link1);

	// Iterate through all tables importing one by one
        foreach ($tables as $table)
        {

        // Get current row count
        $Result2 = @mysql_query("SELECT count(*) FROM $dbname.".$table."",$link2);
        $Row2 = @mysql_Fetch_row($Result2);
        $current_row_count = $Row2[0]+0;
        if ($current_row_count>0) continue;

                // Get target number of rows
                $Result2 = @mysql_query("SELECT count(*) FROM $dbname.".$table."", $link1);
                $Row2 = @mysql_fetch_row($Result2);
                $target_row_count = $Row2[0]+0;

        do
        {

        @mysql_query("DROP TABLE $dbname.".$table."", $link2);

        echo "+ ".$table."\r\n";
        flush();
        exec("/usr/local/bin/mysqldump -h$source_host -u$source_user   -p$source_password  --compress --opt  ".$dbname." ".$table." | mysql -u$dest_user -p$dest_password -C ".$dbname." ");
       
        // In case we got disconnected, close and re-open
        do
        {
        @mysql_close($link2);
	$link2 = mysql_connect("dest","dest_user","dest_password");
        if (empty($link2)) sleep(2);
        } while (empty($link2));

        // Check if we have the desired number of rows now
        $Result2 = @mysql_query("SELECT count(*) FROM $dbname.".$table."",$link2);
        $Row2 = @mysql_Fetch_row($Result2);
        $current_row_count = $Row2[0]+0;
        if ($current_row_count>=$target_row_count )
        {
                echo "$current_row_count = $target_row_count\r\n";
                break;
        }
        echo "+ Error detected. Retrying ($current_row_count != $target_row_count)\r\n";
        sleep(5);
        } while (1);

        }
}
?>