php实现mysql数据库备份类-侯体宗的博客

php实现mysql数据库备份类
php / 管理员发布于 7年前 208

1、实例化DbBak需要告诉它两件事：数据服务器在哪里($connectid)、备份到哪个目录($backupDir)：

require_once('DbBak.php');
require_once('TableBak.php');
$connectid = mysql_connect('localhost','root','123456');
$backupDir = 'data';
$DbBak = new DbBak($connectid,$backupDir);

2、然后就可以开始备份数据库了，你不仅能够指定备份那个数据库，而且能详细设置只备份那几个表：
2.1如果你想备份mybbs库中的所有表，只要这样：

$DbBak->backupDb('mybbs');

2.2如果你只想备份mybbs库中的board、face、friendlist表，可以用一个一维数组指定：

$DbBak->backupDb('mybbs',array('board','face','friendsite'));

2.3如果只想备份一个表，比如board表：
$DbBak->backupDb('mybbs','board');
3，数据恢复：
对于2.1、2.1、2.3三种情况，只要相应的修改下语句，把backupDb换成restoreDb就能实现数据恢复了：

$DbBak->restoreDb('mybbs');
SQL代码
$DbBak->restoreDb('mybbs',array('board','face','friendsite'));
PHP代码
$DbBak->restoreDb('mybbs','board');
PHP代码
require_once('TableBak.php');
class DbBak {
var $_mysql_link_id;
var $_dataDir;
var $_tableList;
var $_TableBak;

function DbBak($_mysql_link_id,$dataDir)
{
( (!is_string($dataDir)) || strlen($dataDir)==0) && die('error:$datadir is not a string');
!is_dir($dataDir) && mkdir($dataDir);
$this->_dataDir = $dataDir;
$this->_mysql_link_id = $_mysql_link_id;
}

function _getTableList($dbName)
{
$tableList = array();
$result=mysql_list_tables($dbName,$this->_mysql_link_id);
for ($i = 0; $i < mysql_num_rows($result); $i++){
        array_push($tableList,mysql_tablename($result, $i));
}
mysql_free_result($result);
return $tableList;
}

function _backupAllTable($dbName)
{
foreach ($this->_getTableList($dbName) as $tableName){
$this->_TableBak->backupTable($tableName);
}
}

function _backupOneTable($dbName,$tableName)
{
!in_array($tableName,$this->_getTableList($dbName)) && die("指定的表名$tableName在数据库中不存在");
$this->_TableBak->backupTable($tableName);
}

function _backupSomeTalbe($dbName,$TableNameList)
{
foreach ($TableNameList as $tableName){
!in_array($tableName,$this->_getTableList($dbName)) && die("指定的表名$tableName在数据库中不存在");
}
foreach ($TableNameList as $tableName){
$this->_TableBak->backupTable($tableName);
}
}

复制代码代码如下:

//只有DbBak才能调用这个类
class TableBak{
var $_mysql_link_id;
var $_dbDir;
//private $_DbManager;
function TableBak($mysql_link_id,$dbDir)
{
$this->_mysql_link_id = $mysql_link_id;
$this->_dbDir = $dbDir;
}

function backupTable($tableName)
{
//step1:创建表的备份目录名：
$tableDir = $this->_dbDir.DIRECTORY_SEPARATOR.$tableName;
!is_dir($tableDir) && mkdir($tableDir);
//step2:开始备份：
$this->_backupTable($tableName,$tableDir);
}

function restoreTable($tableName,$tableBakFile)
{
set_time_limit(0);
$fileArray = @file($tableBakFile) or die("can open file $tableBakFile");
$num = count($fileArray);
mysql_unbuffered_query("DELETE FROM $tableName");
$sql = $fileArray[0];
for ($i=1;$i<$num-1;$i++){
mysql_unbuffered_query($sql.$fileArray[$i]) or (die (mysql_error()));
}
return true;
}

//step1:构造INSERT语句前半部分并写入文件：
$fields = array_keys($fieldInfo);
$fields = implode(',',$fields);
$sqltext="INSERT INTO $tableName($fields)VALUES \r\n";
$datafile = $tableDir.DIRECTORY_SEPARATOR.$tableName.'.sql';
(!$handle = fopen($datafile,'w')) && die("can not open file $datafile");
(!fwrite($handle, $sqltext))   && die("can not write data to file $datafile");
fclose($handle);

//step2:取得数据并写入文件：
//取出表资源：
set_time_limit(0);
$sql = "select * from $tableName";
$result = mysql_query($sql,$this->_mysql_link_id);
//打开数据备份文件:$tableName.xml
$datafile = $tableDir.DIRECTORY_SEPARATOR.$tableName.'.sql';
(!$handle = fopen($datafile,'a')) && die("can not open file $datafile");
//逐条取得表记录并写入文件：
while ($row = mysql_fetch_assoc($result)) {
$row = $this->_quoteRow($fieldInfo,$row);
$record='(' . implode(',',$row) . ");\r\n";
(!fwrite($handle, $record))   && die("can not write data to file $datafile");
}
mysql_free_result($result);
//关闭文件：
fclose($handle);

return true;
}

}
?>

备份mybbs数据库：

SQL代码
//example 1 backup:
require_once('DbBak.php');
require_once('TableBak.php');
$connectid = mysql_connect('localhost','root','123456');
$backupDir = 'data';
$DbBak = new DbBak($connectid,$backupDir);
$DbBak->backupDb('mybbs');

恢复mybbs数据库：

复制代码代码如下:

require_once('DbBak.php');
require_once('TableBak.php');
$connectid = mysql_connect('localhost','root','123456');
$backupDir = 'data';
$DbBak = new DbBak($connectid,$backupDir);
$DbBak->restoreDb('mybbs');

您可能感兴趣的文章:

thinkphp表单上传文件并将文件路径保存到数据库中
PHP表单数据写入MySQL数据库的代码
PHP连接access数据库
PHP通过get方法获得form表单数据方法总结
php实现表单提交上传文件功能
thinkPHP5 ajax提交表单操作实例分析
php如何把表单内容提交到数据库

上一条：
由php if 想到的些问题
下一条：
php 常用字符串函数总结

0条评论 (评论内容有缓存机制,请悉知!)