当前位置:Gxlcms > PHP教程 > php数据库备份类分享一个不错的php数据库备份类

php数据库备份类分享一个不错的php数据库备份类

时间:2021-07-01 10:21:17 帮助过:28人阅读

  1. error_reporting(0);//消灭万恶的php报警提示
  2. //设定邮箱
  3. $options = array('email' => array('email1', 'email2'),
  4. 'folder' => './backup/',
  5. 'mysql' => array('localhost', 'user', 'password', 'db'));
  6. $b = new Backup($options);
  7. // 提交备份命令
  8. if(isset($_POST['backup']))
  9. {
  10. // 开始备份
  11. $b->backupDB();
  12. }
  13. // 显示备份表
  14. $b->outputForm();
  15. ?>

php数据库备份类的实现代码:

  1. /**
  2. * 备份mysql数据库
  3. * edit: bbs.it-home.org
  4. */
  5. class Backup
  6. {
  7. /**
  8. * @var 用于保存配置参数
  9. */
  10. var $config;
  11. /**
  12. * @var 用于保存mysql dump的数据
  13. */
  14. var $dump;
  15. /**
  16. * @var 用于数据库结果数据以及insert指令
  17. */
  18. var $struktur = array();
  19. /**
  20. * @var 压缩文件名zip
  21. */
  22. var $datei;
  23. /**
  24. * 结构函数
  25. * 连接数据库
  26. * @return
  27. */
  28. public function Backup($options)
  29. {
  30. // 从形参中读取配置
  31. foreach($options AS $name => $value)
  32. {
  33. $this->config[$name] = $value;
  34. }
  35. // 连接数据库
  36. mysql_connect($this->config['mysql'][0], $this->config['mysql'][1],
  37. $this->config['mysql'][2]) or die(mysql_error());
  38. mysql_select_db($this->config['mysql'][3]) or die(mysql_error());
  39. }
  40. /**
  41. * 执行备份数据库流程的函数
  42. * @return
  43. */
  44. public function backupDB()
  45. {
  46. // 开始备份的命令
  47. if(isset($_POST['backup']))
  48. {
  49. // 检测是否选择了数据表
  50. if(empty($_POST['table']))
  51. {
  52. die("请选择一个数据表。");
  53. }
  54. /** 开始备份 **/
  55. $tables = array();
  56. $insert = array();
  57. $sql_statement = '';
  58. // 锁定需要备份的数据库,防止读脏数据
  59. foreach($_POST['table'] AS $table)
  60. {
  61. mysql_query("LOCK TABLE $table WRITE");
  62. // 获取数据库结构
  63. $res = mysql_query('SHOW CREATE TABLE '.$table.'');
  64. $createtable = mysql_result($res, 0, 1);
  65. $str = "\n\n".$createtable."\n\n";
  66. array_push($tables, $str);
  67. // 查询数据表中的所有数据行
  68. $sql = 'SELECT * FROM '.$table;
  69. $query = mysql_query($sql) or die(mysql_error());
  70. $feld_anzahl = mysql_num_fields($query);
  71. $sql_statement = '--
  72. -- Data Table `$table`
  73. --
  74. ';
  75. // 开始读数据,并将其转换为insert命令
  76. while($ds = mysql_fetch_object($query)){
  77. $sql_statement .= 'INSERT INTO `'.$table.'` (';
  78. for ($i = 0;$i <$feld_anzahl;$i++){
  79. if ($i ==$feld_anzahl-1){
  80. $sql_statement .= mysql_field_name($query,$i);
  81. } else {
  82. $sql_statement .= mysql_field_name($query,$i).', ';
  83. }
  84. }
  85. $sql_statement .= ') VALUES (';
  86. for ($i = 0;$i <$feld_anzahl;$i++){
  87. $name = mysql_field_name($query,$i);
  88. if (empty($ds->$name)){
  89. $ds->$name = 'NULL';
  90. }
  91. if ($i ==$feld_anzahl-1){
  92. $sql_statement .= '"'.$ds->$name.'"';
  93. } else {
  94. $sql_statement .= '"'.$ds->$name.'", ';
  95. }
  96. }
  97. $sql_statement .= ");\n";
  98. }
  99. // 将insert数据放在数组中,去重
  100. if(!in_array($sql_statement, $insert))
  101. {
  102. array_push($insert, $sql_statement);
  103. unset($sql_statement);
  104. }
  105. unset($sql_statement);
  106. }
  107. // 将数据库结构与insert命令放在一起啦
  108. $this->struktur = array_combine($tables, $insert);
  109. // 执行dump函数
  110. $this->createDUMP($this->struktur);
  111. // 生成zip压缩包
  112. $this->createZIP();
  113. /** 备份结束 **/
  114. // 发一封邮件到指定邮箱,附件包含sql备份,如果你设置了的话^_^
  115. if(isset($this->config['email']) && !empty($this->config['email']))
  116. {
  117. $this->sendEmail();
  118. }
  119. // output
  120. echo '

    备份完成啦

    $this->datei.'">下载备份


  121. ';
  122. }
  123. }
  124. /**
  125. * 发送邮件函数
  126. * @return
  127. */
  128. protected function sendEmail()
  129. {
  130. // 读取邮箱地址
  131. foreach($this->config['email'] AS $email)
  132. {
  133. $to = $email;
  134. $from = $this->config['email'][0];
  135. $message_body = "本邮件中包含的zip压缩包为数据库备份";
  136. $msep = strtoupper (md5 (uniqid (time ())));
  137. // 设置email头
  138. $header =
  139. "From: $from\r\n" .
  140. "MIME-Version: 1.0\r\n" .
  141. "Content-Type: multipart/mixed; boundary=".$msep."\r\n\r\n" .
  142. "--$msep\r\n" .
  143. "Content-Type: text/plain\r\n" .
  144. "Content-Transfer-Encoding: 8bit\r\n\r\n" .
  145. $message_body . "\r\n";
  146. // 文件名
  147. $dateiname = $this->datei;
  148. // 压缩包大小
  149. $dateigroesse = filesize ($dateiname);
  150. // 读取压缩包
  151. $f = fopen ($dateiname, "r");
  152. // 保存到附件
  153. $attached_file = fread ($f, $dateigroesse);
  154. // 关闭压缩包
  155. fclose ($f);
  156. // 建立一个附件
  157. $attachment = chunk_split (base64_encode ($attached_file));
  158. // 设置附件头
  159. $header .=
  160. "--" . $msep . "\r\n" .
  161. "Content-Type: application/zip; name='Backup'\r\n" .
  162. "Content-Transfer-Encoding: base64\r\n" .
  163. "Content-Disposition: attachment; filename='Backup.zip'\r\n" .
  164. "Content-Description: Mysql Datenbank Backup im Anhang\r\n\r\n" .
  165. $attachment . "\r\n";
  166. // 标记附件结束未知
  167. $header .= "--$msep--";
  168. // 邮件标题
  169. $subject = "数据库备份";
  170. // 发送邮件需要开启php相应支持哦^^
  171. if(mail($to, $subject, '', $header) == FALSE)
  172. {
  173. die("无法发送邮件,请检查邮箱地址");
  174. }
  175. echo "

    邮件发送成功

    ";
  176. }
  177. }
  178. /**
  179. * 建立数据库备份的压缩包并保存到服务器指定目录中
  180. * @return
  181. */
  182. protected function createZIP()
  183. {
  184. // 文件夹权限要够
  185. chmod($this->config['folder'], 0777);
  186. // 建立压缩包
  187. $zip = new ZipArchive();
  188. // 设置压缩包文件名
  189. $this->datei = $this->config['folder'].$this->config['mysql'][3]."_"
  190. .date("j_F_Y_g_i_a").".zip";
  191. // 看看压缩包能不能打开
  192. if ($zip->open($this->datei, ZIPARCHIVE::CREATE)!==TRUE) {
  193. exit("无法打开 <".$this->datei.">\n");
  194. }
  195. // 把dump出来的数据放到压缩包里
  196. $zip->addFromString("dump.sql", $this->dump);
  197. // 关闭压缩包
  198. $zip->close();
  199. // 看看压缩包有没有生成
  200. if(!file_exists($this->datei))
  201. {
  202. die("无法生成压缩包");
  203. }
  204. echo "

    数据库备份压缩包成功生成

    ";
  205. }
  206. /**
  207. * mysql dump函数
  208. * @param object $dump
  209. * @return
  210. */
  211. protected function createDUMP($dump)
  212. {
  213. $date = date("F j, Y, g:i a");
  214. $header = << -- SQL Dump
  215. --
  216. -- Host: {$_SERVER['HTTP_HOST']}
  217. -- Erstellungszeit: {$date}
  218. --
  219. -- Datenbank: `{$this->config['mysql'][3]}`
  220. --
  221. -- --------------------------------------------------------
  222. HEADER;
  223. foreach($dump AS $name => $value)
  224. {
  225. $sql .= $name.$value;
  226. }
  227. $this->dump = $header.$sql;
  228. }
  229. /**
  230. * 生成选择数据表的界面函数
  231. * @return
  232. */
  233. public function outputForm()
  234. {
  235. // 选择全部
  236. $result = mysql_list_tables($this->config['mysql'][3]);
  237. $buffer = '
  238. 选择需要备份的数据表
  239. ';
  240. echo $buffer;
  241. }
  242. }
  243. ?>

人气教程排行