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

备份MySQL的php类

程序员文章站 2023-12-27 09:53:51
...
  2. define('MSB_VERSION', '1.0.0');
  4. define('MSB_NL', "\r\n");
  6. define('MSB_STRING', 0);
  7. define('MSB_DOWNLOAD', 1);
  8. define('MSB_SAVE', 2);
  9. define('__SEP__', "/*sep*/" );
  11. set_time_limit( 600 );
  13. class MySQL_Backup {
  14. var $server = 'localhost';
  15. var $port = 3306;
  16. var $username = 'root';
  17. var $password = '';
  18. var $database = '';
  19. var $link_id = -1;
  20. var $connected = false;
  21. var $tables = array();
  22. var $drop_tables = true;
  23. var $struct_only = false;
  24. var $comments = true;
  25. var $backup_dir = '';
  26. var $fname_format = 'd_m_y__H_i_s';
  27. var $error = '';
  29. var $complete_inserts = false;
  30. var $inserts_block = 200;
  32. function Execute($task = MSB_STRING, $fname = '', $compress = false) {
  33. if ( !( $sql = $this->_Retrieve() ) ) {
  34. return false;
  35. }
  36. if ( $task == MSB_SAVE ) {
  37. if (empty($fname)) {
  38. $fname = $this->backup_dir;
  39. $fname .= date($this->fname_format);
  40. $fname .= ($compress ? '.sql.gz' : '.sql');
  41. }
  42. return $this->_SaveToFile($fname, $sql, $compress);
  43. } elseif ($task == MSB_DOWNLOAD) {
  44. if ( empty( $fname ) ) {
  45. $fname = date($this->fname_format);
  46. $fname .= ($compress ? '.sql.gz' : '.sql');
  47. }
  48. return $this->_DownloadFile($fname, $sql, $compress);
  49. } else {
  50. return $sql;
  51. }
  52. }
  54. function _Connect() {
  55. $value = false;
  56. if (!$this->connected) {
  57. $host = $this->server . ':' . $this->port;
  58. $this->link_id = mysql_connect($host, $this->username, $this->password);
  59. }
  60. if ($this->link_id) {
  61. if (empty($this->database)) {
  62. $value = true;
  63. } elseif ($this->link_id !== -1) {
  64. $value = mysql_select_db($this->database, $this->link_id);
  65. } else {
  66. $value = mysql_select_db($this->database);
  67. }
  68. }
  69. if (!$value) {
  70. $this->error = mysql_error();
  71. }
  72. return $value;
  73. }
  75. function _Query($sql) {
  76. if ($this->link_id !== -1) {
  77. $result = mysql_query($sql, $this->link_id);
  78. } else {
  79. $result = mysql_query($sql);
  80. }
  81. if (!$result) {
  82. $this->error = mysql_error();
  83. }
  84. return $result;
  85. }
  87. function _GetTables() {
  88. $value = array();
  89. if ( !( $result = $this->_Query('SHOW TABLES') ) ) {
  90. return false;
  91. }
  92. while ( $row = mysql_fetch_row( $result ) ) {
  93. if ( empty( $this->tables) || in_array( $row[0], $this->tables ) ) {
  94. $value[] = $row[0];
  95. }
  96. }
  97. if (!sizeof($value)) {
  98. $this->error = 'No tables found in database.';
  99. return false;
  100. }
  101. return $value;
  102. }
  104. function _DumpTable( $table ) {
  105. $value = '';
  106. $this->_Query( 'LOCK TABLES ' . $table . ' WRITE' );
  107. if ( $this->comments ) {
  108. $value .= '#' . MSB_NL;
  109. $value .= '# Table structure for table `' . $table . '`' . MSB_NL;
  110. $value .= '#' . MSB_NL . MSB_NL;
  111. }
  112. if ( $this->drop_tables ) {
  113. $value .= 'DROP TABLE IF EXISTS `' . $table . '`;' . __SEP__ . MSB_NL;
  114. }
  115. if ( !( $result = $this->_Query('SHOW CREATE TABLE ' . $table) ) ) {
  116. return false;
  117. }
  118. $row = mysql_fetch_assoc($result);
  119. $value .= str_replace("\n", MSB_NL, $row['Create Table']) . ';' . __SEP__;
  120. $value .= MSB_NL . MSB_NL;
  121. if (!$this->struct_only) {
  122. if ($this->comments) {
  123. $value .= '#' . MSB_NL;
  124. $value .= '# Dumping data for table `' . $table . '`' . MSB_NL;
  125. $value .= '#' . MSB_NL . MSB_NL;
  126. }
  127. $value .= $this->_GetInserts($table);
  128. }
  129. $value .= MSB_NL . MSB_NL;
  130. $this->_Query('UNLOCK TABLES');
  131. return $value;
  132. }
  134. function _GetInserts($table) {
  135. $value = '';
  136. if (!($result = $this->_Query('SELECT * FROM ' . $table))) {
  137. return false;
  138. }
  139. if ( $this->complete_inserts ) {
  140. while ($row = mysql_fetch_row($result)) {
  141. $values = '';
  142. foreach ($row as $data) {
  143. $values .= '\'' . addslashes($data) . '\', ';
  144. }
  145. $values = substr($values, 0, -2);
  146. $value .= 'INSERT INTO ' . $table . ' VALUES (' . $values . ');' . __SEP__ . MSB_NL;
  147. }
  148. } else {
  149. $blocks_counter = 0;
  150. $blocks = array();
  151. while ($row = mysql_fetch_row($result)) {
  152. $values = array();
  153. foreach ($row as $data) {
  154. $values[] = '\'' . addslashes($data) . '\'';
  155. }
  156. $blocks[] = '(' . implode( ',', $values ) . ')';
  158. if ( $blocks_counter inserts_block ) {
  159. $blocks_counter++;
  160. } else {
  161. $value .= 'INSERT INTO ' . $table . ' VALUES ' . implode( ',', $blocks ) . ";" . __SEP__ . MSB_NL;
  162. $blocks = array();
  163. $blocks_counter = 0;
  164. }
  165. }
  166. if ( count( $blocks ) ) {
  167. $value .= 'INSERT INTO ' . $table . ' VALUES ' . implode( ',', $blocks ) . ";" . __SEP__ . MSB_NL;
  168. }
  169. }
  170. return $value;
  171. }
  173. function _Retrieve() {
  174. $value = '';
  175. if (!$this->_Connect()) {
  176. return false;
  177. }
  178. if ($this->comments) {
  179. $value .= '#' . MSB_NL;
  180. $value .= '# MySQL database dump' . MSB_NL;
  181. $value .= '# Created by MySQL_Backup class, ver. ' . MSB_VERSION . MSB_NL;
  182. $value .= '#' . MSB_NL;
  183. $value .= '# Host: ' . $this->server . MSB_NL;
  184. $value .= '# Generated: ' . date('M j, Y') . ' at ' . date('H:i') . MSB_NL;
  185. $value .= '# MySQL version: ' . mysql_get_server_info() . MSB_NL;
  186. $value .= '# PHP version: ' . phpversion() . MSB_NL;
  187. if (!empty($this->database)) {
  188. $value .= '#' . MSB_NL;
  189. $value .= '# Database: `' . $this->database . '`' . MSB_NL;
  190. }
  191. $value .= '#' . MSB_NL . MSB_NL . MSB_NL;
  192. }
  193. if (!($tables = $this->_GetTables())) {
  194. return false;
  195. }
  196. foreach ($tables as $table) {
  197. if (!($table_dump = $this->_DumpTable($table))) {
  198. $this->error = mysql_error();
  199. return false;
  200. }
  201. $value .= $table_dump;
  202. }
  203. return $value;
  204. }
  206. function _SaveToFile($fname, $sql, $compress) {
  207. if ($compress) {
  208. if (!($zf = gzopen($fname, 'w9'))) {
  209. $this->error = 'Can\'t create the output file.';
  210. return false;
  211. }
  212. gzwrite($zf, $sql);
  213. gzclose($zf);
  214. } else {
  215. if (!($f = fopen($fname, 'w'))) {
  216. $this->error = 'Can\'t create the output file.';
  217. return false;
  218. }
  219. fwrite($f, $sql);
  220. fclose($f);
  221. }
  222. return true;
  223. }
  225. function _DownloadFile($fname, $sql, $compress) {
  226. header('Content-disposition: filename=' . $fname);
  227. header('Content-type: application/octetstream');
  228. header('Pragma: no-cache');
  229. header('Expires: 0');
  230. echo ($compress ? gzencode($sql) : $sql);
  231. return true;
  232. }
  233. }
  235. ?>
复制代码

MySQL, php
相关标签： 备份MySQL的php类

上一篇：

下一篇：

推荐阅读