利用php怎么對mysql備份恢復進行分卷處理

本篇文章給大家分享的是有關利用php怎么對mysql備份恢復進行分卷處理，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

具體分析如下：

分卷處理就是把握們要處理的數據分成一個個小文件進行處理了,這里我來給大家介紹一個php mysql備份恢復分卷處理類,實現mysql數據庫分卷備份,選擇表進行備份,實現單個sql文件及分卷sql導入.

分卷導入類及思路詳解

數據庫導入導出是一個后臺必要擁有的功能,網上一搜,有很多關于數據庫導入導出的,但基本上一個大的系統,包含了許多我們并不需要的,而且他們都是自己的后臺的形式,我并不喜歡的是拿人家的東西整合到自己的后臺,我需要的是自己東西,于是參照了很多,自己寫了一個關于分卷導入類,以方便調用,歡迎大家拍磚.

這里針對分卷文件是以‘_v1.sql'為結尾,實現單個sql文件及分卷sql導入,分卷導入可選擇是否當前分卷導入余下分卷,我們只需要直接調用類即可完成.

分別是主機，用戶名，密碼，數據庫名，數據庫編碼

復制代碼 代碼如下:

$db = new DataManage ( 'localhost', 'root', 'root', 'test', 'utf8' );

sql文件,是否只導入單個sql(即如果有其他分卷也不導入).

復制代碼 代碼如下:

$db->restore ( './backup/20120516211738_all_v1.sql', false );

對應如何去列出備份的sql文件或選擇sql之類的,自己去實現,那個不在這個范疇了,也很簡單的.

還有目前只實現了數據庫導入,關于數據庫導出的,正在編寫功能,下面是完整的類代碼,具體思路及實現代碼里面都有說明,這里不在贅述,代碼如下:

復制代碼 代碼如下:

<?php
/**
 * @author yanue
 * 說明：分卷文件是以_v1.sql為結尾
 * 功能：實現單個sql文件及分卷sql導入,分卷導入可選擇是否當前分卷導入余下分卷
 * 使用方法：
 *
 *
 * ------------------------------------------------------------------
//分別是主機，用戶名，密碼，數據庫名，數據庫編碼
$db = new DataManage ( 'localhost', 'root', 'root', 'test', 'utf8' );
//sql文件，是否只導入單個sql（即如果有其他分卷也不導入）
$db->restore ( './backup/20120516211738_all_v1.sql', false );
 *----------------------------------------------------------------------
 */
class DataManage {
 var $db; // 數據庫連接
 var $database; // 所用數據庫
 var $sqldir; // 數據庫備份文件夾
 
 /**
  * 初始化
  *
  * @param string $host
  * @param string $username
  * @param string $password
  * @param string $database
  * @param string $charset
  */
 function __construct($host = 'localhost', $username = 'root', $password = '', $database = 'test', $charset = 'utf8') {
  $this->host = $host;
  $this->username = $username;
  $this->password = $password;
  $this->database = $database;
  $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 );
 }
 
 /**
  * 導入備份數據
  * 說明：分卷文件格式20120516211738_all_v1.sql
  *
  * @param string $sqlfile
  * @param bool $single
  */
 function restore($sqlfile, $single = FALSE) {
  // 檢測文件是否存在
  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 "請勿刷新及關閉瀏覽器以防止程序被中止，如有不慎！將導致數據庫結構受損<br />";
  echo "正在導入備份數據，請稍等！<br />";
  if (emptyempty ( $volume [1] ) || $single) {
   echo "正在導入sql：<span style='color:#f00;'>" . $sqlfile . '</span><br />';
   // 沒有分卷
   if ($this->_import ( $sqlfile )) {
    echo "數據庫導入成功！";
   } else {
    exit ( '數據庫導入失敗！' );
   }
  } else {
   // 存在分卷，則獲取當前是第幾分卷，循環執行余下分卷
   $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 "正在導入分卷$volume_id：<span style='color:#f00;'>" . $tmpfile . '</span><br />';
     if ($this->_import ( $tmpfile )) {
 
     } else {
      exit ( "導入分卷$volume_id：<span style='color:#f00;'>" . $tmpfile . '</span>失敗！可能是數據庫結構已損壞！請嘗試從分卷1開始導入' );
     }
    } else {
     echo "此分卷備份全部導入成功！<br />";
     return;
    }
    $volume_id ++;
   }
  }
 }
 
 /**
  * 將sql導入到數據庫（普通導入）
  *
  * @param string $sqlfile
  * @return boolean
  */
 private function _import($sqlfile) {
  $name = basename ( $sqlfile );
  $sqls = file ( $sqlfile );
  foreach ( $sqls as $sql ) {
   str_replace ( "r", "", $sql );
   str_replace ( "n", "", $sql );
   if (! mysql_query ( trim ( $sql ), $this->db ))
    return false;
  }
  return true;
 }
 
 // 關閉數據庫連接
 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 );
 }
}
?>

mysql備份恢復分卷處理,調用簡單.

分卷導入思路:

按行讀取sql文件,將每一行當作完整的sql語句存到數組再循環執行插入數據庫就可以了,但是在創建表語句分了多行,這個需要單獨處理,就這個花了我好長時間的.感覺文章好長啊,主要是那個類文件給占用了.

更新說明:

1.去除sql導入的時候排除sql文件里面的注釋'– ‘ 從而解決sql中單雙引號不能導入

2.單行讀取后的sql直接執行,避免重新將sql語句組合到數組中再從數組中讀取導入sql,提高效率.

下載地址: https://github.com/yanue/Dbmanage

導出后的sql文件格式如下:

復制代碼 代碼如下:

--
-- MySQL database dump
-- Created by DBManage class, Power By yanue. 
--
-- 主機: localhost
-- 生成日期: 2012 年  10 月 06 日 22:32
-- MySQL版本: 5.1.50-community
-- PHP 版本: 5.3.9-ZS5.6.0
 
--
-- 數據庫: `test`
--
 
-- -------------------------------------------------------
 
--
-- 表的結構aa
--
 
DROP TABLE IF EXISTS `aa`;
CREATE TABLE `aa` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `content` text NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
 
--
-- 轉存表中的數據 aa
--
 
INSERT INTO `aa` VALUES('1','<p id="test"><span class='hahh' >我是測試數據 呵呵</span></p>');

下面是類代碼:

復制代碼 代碼如下:

<?php
/**
 * @author yanue
 * @copyright  Copyright (c) 2012 yanue.net
 * @version 1.1
 * 創建時間： 2012年5月21日
 
更新時間： 2012年10月6日
更新說明： 1.去除sql導入的時候排除sql文件里面的注釋'-- ' 從而解決sql中單雙引號不能導入
2.單行讀取后的sql直接執行，避免重新將sql語句組合到數組中再從數組中讀取導入sql，提高效率
 
 * 說明：分卷文件是以_v1.sql為結尾(20120522021241_all_v1.sql)
 * 功能：實現mysql數據庫分卷備份,選擇表進行備份,實現單個sql文件及分卷sql導入
 * 使用方法：
 *
 * ------1. 數據庫備份（導出）------------------------------------------------------------
//分別是主機，用戶名，密碼，數據庫名，數據庫編碼
$db = new DBManage ( 'localhost', 'root', 'root', 'test', 'utf8' );
// 參數：備份哪個表(可選),備份目錄(可選，默認為backup),分卷大小(可選,默認2000，即2M)
$db->backup ();
 * ------2. 數據庫恢復（導入）------------------------------------------------------------
//分別是主機，用戶名，密碼，數據庫名，數據庫編碼
$db = new DBManage ( 'localhost', 'root', 'root', 'test', 'utf8' );
//參數：sql文件
$db->restore ( './backup/20120516211738_all_v1.sql');
 *----------------------------------------------------------------------
 */
class DbManage {
    var $db; // 數據庫連接
    var $database; // 所用數據庫
    var $sqldir; // 數據庫備份文件夾
    // 換行符
    private $ds = "n";
    // 存儲SQL的變量
    public $sqlContent = "";
    // 每條sql語句的結尾符
    public $sqlEnd = ";";
 
    /**
     * 初始化
     *
     * @param string $host
     * @param string $username
     * @param string $password
     * @param string $database
     * @param string $charset
     */
    function __construct($host = 'localhost', $username = 'root', $password = '', $database = 'test', $charset = 'utf8') {
        $this->host = $host;
        $this->username = $username;
        $this->password = $password;
        $this->database = $database;
        $this->charset = $charset;
        set_time_limit(0);//無時間限制
@ob_end_flush();
        // 連接數據庫
        $this->db = @mysql_connect ( $this->host, $this->username, $this->password ) or die( '<p class="dbDebug"><span class="err">Mysql Connect Error : </span>'.mysql_error().'</p>');
        // 選擇使用哪個數據庫
        mysql_select_db ( $this->database, $this->db ) or die('<p class="dbDebug"><span class="err">Mysql Connect Error:</span>'.mysql_error().'</p>');
        // 數據庫編碼方式
        mysql_query ( 'SET NAMES ' . $this->charset, $this->db );
 
    }
 
    /*
     * 新增查詢數據庫表
     */
    function getTables() {
        $res = mysql_query ( "SHOW TABLES" );
        $tables = array ();
        while ( $row = mysql_fetch_array ( $res ) ) {
            $tables [] = $row [0];
        }
        return $tables;
    }
 
    /*
     *
     * ------------------------------------------數據庫備份start----------------------------------------------------------
     */
 
    /**
     * 數據庫備份
     * 參數：備份哪個表(可選),備份目錄(可選，默認為backup),分卷大小(可選,默認2000，即2M)
     *
     * @param $string $dir
     * @param int $size
     * @param $string $tablename
     */
    function backup($tablename = '', $dir, $size) {
        $dir = $dir ? $dir : './backup/';
        // 創建目錄
        if (! is_dir ( $dir )) {
            mkdir ( $dir, 0777, true ) or die ( '創建文件夾失敗' );
        }
        $size = $size ? $size : 2048;
        $sql = '';
        // 只備份某個表
        if (! emptyempty ( $tablename )) {
            if(@mysql_num_rows(mysql_query("SHOW TABLES LIKE '".$tablename."'")) == 1) {
             } else {
                $this->_showMsg('表-<b>' . $tablename .'</b>-不存在，請檢查！',true);
                die();
            }
            $this->_showMsg('正在備份表 <span class="imp">' . $tablename.'</span>');
            // 插入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 * 1024) {
                    $file = $filename . "_v" . $p . ".sql";
                    if ($this->_write_file ( $sql, $file, $dir )) {
                        $this->_showMsg("表-<b>" . $tablename . "</b>-卷-<b>" . $p . "</b>-數據備份完成,備份文件 [ <span class='imp'>" .$dir . $file ."</span> ]");
                    } else {
                        $this->_showMsg("備份表 -<b>" . $tablename . "</b>- 失敗",true);
                        return false;
                    }
                    // 下一個分卷
                    $p ++;
                    // 重置$sql變量為空，重新計算該變量大小
                    $sql = "";
                }
            }
            // 及時清除數據
            unset($data,$record);
            // sql大小不夠分卷大小
            if ($sql != "") {
                $filename .= "_v" . $p . ".sql";
                if ($this->_write_file ( $sql, $filename, $dir )) {
                    $this->_showMsg( "表-<b>" . $tablename . "</b>-卷-<b>" . $p . "</b>-數據備份完成,備份文件 [ <span class='imp'>" .$dir . $filename ."</span> ]");
                } else {
                    $this->_showMsg("備份卷-<b>" . $p . "</b>-失敗<br />");
                    return false;
                }
            }
            $this->_showMsg("恭喜您! <span class='imp'>備份成功</span>");
        } else {
            $this->_showMsg('正在備份');
            // 備份全部表
            if ($tables = mysql_query ( "show table status from " . $this->database )) {
                $this->_showMsg("讀取數據庫結構成功！");
            } else {
                $this->_showMsg("讀取數據庫結構失敗！");
                exit ( 0 );
            }
            // 插入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, $num_fields, $record );
                    // 如果大于分卷大小，則寫入文件
                    if (strlen ( $sql ) >= $size * 1000) {
 
                        $file = $filename . "_v" . $p . ".sql";
                        // 寫入文件
                        if ($this->_write_file ( $sql, $file, $dir )) {
                            $this->_showMsg("-卷-<b>" . $p . "</b>-數據備份完成,備份文件 [ <span class='imp'>".$dir.$file."</span> ]");
                        } else {
                            $this->_showMsg("卷-<b>" . $p . "</b>-備份失敗!",true);
                            return false;
                        }
                        // 下一個分卷
                        $p ++;
                        // 重置$sql變量為空，重新計算該變量大小
                        $sql = "";
                    }
                }
            }
            // sql大小不夠分卷大小
            if ($sql != "") {
                $filename .= "_v" . $p . ".sql";
                if ($this->_write_file ( $sql, $filename, $dir )) {
                    $this->_showMsg("-卷-<b>" . $p . "</b>-數據備份完成,備份文件 [ <span class='imp'>".$dir.$filename."</span> ]");
                } else {
                    $this->_showMsg("卷-<b>" . $p . "</b>-備份失敗",true);
                    return false;
                }
            }
            $this->_showMsg("恭喜您! <span class='imp'>備份成功</span>");
        }
    }
 
    //  及時輸出信息
    private function _showMsg($msg,$err=false){
        $err = $err ? "<span class='err'>ERROR:</span>" : '' ;
        echo "<p class='dbDebug'>".$err . $msg."</p>";
        flush();
 
    }
 
    /**
     * 插入數據庫備份基礎信息
     *
     * @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, $num_fields, $record) {
        // sql字段逗號分割
        $insert = '';
        $comma = "";
        $insert .= "INSERT INTO `" . $table . "` VALUES(";
        // 循環每個子段下面的內容
        for($i = 0; $i < $num_fields; $i ++) {
            $insert .= ($comma . "'" . mysql_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, $filename, $dir) {
        $dir = $dir ? $dir : './backup/';
        // 創建目錄
        if (! is_dir ( $dir )) {
            mkdir ( $dir, 0777, true );
        }
        $re = true;
        if (! @$fp = fopen ( $dir . $filename, "w+" )) {
            $re = false;
            $this->_showMsg("打開sql文件失敗！",true);
        }
        if (! @fwrite ( $fp, $sql )) {
            $re = false;
            $this->_showMsg("寫入sql文件失敗，請文件是否可寫",true);
        }
        if (! @fclose ( $fp )) {
            $re = false;
            $this->_showMsg("關閉sql文件失敗！",true);
        }
        return $re;
    }
 
    /*
     *
     * -------------------------------上：數據庫導出-----------分割線----------下：數據庫導入--------------------------------
     */
 
    /**
     * 導入備份數據
     * 說明：分卷文件格式20120516211738_all_v1.sql
     * 參數：文件路徑(必填)
     *
     * @param string $sqlfile
     */
    function restore($sqlfile) {
        // 檢測文件是否存在
        if (! file_exists ( $sqlfile )) {
            $this->_showMsg("sql文件不存在！請檢查",true);
            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];
        $this->_showMsg("請勿刷新及關閉瀏覽器以防止程序被中止，如有不慎！將導致數據庫結構受損");
        $this->_showMsg("正在導入備份數據，請稍等！");
        if (emptyempty ( $volume [1] )) {
            $this->_showMsg ( "正在導入sql：<span class='imp'>" . $sqlfile . '</span>');
            // 沒有分卷
            if ($this->_import ( $sqlfile )) {
                $this->_showMsg( "數據庫導入成功！");
            } else {
                 $this->_showMsg('數據庫導入失敗！',true);
                exit ();
            }
        } else {
            // 存在分卷，則獲取當前是第幾分卷，循環執行余下分卷
            $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 )) {
                    // 執行導入方法
                    $this->msg .= "正在導入分卷 $volume_id ：<span style='color:#f00;'>" . $tmpfile . '</span><br />';
                    if ($this->_import ( $tmpfile )) {
 
                    } else {
                        $volume_id = $volume_id ? $volume_id :1;
                        exit ( "導入分卷：<span style='color:#f00;'>" . $tmpfile . '</span>失敗！可能是數據庫結構已損壞！請嘗試從分卷1開始導入' );
                    }
                } else {
                    $this->msg .= "此分卷備份全部導入成功！<br />";
                    return;
                }
                $volume_id ++;
            }
        }if (emptyempty ( $volume [1] )) {
            $this->_showMsg ( "正在導入sql：<span class='imp'>" . $sqlfile . '</span>');
            // 沒有分卷
            if ($this->_import ( $sqlfile )) {
                $this->_showMsg( "數據庫導入成功！");
            } else {
                 $this->_showMsg('數據庫導入失敗！',true);
                exit ();
            }
        } else {
            // 存在分卷，則獲取當前是第幾分卷，循環執行余下分卷
            $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 )) {
                    // 執行導入方法
                    $this->msg .= "正在導入分卷 $volume_id ：<span style='color:#f00;'>" . $tmpfile . '</span><br />';
                    if ($this->_import ( $tmpfile )) {
 
                    } else {
                        $volume_id = $volume_id ? $volume_id :1;
                        exit ( "導入分卷：<span style='color:#f00;'>" . $tmpfile . '</span>失敗！可能是數據庫結構已損壞！請嘗試從分卷1開始導入' );
                    }
                } else {
                    $this->msg .= "此分卷備份全部導入成功！<br />";
                    return;
                }
                $volume_id ++;
            }
        }
    }
 
    /**
     * 將sql導入到數據庫（普通導入）
     *
     * @param string $sqlfile
     * @return boolean
     */
    private function _import($sqlfile) {
        // sql文件包含的sql語句數組
        $sqls = array ();
        $f = fopen ( $sqlfile, "rb" );
        // 創建表緩沖變量
        $create_table = '';
        while ( ! feof ( $f ) ) {
            // 讀取每一行sql
            $line = fgets ( $f );
            // 這一步為了將創建表合成完整的sql語句
            // 如果結尾沒有包含';'(即為一個完整的sql語句，這里是插入語句)，并且不包含'ENGINE='(即創建表的最后一句)
            if (! preg_match ( '/;/', $line ) || preg_match ( '/ENGINE=/', $line )) {
                // 將本次sql語句與創建表sql連接存起來
                $create_table .= $line;
                // 如果包含了創建表的最后一句
                if (preg_match ( '/ENGINE=/', $create_table)) {
                    //執行sql語句創建表
                    $this->_insert_into($create_table);
                    // 清空當前，準備下一個表的創建
                    $create_table = '';
                }
                // 跳過本次
                continue;
            }
            //執行sql語句
            $this->_insert_into($line);
        }
        fclose ( $f );
        return true;
    }
 
    //插入單條sql語句
    private function _insert_into($sql){
        if (! mysql_query ( trim ( $sql ) )) {
            $this->msg .= mysql_error ();
            return false;
        }
    }
 
    /*
     * -------------------------------數據庫導入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() {
        if($this->db){
            mysql_query ( "unlock tables", $this->db );
            mysql_close ( $this->db );
        }
    }
}
?>

以上就是利用php怎么對mysql備份恢復進行分卷處理，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。