php备份mysql数据库程序代码

在我们开发中数据库备份是很重要的环节,下面我们来分享两个php备份mysql数据库类,有需要的朋友可稍加修改即可使用.

先看备份的类文件backdata.class.php,代码如下:

1. <?php 
2. /* 
3. * 
4. *简单的一个Mysql备份数据类  
5. * 
6. */ 
7. class backupData{ 
8.     private    $mysql_link;//链接标识 
9.     private    $dbName;    //数据库名 
10.     private    $dataDir;     //数据所要存放的目录 
11.     private    $tableNames;//表名 
12.  
13.     public function __construct($mysql_link){ 
14.          $this->mysql_link = $mysql_link; 
15.     } 
16.     public function backupTables($dbName,$dataDir,$tableNames){//开始备份 
17.         $this->dbName  = $dbName; 
18.         $this->dataDir  = $dataDir; 
19.         $this->tableNames = $tableNames; 
20.         $tables=$this->delarray($this->tableNames); 
21.         $sqls=''; 
22.         foreach($tables as $tablename){ 
23.             if($tablename==''){//表不存在时 
24.                 continue; 
25.             } 
26.              
27.             //************************以下是形成SQL的前半部分************** 
28.             //如果存在表，就先删除 
29.             $sqls .= "DROP TABLE IF EXISTS $tablename;n"; 
30.             //读取表结构 
31.             $rs = mysql_query("SHOW CREATE TABLE $tablename",$this->mysql_link);   
32.             $row=mysql_fetch_row($rs); 
33.             //获得表结构组成SQL 
34.             $sqls.=$row['1'].";nn"; 
35.             unset($rs); 
36.             unset($row); 
37.              
38.             //************************以下是形成SQL的后半部分************** 
39.             //查寻出表中的所有数据 
40.             $rs=mysql_query("select * from $tablename",$this->mysql_link); 
41.             //表的字段个数 
42.             $field=mysql_num_fields($rs); 
43.             //形成此种SQL语句:"INSERT INTO `groups` VALUES('1499e0ca25988d','主任','','0');" 
44.             while($rows=mysql_fetch_row($rs)){ 
45.                 $comma='';//逗号 
46.                 $sqls.="INSERT INTO `$tablename` VALUES("; 
47.                 for($i=0;$i<$field;$i++){ 
48.                     $sqls.=$comma."'".$rows[$i]."'"; 
49.                     $comma=','; 
50.                 } 
51.                 $sqls.=");nnn"; 
52.             } 
53.         } 
54.         $backfilepath=$this->dataDir.date("Ymdhis",time()).'.sql'; 
55.          
56.         //写入文件 
57.         $filehandle = fopen($backfilepath, "w"); 
58.         fwrite($filehandle, $sqls); 
59.         fclose($filehandle); 
60.     } 
61.     private function delarray($array){    //处理传入进来的数组 
62.         foreach($array as $tables){ 
63.             if($tables=='*'){    //所有的表(获得表名时不能按常规方式来组成一个数组) 
64.                 $newtables=mysql_list_tables($this->dbName,$this->mysql_link); 
65.                 $tableList = array(); 
66.                 for ($i = 0; $i < mysql_numrows($newtables); $i++){ 
67.                     array_push($tableList,mysql_tablename($newtables, $i)); 
68.                 } 
69.                 $tableList=$tableList; 
70.             }else{ 
71.                 $tableList=$array; 
72.                 break; 
73.             } 
74.         } 
75.         return $tableList; 
76.     } 
77. } 
78.  
79. ?> 

数据库备份用法,代码如下:

1. require_once("backdata.class.php"); 
2. $link = @mysql_connect("localhost","数据库名","密码") or die ('Could not connect to server.'); 
3. mysql_query("use cms",$link); 
4. mysql_query("set names utf8",$link); 
5. $dbbck=new backupData($link);//实例化它，只要一个链接标识就行了  
6. //备份数据时，如想备份一个数据库中的所有表，你可这样写：  
7. $dbbck->backupTables("cms","./",array('*')); 
8. //备份数据时，如想备份一个数据库中的仅一个表时，你可这样写：  
9. $dbbck->backupTables("cms","./",array('user')); 
10. //备份数据时，如想备份一个数据库中的多个表时，你可这样写：  
11. $dbbck->backupTables("cms","./",array('user','acl','informatoin')); 
12. //注解：$dbbck->backupTables("参1","参2",array());中，  

参1为:数据库名.

参2为:要存放备份数据的位置,即目录地址.

第三个为:你要保存那些表.

再来分享一个数据库备份类,代码如下:

1. /** 
2.   * 说明，该类适用于小型的网站的数据库备份，内置mysql连接，只需要简单配置数据连接 
3.   * 及存贮备份的位置即可。 
4.   * 类实列化并且连接数据库以后可执行以下操作 
5.   * get_db_table($database)    取得所有数据表 
6.   * export_sql($table,$subsection=0))   生成sql文件,注意生成sql文件只保存到服务器目录，不提供下载 
7.   * import_sql($dir)     恢复数据只导入服务器目录下的sql文件 
8.   * 该类制作简单，可任意传播，如何您对该类有什么提议，请发送邮件给小虾 
9.   * @author 赵红健[游天小虾] 
10.   * email:328742379@qq.com 
11.   * qq交流群：69574955 聚义堂-网页制作交 
12.   */ 
13.  
14. class data { 
15.  public   $data_dir    = "class/"; //备份文件存放的路径 
16.  public   $transfer     ="";   //临时存放sql[切勿不要对该属性赋值，否则会生成错误的sql语句] 
17.  
18. /** 
19.  *数据库连接 
20.  *@param string $host 数据库主机名 
21.  *@param string $user 用户名 
22.  *@param string $pwd  密码 
23.  *@param string $db   选择数据库名 
24.  *@param string $charset 编码方式 
25.  */ 
26.  function connect_db($host,$user,$pwd,$db,$charset='gbk'){ 
27.   if(!$conn = mysql_connect($host,$user,$pwd)){ 
28.    return false; 
29.   } 
30.   mysql_select_db($db); 
31.   mysql_query("set names $charset"); 
32.   return true; 
33.  } 
34.  
35. /** 
36.  * 生成sql语句 
37.  * @param   $table     要备份的表 
38.  * @return  $tabledump 生成的sql语句 
39.  */ 
40.  public function set_sql($table,$subsection=0,&$tabledom=''){ 
41.   $tabledom .= "drop table if exists $tablen"; 
42.   $createtable = mysql_query("show create table $table"); 
43.   $create = mysql_fetch_row($createtable); 
44.   $create[1] = str_replace("n","",$create[1]); 
45.   $create[1] = str_replace("t","",$create[1]); 
46.  
47.   $tabledom  .= $create[1].";n"; 
48.  
49.   $rows = mysql_query("select * from $table"); 
50.   $numfields = mysql_num_fields($rows); 
51.   $numrows = mysql_num_rows($rows); 
52.   $n = 1; 
53.   $sqlarry = array(); 
54.   while ($row = mysql_fetch_row($rows)){ 
55.      $comma = ""; 
56.      $tabledom  .= "insert into $table values("; 
57.      for($i = 0; $i < $numfields; $i++) 
58.      { 
59.     $tabledom  .= $comma."'".mysql_escape_string($row[$i])."'"; 
60.     $comma = ","; 
61.      } 
62.     $tabledom  .= ")n"; 
63.      if($subsection != 0 && strlen($this->transfer )>=$subsection*1000){ 
64.        $sqlarry[$n]= $tabledom; 
65.        $tabledom = ''; $n++; 
66.      } 
67.   } 
68.   return $sqlarry; 
69.    } 
70.  
71. /** 
72.  *列表数据库中的表 
73.  *@param  database $database 要操作的数据库名 
74.  *@return array    $dbarray  所列表的数据库表 
75.  */ 
76.  public function get_db_table($database){ 
77.   $result = mysql_list_tables($database); 
78.   while($tmparry = mysql_fetch_row($result)){ 
79.    $dbarry[]  = $tmparry[0]; 
80.   } 
81.   return $dbarry; 
82.  } 
83.  
84. /** 
85.  *验证目录是否有效 
86.  *@param diretory $dir 
87.  *@return booln 
88.  */ 
89.  function check_write_dir($dir){ 
90.   if(!is_dir($dir)) {@mkdir($dir, 0777);} 
91.   if(is_dir($dir)){ 
92.    if($link = opendir($dir)){ 
93.     $filearry = scandir($dir); 
94.     for($i=0;$i<count($filearry);$i++){ 
95.      if($filearry[$i]!='.' || $filearry != '..'){ 
96.       @unlink($dir.$filearry[$i]); 
97.      } 
98.     } 
99.    } 
100.   } 
101.   return true; 
102.  } 
103. /** 
104.  *将数据写入到文件中 
105.  *@param file $filename 文件名 
106.  *@param string $str   要写入的信息 
107.  *@return booln 写入成功则返回true,否则false 
108.  */ 
109.  private function write_sql($filename,$str){ 
110.   $re= true; 
111.   if(!@$fp=fopen($filename,"w+")) {$re=false; echo "在打开文件时遇到错误，备份失败!";} 
112.   if(!@fwrite($fp,$str)) {$re=false; echo "在写入信息时遇到错误，备份失败!";} 
113.   if(!@fclose($fp)) {$re=false; echo "在关闭文件 时遇到错误，备份失败!";} 
114.   return $re; 
115.  } 
116.  
117. /** 
118.  *生成sql文件 
119.  *@param string $sql sql    语句 
120.  *@param number $subsection 分卷大小，以kb为单位，为0表示不分卷 
121.  */ 
122.      public function export_sql($table,$subsection=0){ 
123.       if(!$this->check_write_dir($this->data_dir)){echo '您没有权限操作目录,备份失败';return false;} 
124.       if($subsection == 0){ 
125.        if(!is_array($table)){ 
126.     $this->set_sql($table,0,$this->transfer); 
127.    }else{ 
128.     for($i=0;$i<count($table);$i++){ 
129.      $this->set_sql($table[$i],0,$this->transfer); 
130.     } 
131.    } 
132.        $filename = $this->data_dir.date("ymd",time()).'_all.sql'; 
133.        if(!$this->write_sql($filename,$this->transfer)){return false;} 
134.       }else{ 
135.        if(!is_array($table)){ 
136.     $sqlarry = $this->set_sql($table,$subsection,$this->transfer); 
137.     $sqlarry[] = $this->transfer; 
138.    }else{ 
139.     $sqlarry = array(); 
140.     for($i=0;$i<count($table);$i++){ 
141.      $tmparry = $this->set_sql($table[$i],$subsection,$this->transfer); 
142.      $sqlarry = array_merge($sqlarry,$tmparry); 
143.     } 
144.     $sqlarry[] = $this->transfer; 
145.    } 
146.        for($i=0;$i<count($sqlarry);$i++){ 
147.         $filename = $this->data_dir.date("ymd",time()).'_part'.$i.'.sql'; 
148.         if(!$this->write_sql($filename,$sqlarry[$i])){return false;} 
149.        } 
150.       } 
151.       return true; 
152.     } 
153. /** 
154.  *载入sql文件 
155.  *@param diretory $dir 
156.  *@return booln 
157.  *注意:请不在目录下面存放其它文件，或者目录 
158.  *以节省恢复时间 
159.  */ 
160.     public function import_sql($dir){ 
161.   if($link = opendir($dir)){ 
162.    $filearry = scandir($dir); 
163.     $pattern = "_part[0-9]+.sql$|_all.sql$"; 
164.    for($i=0;$i<count($filearry);$i++){ 
165.     if(eregi($pattern,$filearry[$i])){ 
166.      $sqls=file($dir.$filearry[$i]); 
167.      foreach($sqls as $sql){ 
168.       str_replace("r","",$sql); 
169.       str_replace("n","",$sql); 
170.       if(!mysql_query(trim($sql))) return false; 
171.      }  //Vevb.com 
172.     } 
173.    } 
174.    return true; 
175.   } 
176.     } 
177.  
178. } 

应用方法,代码如下:

1. //$d = new data(); 
2.  
3. //连接数据库 
4. //if(!$d->connect_db('localhost','root','','guestbook','gbk')){ 
5. // echo '数据库连接失败'; 
6. //} 
7.  
8. //查找数据库内所有数据表 
9. //$tablearry = $d->get_db_table('guestbook'); 
10.  
11. //备份并生成sql文件 
12. //if(!$d->export_sql($tablearry)){ 
13. // echo '备份失败'; 
14. //}else{ 
15. // echo '备份成功'; 
16. //} 
17.  
18. //恢复导入sql文件夹 
19. //if($d->import_sql($d->data_dir)){ 
20. // echo '恢复成功'; 
21. //}else{ 
22. // echo '恢复失败'; 
23. //}