分卷處理就是把握們要處理的數據分成一個個小文件進行處理了，下面我來給大家介紹一個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
* @copyright Copyright (c) 2012 www.yanue.net
* 說明：分卷文件是以_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 (empty ( $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語句存到數組再循環執行插入數據庫就可以了，但是在創建表語句分了多行，這個需要單獨處理（就這個花了我好長時間的）；
（哇，感覺文章好長啊！主要是那個類文件給占用了）。
更新時間： 2012年10月6日
更新說明： 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' style="line-height:;">我是測試數據 呵呵</span></p>');下面是類代碼：
<?php
/**
* @author yanue
* @copyright Copyright (c) 2012 yanue.net
* @link http://yanue.net/archives/174.html
* @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 (! empty ( $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 (empty ( $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 (empty ( $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 );
}
}
}
