利用PHP實現(xiàn)一個MySQL備份和恢復程序
更新時間：2023年09月13日 09:23:28 作者：掘金歸海一刀
由于客戶用的阿里云將要到期,需要把項目和阿里云上的數(shù)據(jù)庫都轉(zhuǎn)到政府云,數(shù)據(jù)肯定要轉(zhuǎn)過去,但是阿里云導出數(shù)據(jù)有數(shù)量限制,導出不全,所以就要程序執(zhí)行下,生成sql文件,然后導入政府云數(shù)據(jù)庫,下面分享下具體實現(xiàn)過程
背景
由于客戶用的阿里云將要到期，現(xiàn)在要把項目交給政府，需要把項目和阿里云上的數(shù)據(jù)庫都轉(zhuǎn)到政府云，數(shù)據(jù)肯定要轉(zhuǎn)過去，但是阿里云導出數(shù)據(jù)有數(shù)量限制，導出不全，所以就要程序執(zhí)行下，生成sql文件，然后導入政府云數(shù)據(jù)庫。這樣我們就需要一個腳本執(zhí)行下，下面分享下具體實現(xiàn)過程。
操作類的封裝
為了程序的代碼重用，我們首先封裝個類來實現(xiàn)備份與備份恢復功能，為了節(jié)約時間，直接上代碼，不懂的可以看下注釋
<?php
class DbOperate
{
var $conn; // 數(shù)據(jù)庫連接
var $database; // 所用數(shù)據(jù)庫
var $sqldir; // 數(shù)據(jù)庫備份文件夾
var $record;
// sql語句變量
public $sqlContent = "";
/**
* 實例化
* @param string $host $username $password $database $charset
*/
function __construct($host = 'localhost', $username = 'root', $password = '123456', $database = 'test', $charset = 'utf8')
{
$this->host = $host;
$this->username = $username;
$this->password = $password;
$this->database = $database;
$this->charset = $charset;
// 數(shù)據(jù)庫連接
$this->conn = mysqli_connect ( $this->host, $this->username, $this->password ) or die ( "數(shù)據(jù)庫連接失敗!" );
// 數(shù)據(jù)庫選擇
mysql_select_db ( $this->database, $this->conn ) or die ( "無法打開數(shù)據(jù)庫" );
// 設(shè)置數(shù)據(jù)庫編碼
mysql_query ( 'SET NAMES ' . $this->charset, $this->conn );
}
/**
* 數(shù)據(jù)庫導出sql文件
* @param 備份表名稱(為空導出全部表),備份目錄(默認目錄‘，./sql/'),文件大小(可選,默認5000，即5M左右)
*/
function export($tablename = '', $dir, $size)
{
$dir = $dir ? $dir : './sql/';
$size = $size ? $size : 5000;
$sql = '';
// 導出單張表
if (! empty ( $tablename ))
{
echo '正在導出表' . $tablename . PHP_EOL;
// 插入數(shù)據(jù)庫信息
$sql = $this->get_mysql_info();
// 插入表結(jié)構(gòu)信息-獲取表的基本信息
$sql .= $this->get_table_structure ( $tablename );
// 插入數(shù)據(jù)-執(zhí)行查詢語句
$data = mysql_query ( "SELECT * FROM " . $tablename );
// 文件名前面部分
$filename = date ( 'YmdHis' ) . "_" . $tablename;
// 字段數(shù)量
$num_fields = mysql_num_fields ( $data );
// 第一個sql文件
$no = 1;
// 循環(huán)每條記錄
while ( $record = mysql_fetch_array ( $data ) )
{
// 單條記錄
$sql .= $this->insert_record ( $tablename, $num_fields, $record );
// 如果大于分卷大小，則寫入文件
if (strlen ( $sql ) >= $size * 1000)
{
$file = $filename . "_num" . $no . ".sql";
if ($this->write_file ( $sql, $file, $dir ))
{
echo "表-" . $tablename . "-編號-" . $no . "-數(shù)據(jù)導出完成,生成SQL文件 $dir$filename".PHP_EOL;
}
else
{
echo "導出表-" . $tablename . "-失敗".PHP_EOL;
}
// 下一個SQL文件
$no ++;
// 重置$sql變量為空，重新計算該變量大小
$sql = "";
}
}
// sql大小不夠
if ($sql != "")
{
$filename .= "_num" . $no . ".sql";
if ($this->write_file ( $sql, $filename, $dir ))
{
echo "表-" . $tablename . "-編號-" . $no . "-數(shù)據(jù)導出完成,生成sql文件 $dir$filename".PHP_EOL;
}
else
{
echo "表-" . $tablename . "-編號-" . $no . "-數(shù)據(jù)寫入失敗".PHP_EOL;
}
}
}
else
{ // 備份全部表
if ($tables = mysql_query ( "show table status from " . $this->database ))
{
echo "讀取數(shù)據(jù)庫結(jié)構(gòu)成功".PHP_EOL;
}
else
{
exit ( "讀取數(shù)據(jù)庫結(jié)構(gòu)成功" ).PHP_EOL;
}
// 插入dump信息
$sql .= $this->get_mysql_info();
// 文件名前面部分
$filename = date ( 'YmdHis' ) . "_all";
// 查出所有表
$tables = mysql_query ( 'SHOW TABLES' );
// SQL文件編號
$no = 1;
// 循環(huán)所有表
while ( $table = mysql_fetch_array ( $tables ) )
{
echo '開始導出表：'.$table [0].PHP_EOL;
// 獲取表名
$tablename = $table [0];
// 獲取表結(jié)構(gòu)
$sql .= $this->get_table_structure ( $tablename );
$data = mysql_query ( "SELECT * FROM " . $tablename );
$num_fields = mysql_num_fields ( $data );
// 循環(huán)每條記錄
while ( $record = mysql_fetch_array ( $data ) )
{
// 單條記錄
$sql .= $this->insert_record ( $tablename, $num_fields, $record );
// 如果達到定義的文件大小，就寫入文件
if (strlen ( $sql ) >= $size * 1000)
{
$file = $filename . "_num" . $no . ".sql";
// 寫入文件
if ($this->write_file ( $sql, $file, $dir ))
{
echo "表-" . $tablename . "-編號-" . $no . "-數(shù)據(jù)寫入成功-$dir$file".PHP_EOL;
}
else
{
echo "表-" . $tablename . "-編號-" . $no . "-數(shù)據(jù)寫入失敗".PHP_EOL;
}
// 下一個sql文件
$no ++;
// 重置$sql變量為空，重新計算寫入sql大小
$sql = "";
}
}
}
// sql大小不夠分卷大小
if ($sql != "")
{
$filename .= "_num" . $p . ".sql";
if ($this->write_file ( $sql, $filename, $dir ))
{
echo "-編號-" . $no . "-數(shù)據(jù)導出完成,生成SQL文件 $dir$filename".PHP_EOL;
}
else
{
echo "-編號-" . $no . "-寫入失敗".PHP_EOL;
}
}
}
}
/**
* 獲取mysql基礎(chǔ)信息
*
* @return string
*/
private function get_mysql_info() {
$value = '';
$value .= '--' . "\n";
$value .= '-- 主機: ' . $this->host . "\n";
$value .= '-- 生成日期: ' . date ( 'Y' ) . ' 年 ' . date ( 'm' ) . ' 月 ' . date ( 'd' ) . ' 日 ' . date ( 'H:i' ) . "\n";
$value .= '-- MySQL版本: ' . mysql_get_server_info () . "\n";
$value .= "\n";
$value .= '--' . "\n";
$value .= '-- 數(shù)據(jù)庫: `' . $this->database . '`' . "\n";
$value .= '--' . "\n" . "\n";
$value .= '-- -------------------------------------------------------';
$value .= "\n" . "\n";
return $value;
}
/**
* 獲取表結(jié)構(gòu)
* @param $table
* @return string
*/
private function get_table_structure($table) {
$sql = '';
$sql .= "--" . "\n";
$sql .= "-- 表的結(jié)構(gòu)" . $table . "\n";
$sql .= "--" . "\n" . "\n";
// 如果存在則刪除表
$sql .= "DROP TABLE IF EXISTS `" . $table . '`' . ";" . "\n";
// 獲取詳細表信息
$res = mysql_query ( 'SHOW CREATE TABLE `' . $table . '`' );
$row = mysql_fetch_array ( $res );
$sql .= $row [1];
$sql .= ";" . "\n";
// 加上
$sql .= "\n";
$sql .= "--" . "\n";
$sql .= "-- 轉(zhuǎn)存表中的數(shù)據(jù) " . $table . "\n";
$sql .= "--" . "\n";
$sql .= "\n";
return $sql;
}
/**
* 插入單條記錄
*
* @param string $table
* @param int $num_fields
* @param array $record
* @return string
*/
private function insert_record($table, $num_fields, $record) {
// sql字段逗號分割
$comma = "";
$insert .= "INSERT INTO `" . $table . "` VALUES(";
// 循環(huán)每個子段下面的內(nèi)容
for($i = 0; $i < $num_fields; $i ++) {
$insert .= ($comma . "'" . mysql_escape_string ( $record [$i] ) . "'");
$comma = ",";
}
$insert .= ");" . "\n";
return $insert;
}
/**
* 寫入文件
*
* @param string $sql
* @param string $filename
* @param string $dir
* @return boolean
*/
private function write_file($sql, $filename, $dir) {
$dir = $dir ? $dir : './sql/';
// 不存在文件夾則創(chuàng)建
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 "關(guān)閉文件失??！";
}
return $re;
}
/**
* 導入sql文件數(shù)據(jù)
* 說明：sql文件格式20120516211738_all_no1.sql
* 參數(shù)：sql文件路徑(必填)
*
* @param string $sqlfile
*/
function import($sqlfile)
{
// 檢測文件是否存在
if (! file_exists ( $sqlfile ))
{
exit ( "文件不存在！請檢查" );
}
$this->lock ( $this->database );
// 獲取數(shù)據(jù)庫存儲位置
$sqlpath = pathinfo ( $sqlfile );
$this->sqldir = $sqlpath ['dirname'];
$volume = explode ( "_no", $sqlfile );
$volume_path = $volume [0];
echo "正在導入sql數(shù)據(jù)，請稍等！".PHP_EOL;
if (empty ( $volume [1] ))
{
echo "正在導入sql：" . $sqlfile . PHP_EOL;
if ($this->_import ( $sqlfile )) {
echo "數(shù)據(jù)導入成功！";
}
else
{
exit ( '數(shù)據(jù)導入失?。? );
}
}
else
{
$volume_id = explode ( ".sq", $volume [1] );
$volume_id = intval ( $volume_id [0] );
while ( $volume_id )
{
$tmpfile = $volume_path . "_no" . $volume_id . ".sql";
// 存在其他分卷，繼續(xù)執(zhí)行
if (file_exists ( $tmpfile )) {
// 執(zhí)行導入方法
echo "正在導入分卷$volume_id：" . $tmpfile . PHP_EOL;
if ($this->_import ( $tmpfile ))
{
}
else
{
exit ( "導入$volume_id：" . $tmpfile . '失??！可能是數(shù)據(jù)庫結(jié)構(gòu)已損壞！請嘗試從編號1開始導入' );
}
}
else
{
echo "此文件數(shù)據(jù)全部導入成功！".PHP_EOL;
return;
}
$volume_id++;
}
}
}
/**
* 將sql導入到數(shù)據(jù)庫（普通導入）
*
* @param string $sqlfile
* @return boolean
*/
private function _import($sqlfile) {
// sql文件包含的sql語句數(shù)組
$sqls = array ();
$f = fopen ( $sqlfile, "rb" );
// 創(chuàng)建表緩沖變量
$create = '';
while ( ! feof ( $f ) ) {
// 讀取每一行sql
$line = fgets ( $f );
// 如果包含'-- '等注釋，或為空白行，則跳過
if (trim ( $line ) == '' || preg_match ( '/--*?/', $line, $match )) {
continue;
}
// 如果結(jié)尾包含';'(即為一個完整的sql語句，這里是插入語句)，并且不包含'ENGINE='(即創(chuàng)建表的最后一句)，
if (! preg_match ( '/;/', $line, $match ) || preg_match ( '/ENGINE=/', $line, $match )) {
// 將本次sql語句與創(chuàng)建表sql連接存起來
$create .= $line;
// 如果包含了創(chuàng)建表的最后一句
if (preg_match ( '/ENGINE=/', $create, $match )) {
// 則將其合并到sql數(shù)組
$sqls [] = $create;
// 清空當前，準備下一個表的創(chuàng)建
$create = '';
}
// 跳過本次
continue;
}
$sqls [] = $line;
}
fclose ( $f );
// 循環(huán)sql語句數(shù)組，分別執(zhí)行
foreach ( $sqls as $sql ) {
str_replace ( "\n", "", $sql );
if (! mysql_query ( trim ( $sql ) )) {
echo mysql_error ();
return false;
}
}
return true;
}
// 關(guān)閉數(shù)據(jù)庫連接
private function close() {
mysql_close ( $this->conn );
}
// 鎖定數(shù)據(jù)庫，以免備份或?qū)霑r出錯
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;
}
// 析構(gòu)
function __destruct() {
mysql_query ( "unlock tables", $this->conn );
mysql_close ( $this->conn );
}
}
?>調(diào)用操作類，實現(xiàn)導出sql、導入數(shù)據(jù)
<?php
include 'DbOperate.php';
/**
* 數(shù)據(jù)庫導出完整數(shù)據(jù)
* @param 主機名、數(shù)據(jù)庫賬號、數(shù)據(jù)庫密碼、數(shù)據(jù)庫名、編碼格式
*/
$db = new DbOperate ( '主機名','數(shù)據(jù)庫賬號','數(shù)據(jù)庫密碼','數(shù)據(jù)庫名','編碼格式' );
// 參數(shù)：備份哪個表(可選),備份目錄(可選，默認為backup),分卷大小(可選,默認2000，即2M)
$db->export('',"/data/wwwtest/mysql_backup/sql/");
/**
* 數(shù)據(jù)庫導入
* @param sql文件路徑
*/
//$db->import ( 'sql文件路徑');
$db->close();//關(guān)閉數(shù)據(jù)庫連接執(zhí)行以上代碼，就可以實現(xiàn)數(shù)據(jù)庫全部數(shù)據(jù)導出了，如果想要導出某張表，第一個參數(shù)寫上表名稱即可。那么將導出的數(shù)據(jù)導入新的數(shù)據(jù)庫又該怎么辦呢？直接將上面的程序改下數(shù)據(jù)庫連接配置，將調(diào)用導出export的方法注釋掉，打開下面的import方法，運行程序，就可以實現(xiàn)數(shù)據(jù)的導入了。
總結(jié)
MySQL數(shù)據(jù)庫導出，雖然也可以用數(shù)據(jù)庫工具實現(xiàn)，例如navicat等，但是對于阿里云的數(shù)據(jù)庫，連接需要設(shè)置白名單，而自己公司的公網(wǎng)ip又經(jīng)常變，操作起來就會很麻煩，所以寫個腳本還是有必要的。由于工作中有用到，記錄下實現(xiàn)過程，把工作中的經(jīng)驗記錄下來，加深下印象。同時也希望能夠幫到有需要的同學。
到此這篇關(guān)于利用PHP實現(xiàn)一個MySQL備份和恢復程序的文章就介紹到這了,更多相關(guān)PHP實現(xiàn)MySQL備份和恢復內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了PHP實現(xiàn)貨幣換算的方法,以實例形式較為詳細的講述了貨幣轉(zhuǎn)換的實現(xiàn)方法,并舉英鎊轉(zhuǎn)換美元為例講述具體用法,需要的朋友可以參考下2014-11-11
用PHP上傳文件時，我們會用程序去監(jiān)聽瀏覽器發(fā)送過來的文件信息，首先會通 過$_FILES[fieldName]['error']的不同數(shù)值來判斷此欲上傳的文件狀態(tài)是否正常。$_FILES[fieldName] ['error']==0代表一切正常，其它數(shù)值的具體含義請參考下面一段程序的注釋部分，如有翻譯不到之處還望指正2014-01-01
這篇文章主要介紹了PHP+JS實現(xiàn)的商品秒殺倒計時用法,結(jié)合實例形式分析了php+js針對日期與時間操作的相關(guān)技巧,需要的朋友可以參考下2016-11-11
PHP使用CURL實現(xiàn)多線程抓取網(wǎng)頁
PHP 利用 Curl 可以完成各種傳送文件操作，比如模擬瀏覽器發(fā)送GET，POST請求等等，然而因為php語言本身不支持多線程，所以開發(fā)爬蟲程序效率并不高，不過可以用 Curl ，借助Curl 這個功能實現(xiàn)并發(fā)多線程的訪問多個url地址以實現(xiàn)并發(fā)多線程抓取網(wǎng)頁或者下載文件2015-04-04
前兩天，一朋友讓我?guī)退麑懸粋€收集表單內(nèi)容并寫入文件的簡單PHP代碼，由于最近工作忙，也沒有時間來寫，今天終于抽出點時間來完成了這個任務(wù)，下面就把相關(guān)的代碼開源出來，供大家參考2012-01-01
這篇文章主要介紹了使用PHP生成PDF方法詳解的相關(guān)資料,需要的朋友可以參考下2015-01-01
這篇文章主要介紹了PHP實現(xiàn)的進度條效果,結(jié)合實例形式分析了PHP結(jié)合JavaScript動態(tài)顯示百分比進度條功能,涉及PHP緩存、數(shù)學運算及JavaScript頁面元素動態(tài)操作相關(guān)技巧,需要的朋友可以參考下2016-05-05
PHP中的目錄遍歷細說教程在編寫PHP應(yīng)用的過程當中，對指定目錄的遍歷、文件的篩選是在所難免也是至關(guān)重要的，PHP本身提供了解析和讀取目錄的強大方法2023-03-03
php從memcache讀取數(shù)據(jù)再批量寫入mysql的方法
這篇文章主要介紹了php從memcache讀取數(shù)據(jù)再批量寫入mysql的方法,可利用memcache緩解服務(wù)器讀寫壓力,并實現(xiàn)數(shù)據(jù)庫數(shù)據(jù)的寫入操作,非常具有實用價值,需要的朋友可以參考下2014-12-12
PHP基于timestamp和nonce實現(xiàn)的防止重放攻擊方案分析
這篇文章主要介紹了PHP基于timestamp和nonce實現(xiàn)的防止重放攻擊方案,簡單講述了重放攻擊相關(guān)原理并結(jié)合實例形式分析了php使用timestamp和nonce實現(xiàn)的防止重放攻擊相關(guān)操作技巧,需要的朋友可以參考下2019-07-07