首页 > 后端开发 > php教程 > php数据库备份类 分享一个不错的php数据库备份类

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

WBOY
发布: 2016-07-25 08:56:00
原创
1118 人浏览过
  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. ?>
复制代码


来源:php.cn
本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板