php备份mysql数据库程序代码

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

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

1. <?php
2. /*
3. *
4. *简单的一个Mysql备份数据类
5. *
6. */
7. classbackupData{
8. private$mysql_link;//链接标识
9. private$dbName;//数据库名
10. private$dataDir;//数据所要存放的目录
11. private$tableNames;//表名
13. publicfunction__construct($mysql_link){
14. $this->mysql_link=$mysql_link;
15. }
16. publicfunctionbackupTables($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($tablesas$tablename){
23. if($tablename==''){//表不存在时
24. continue;
25. }
27. //************************以下是形成SQL的前半部分**************
28. //如果存在表，就先删除
29. $sqls.="DROPTABLEIFEXISTS$tablename;n";
30. //读取表结构
31. $rs=mysql_query("SHOWCREATETABLE$tablename",$this->mysql_link);
32. $row=mysql_fetch_row($rs);
33. //获得表结构组成SQL
34. $sqls.=$row['1'].";nn";
35. unset($rs);
36. unset($row);
38. //************************以下是形成SQL的后半部分**************
39. //查寻出表中的所有数据
40. $rs=mysql_query("select*from$tablename",$this->mysql_link);
41. //表的字段个数
42. $field=mysql_num_fields($rs);
43. //形成此种SQL语句:"INSERTINTO`groups`VALUES('1499e0ca25988d','主任','','0');"
44. while($rows=mysql_fetch_row($rs)){
45. $comma='';//逗号
46. $sqls.="INSERTINTO`$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';
56. //写入文件
57. $filehandle=fopen($backfilepath,"w");
58. fwrite($filehandle,$sqls);
59. fclose($filehandle);
60. }
61. privatefunctiondelarray($array){//处理传入进来的数组
62. foreach($arrayas$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. }
79. ?>

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

1. require_once("backdata.class.php");
2. $link=@mysql_connect("localhost","数据库名","密码")ordie('Couldnotconnecttoserver.');
3. mysql_query("usecms",$link);
4. mysql_query("setnamesutf8",$link);
5. $dbbck=newbackupData($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. */
14. classdata{
15. public$data_dir="class/";//备份文件存放的路径
16. public$transfer="";//临时存放sql[切勿不要对该属性赋值，否则会生成错误的sql语句]
18. /**
19. *数据库连接
20. *@paramstring$host数据库主机名
21. *@paramstring$user用户名
22. *@paramstring$pwd密码
23. *@paramstring$db选择数据库名
24. *@paramstring$charset编码方式
25. */
26. functionconnect_db($host,$user,$pwd,$db,$charset='gbk'){
27. if(!$conn=mysql_connect($host,$user,$pwd)){
28. returnfalse;
29. }
30. mysql_select_db($db);
31. mysql_query("setnames$charset");
32. returntrue;
33. }
35. /**
36. *生成sql语句
37. *@param$table要备份的表
38. *@return$tabledump生成的sql语句
39. */
40. publicfunctionset_sql($table,$subsection=0,&$tabledom=''){
41. $tabledom.="droptableifexists$tablen";
42. $createtable=mysql_query("showcreatetable$table");
43. $create=mysql_fetch_row($createtable);
44. $create[1]=str_replace("n","",$create[1]);
45. $create[1]=str_replace("t","",$create[1]);
47. $tabledom.=$create[1].";n";
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.="insertinto$tablevalues(";
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. }
71. /**
72. *列表数据库中的表
73. *@paramdatabase$database要操作的数据库名
74. *@returnarray$dbarray所列表的数据库表
75. */
76. publicfunctionget_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. }
84. /**
85. *验证目录是否有效
86. *@paramdiretory$dir
87. *@returnbooln
88. */
89. functioncheck_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. returntrue;
102. }
103. /**
104. *将数据写入到文件中
105. *@paramfile$filename文件名
106. *@paramstring$str要写入的信息
107. *@returnbooln写入成功则返回true,否则false
108. */
109. privatefunctionwrite_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. }
117. /**
118. *生成sql文件
119. *@paramstring$sqlsql语句
120. *@paramnumber$subsection分卷大小，以kb为单位，为0表示不分卷
121. */
122. publicfunctionexport_sql($table,$subsection=0){
123. if(!$this->check_write_dir($this->data_dir)){echo'您没有权限操作目录,备份失败';returnfalse;}
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)){returnfalse;}
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])){returnfalse;}
149. }
150. }
151. returntrue;
152. }
153. /**
154. *载入sql文件
155. *@paramdiretory$dir
156. *@returnbooln
157. *注意:请不在目录下面存放其它文件，或者目录
158. *以节省恢复时间
159. */
160. publicfunctionimport_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($sqlsas$sql){
168. str_replace("r","",$sql);
169. str_replace("n","",$sql);
170. if(!mysql_query(trim($sql)))returnfalse;
171. }//phpfensi.com
172. }
173. }
174. returntrue;
175. }
176. }
178. }

应用方法,代码如下:

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