详解MYSQL的备份还原(PHP实现)

更新时间：2013年06月02日 20:59:58 作者：

本篇文章是对MYSQL的备份还原进行了详细的分析介绍，需要的朋友参考下

手把手教你实现MYSQL的备份还原
示例代码用我比较熟悉的PHP，当然你看完并理解了其中的思路，相信你也可以快速地用你熟悉的语言自己写出来。
一、新建dbBackup类，设置默认参数。

class dbBackup {
    public $host='localhost';    //数据库地址
    public $user='root';    //登录名
    public $pwd='';    //密码
    public $database;    //数据库名
    public $charset='utf8';    //数据库连接编码：mysql_set_charset
}

二、添加数据库连接function。

复制代码代码如下:

/**
     * 连接数据库 ...
     */
    function db() {        
        $con = mysql_connect($this->host,$this->user,$this->pwd);
        if (!$con){
            die('Could not connect');
        }

        $db_selected = mysql_select_db($this->database, $con);
        if (!$db_selected) {
            die('Can\'t use select db');
        }

        mysql_set_charset($this->charset);　　//设置编码

        return $con;
    }

三、查询数据库表集合

复制代码代码如下:

/**
     * 表集合 ...
     */
    function tblist() {
        $list=array();

        $rs=mysql_query("SHOW TABLES FROM $this->database");
        while ($temp=mysql_fetch_row($rs)) {
            $list[]=$temp[0];
        }

        return $list;
    }

四、查询表结构

复制代码代码如下:

/**
     * 表结构SQL ...
     */
    function sqlcreate() {
        $sql='';

        $tb=$this->tblist();        
        foreach ($tb as $v) {
            $rs=mysql_query("SHOW CREATE TABLE $v");
            $temp=mysql_fetch_row($rs);
            $sql.="-- 表的结构：{$temp[0]} --\r\n";
            $sql.="{$temp[1]}";
            $sql.=";-- <xjx> --\r\n\r\n";
        }
        return $sql;
    }

注：$sql.=";-- <xjx> --\r\n\r\n"; 每句SQL后面必须加上分号(;)分割，MYSQL导入才能识别。-- <xjx> -- 是程序对SQL语句分割的标识，可以自定义但必须是注释语句，否则影响SQL语句。\r\n无实际意义用于文本美观

五、INSERT INTO语句

复制代码代码如下:

/**
     * 数据插入SQL ...
     */
    function sqlinsert() {
        $sql='';

        $tb=$this->tblist();        
        foreach ($tb as $v) {
            $rs=mysql_query("SELECT * FROM $v");
            if (!mysql_num_rows($rs)) {//无数据返回
                continue;
            }        
            $sql.="-- 表的数据：$v --\r\n";
            $sql.="INSERT INTO `$v` VALUES\r\n";        
            while ($temp=mysql_fetch_row($rs)) {
                $sql.='(';
                foreach ($temp as $v2) {
                    if ($v2===null) {
                        $sql.="NULL,";
                    }
                    else {
                        $v2=mysql_real_escape_string($v2);
                        $sql.="'$v2',";
                    }                    
                }
                $sql=mb_substr($sql, 0, -1);
                $sql.="),\r\n";
            }
            $sql=mb_substr($sql, 0, -3);
            $sql.=";-- <xjx> --\r\n\r\n";    
        }

        return $sql;
    }

注：
1.无数据返回时必须跳出本次循环，避免生成多余代码
2.当字段值为(NULL)时，插入字符为(NULL)而不是('NULL')，没有单引号。3.$v2=mysql_real_escape_string($v2)，这是必要的转义
4.mb_substr($sql, 0, -1)、mb_substr($sql, 0, -3)，必须去除最后一个逗号(,) 否则SQL语句出错5.$sql.=";-- <xjx> --\r\n\r\n"，详见第四步注

六、备份操作

复制代码代码如下:

/**
     * 备份 ...
     * @param $filename 文件路径
     */
    function beifen($filename) {
        $this->db();    //连接数据库

        $sql=$this->sqlcreate();
        $sql2=$this->sqlinsert();        
        $data=$sql.$sql2;

        return file_put_contents($filename, $data);
    }

七、还原操作

复制代码代码如下:

/**
     * 还原 ...
     * @param $filename 文件路径
     */
    function huanyuan($filename) {
        $this->db();    //连接数据库

        //删除数据表
        $list=$this->tblist();
        $tb='';
        foreach ($list as $v) {
            $tb.="`$v`,";
        }
        $tb=mb_substr($tb, 0, -1);
        if ($tb) {
            $rs=mysql_query("DROP TABLE $tb");
            if ($rs===false) {
                return false;
            }
        }

        //执行SQL
        $str=file_get_contents($filename);
        $arr=explode('-- <xjx> --', $str);
        array_pop($arr);

        foreach ($arr as $v) {
            $rs=mysql_query($v);
            if ($rs===false) {
                return false;
            }
        }

        return true;
    }

备份示例：

复制代码代码如下:

$x=new dbBackup();
$x->database='test';
$rs=$x->beifen('db.sql');
var_dump($rs);

还原示例：

复制代码代码如下:

$x=new dbBackup();
$x->database='test';
$rs=$x->huanyuan('db.sql');
var_dump($rs);

完整代码：

复制代码代码如下:

class dbBackup {
    public $host='localhost';    //数据库地址
    public $user='root';    //登录名
    public $pwd='';    //密码
    public $database;    //数据库名
    public $charset='utf8';    //数据库连接编码：mysql_set_charset

    /**
     * 备份 ...
     * @param $filename 文件路径
     */
    function beifen($filename) {
        $this->db();    //连接数据库

        $sql=$this->sqlcreate();
        $sql2=$this->sqlinsert();        
        $data=$sql.$sql2;

        return file_put_contents($filename, $data);
    }

    /**
     * 还原 ...
     * @param $filename 文件路径
     */
    function huanyuan($filename) {
        $this->db();    //连接数据库

        //删除数据表
        $list=$this->tblist();
        $tb='';
        foreach ($list as $v) {
            $tb.="`$v`,";
        }
        $tb=mb_substr($tb, 0, -1);
        if ($tb) {
            $rs=mysql_query("DROP TABLE $tb");
            if ($rs===false) {
                return false;
            }
        }

        //执行SQL
        $str=file_get_contents($filename);
        $arr=explode('-- <xjx> --', $str);
        array_pop($arr);

        foreach ($arr as $v) {
            $rs=mysql_query($v);
            if ($rs===false) {
                return false;
            }
        }

        return true;
    }

    /**
     * 连接数据库 ...
     */
    function db() {        
        $con = mysql_connect($this->host,$this->user,$this->pwd);
        if (!$con){
            die('Could not connect');
        }

        $db_selected = mysql_select_db($this->database, $con);
        if (!$db_selected) {
            die('Can\'t use select db');
        }

        mysql_set_charset($this->charset);    //设置编码

        return $con;
    }

    /**
     * 表集合 ...
     */
    function tblist() {
        $list=array();

        $rs=mysql_query("SHOW TABLES FROM $this->database");
        while ($temp=mysql_fetch_row($rs)) {
            $list[]=$temp[0];
        }

        return $list;
    }

    /**
     * 表结构SQL ...
     */
    function sqlcreate() {
        $sql='';

        $tb=$this->tblist();        
        foreach ($tb as $v) {
            $rs=mysql_query("SHOW CREATE TABLE $v");
            $temp=mysql_fetch_row($rs);
            $sql.="-- 表的结构：{$temp[0]} --\r\n";
            $sql.="{$temp[1]}";
            $sql.=";-- <xjx> --\r\n\r\n";
        }
        return $sql;
    }

    /**
     * 数据插入SQL ...
     */
    function sqlinsert() {
        $sql='';

        $tb=$this->tblist();        
        foreach ($tb as $v) {
            $rs=mysql_query("SELECT * FROM $v");
            if (!mysql_num_rows($rs)) {//无数据返回
                continue;
            }        
            $sql.="-- 表的数据：$v --\r\n";
            $sql.="INSERT INTO `$v` VALUES\r\n";        
            while ($temp=mysql_fetch_row($rs)) {
                $sql.='(';
                foreach ($temp as $v2) {
                    if ($v2===null) {
                        $sql.="NULL,";
                    }
                    else {
                        $v2=mysql_real_escape_string($v2);
                        $sql.="'$v2',";
                    }                    
                }
                $sql=mb_substr($sql, 0, -1);
                $sql.="),\r\n";
            }
            $sql=mb_substr($sql, 0, -3);
            $sql.=";-- <xjx> --\r\n\r\n";    
        }

        return $sql;
    }
}
//备份
//$x=new dbBackup();
//$x->database='test';
//$rs=$x->beifen('db.sql');
//var_dump($rs);
//还原
//$x=new dbBackup();
//$x->database='test';
//$rs=$x->huanyuan('db.sql');
//var_dump($rs);

您可能感兴趣的文章:

Mysql 远程连接遇到的问题排查
无法连接到远程MySQL数据库可能是由于多种原因导致的,本文主要介绍了Mysql远程连接遇到的问题排查,具有一定的参考价值,感兴趣的可以了解一下
2024-07-07
mysql distinct去重,IFNULL空值处理方式
文章介绍了如何在MySQL中使用`DISTINCT`命令去重和使用`IFNULL`函数处理空值,首先,通过Navicat新建数据库并准备数据,然后展示了如何使用`DISTINCT`命令去除重复数据和使用`IFNULL`函数将空值替换为“暂无”
2025-01-01
修改MySQL所有表的编码或修改某个字段的编码步骤详解
这篇文章主要给大家介绍了关于修改MySQL所有表的编码或修改某个字段编码的相关资料,在进行数据库编码更改之前,需要先确定目标编码格式,常见的编码格式有UTF-8、GBK等,需要的朋友可以参考下
2023-12-12
超越MySQL 对流行数据库进行分支的知识小结
尽管MySQL是最受欢迎的程序之一，但是许多开发人员认为有必要将其拆分成其他项目，并且每个分支项目都有自己的专长。该需求，以及 Oracle 对核心产品增长缓慢的担忧，导致出现了许多开发人员感兴趣的子项目和分支
2012-01-01
MySQL的索引系统采用B+树的原因解析
索引是为了加速对表中数据行的检索而创建的一种分散的存储结构，这篇文章主要介绍了MySQL的索引系统采用B+树的原因解析,需要的朋友可以参考下
2021-09-09
MySQL中SQL Mode的查看与设置详解
在本篇文章里小编给各位分享的是关于MySQL中SQL Mode的查看与设置详解内容，需要的朋友们可以参考下。
2020-03-03
MySQL Packet for query is too large 问题及解决方法
这篇文章主要介绍了MySQL Packet for query is too large 问题及解决方法,需要的朋友可以参考下
2018-05-05
mysql如何将时间格式化为yyyy-MM-dd或yyyy-MM-dd HH:mm:ss
这篇文章主要介绍了mysql如何将时间格式化为yyyy-MM-dd或yyyy-MM-dd HH:mm:ss问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-07-07
MySQL8.0.32的安装与配置超详细图文教程
这篇文章主要介绍了MySQL8.0.32的安装与配置超详细图文教程,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-03-03
MySQL中JSON字段数据类型详解
JSON我相信大家都已经很熟悉了,但在 MySQL中,直至 5.7 版本中,才正式引入 JSON数据类型,下面这篇文章主要给大家介绍了关于MySQL中JSON字段数据类型的相关资料,需要的朋友可以参考下
2022-06-06

详解MYSQL的备份还原(PHP实现)

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具