备份MySQL的php类

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