MySQL远程表同步_mysql同步远程数据库某个表
mysql同步远程数据库某个表
final class mysql39to29 {
private $data_39;
function data_39()
{
$this->data_39 = ‘’;
$con = mysql_connect(“192.168.0.3”,”root”,”root”);
if (!$con)
{
die(‘Could not connect: ‘ . mysql_error());
}
mysql_select_db(“epg”, $con);
$result = mysql_query(“SELECT * FROM list”);
while($row = mysql_fetch_array($result))
{
$this->data_39.= “(
‘“.$row[“id”].”‘,
‘“.$row[“title”].”‘,
‘“.$row[“sheng_id”].”‘,
‘“.$row[“channel_id”].”‘,
‘“.$row[“default_source_id”].”‘,
‘“.$row[“default_source_id_6007”].”‘,
‘“.$row[“source_id”].”‘,
‘“.$row[“roms”].”‘,
‘“.$row[“clients”].”‘,
‘“.$row[“category_id”].”‘,
‘“.$row[“alias”].”‘,
‘“.$row[“available”].”‘,
‘“.$row[“type”].”‘,
‘“.$row[“replayable”].”‘,
‘“.$row[“imgurl”].”‘,
‘“.$row[“custom”].”‘,
‘“.$row[“order”].”‘,
‘“.$row[“key_id”].”‘),\n”;
}
mysql_close($con);
$this->data_39 = rtrim($this->data_39, “,\n”);
return $this->data_39;
}
function update_29()
{
$con = mysql_connect(“192.168.0.9”,”analysis”,”123456”);
if (!$con)
{
die(‘Could not connect: ‘ . mysql_error());
}
mysql_query(“SET NAMES ‘utf8’”, $con);
mysql_select_db(“analysis”, $con);
$sql_del = “TRUNCATE TABLE listyy;”;
$result = mysql_query($sql_del, $con);
$sql = “INSERT INTO listyy values “.$this->data_39.”;”;
$result = mysql_query($sql, $con);
}
}
$ob = new mysql39to29();
$ob->data_39();
$ob->update_29();
还没有评论,来说两句吧...