欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  后端开发

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

程序员文章站 2022-04-29 10:14:50
...
  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 if ($i ==$feld_anzahl-1){
  79. $sql_statement .= mysql_field_name($query,$i);
  80. } else {
  81. $sql_statement .= mysql_field_name($query,$i).', ';
  82. }
  83. }
  84. $sql_statement .= ') VALUES (';
  85. for ($i = 0;$i $name = mysql_field_name($query,$i);
  86. if (empty($ds->$name)){
  87. $ds->$name = 'NULL';
  88. }
  89. if ($i ==$feld_anzahl-1){
  90. $sql_statement .= '"'.$ds->$name.'"';
  91. } else {
  92. $sql_statement .= '"'.$ds->$name.'", ';
  93. }
  94. }
  95. $sql_statement .= ");\n";
  96. }
  97. // 将insert数据放在数组中,去重
  98. if(!in_array($sql_statement, $insert))
  99. {
  100. array_push($insert, $sql_statement);
  101. unset($sql_statement);
  102. }
  103. unset($sql_statement);
  104. }
  105. // 将数据库结构与insert命令放在一起啦
  106. $this->struktur = array_combine($tables, $insert);
  107. // 执行dump函数
  108. $this->createDUMP($this->struktur);
  109. // 生成zip压缩包
  110. $this->createZIP();
  111. /** 备份结束 **/
  112. // 发一封邮件到指定邮箱,附件包含sql备份,如果你设置了的话^_^
  113. if(isset($this->config['email']) && !empty($this->config['email']))
  114. {
  115. $this->sendEmail();
  116. }
  117. // output
  118. echo '

    备份完成啦

    下载备份


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

    邮件发送成功

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

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

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


  237. ';
  238. echo $buffer;
  239. }
  240. }
  241. ?>
复制代码