";
// build a connection to the remote mysql
$cR = mysql_connect( "REMOTE_SERVER_HERE", "READ_USERNAME_HERE", "PASSWORD_HERE");
if( ! $cR)
{
print 'No remote connection';
return;
}
// build a local connection
$cL = mysql_connect( "LOCAL_SERVER_HERE", "WRITE_USERNAME_HERE", "PASSWORD_HERE");
if( ! $cL)
{
print 'no local connection.';
return;
}
// get the highest local number
$qs = "select id from TABLE_NAME_HERE order by id desc limit 1";
$rLocal = mysql_db_query( "DATABASE_NAME_HERE", $qs, $cL);
if( ! $rLocal)
{
print "query error: $qs
";
return;
}
$row = mysql_fetch_row( $rLocal);
$num = $row[0];
// qs remote
// Hinweis: das und den fetch() kann man natuerlich auch
// etwas effizienter machen...
$qsr = "select * from TABLE_NAME_HERE where id>$num order by id";
$rRemote = mysql_db_query( "DATABASE_NAME_HERE", $qsr, $cR);
if( ! $rRemote)
{
print "query error: $qsr
";
return;
}
$count = mysql_num_rows( $rRemote);
for( $i=0; $i<$count; $i++)
{
print "Updating: $i ...
";
$row = mysql_fetch_row( $rRemote);
$qsLocal = "insert into TABEL_NAME_HERE( id, id_msg, id_parent, id_forum, id_user, name, topic, msg, date, time, id_root) values( $row[0], '" . AddSlashes( $row[1]) . "','" . AddSlashes( $row[2]) . "','" . AddSlashes( $row[3]) . "','" . AddSlashes( $row[4]) . "','" . AddSlashes( $row[5]) . "','" . AddSlashes( $row[6]) . "','" . AddSlashes( $row[7]) . "','" . AddSlashes( $row[8]) . "','" . AddSlashes( $row[9]) . "','" . AddSlashes( $row[10]) . "')";
$rLocal = mysql_db_query( "DATABASE_NAME_HERE", $qsLocal, $cL);
if( ! $rLocal)
{
print "query error: $qsLocal
";
return;
}
}
print "UPDATE done
";
}
function UpdateFull()
{
print "UPDATE FULL begin
";
// build a connection to the remote mysql
$cR = mysql_connect( "REMOTE_SERVER_HERE", "READ_USERNAME_HERE", "PASSWORD_HERE");
if( ! $cR)
{
print 'No remote connection';
return;
}
// build a local connection
$cL = mysql_connect( "LOCAL_SERVER_HERE", "WRITE_USERNAME_HERE", "PASSWORD_HERE");
if( ! $cL)
{
print 'no local connection.';
return;
}
// delete the local table
$strDel = "delete from TABLE_NAME_HERE";
$r = mysql_db_query( "DATABASE_NAME_HERE", $strDel, $cL);
if( ! $r)
{
print "Fehler bei delete: qs: $strDel
";
return;
}
// get everything from remote
$qs = "select * from TABEL_NAME_HERE";
$r = mysql_db_query( "DATABASE_NAME_HERE", $qs, $cR);
if( ! $r)
{
print "query error: $qs
";
return;
}
$num = mysql_num_rows( $r);
print "Updating: $num
";
for( $i=0; $i<$num; $i++)
{
$row = mysql_fetch_row( $r);
$qs = "insert into TABLE_NAME_HERE(idx, hits) values( $row[0], $row[1])";
$ins = mysql_db_query( "DATABASE_NAME_HERE", $qs, $cL);
if( ! $ins)
{
print "query error: $qs
";
return;
}
}
print "DONE !
";
}
function Update()
{
UpdateFull();
UpdateNew();
}
?>