thinkPHP3.2.3—后台备份数据库

  • 爵特猛
  • 2018-7-13 19:09
  • PHP
  • 700

使用thinkPHP3.2.3做一个数据库备份的功能,可以实现MySQL的数据导出和导入,生成sql后缀文件,可下载SQL文件。


  1. 首先,在 /ThinkPHP/Library/OT 目录下新建一个数据导出模型类文件,命名为Database.class.php

<?php
/*---------------------------------------------
 * @数据库备份还原控制器
 * @第一:本控制器依靠config中的配置运行,须在config中新增配置:
 *		'DB_PATH_NAME'=> 'db',        //备份目录名称,主要是为了创建备份目录;
 *		'DB_PATH'     => './db/',     //数据库备份路径必须以 / 结尾;
 *		'DB_PART'     => '20971520',  //该值用于限制压缩后的分卷最大长度。单位:B;建议设置20M
 *		'DB_COMPRESS' => '1',         //压缩备份文件需要PHP环境支持gzopen,gzwrite函数        0:不压缩 1:启用压缩
 *		'DB_LEVEL'    => '9',         //压缩级别   1:普通   4:一般   9:最高
 * @第二:本控制器依赖ThinkPHP/Library/OT/Database.class.php
 * @第三:在Application/Common/function.php里面加个format_bytes()函数;
			/**
			 * 格式化字节大小
			 * @param  number $size      字节数
			 * @param  string $delimiter 数字和单位分隔符
			 * @return string            格式化后的带单位的大小
			 *
			function format_bytes($size, $delimiter = '') {
				$units = array('B', 'KB', 'MB', 'GB', 'TB', 'PB');
				for ($i = 0; $size >= 1024 && $i < 5; $i++) $size /= 1024;
				return round($size, 2) . $delimiter . $units[$i];
			}
 * @第四:模版文件,Home/View/Database下面的2个文件 export.html备份数据库  import.html还原数据库
 * @第五:模版文件中需jquery支持(模版中有ajax),并且要想实现模版中的多选需引用以下js:
 		 <script>
 			;$(function(){
				//全选的实现
				$(".check-all").click(function(){
					$(".ids").prop("checked", this.checked);
				});
				$(".ids").click(function(){
					var option = $(".ids");
					option.each(function(i){
						if(!this.checked){
							$(".check-all").prop("checked", false);
							return false;
						}else{
							$(".check-all").prop("checked", true);
						}
					});
				});

			});
         </script>
 * @第六:引用方法:<a href="{:U('Database/index',array('type'=>'export'))}">备份数据库</a>
 * 		          <a href="{:U('Database/index',array('type'=>'import'))}">还原数据库</a>
 *---------------------------------------------
 */

namespace OT;
use Think\Db;

//数据导出模型
class Database{
    /**
     * 文件指针
     * @var resource
     */
    private $fp;

    /**
     * 备份文件信息 part - 卷号,name - 文件名
     * @var array
     */
    private $file;

    /**
     * 当前打开文件大小
     * @var integer
     */
    private $size = 0;

    /**
     * 备份配置
     * @var integer
     */
    private $config;

    /**
     * 数据库备份构造方法
     * @param array  $file   备份或还原的文件信息
     * @param array  $config 备份配置信息
     * @param string $type   执行类型,export - 备份数据, import - 还原数据
     */
    public function __construct($file, $config, $type = 'export'){
        $this->file   = $file;
        $this->config = $config;
    }

    /**
     * 打开一个卷,用于写入数据
     * @param  integer $size 写入数据的大小
     */
    private function open($size){
        if($this->fp){
            $this->size += $size;
            if($this->size > $this->config['part']){
                $this->config['compress'] ? @gzclose($this->fp) : @fclose($this->fp);
                $this->fp = null;
                $this->file['part']++;
                session('backup_file', $this->file);
                $this->create();
            }
        } else {
            $backuppath = $this->config['path'];
            $filename   = "{$backuppath}{$this->file['name']}-{$this->file['part']}.sql";
            if($this->config['compress']){
                $filename = "{$filename}.gz";
                $this->fp = @gzopen($filename, "a{$this->config['level']}");
            } else {
                $this->fp = fopen($filename, 'a');
            }
            $this->size = filesize($filename) + $size;
        }
    }

    /**
     * 写入初始数据
     * @return boolean true - 写入成功,false - 写入失败
     */
    public function create(){
        $sql  = "-- -----------------------------\n";
        $sql .= "-- Think MySQL Data Transfer \n";
        $sql .= "-- \n";
        $sql .= "-- Host     : " . C('DB_HOST') . "\n";
        $sql .= "-- Port     : " . C('DB_PORT') . "\n";
        $sql .= "-- Database : " . C('DB_NAME') . "\n";
        $sql .= "-- \n";
        $sql .= "-- Part : #{$this->file['part']}\n";
        $sql .= "-- Date : " . date("Y-m-d H:i:s") . "\n";
        $sql .= "-- -----------------------------\n\n";
        $sql .= "SET FOREIGN_KEY_CHECKS = 0;\n\n";
        return $this->write($sql);
    }

    /**
     * 写入SQL语句
     * @param  string $sql 要写入的SQL语句
     * @return boolean     true - 写入成功,false - 写入失败!
     */
    private function write($sql){
        $size = strlen($sql);

        //由于压缩原因,无法计算出压缩后的长度,这里假设压缩率为50%,
        //一般情况压缩率都会高于50%;
        $size = $this->config['compress'] ? $size / 2 : $size;

        $this->open($size);
        return $this->config['compress'] ? gzwrite($this->fp, $sql) : fwrite($this->fp, $sql);
    }

    /**
     * 备份表结构
     * @param  string  $table 表名
     * @param  integer $start 起始行数
     * @return boolean        false - 备份失败
     */
    public function backup($table, $start){
        //创建DB对象
        $db = Db::getInstance();

        //备份表结构
        if(0 == $start){
            $result = $db->query("SHOW CREATE TABLE `{$table}`");
            $sql  = "\n";
            $sql .= "-- -----------------------------\n";
            $sql .= "-- Table structure for `{$table}`\n";
            $sql .= "-- -----------------------------\n";
            $sql .= "DROP TABLE IF EXISTS `{$table}`;\n";
            $sql .= trim($result[0]['create table']) . ";\n\n";
            if(false === $this->write($sql)){
                return false;
            }
        }

        //数据总数
        $result = $db->query("SELECT COUNT(*) AS count FROM `{$table}`");
        $count  = $result['0']['count'];

        //备份表数据
        if($count){
            //写入数据注释
            if(0 == $start){
                $sql  = "-- -----------------------------\n";
                $sql .= "-- Records of `{$table}`\n";
                $sql .= "-- -----------------------------\n";
                $this->write($sql);
            }

            //备份数据记录
            $result = $db->query("SELECT * FROM `{$table}` LIMIT {$start}, 1000");
            foreach ($result as $row) {
                // $row = array_map('mysql_real_escape_string', $row);
                // $sql = "INSERT INTO `{$table}` VALUES ('" . implode("', '", $row) . "');\n";
                $sql = "INSERT INTO `{$table}` VALUES (" . $this->_implode_insert_values($row) . ");\r\n";

                if(false === $this->write($sql)){
                    return false;
                }
            }

            //还有更多数据
            if($count > $start + 1000){
                return array($start + 1000, $count);
            }
        }

        //备份下一表
        return 0;
    }

    /**
     * 对 MYSQL INSERT INTO 语句的values部分内容进行字符串连接
     *
     * @param array $values
     * @return string
     */
    private function _implode_insert_values($values)
    {
        $str = '';
        $values = array_values($values);
        foreach ($values as $k => $v)
        {
            $v = ($v === null) ? 'null' : "'" . addslashes($v) . "'";
            $str = ($k == 0) ? $str . $v : $str . ',' . $v;
        }
        return $str;
    }

    public function import($start){
        //还原数据
        $db = Db::getInstance();

        if($this->config['compress']){
            $gz   = gzopen($this->file[1], 'r');
            $size = 0;
        } else {
            $size = filesize($this->file[1]);
            $gz   = fopen($this->file[1], 'r');
        }

        $sql  = '';
        if($start){
            $this->config['compress'] ? gzseek($gz, $start) : fseek($gz, $start);
        }

        for($i = 0; $i < 1000; $i++){
            $sql .= $this->config['compress'] ? gzgets($gz) : fgets($gz);
            if(preg_match('/.*;$/', trim($sql))){
                if(false !== $db->execute($sql)){
                    $start += strlen($sql);
                } else {
                    return false;
                }
                $sql = '';
            } elseif ($this->config['compress'] ? gzeof($gz) : feof($gz)) {
                return 0;
            }
        }

        return array($start, $size);
    }

    /**
     * 析构方法,用于关闭文件资源
     */
    public function __destruct(){
        $this->config['compress'] ? @gzclose($this->fp) : @fclose($this->fp);
    }
}

    2.建好第三方类库之后,需要在config.php配置文件中写入相应配置

    'DB_PATH_NAME'=> 'db_backup',        //备份目录名称,主要是为了创建备份目录;
    'DB_PATH'     => './db_backup/',     //数据库备份路径必须以 / 结尾;
    'DB_PART'     => '20971520',  //该值用于限制压缩后的分卷最大长度。单位:B;建议设置20M
    'DB_COMPRESS' => '1',         //压缩备份文件需要PHP环境支持gzopen,gzwrite函数        0:不压缩 1:启用压缩
    'DB_LEVEL'    => '9',         //压缩级别   1:普通   4:一般   9:最高

    3.写入配置文件后,增加一个新的控制器,我这里是在后台admin模块新增了一个DatabaseController.class.php

<?php
/*---------------------------------------------
 * @数据库备份还原控制器
 * @第一:本控制器依靠config中的配置运行:
 *      'DB_PATH_NAME'=> 'db',        //备份目录名称,主要是为了创建备份目录;
 *      'DB_PATH'     => './db/',     //数据库备份路径必须以 / 结尾;
 *      'DB_PART'     => '20971520',  //该值用于限制压缩后的分卷最大长度。单位:B;建议设置20M
 *      'DB_COMPRESS' => '1',         //压缩备份文件需要PHP环境支持gzopen,gzwrite函数        0:不压缩 1:启用压缩
 *      'DB_LEVEL'    => '9',         //压缩级别   1:普通   4:一般   9:最高
 * @第二:本控制器依赖ThinkPHP/Library/OT/Database.class.php
 * @第三:模版,Home/View/Database下面的2个文件 export.html备份数据库  import.html还原数据库
 * @第四:引用方法:<a href="{:U('Database/index',array('type'=>'export'))}">备份数据库</a>
 *                <a href="{:U('Database/index',array('type'=>'import'))}">还原数据库</a>
 *---------------------------------------------
 */

namespace Admin\Controller;
use Think\Db;
use OT\Database;
use Admin\Controller\AdminBaseController;

/**
 * 数据库备份还原控制器
 */
class DatabaseController extends AdminBaseController{

    /**
     * 数据库备份/还原列表
     * @param  String $type import-还原,export-备份
     */
    public function index($type = null){
        switch ($type) {
            /* 数据还原 */
            case 'import':
                //判断目录是否存在
                is_writeable($config['path']) || mkdir('./'.C("DB_PATH_NAME").'',0777,true);
                //列出备份文件列表
                $path = realpath(C('DB_PATH'));
                $flag = \FilesystemIterator::KEY_AS_FILENAME;
                $glob = new \FilesystemIterator($path,  $flag);

                $list = array();
                foreach ($glob as $name => $file) {
                    if(preg_match('/^\d{8,8}-\d{6,6}-\d+\.sql(?:\.gz)?$/', $name)){
                        $name = sscanf($name, '%4s%2s%2s-%2s%2s%2s-%d');

                        $date = "{$name[0]}-{$name[1]}-{$name[2]}";
                        $time = "{$name[3]}:{$name[4]}:{$name[5]}";
                        $part = $name[6];

                        if(isset($list["{$date} {$time}"])){
                            $info = $list["{$date} {$time}"];
                            $info['part'] = max($info['part'], $part);
                            $info['size'] = $info['size'] + $file->getSize();
                        } else {
                            $info['part'] = $part;
                            $info['size'] = $file->getSize();
                        }
                        $extension        = strtoupper(pathinfo($file->getFilename(), PATHINFO_EXTENSION));
                        $info['compress'] = ($extension === 'SQL') ? '-' : $extension;
                        $info['time']     = strtotime("{$date} {$time}");
                        $info['filename'] = $file->getFilename();

                        $list["{$date} {$time}"] = $info;
                    }
                }
                $title = '数据还原';
                break;

            /* 数据备份 */
            case 'export':
                //判断目录是否存在
                is_writeable($config['path']) || mkdir('./'.C("DB_PATH_NAME").'',0777,true);
                $Db    = Db::getInstance();
                $list  = $Db->query('SHOW TABLE STATUS');
                $list  = array_map('array_change_key_case', $list);
                $title = '数据备份';
                break;

            default:
                $this->error('参数错误!');
        }

        //渲染模板
        $this->assign('meta_title', $title);
        $this->assign('list', $list);
        $this->display($type);
    }

    /**
     * 下载备份文件
     * @author lizhengmeng
     * @DateTime 2018-7-3 10:18:53
     */
    public function download()
    {
        $path = C('DB_PATH');
        $param = I('get.');
        $sql_file = $path.$param['filename'];
        if (file_exists($sql_file))
        {
            header('Content-type: application/unknown');
            header('Content-Disposition: attachment; filename="' . $param['filename'] . '"');
            header("Content-Length: " . filesize($sql_file) . "; ");
            readfile($sql_file);
        } else
        {
            $this->error($sql_file.'文件不存在!');
        }
    }

    /**
     * 优化表
     * @param  String $tables 表名
     */
    public function optimize($tables = null){
        if($tables) {
            $Db   = Db::getInstance();
            if(is_array($tables)){
                $tables = implode('`,`', $tables);
                $list = $Db->query("OPTIMIZE TABLE `{$tables}`");

                if($list){
                    $this->success("数据表优化完成!");
                } else {
                    $this->error("数据表优化出错请重试!");
                }
            } else {
                $list = $Db->query("OPTIMIZE TABLE `{$tables}`");
                if($list){
                    $this->success("数据表'{$tables}'优化完成!");
                } else {
                    $this->error("数据表'{$tables}'优化出错请重试!");
                }
            }
        } else {
            $this->error("请指定要优化的表!");
        }
    }

    /**
     * 修复表
     * @param  String $tables 表名
     */
    public function repair($tables = null){
        if($tables) {
            $Db   = Db::getInstance();
            if(is_array($tables)){
                $tables = implode('`,`', $tables);
                $list = $Db->query("REPAIR TABLE `{$tables}`");

                if($list){
                    $this->success("数据表修复完成!");
                } else {
                    $this->error("数据表修复出错请重试!");
                }
            } else {
                $list = $Db->query("REPAIR TABLE `{$tables}`");
                if($list){
                    $this->success("数据表'{$tables}'修复完成!");
                } else {
                    $this->error("数据表'{$tables}'修复出错请重试!");
                }
            }
        } else {
            $this->error("请指定要修复的表!");
        }
    }

    /**
     * 删除备份文件
     * @param  Integer $time 备份时间
     */
    public function del($time = 0){
        if($time){
            $name  = date('Ymd-His', $time) . '-*.sql*';
            $path  = realpath(C('DB_PATH')). DIRECTORY_SEPARATOR . $name;
            array_map("unlink", glob($path));
            if(count(glob($path))){
                $this->success($path.'备份文件删除失败,请检查权限!');
            } else {
                $this->success('备份文件删除成功!');
            }
        } else {
            $this->error('参数错误!');
        }
    }

    /**
     * 备份数据库
     * @param  String  $tables 表名
     * @param  Integer $id     表ID
     * @param  Integer $start  起始行数
     */
    public function export($tables = null, $id = null, $start = null){
        if(IS_POST && !empty($tables) && is_array($tables)){ //初始化
            //读取备份配置
            $config = array(
                'path'     => realpath(C('DB_PATH')) . DIRECTORY_SEPARATOR,  //路径
                'part'     => C('DB_PART'),  //分卷大小 20M
                'compress' => C('DB_COMPRESS'),  //0:不压缩 1:启用压缩
                'level'    => C('DB_LEVEL'),  //压缩级别, 1:普通 4:一般  9:最高
            );
            //检查是否有正在执行的任务
            $lock = "{$config['path']}backup.lock";
            if(is_file($lock)){
                $this->error('检测到有一个备份任务正在执行,请稍后再试!');
            } else {
                //创建锁文件
                file_put_contents($lock, NOW_TIME);
            }

            //检查备份目录是否可写 创建备份目录
            is_writeable($config['path']) || mkdir('./'.C("DB_PATH_NAME").'',0777,true);
            session('backup_config', $config);

            //生成备份文件信息
            $file = array(
                'name' => date('Ymd-His', NOW_TIME),
                'part' => 1,
            );
            session('backup_file', $file);

            //缓存要备份的表
            session('backup_tables', $tables);

            //创建备份文件
            $Database = new Database($file, $config);
            if(false !== $Database->create()){
                $tab = array('id' => 0, 'start' => 0);
                $this->success('初始化成功!', '', array('tables' => $tables, 'tab' => $tab));
            } else {
                $this->error('初始化失败,备份文件创建失败!');
            }
        } elseif (IS_GET && is_numeric($id) && is_numeric($start)) { //备份数据
            $tables = session('backup_tables');
            //备份指定表
            $Database = new Database(session('backup_file'), session('backup_config'));
            $start  = $Database->backup($tables[$id], $start);
            if(false === $start){ //出错
                $this->error('备份出错!');
            } elseif (0 === $start) { //下一表
                if(isset($tables[++$id])){
                    $tab = array('id' => $id, 'start' => 0);
                    $this->success('备份完成!', '', array('tab' => $tab));
                } else { //备份完成,清空缓存
                    unlink(session('backup_config.path') . 'backup.lock');
                    session('backup_tables', null);
                    session('backup_file', null);
                    session('backup_config', null);
                    $this->success('备份完成!');
                }
            } else {
                $tab  = array('id' => $id, 'start' => $start[0]);
                $rate = floor(100 * ($start[0] / $start[1]));
                $this->success("正在备份...({$rate}%)", '', array('tab' => $tab));
            }

        } else { //出错
            $this->error('参数错误!');
        }
    }

    /**
     * 还原数据库
     */
    public function import($time = 0, $part = null, $start = null){
        if(is_numeric($time) && is_null($part) && is_null($start)){ //初始化
            //获取备份文件信息
            $name  = date('Ymd-His', $time) . '-*.sql*';
            $path  = realpath(C('DB_PATH')). DIRECTORY_SEPARATOR . $name;
            $files = glob($path);
            $list  = array();
            foreach($files as $name){
                $basename = basename($name);
                $match    = sscanf($basename, '%4s%2s%2s-%2s%2s%2s-%d');
                $gz       = preg_match('/^\d{8,8}-\d{6,6}-\d+\.sql.gz$/', $basename);
                $list[$match[6]] = array($match[6], $name, $gz);
            }
            ksort($list);

            //检测文件正确性
            $last = end($list);
            if(count($list) === $last[0]){
                session('backup_list', $list); //缓存备份列表
                $this->success('初始化完成!', '', array('part' => 1, 'start' => 0));
            } else {
                $this->error('备份文件可能已经损坏,请检查!');
            }
        } elseif(is_numeric($part) && is_numeric($start)) {
            $list  = session('backup_list');
            $db = new Database($list[$part], array(
                'path'     => realpath(C('DB_PATH')) . DIRECTORY_SEPARATOR,
                'compress' => $list[$part][2]));

            $start = $db->import($start);

            if(false === $start){
                $this->error('还原数据出错!');
            } elseif(0 === $start) { //下一卷
                if(isset($list[++$part])){
                    $data = array('part' => $part, 'start' => 0);
                    $this->success("正在还原...#{$part}", '', $data);
                } else {
                    session('backup_list', null);
                    $this->success('还原完成!');
                }
            } else {
                $data = array('part' => $part, 'start' => $start[0]);
                if($start[1]){
                    $rate = floor(100 * ($start[0] / $start[1]));
                    $this->success("正在还原...#{$part} ({$rate}%)", '', $data);
                } else {
                    $data['gz'] = 1;
                    $this->success("正在还原...#{$part}", '', $data);
                }
            }

        } else {
            $this->error('参数错误!');
        }
    }

}

    4.核心类,配置文件,控制器都准备好之后,最后就是视图层操作了。需要写两个模板文件,一个是数据备份视图用来进行备份操作,一个是数据还原视图用来显示备份的文件及下载。这里我也写好了,模板文件基于bootstrap,样式自己调整了。

数据备份视图(/Database/export.html):

<!--_meta 作为公共模版分离出去-->
<!DOCTYPE HTML>
<html>
<head>
<meta charset="utf-8">
<meta name="renderer" content="webkit|ie-comp|ie-stand">
<meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1">
<meta name="viewport" content="width=device-width,initial-scale=1,minimum-scale=1.0,maximum-scale=1.0,user-scalable=no" />
<meta http-equiv="Cache-Control" content="no-siteapp" />
<link rel="Bookmark" href="/favicon.ico" >
<link rel="Shortcut Icon" href="/favicon.ico" />
<!--[if lt IE 9]>
<script type="text/javascript" src="__STATIC__/tools/html5shiv.js"></script>
<script type="text/javascript" src="__STATIC__/tools/respond.min.js"></script>
<![endif]-->
<include file="Public/css"/>
<!--[if IE 6]>
<script type="text/javascript" src="__STATIC__/tools/DD_belatedPNG_0.0.8a-min.js" ></script>
<script>DD_belatedPNG.fix('*');</script>
<![endif]-->
<!--/meta 作为公共模版分离出去-->
</head>
<body id="body-right">
<nav class="breadcrumb">
    <i class="Hui-iconfont">&#xe67f;</i> 首页
    <span class="c-gray en">&gt;</span> 数据管理
    <span class="c-gray en">&gt;</span> 数据备份
    <a class="btn btn-success radius r" style="line-height:1.6em;margin-top:3px" href="javascript:location.replace(location.href);" title="刷新" ><i class="Hui-iconfont">&#xe68f;</i></a>
</nav>

<div class="page-container">

    <div class="cl pd-5 bg-1 bk-gray mt-20">
        <span class="l">
            <a id="export" class="btn btn-success radius" href="javascript:;" autocomplete="off">立即备份</a>
            <a id="optimize" class="btn btn-secondary radius" data-title="优化表" href="{:U('Database/optimize')}">优化表</a>
            <a id="repair" class="btn btn-secondary radius" data-title="修复表" href="{:U('Database/repair')}">修复表</a>
        </span>
    </div>


    <div class="mt-20">
        <form id="export-form" method="post" action="{:U('Database/export')}">
        <table class="table table-border table-bordered table-bg table-hover table-sort">
            <thead>
                <tr class="text-c">
                    <th width="48"><input class="check-all" checked="chedked" type="checkbox" value=""></th>
                    <th>表名</th>
                    <th>数据量</th>
                    <th>数据大小</th>
                    <th>创建时间</th>
                    <th>备份状态</th>
                    <th>操作</th>
                </tr>
            </thead>
            <tbody>
                <volist name="list" id="table">
                    <tr class="text-c">
                        <td class="num">
                            <input class="ids" checked="chedked" type="checkbox" name="tables[]" value="{$table.name}">
                        </td>
                        <td>{$table.name}</td>
                        <td>{$table.rows}</td>
                        <td>{$table.data_length|format_bytes}</td>
                        <td>{$table.create_time}</td>
                        <td class="info">未备份</td>
                        <td class="action">
                            <a class="ajax-get no-refresh" href="{:U('Database/optimize?tables='.$table['name'])}">优化表</a>&nbsp;
                            <a class="ajax-get no-refresh" href="{:U('Database/repair?tables='.$table['name'])}">修复表</a>
                        </td>
                    </tr>
                </volist>
            </tbody>
        </table>
        </form>

    </div>
</div>
    <!-- /应用列表 -->
<!--_footer 作为公共模版分离出去-->
<include file="Public/js"/>
<!--请在下方写此页面业务相关的脚本-->
  <script type="text/javascript">
    (function($){
        var $form = $("#export-form"), $export = $("#export"), tables
            $optimize = $("#optimize"), $repair = $("#repair");

        $optimize.add($repair).click(function(){
            $.post(this.href, $form.serialize(), function(data){
                if(data.status){
                    alert(data.info,'alert-success');
                } else {
                    alert(data.info,'alert-error');
                }
                setTimeout(function(){
                    $('#top-alert').find('button').click();
                    $(that).removeClass('disabled').prop('disabled',false);
                },1500);
            }, "json");
            return false;
        });

        $export.click(function(){
            $export.parent().children().addClass("disabled");
            $export.html("正在发送备份请求...");
            $.post(
                $form.attr("action"),
                $form.serialize(),
                function(data){
                    if(data.status){
                        tables = data.tables;
                        $export.html(data.info + "开始备份,请不要关闭本页面!");
                        backup(data.tab);
                        window.onbeforeunload = function(){ return "正在备份数据库,请不要关闭!" }
                    } else {
                        alert(data.info,'alert-error');
                        $export.parent().children().removeClass("disabled");
                        $export.html("立即备份");
                        setTimeout(function(){
                            $('#top-alert').find('button').click();
                            $(that).removeClass('disabled').prop('disabled',false);
                        },1500);
                    }
                },
                "json"
            );
            return false;
        });

        function backup(tab, status){
            status && showmsg(tab.id, "开始备份...(0%)");
            $.get($form.attr("action"), tab, function(data){
                if(data.status){
                    showmsg(tab.id, data.info);

                    if(!$.isPlainObject(data.tab)){
                        $export.parent().children().removeClass("disabled");
                        $export.html("备份完成,点击重新备份");
                        window.onbeforeunload = function(){ return null }
                        return;
                    }
                    backup(data.tab, tab.id != data.tab.id);
                } else {
                    alert(data.info,'alert-error');
                    $export.parent().children().removeClass("disabled");
                    $export.html("立即备份");
                    setTimeout(function(){
                        $('#top-alert').find('button').click();
                        $(that).removeClass('disabled').prop('disabled',false);
                    },1500);
                }
            }, "json");

        }

        function showmsg(id, msg){
            $form.find("input[value=" + tables[id] + "]").closest("tr").find(".info").html(msg);
        }
    })(jQuery);
    </script>
</body>
</html>

数据还原视图(/Database/import.html):

<!--_meta 作为公共模版分离出去-->
<!DOCTYPE HTML>
<html>
<head>
<meta charset="utf-8">
<meta name="renderer" content="webkit|ie-comp|ie-stand">
<meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1">
<meta name="viewport" content="width=device-width,initial-scale=1,minimum-scale=1.0,maximum-scale=1.0,user-scalable=no" />
<meta http-equiv="Cache-Control" content="no-siteapp" />
<link rel="Bookmark" href="/favicon.ico" >
<link rel="Shortcut Icon" href="/favicon.ico" />
<!--[if lt IE 9]>
<script type="text/javascript" src="__STATIC__/tools/html5shiv.js"></script>
<script type="text/javascript" src="__STATIC__/tools/respond.min.js"></script>
<![endif]-->
<include file="Public/css"/>
<!--[if IE 6]>
<script type="text/javascript" src="__STATIC__/tools/DD_belatedPNG_0.0.8a-min.js" ></script>
<script>DD_belatedPNG.fix('*');</script>
<![endif]-->
<!--/meta 作为公共模版分离出去-->
</head>
<body id="body-right">
    <!-- 标题栏 -->
    <nav class="breadcrumb">
        <i class="Hui-iconfont">&#xe67f;</i> 首页
        <span class="c-gray en">&gt;</span> 数据管理
        <span class="c-gray en">&gt;</span> 数据还原
        <a class="btn btn-success radius r" style="line-height:1.6em;margin-top:3px" href="javascript:location.replace(location.href);" title="刷新" ><i class="Hui-iconfont">&#xe68f;</i></a>
    </nav>
    <!-- /标题栏 -->

    <!-- 应用列表 -->
    <div class="page-container">
        <div class="mt-20">
            <table class="table table-border table-bordered table-bg table-hover table-sort">
                <thead>
                    <tr class="text-c">
                        <th width="200">备份名称</th>
                        <th width="80">卷数</th>
                        <th width="80">压缩</th>
                        <th width="80">数据大小</th>
                        <th width="200">备份时间</th>
                        <th>状态</th>
                        <th width="120">操作</th>
                    </tr>
                </thead>
                <tbody>
                    <volist name="list" id="data">
                        <tr class="text-c">
                            <td>{$data.time|date='Ymd-His',###}</td>
                            <td>{$data.part}</td>
                            <td>{$data.compress}</td>
                            <td>{$data.size|format_bytes}</td>
                            <td>{$key}</td>
                            <td>-</td>
                            <td class="action">
                                <a class="db-import" href="{:U('Database/import',array('time'=>$data['time']))}">还原</a>&nbsp;
                                <a class="db-download" href="{:U('Database/download')}?filename={$data['filename']}">下载</a>&nbsp;
                                <a class="ajax-get confirm" data-url="{:U('Database/del',array('time'=>$data['time']))}" onClick="del(this)" href="javascript:;">删除</a>
                            </td>
                        </tr>
                    </volist>
                </tbody>
            </table>
        </div>
    </div>
    <!-- /应用列表 -->
<!--_footer 作为公共模版分离出去-->
<include file="Public/js"/>
<!--请在下方写此页面业务相关的脚本-->
    <script type="text/javascript">
        $(".db-import").click(function(){
            var self = this, status = ".";
            $.get(self.href, success, "json");
            window.onbeforeunload = function(){ return "正在还原数据库,请不要关闭!" }
            return false;

            function success(data){
                console.log(data);
                if(data.status){
                    if(data.gz){
                        data.info += status;
                        if(status.length === 5){
                            status = ".";
                        } else {
                            status += ".";
                        }
                    }
                    $(self).parent().prev().text(data.info);
                    if(data.part){
                        $.get(self.href,
                            {"part" : data.part, "start" : data.start},
                            success,
                            "json"
                        );
                    }  else {
                        window.onbeforeunload = function(){ return null; }
                    }
                } else {
                    alert(data.info,'alert-error');
                }
            }
        });
    </script>
</body>
</html>

全部完成!加了之后能方便快捷的直接在后台进行数据库的备份、还原、备份文件下载操作了!

对了,我这个还有个问题,一直不知道该怎么解决。就是备份类似文章表这种存储了转义后的HTML代码时,备份写入的insert语句会换行,insert语句存在换行时,直接导入数据库会失败。有哪位大神看到了,能解决的欢迎留言交流。

本文为爵特猛原创文章,转载无需和我联系,但请注明来自爵特猛博客www.juetemeng.com