本文实例讲述了php实现MySQL数据库备份与还原类。分享给大家供大家参考。具体分析如下：
这是一个非常简单的利用php来备份mysql数据库的类文件,我们只要简单的在dbmange中配置好连接地址用户名与数据库即可,下面我们一起来看这个例子,代码如下:
<?php <br />/** <br /> * 创建时间： 2012年5月21日 <br /> * <br /> * 说明：分卷文件是以_v1.sql为结尾(20120522021241_all_v1.sql) <br /> * 功能：实现mysql数据库分卷备份,选择表进行备份,实现单个sql文件及分卷sql导入 <br /> * 使用方法： <br /> * <br /> * ------1. 数据库备份（导出）------------------------------------------------------------ <br />//分别是主机，用户名，密码，数据库名，数据库编码 <br />$db = new DBManage ( 'localhost', 'root', 'root', 'test', 'utf8' ); <br />// 参数：备份哪个表(可选),备份目录(可选，默认为backup),分卷大小(可选,默认2000，即2M) <br />$db->backup (); <br /> * ------2. 数据库恢复（导入）------------------------------------------------------------ <br />//分别是主机，用户名，密码，数据库名，数据库编码 <br />$db = new DBManage ( 'localhost', 'root', 'root', 'test', 'utf8' ); <br />//参数：sql文件 <br />$db->restore ( './backup/20120516211738_all_v1.sql'); <br /> *---------------------------------------------------------------------- <br /> */ <br />class DBManage <br />{ <br /> var $db; // 数据库连接 <br /> var $database; // 所用数据库 <br /> var $sqldir; // 数据库备份文件夹 <br /> var $record; <br /> // 换行符 <br /> private $ds = "n"; <br /> // 存储SQL的变量 <br /> public $sqlContent = ""; <br /> // 每条sql语句的结尾符 <br /> public $sqlEnd = ";"; <br /> /** <br /> * 初始化 <br /> * <br /> * @param string $host <br /> * @param string $username <br /> * @param string $password <br /> * @param string $thisatabase <br /> * @param string $charset <br /> */ <br /> function __construct($host = 'localhost', $username = 'root', $password = '', $thisatabase = 'test', $charset = 'utf8') <br /> { <strong style="color:transparent">本&文来源gao@daima#com搞(%代@#码网@</strong><textarea>搞gaodaima代码</textarea> <br /> $this->host = $host; <br /> $this->username = $username; <br /> $this->password = $password; <br /> $this->database = $thisatabase; <br /> $this->charset = $charset; <br /> // 连接数据库 <br /> $this->db = mysql_connect ( $this->host, $this->username, $this->password ) or die ( "数据库连接失败." ); <br /> // 选择使用哪个数据库 <br /> mysql_select_db ( $this->database, $this->db ) or die ( "无法打开数据库" ); <br /> // 数据库编码方式 <br /> mysql_query ( 'SET NAMES ' . $this->charset, $this->db ); <br /> } <br /> <br /> /* <br /> * ------------------------------------------数据库备份start---------------------------------------------------------- <br /> */ <br /> <br /> /** <br /> * 数据库备份 <br /> * 参数：备份哪个表(可选),备份目录(可选，默认为backup),分卷大小(可选,默认2000，即2M) <br /> * <br /> * @param $string $dir <br /> * @param int $size <br /> * @param $string $tablename <br /> */ <br /> function backup($tablename = '', $dir = '', $size = 2000) <br /> { <br /> //$dir = $dir ? $dir : 'backup/'; <br /> //$size = $size ? $size : 2000; <br /> $sql = ''; <br /> // 只备份某个表 <br /> if (! emptyempty ( $tablename )) <br /> { <br /> echo '正在备份表' . $tablename . '<br />'; <br /> // 插入dump信息 <br /> $sql = $this->_retrieve(); <br /> // 插入表结构信息 <br /> $sql .= $this->_insert_table_structure ( $tablename ); <br /> // 插入数据 <br /> $data = mysql_query ( "select * from " . $tablename ); <br /> // 文件名前面部分 <br /> $filename = date ( 'YmdHis' ) . "_" . $tablename; <br /> // 字段数量 <br /> $num_fields = mysql_num_fields ( $data ); <br /> // 第几分卷 <br /> $p = 1; <br /> // 循环每条记录 <br /> while ( $record = mysql_fetch_array ( $data ) ) <br /> { <br /> // 单条记录 <br /> $sql .= $this->_insert_record ( $tablename, $num_fields, $record ); <br /> // 如果大于分卷大小，则写入文件 <br /> if (strlen ( $sql ) >= $size * 1000) <br /> { <br /> $file = $filename . "_v" . $p . ".sql"; <br /> if ($this->_write_file ( $sql, $file, $dir )) <br /> { <br /> echo "表-" . $tablename . "-卷-" . $p . "-数据备份完成,生成备份文件 <span style='color:#f00'>$dir$filename</span><br />"; <br /> } <br /> else <br /> { <br /> echo "备份表-" . $tablename . "-失败<br />"; <br /> } <br /> // 下一个分卷 <br /> $p ++; <br /> // 重置$sql变量为空，重新计算该变量大小 <br /> $sql = ""; <br /> } <br /> } <br /> // sql大小不够分卷大小 <br /> if ($sql != "") <br /> { <br /> $filename .= "_v" . $p . ".sql"; <br /> if ($this->_write_file ( $sql, $filename, $dir )) <br /> { <br /> echo "表-" . $tablename . "-卷-" . $p . "-数据备份完成,生成备份文件 <span style='color:#f00'>$dir$filename</span><br />"; <br /> } <br /> else <br /> { <br /> echo "备份卷-" . $p . "-失败<br />"; <br /> } <br /> } <br /> } <br /> else <br /> { // 备份全部表 <br /> if ($tables = mysql_query ( "show table status from " . $this->database )) <br /> { <br /> echo "读取数据库结构成功！<br />"; <br /> } <br /> else <br /> { <br /> exit ( "读取数据库结构成功！<br />" ); <br /> } <br /> // 插入dump信息 <br /> $sql .= $this->_retrieve(); <br /> // 文件名前面部分 <br /> $filename = date ( 'YmdHis' ) . "_all"; <br /> // 查出所有表 <br /> $tables = mysql_query ( 'SHOW TABLES' ); <br /> // 第几分卷 <br /> $p = 1; <br /> // 循环所有表 <br /> while ( $table = mysql_fetch_array ( $tables ) ) <br /> { <br /> // 获取表名 <br /> $tablename = $table [0]; <br /> // 获取表结构 <br /> $sql .= $this->_insert_table_structure ( $tablename ); <br /> $data = mysql_query ( "select * from " . $tablename ); <br /> $num_fields = mysql_num_fields ( $data ); <br /> <br /> // 循环每条记录 <br /> while ( $record = mysql_fetch_array ( $data ) ) <br /> { <br /> // 单条记录 <br /> $sql .= $this->_insert_record ( $tablename, $num_fields, $record ); <br /> // 如果大于分卷大小，则写入文件 <br /> if (strlen ( $sql ) >= $size * 1000) <br /> { <br /> <br /> $file = $filename . "_v" . $p . ".sql"; <br /> // 写入文件 <br /> if ($this->_write_file ( $sql, $file, $dir )) <br /> { <br /> echo "-卷-" . $p . "-数据备份完成,生成备份文件<span style='color:#f00'>$dir$file</span><br />"; <br /> } <br /> else <br /> { <br /> echo "备份卷-" . $p . "-失败<br />"; <br /> } <br /> // 下一个分卷 <br /> $p ++; <br /> // 重置$sql变量为空，重新计算该变量大小 <br /> $sql = ""; <br /> } <br /> } <br /> } <br /> // sql大小不够分卷大小 <br /> if ($sql != "") <br /> { <br /> $filename .= "_v" . $p . ".sql"; <br /> if ($this->_write_file ( $sql, $filename, $dir )) <br /> { <br /> echo "-卷-" . $p . "-数据备份完成,生成备份文件 <span style='color:#f00'>$dir$filename<br />"; <br /> } <br /> else <br /> { <br /> echo "备份卷-" . $p . "-失败<br />"; <br /> } <br /> } <br /> } <br /> } <br /> <br /> /** <br /> * 插入数据库备份基础信息 <br /> * <br /> * @return string <br /> */ <br /> private function _retrieve() { <br /> $value = ''; <br /> $value .= '--' . $this->ds; <br /> $value .= '-- MySQL database dump' . $this->ds; <br /> $value .= '-- Created by DBManage class, Power By yanue. ' . $this->ds; <br /> $value .= '-- http://yanue.net ' . $this->ds; <br /> $value .= '--' . $this->ds; <br /> $value .= '-- 主机: ' . $this->host . $this->ds; <br /> $value .= '-- 生成日期: ' . date ( 'Y' ) . ' 年 ' . date ( 'm' ) . ' 月 ' . date ( 'd' ) . ' 日 ' . date ( 'H:i' ) . $this->ds; <br /> $value .= '-- MySQL版本: ' . mysql_get_server_info () . $this->ds; <br /> $value .= '-- PHP 版本: ' . phpversion () . $this->ds; <br /> $value .= $this->ds; <br /> $value .= '--' . $this->ds; <br /> $value .= '-- 数据库: `' . $this->database . '`' . $this->ds; <br /> $value .= '--' . $this->ds . $this->ds; <br /> $value .= '-- -------------------------------------------------------'; <br /> $value .= $this->ds . $this->ds; <br /> return $value; <br /> } <br /> <br /> /** <br /> * 插入表结构 <br /> * <br /> * @param unknown_type $table <br /> * @return string <br /> */ <br /> private function _insert_table_structure($table) { <br /> $sql = ''; <br /> $sql .= "--" . $this->ds; <br /> $sql .= "-- 表的结构" . $table . $this->ds; <br /> $sql .= "--" . $this->ds . $this->ds; <br /> <br /> // 如果存在则删除表 <br /> $sql .= "DROP TABLE IF EXISTS `" . $table . '`' . $this->sqlEnd . $this->ds; <br /> // 获取详细表信息 <br /> $res = mysql_query ( 'SHOW CREATE TABLE `' . $table . '`' ); <br /> $row = mysql_fetch_array ( $res ); <br /> $sql .= $row [1]; <br /> $sql .= $this->sqlEnd . $this->ds; <br /> // 加上 <br /> $sql .= $this->ds; <br /> $sql .= "--" . $this->ds; <br /> $sql .= "-- 转存表中的数据 " . $table . $this->ds; <br /> $sql .= "--" . $this->ds; <br /> $sql .= $this->ds; <br /> return $sql; <br /> } <br /> <br /> /** <br /> * 插入单条记录 <br /> * <br /> * @param string $table <br /> * @param int $num_fields <br /> * @param array $record <br /> * @return string <br /> */ <br /> private function _insert_record($table, $num_fields, $record) { <br /> // sql字段逗号分割 <br /> $insert = $comma = ""; <br /> $insert .= "INSERT INTO `" . $table . "` VALUES("; <br /> // 循环每个子段下面的内容 <br /> for($i = 0; $i < $num_fields; $i ++) { <br /> $insert .= ($comma . "'" .mysql_real_escape_string ( $record [$i] ) . "'"); <br /> $comma = ","; <br /> } <br /> $insert .= ");" . $this->ds; <br /> return $insert; <br /> } <br /> <br /> /** <br /> * 写入文件 <br /> * <br /> * @param string $sql <br /> * @param string $filename <br /> * @param string $dir <br /> * @return boolean <br /> */ <br /> private function _write_file($sql, $filename, $dir) { <br /> $dir = $dir ? $dir : './backup/'; <br /> // 不存在文件夹则创建 <br /> if (! file_exists ( $dir )) { <br /> mkdir ( $dir ); <br /> } <br /> $re = true; <br /> if (! @$fp = fopen ( $dir . $filename, "w+" )) { <br /> $re = false; <br /> echo "打开文件失败！"; <br /> } <br /> if (! @fwrite ( $fp, $sql )) { <br /> $re = false; <br /> echo "写入文件失败，请文件是否可写"; <br /> } <br /> if (! @fclose ( $fp )) { <br /> $re = false; <br /> echo "关闭文件失败！"; <br /> } <br /> return $re; <br /> } <br /> <br /> /* <br /> * <br /> * -------------------------------上：数据库导出-----------分割线----------下：数据库导入-------------------------------- <br /> */ <br /> <br /> /** <br /> * 导入备份数据 <br /> * 说明：分卷文件格式20120516211738_all_v1.sql <br /> * 参数：文件路径(必填) <br /> * <br /> * @param string $sqlfile <br /> */ <br /> function restore($sqlfile) <br /> { <br /> // 检测文件是否存在 <br /> if (! file_exists ( $sqlfile )) <br /> { <br /> exit ( "文件不存在！请检查" ); <br /> } <br /> $this->lock ( $this->database ); <br /> // 获取数据库存储位置 <br /> $sqlpath = pathinfo ( $sqlfile ); <br /> $this->sqldir = $sqlpath ['dirname']; <br /> // 检测是否包含分卷，将类似20120516211738_all_v1.sql从_v分开,有则说明有分卷 <br /> $volume = explode ( "_v", $sqlfile ); <br /> $volume_path = $volume [0]; <br /> echo "请勿刷新及关闭浏览器以防止程序被中止，如有不慎！将导致数据库结构受损<br />"; <br /> echo "正在导入备份数据，请稍等！<br />"; <br /> if (emptyempty ( $volume [1] )) <br /> { <br /> echo "正在导入sql：<span style='color:#f00'>" . $sqlfile . '</span><br />'; <br /> // 没有分卷 <br /> if ($this->_import ( $sqlfile )) { <br /> echo "数据库导入成功！"; <br /> } <br /> else <br /> { <br /> exit ( '数据库导入失败！' ); <br /> } <br /> } <br /> else <br /> { <br /> //$volume_id = array(); <br /> // 存在分卷，则获取当前是第几分卷，循环执行余下分卷 <br /> $volume_id = explode ( ".sq", $volume [1] ); <br /> // 当前分卷为$volume_id <br /> $volume_id = intval ( $volume_id [0] ); <br /> while ( $volume_id ) <br /> { <br /> $tmpfile = $volume_path . "_v" . $volume_id . ".sql"; <br /> // 存在其他分卷，继续执行 <br /> if (file_exists ( $tmpfile )) { <br /> // 执行导入方法 <br /> echo "正在导入分卷<span style='color:#f00'>" . $tmpfile . '</span><br />'; <br /> if ($this->_import ( $tmpfile )) <br /> { <br /> <br /> } <br /> else <br /> { <br /> exit ( "导入分卷<span style='color:#f00'>" . $tmpfile . '</span>失败！可能是数据库结构已损坏！请尝试从分卷1开始导入' ); <br /> } <br /> } <br /> else <br /> { <br /> echo "此分卷备份全部导入成功！<br />"; <br /> return; <br /> } <br /> $volume_id++; <br /> } <br /> } <br /> } <br /> <br /> /** <br /> * 将sql导入到数据库（普通导入） <br /> * <br /> * @param string $sqlfile <br /> * @return boolean <br /> */ <br /> private function _import($sqlfile) { <br /> // sql文件包含的sql语句数组 <br /> $sqls = array (); <br /> $f = fopen ( $sqlfile, "rb" ); <br /> // 创建表缓冲变量 <br /> $create = ''; <br /> while ( ! feof ( $f ) ) { <br /> // 读取每一行sql <br /> $line = fgets ( $f ); <br /> // 如果包含'-- '等注释，或为空白行，则跳过 <br /> if (trim ( $line ) == '' || preg_match ( '/--*?/', $line, $match )) { <br /> continue; <br /> } <br /> // 如果结尾包含';'(即为一个完整的sql语句，这里是插入语句)，并且不包含'ENGINE='(即创建表的最后一句)， <br /> if (! preg_match ( '/;/', $line, $match ) || preg_match ( '/ENGINE=/', $line, $match )) { <br /> // 将本次sql语句与创建表sql连接存起来 <br /> $create .= $line; <br /> // 如果包含了创建表的最后一句 <br /> if (preg_match ( '/ENGINE=/', $create, $match )) { <br /> // 则将其合并到sql数组 <br /> $sqls [] = $create; <br /> // 清空当前，准备下一个表的创建 <br /> $create = ''; <br /> } <br /> // 跳过本次 <br /> continue; <br /> } <br /> $sqls [] = $line; <br /> } <br /> fclose ( $f ); <br /> // 循环sql语句数组，分别执行 <br /> foreach ( $sqls as $sql ) { <br /> str_replace ( "n", "", $sql ); <br /> if (! mysql_query ( trim ( $sql ) )) { <br /> echo mysql_error (); <br /> return false; <br /> } <br /> } <br /> return true; <br /> } <br /> <br /> /* <br /> * -------------------------------数据库导入end--------------------------------- <br /> */ <br /> <br /> // 关闭数据库连接 <br /> private function close() { <br /> mysql_close ( $this->db ); <br /> } <br /> <br /> // 锁定数据库，以免备份或导入时出错 <br /> private function lock($tablename, $op = "WRITE") { <br /> if (mysql_query ( "lock tables " . $tablename . " " . $op )) <br /> return true; <br /> else <br /> return false; <br /> } <br /> <br /> // 解锁 <br /> private function unlock() { <br /> if (mysql_query ( "unlock tables" )) <br /> return true; <br /> else <br /> return false; <br /> } <br /> <br /> // 析构 <br /> function __destruct() { <br /> mysql_query ( "unlock tables", $this->db ); <br /> mysql_close ( $this->db ); <br /> }<br />} <br /> <br />$db = new DBManage ( 'localhost', 'root', '', 'tao', 'gbk' ); <br />//$db->backup ('tao_admin'); <br />$db->restore ( './backup/20140228222713_tao_admin_v1.sql'); <br />?>
希望本文所述对大家的PHP程序设计有所帮助。
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：php实现MySQL数据库备份与还原类实例_php技巧
转载请注明原文链接：php实现MySQL数据库备份与还原类实例_php技巧
