1. #!/usr/bin/env php
   
2. <?php
   
3. /**
   
4. * DB同步脚本
   
5. **/
   
6. ini_set('date.timezone','Asia/Shanghai');
   
7. define("SCRIPT_PATH", realpath(dirname(__FILE__)));
   
8. # 数据文件根目录
   
9. define("DATA_ROOT_PATH", SCRIPT_PATH."/data/");
   
10. # 数据文件子目录(按时间命名)
    
11. define("DATE_FORMT","Y/m/d");
    
12. 
    
13. #######################################################
    
14. # 源数据库配置
    
15. $source_db_map = array (
    
16.     'test' => array(’127.0.0.1’,’3306’,’root’,’root’),
    
17. );
    
18. 
    
19. # 目标数据库配置
    
20. $dest_db_map = array(
    
21.     'test' => array('127.0.0.1','9988','root','root'),
    
22. );
    
23. ######################################################
    
24. 
    
25. 
    
26. if (__FILE__ == realpath($_SERVER['SCRIPT_FILENAME']))
    
27. {
    
28.     dumpdb(’test’,’t_users’,’test’);
    
29. }
    
30. 
    
31. // 从进程管道中读取输出数据
    
32. function pfile_get_contents($cmd)
    
33. {/*{{{*/
    
34.     echo ">>> $cmd\n";
    
35.     $buf='';
    
36.     $file = popen($cmd,"r");
    
37.     while (!feof($file)) {
    
38.         $buf.=fgets($file);
    
39.     }   
    
40.     pclose($file);
    
41.     return $buf;
    
42. }/*}}}*/
    
43. 
    
44. // 将数据表从源数据库导入目标数据库(自动创建表)
    
45. function dumpdb($src_db, $table, $dest_db)
    
46. {/*{{{*/
    
47.     global $source_db_map, $dest_db_map;
    
48.     if (!isset($source_db_map[$src_db])) {die("unknow src_db : $src_db\n");}
    
49.     if (!isset($dest_db_map[$dest_db])) {die("unknow dest_db : $dest_db\n");}
    
50.     $scfg = $source_db_map[$src_db];
    
51.     $dcfg = $dest_db_map[$dest_db];
    
52.     $mysql_src = "mysql -h".$scfg[0]." -P".$scfg[1]." -u".$scfg[2]." -p".$scfg[3];
    
53.     $mysql_dest = "mysql -h".$dcfg[0]." -P".$dcfg[1]." -u".$dcfg[2]." -p".$dcfg[3];
    
54. 
    
55.     //1. 导出建表语句
    
56.     $cmd = $mysql_src." -N -e \"use $src_db; show create table $table \G\"";
    
57.     $create_sql = pfile_get_contents($cmd);
    
58.     // 处理建表语句,发现不同mysql版本支持的建表语句不同,这里做下适配
    
59.     $pos = strpos($create_sql,'CREATE TABLE');
    
60.     $create_sql = substr($create_sql, $pos);
    
61.     $create_sql = str_replace('CREATE TABLE','CREATE TABLE IF NOT EXISTS', $create_sql);
    
62.     $create_sql = str_replace('ON UPDATE CURRENT_TIMESTAMP','', $create_sql);
    
63.     $create_sql = str_replace('DEFAULT CURRENT_TIMESTAMP','', $create_sql);
    
64.     echo $create_sql."\n";
    
65. 
    
66.     //2. 创建数据表
    
67.     $con = mysql_connect($dcfg[0].":".$dcfg[1],$dcfg[2],$dcfg[3]);
    
68.     if (!$con) {die('Could not connect: ' . mysql_error());}
    
69.     mysql_select_db($dest_db, $con);
    
70.     if (!mysql_query($create_sql,$con)) {die('Error creating table: '.mysql_error());}
    
71.     mysql_close($con);
    
72. 
    
73.     //3. 导出数据到文件
    
74.     $filepath = DATA_ROOT_PATH."/".date(DATE_FORMT);
    
75.     if (!is_dir($filepath)) mkdir($filepath,0777,true);
    
76.     $file = $filepath."/".$table;
    
77.     if (is_file($file)) {die("file is exist: $file \n");}
    
78.     $cmd = $mysql_src." -N -e \"use $src_db; SELECT * FROM $table\" > $file";
    
79.     runcmd($cmd);
    
80. 
    
81.     //4. 载入目标数据库
    
82.     $cmd = $mysql_dest." -N -e \"use $dest_db; load data infile '$file' ignore into table $table\"";
    
83.     runcmd($cmd);
    
84. }/*}}}*/
    
85. 
    
86. function runcmd($cmd)
    
87. {/*{{{*/
    
88.     echo ">>> $cmd\n";
    
89.     system($cmd);
    
90. }/*}}}*/
    
91. 
    
92. 
    
93. // vim600: sw=4 ts=4 fdm=marker syn=php
    
94. ?>

复制代码

1. #!/usr/bin/env php
   
2. <?php
   
3. /**
   
4. * DB同步脚本
   
5. **/
   
6. ini_set('date.timezone','Asia/Shanghai');
   
7. define("SCRIPT_PATH", realpath(dirname(__FILE__)));
   
8. # 数据文件根目录
   
9. define("DATA_ROOT_PATH", SCRIPT_PATH."/data/");
   
10. # 数据文件子目录(按时间命名)
    
11. define("DATE_FORMT","Y/m/d");
    
12. 
    
13. #######################################################
    
14. # 源数据库配置
    
15. $source_db_map = array (
    
16.     'test' => array(’127.0.0.1’,’3306’,’root’,’root’),
    
17. );
    
18. 
    
19. # 目标数据库配置
    
20. $dest_db_map = array(
    
21.     'test' => array('127.0.0.1','9988','root','root'),
    
22. );
    
23. ######################################################
    
24. 
    
25. 
    
26. if (__FILE__ == realpath($_SERVER['SCRIPT_FILENAME']))
    
27. {
    
28.     dumpdb(’test’,’t_users’,’test’);
    
29. }
    
30. 
    
31. // 从进程管道中读取输出数据
    
32. function pfile_get_contents($cmd)
    
33. {/*{{{*/
    
34.     echo ">>> $cmd\n";
    
35.     $buf='';
    
36.     $file = popen($cmd,"r");
    
37.     while (!feof($file)) {
    
38.         $buf.=fgets($file);
    
39.     }   
    
40.     pclose($file);
    
41.     return $buf;
    
42. }/*}}}*/
    
43. 
    
44. // 将数据表从源数据库导入目标数据库(自动创建表)
    
45. function dumpdb($src_db, $table, $dest_db)
    
46. {/*{{{*/
    
47.     global $source_db_map, $dest_db_map;
    
48.     if (!isset($source_db_map[$src_db])) {die("unknow src_db : $src_db\n");}
    
49.     if (!isset($dest_db_map[$dest_db])) {die("unknow dest_db : $dest_db\n");}
    
50.     $scfg = $source_db_map[$src_db];
    
51.     $dcfg = $dest_db_map[$dest_db];
    
52.     $mysql_src = "mysql -h".$scfg[0]." -P".$scfg[1]." -u".$scfg[2]." -p".$scfg[3];
    
53.     $mysql_dest = "mysql -h".$dcfg[0]." -P".$dcfg[1]." -u".$dcfg[2]." -p".$dcfg[3];
    
54. 
    
55.     //1. 导出建表语句
    
56.     $cmd = $mysql_src." -N -e \"use $src_db; show create table $table \G\"";
    
57.     $create_sql = pfile_get_contents($cmd);
    
58.     // 处理建表语句,发现不同mysql版本支持的建表语句不同,这里做下适配
    
59.     $pos = strpos($create_sql,'CREATE TABLE');
    
60.     $create_sql = substr($create_sql, $pos);
    
61.     $create_sql = str_replace('CREATE TABLE','CREATE TABLE IF NOT EXISTS', $create_sql);
    
62.     $create_sql = str_replace('ON UPDATE CURRENT_TIMESTAMP','', $create_sql);
    
63.     $create_sql = str_replace('DEFAULT CURRENT_TIMESTAMP','', $create_sql);
    
64.     echo $create_sql."\n";
    
65. 
    
66.     //2. 创建数据表
    
67.     $con = mysql_connect($dcfg[0].":".$dcfg[1],$dcfg[2],$dcfg[3]);
    
68.     if (!$con) {die('Could not connect: ' . mysql_error());}
    
69.     mysql_select_db($dest_db, $con);
    
70.     if (!mysql_query($create_sql,$con)) {die('Error creating table: '.mysql_error());}
    
71.     mysql_close($con);
    
72. 
    
73.     //3. 导出数据到文件
    
74.     $filepath = DATA_ROOT_PATH."/".date(DATE_FORMT);
    
75.     if (!is_dir($filepath)) mkdir($filepath,0777,true);
    
76.     $file = $filepath."/".$table;
    
77.     if (is_file($file)) {die("file is exist: $file \n");}
    
78.     $cmd = $mysql_src." -N -e \"use $src_db; SELECT * FROM $table\" > $file";
    
79.     runcmd($cmd);
    
80. 
    
81.     //4. 载入目标数据库
    
82.     $cmd = $mysql_dest." -N -e \"use $dest_db; load data infile '$file' ignore into table $table\"";
    
83.     runcmd($cmd);
    
84. }/*}}}*/
    
85. 
    
86. function runcmd($cmd)
    
87. {/*{{{*/
    
88.     echo ">>> $cmd\n";
    
89.     system($cmd);
    
90. }/*}}}*/
    
91. 
    
92. 
    
93. // vim600: sw=4 ts=4 fdm=marker syn=php
    
94. ?>

复制代码