php实现MySQL数据库备份与还原类实例

前端之家收集整理的这篇文章主要介绍了php实现MySQL数据库备份与还原类实例前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

本文实例讲述了PHP实现MysqL数据库备份与还原类。分享给大家供大家参考。具体分析如下:

这是一个非常简单的利用PHP来备份MysqL数据库的类文件,我们只要简单的在dbmange中配置好连接地址用户名数据库即可,下面我们一起来看这个例子,代码如下:

代码如下:
backup (); * ------2. 数据库恢复(导入)------------------------------------------------------------ //分别是主机,用户名,密码,数据库名,数据库编码 $db = new DBManage ( 'localhost','utf8' ); //参数:sql文件 $db->restore ( './backup/20120516211738_all_v1.sql'); *---------------------------------------------------------------------- */ class DBManage { var $db; // 数据库连接 var $database; // 所用数据库 var $sqldir; // 数据库备份文件夹 var $record; // 换行符 private $ds = "n"; // 存储sql的变量 public $sqlContent = ""; // 每条sql语句的结尾符 public $sqlEnd = ";"; /** * 初始化 * * @param string $host * @param string $username * @param string $password * @param string $thisatabase * @param string $charset */ function __construct($host = 'localhost',$username = 'root',$password = '',$thisatabase = 'test',$charset = 'utf8') { $this->host = $host; $this->username = $username; $this->password = $password; $this->database = $thisatabase; $this->charset = $charset; // 连接数据库 $this->db = MysqL_connect ( $this->host,$this->username,$this->password ) or die ( "数据库连接失败." ); // 选择使用哪个数据库 MysqL_select_db ( $this->database,$this->db ) or die ( "无法打开数据库" ); // 数据库编码方式 MysqL_query ( 'SET NAMES ' . $this->charset,$this->db ); }

/*

  • ------------------------------------------数据库备份start----------------------------------------------------------
    */

/**

  • 数据库备份
  • 参数:备份哪个表(可选),默认2000,即2M)
  • @param $string $dir
  • @param int $size
  • @param $string $tablename
    /
    function backup($tablename = '',$dir = '',$size = 2000)
    {
    //$dir = $dir ? $dir : 'backup/';
    //$size = $size ? $size : 2000;
    $sql = '';
    // 只备份某个表
    if (! emptyempty ( $tablename ))
    {
    echo '正在备份表' . $tablename . '
    ';
    // 插入dump信息
    $sql = $this->_retrieve();
    // 插入表结构信息
    $sql .= $this->_insert_table_structure ( $tablename );
    // 插入数据
    $data = MysqL_query ( "select
    from " . $tablename );
    // 文件名前面部分
    $filename = date ( 'YmdHis' ) . "_" . $tablename;
    // 字段数量
    $num_fields = MysqL_num_fields ( $data );
    // 第几分卷
    $p = 1;
    // 循环每条记录
    while ( $record = MysqL_fetch_array ( $data ) )
    {
    // 单条记录
    $sql .= $this->_insert_record ( $tablename,$num_fields,$record );
    // 如果大于分卷大小,则写入文件
    if (strlen ( $sql ) >= $size 1000)
    {
    $file = $filename . "_v" . $p . ".sql";
    if ($this->_write_file ( $sql,$file,$dir ))
    {
    echo "表-" . $tablename . "-卷-" . $p . "-数据备份完成,生成备份文件 $dir$filename
    ";
    }
    else
    {
    echo "备份表-" . $tablename . "-失败
    ";
    }
    // 下一个分卷
    $p ++;
    // 重置$sql变量为空,重新计算该变量大小
    $sql = "";
    }
    }
    // sql大小不够分卷大小
    if ($sql != "")
    {
    $filename .= "_v" . $p . ".sql";
    if ($this->_write_file ( $sql,$filename,生成备份文件 $dir$filename
    ";
    }
    else
    {
    echo "备份卷-" . $p . "-失败
    ";
    }
    }
    }
    else
    { // 备份全部表
    if ($tables = MysqL_query ( "show table status from " . $this->database ))
    {
    echo "读取数据库结构成功!
    ";
    }
    else
    {
    exit ( "读取数据库结构成功!
    " );
    }
    // 插入dump信息
    $sql .= $this->_retrieve();
    // 文件名前面部分
    $filename = date ( 'YmdHis' ) . "_all";
    // 查出所有表
    $tables = MysqL_query ( 'SHOW TABLES' );
    // 第几分卷
    $p = 1;
    // 循环所有表
    while ( $table = MysqL_fetch_array ( $tables ) )
    {
    // 获取表名
    $tablename = $table [0];
    // 获取表结构
    $sql .= $this->_insert_table_structure ( $tablename );
    $data = MysqL_query ( "select
    from " . $tablename );
    $num_fields = MysqL_num_fields ( $data );

// 循环每条记录
while ( $record = MysqL_fetch_array ( $data ) )
{
// 单条记录
$sql .= $this->_insert_record ( $tablename,$record );
// 如果大于分卷大小,则写入文件
if (strlen ( $sql ) >= $size * 1000)
{

$file = $filename . "_v" . $p . ".sql";
// 写入文件
if ($this->_write_file ( $sql,$dir ))
{
echo "-卷-" . $p . "-数据备份完成,生成备份文件$dir$file
";
}
else
{
echo "备份卷-" . $p . "-失败
";
}
// 下一个分卷
$p ++;
// 重置$sql变量为空,重新计算该变量大小
$sql = "";
}
}
}
// sql大小不够分卷大小
if ($sql != "")
{
$filename .= "_v" . $p . ".sql";
if ($this->_write_file ( $sql,生成备份文件 $dir$filename
";
}
else
{
echo "备份卷-" . $p . "-失败
";
}
}
}
}

/**

  • 插入数据库备份基础信息
  • @return string
    */
    private function _retrieve() {
    $value = '';
    $value .= '--' . $this->ds;
    $value .= '-- MysqL database dump' . $this->ds;
    $value .= '-- Created by DBManage class,Power By yanue. ' . $this->ds;
    $value .= '-- http://yanue.net ' . $this->ds;
    $value .= '--' . $this->ds;
    $value .= '-- 主机: ' . $this->host . $this->ds;
    $value .= '-- 生成日期: ' . date ( 'Y' ) . ' 年 ' . date ( 'm' ) . ' 月 ' . date ( 'd' ) . ' 日 ' . date ( 'H:i' ) . $this->ds;
    $value .= '-- MysqL版本: ' . MysqL_get_server_info () . $this->ds;
    $value .= '-- PHP 版本: ' . PHPversion () . $this->ds;
    $value .= $this->ds;
    $value .= '--' . $this->ds;
    $value .= '-- 数据库: ' . $this->database . '' . $this->ds;
    $value .= '--' . $this->ds . $this->ds;
    $value .= '-- -------------------------------------------------------';
    $value .= $this->ds . $this->ds;
    return $value;
    }

/**

  • 插入表结构
  • @param unknown_type $table
  • @return string
    */
    private function _insert_table_structure($table) {
    $sql = '';
    $sql .= "--" . $this->ds;
    $sql .= "-- 表的结构" . $table . $this->ds;
    $sql .= "--" . $this->ds . $this->ds;

// 如果存在则删除
$sql .= "DROP TABLE IF EXISTS " . $table . '' . $this->sqlEnd . $this->ds;
// 获取详细表信息
$res = MysqL_query ( 'SHOW CREATE TABLE ' . $table . '' );
$row = MysqL_fetch_array ( $res );
$sql .= $row [1];
$sql .= $this->sqlEnd . $this->ds;
// 加上
$sql .= $this->ds;
$sql .= "--" . $this->ds;
$sql .= "-- 转存表中的数据 " . $table . $this->ds;
$sql .= "--" . $this->ds;
$sql .= $this->ds;
return $sql;
}

/**

  • 插入单条记录
  • @param string $table
  • @param int $num_fields
  • @param array $record
  • @return string
    */
    private function _insert_record($table,$record) {
    // sql字段逗号分割
    $insert = $comma = "";
    $insert .= "INSERT INTO " . $table . " VALUES(";
    // 循环每个子段下面的内容
    for($i = 0; $i < $num_fields; $i ++) {
    $insert .= ($comma . "'" .mysql_real_escape_string ( $record [$i] ) . "'");
    $comma = ",";
    }
    $insert .= ");" . $this->ds;
    return $insert;
    }

/**

  • 写入文件
  • @param string $sql
  • @param string $filename
  • @param string $dir
  • @return boolean
    */
    private function _write_file($sql,$dir) {
    $dir = $dir ? $dir : './backup/';
    // 不存在文件夹则创建
    if (! file_exists ( $dir )) {
    mkdir ( $dir );
    }
    $re = true;
    if (! @$fp = fopen ( $dir . $filename,"w+" )) {
    $re = false;
    echo "打开文件失败!";
    }
    if (! @fwrite ( $fp,$sql )) {
    $re = false;
    echo "写入文件失败,请文件是否可写";
    }
    if (! @fclose ( $fp )) {
    $re = false;
    echo "关闭文件失败!";
    }
    return $re;
    }

/*

  • -------------------------------上:数据库导出-----------分割线----------下:数据库导入--------------------------------
    */

/**

  • 导入备份数据
  • 说明:分卷文件格式20120516211738_all_v1.sql
  • 参数:文件路径(必填)
  • @param string $sqlfile
    */
    function restore($sqlfile)
    {
    // 检测文件是否存在
    if (! file_exists ( $sqlfile ))
    {
    exit ( "文件不存在!请检查" );
    }
    $this->lock ( $this->database );
    // 获取数据库存储位置
    $sqlpath = pathinfo ( $sqlfile );
    $this->sqldir = $sqlpath ['dirname'];
    // 检测是否包含分卷,将类似20120516211738_all_v1.sql从_v分开,有则说明有分卷
    $volume = explode ( "_v",$sqlfile );
    $volume_path = $volume [0];
    echo "请勿刷新及关闭浏览器以防止程序被中止,如有不慎!将导致数据库结构受损
    ";
    echo "正在导入备份数据,请稍等!
    ";
    if (emptyempty ( $volume [1] ))
    {
    echo "正在导入sql" . $sqlfile . '
    ';
    // 没有分卷
    if ($this->_import ( $sqlfile )) {
    echo "数据库导入成功!";
    }
    else
    {
    exit ( '数据库导入失败!' );
    }
    }
    else
    {
    //$volume_id = array();
    // 存在分卷,则获取当前是第几分卷,循环执行余下分卷
    $volume_id = explode ( ".sq",$volume [1] );
    // 当前分卷为$volume_id
    $volume_id = intval ( $volume_id [0] );
    while ( $volume_id )
    {
    $tmpfile = $volume_path . "_v" . $volume_id . ".sql";
    // 存在其他分卷,继续执行
    if (file_exists ( $tmpfile )) {
    // 执行导入方法
    echo "正在导入分卷" . $tmpfile . '
    ';
    if ($this->_import ( $tmpfile ))
    {

}
else
{
exit ( "导入分卷" . $tmpfile . '失败!可能是数据库结构已损坏!请尝试从分卷1开始导入' );
}
}
else
{
echo "此分卷备份全部导入成功!
";
return;
}
$volume_id++;
}
}
}

/**

  • sql导入到数据库(普通导入)
  • @param string $sqlfile
  • @return boolean
    /
    private function _import($sqlfile) {
    // sql文件包含的sql语句数组
    $sqls = array ();
    $f = fopen ( $sqlfile,"rb" );
    // 创建表缓冲变量
    $create = '';
    while ( ! feof ( $f ) ) {
    // 读取每一行sql
    $line = fgets ( $f );
    // 如果包含'-- '等注释,或为空白行,则跳过
    if (trim ( $line ) == '' || preg_match ( '/--
    ?/',$line,$match )) {
    continue;
    }
    // 如果结尾包含';'(即为一个完整的sql语句,这里是插入语句),并且不包含'ENGINE='(即创建表的最后一句),
    if (! preg_match ( '/;/',$match ) || preg_match ( '/ENGINE=/',$match )) {
    // 将本次sql语句与创建表sql连接存起来
    $create .= $line;
    // 如果包含了创建表的最后一句
    if (preg_match ( '/ENGINE=/',$create,$match )) {
    // 则将其合并到sql数组
    $sqls [] = $create;
    // 清空当前,准备下一个表的创建
    $create = '';
    }
    // 跳过本次
    continue;
    }
    $sqls [] = $line;
    }
    fclose ( $f );
    // 循环sql语句数组,分别执行
    foreach ( $sqls as $sql ) {
    str_replace ( "n","",$sql );
    if (! MysqL_query ( trim ( $sql ) )) {
    echo MysqL_error ();
    return false;
    }
    }
    return true;
    }

/*

  • -------------------------------数据库导入end---------------------------------
    */

// 关闭数据库连接
private function close() {
MysqL_close ( $this->db );
}

// 锁定数据库,以免备份或导入时出错
private function lock($tablename,$op = "WRITE") {
if (MysqL_query ( "lock tables " . $tablename . " " . $op ))
return true;
else
return false;
}

// 解锁
private function unlock() {
if (MysqL_query ( "unlock tables" ))
return true;
else
return false;
}

// 析构
function __destruct() {
MysqL_query ( "unlock tables",$this->db );
MysqL_close ( $this->db );
}
}

$db = new DBManage ( 'localhost','','tao','gbk' );
//$db->backup ('tao_admin');
$db->restore ( './backup/20140228222713_tao_admin_v1.sql');
?>

希望本文所述对大家的PHP程序设计有所帮助。

原文链接:https://www.f2er.com/php/23134.html

猜你在找的PHP相关文章