require_once('DbBak.php');
require_once('TableBak.php');
$connectid=mysql_connect('localhost','root','123456');
$backupDir='data';
$DbBak=newDbBak($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');
classDbBak{
var$_mysql_link_id;
var$_dataDir;
var$_tableList;
var$_TableBak;
functionDbBak($_mysql_link_id,$dataDir)
{
((!is_string($dataDir))||strlen($dataDir)==0)&&die('error:$datadirisnotastring');
!is_dir($dataDir)&&mkdir($dataDir);
$this->_dataDir=$dataDir;
$this->_mysql_link_id=$_mysql_link_id;
}
functionbackupDb($dbName,$tableName=null)
{
((!is_string($dbName))||strlen($dbName)==0)&&die('$dbNamemustbeastringvalue');
//step1:选择数据库：
mysql_select_db($dbName);
//step2:创建数据库备份目录
$dbDir=$this->_dataDir.DIRECTORY_SEPARATOR.$dbName;
!is_dir($dbDir)&&mkdir($dbDir);
//step3:得到数据库所有表名并开始备份表
$this->_TableBak=newTableBak($this->_mysql_link_id,$dbDir);
if(is_null($tableName)){//backupalltableinthedb
$this->_backupAllTable($dbName);
return;
}
if(is_string($tableName)){
(strlen($tableName)==0)&&die('....');
$this->_backupOneTable($dbName,$tableName);
return;
}
if(is_array($tableName)){
foreach($tableNameas$table){
((!is_string($table))||strlen($table)==0)&&die('....');
}
$this->_backupSomeTalbe($dbName,$tableName);
return;
}
}
functionrestoreDb($dbName,$tableName=null){
((!is_string($dbName))||strlen($dbName)==0)&&die('$dbNamemustbeastringvalue');
//step1:检查是否存在数据库并连接：
@mysql_select_db($dbName)||die("thedatabase$dbNamedosenotexists");
//step2:检查是否存在数据库备份目录
$dbDir=$this->_dataDir.DIRECTORY_SEPARATOR.$dbName;
!is_dir($dbDir)&&die("$dbDirnotexists");
//step3:startrestore
$this->_TableBak=newTableBak($this->_mysql_link_id,$dbDir);
if(is_null($tableName)){//backupalltableinthedb
$this->_restoreAllTable($dbName);
return;
}
if(is_string($tableName)){
(strlen($tableName)==0)&&die('....');
$this->_restoreOneTable($dbName,$tableName);
return;
}
if(is_array($tableName)){
foreach($tableNameas$table){
((!is_string($table))||strlen($table)==0)&&die('....');
}
$this->_restoreSomeTalbe($dbName,$tableName);
return;
}
}
function_getTableList($dbName)
{
$tableList=array();
$result=mysql_list_tables($dbName,$this->_mysql_link_id);
for($i=0;$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($TableNameListas$tableName){
!in_array($tableName,$this->_getTableList($dbName))&&die("指定的表名$tableName在数据库中不存在");
}
foreach($TableNameListas$tableName){
$this->_TableBak->backupTable($tableName);
}
}
function_restoreAllTable($dbName)
{
//step1:检查是否存在所有数据表的备份文件以及是否可写：
foreach($this->_getTableList($dbName)as$tableName){
$tableBakFile=$this->_dataDir.DIRECTORY_SEPARATOR
.$dbName.DIRECTORY_SEPARATOR
.$tableName.DIRECTORY_SEPARATOR
.$tableName.'.sql';
!is_writeable($tableBakFile)&&die("$tableBakFilenotexistsorunwirteable");
}
//step2:startrestore
foreach($this->_getTableList($dbName)as$tableName){
$tableBakFile=$this->_dataDir.DIRECTORY_SEPARATOR
.$dbName.DIRECTORY_SEPARATOR
.$tableName.DIRECTORY_SEPARATOR
.$tableName.'.sql';
$this->_TableBak->restoreTable($tableName,$tableBakFile);
}
}
function_restoreOneTable($dbName,$tableName)
{
//step1:检查是否存在数据表:
!in_array($tableName,$this->_getTableList($dbName))&&die("指定的表名$tableName在数据库中不存在");
//step2:检查是否存在数据表备份文件以及是否可写：
$tableBakFile=$this->_dataDir.DIRECTORY_SEPARATOR
.$dbName.DIRECTORY_SEPARATOR
.$tableName.DIRECTORY_SEPARATOR
.$tableName.'.sql';
!is_writeable($tableBakFile)&&die("$tableBakFilenotexistsorunwirteable");
//step3:startrestore
$this->_TableBak->restoreTable($tableName,$tableBakFile);
}
function_restoreSomeTalbe($dbName,$TableNameList)
{
//step1:检查是否存在数据表:
foreach($TableNameListas$tableName){
!in_array($tableName,$this->_getTableList($dbName))&&die("指定的表名$tableName在数据库中不存在");
}
//step2:检查是否存在数据表备份文件以及是否可写：
foreach($TableNameListas$tableName){
$tableBakFile=$this->_dataDir.DIRECTORY_SEPARATOR
.$dbName.DIRECTORY_SEPARATOR
.$tableName.DIRECTORY_SEPARATOR
.$tableName.'.sql';
!is_writeable($tableBakFile)&&die("$tableBakFilenotexistsorunwirteable");
}
//step3:startrestore:
foreach($TableNameListas$tableName){
$tableBakFile=$this->_dataDir.DIRECTORY_SEPARATOR
.$dbName.DIRECTORY_SEPARATOR
.$tableName.DIRECTORY_SEPARATOR
.$tableName.'.sql';
$this->_TableBak->restoreTable($tableName,$tableBakFile);
}
}
}
?>
复制代码 代码如下:
//只有DbBak才能调用这个类
classTableBak{
var$_mysql_link_id;
var$_dbDir;
//private$_DbManager;
functionTableBak($mysql_link_id,$dbDir)
{
$this->_mysql_link_id=$mysql_link_id;
$this->_dbDir=$dbDir;
}
functionbackupTable($tableName)
{
//step1:创建表的备份目录名：
$tableDir=$this->_dbDir.DIRECTORY_SEPARATOR.$tableName;
!is_dir($tableDir)&&mkdir($tableDir);
//step2:开始备份：
$this->_backupTable($tableName,$tableDir);
}
functionrestoreTable($tableName,$tableBakFile)
{
set_time_limit(0);
$fileArray=@file($tableBakFile)ordie("canopenfile$tableBakFile");
$num=count($fileArray);
mysql_unbuffered_query("DELETEFROM$tableName");
$sql=$fileArray[0];
for($i=1;$i<$num-1;$i++){
mysql_unbuffered_query($sql.$fileArray[$i])or(die(mysql_error()));
}
returntrue;
}
function_getFieldInfo($tableName){
$fieldInfo=array();
$sql="SELECT*FROM$tableNameLIMIT1";
$result=mysql_query($sql,$this->_mysql_link_id);
$num_field=mysql_num_fields($result);
for($i=0;$i<$num_field;$i++){
$field_name=mysql_field_name($result,$i);
$field_type=mysql_field_type($result,$i);
$fieldInfo[$field_name]=$field_type;
}
mysql_free_result($result);
return$fieldInfo;
}
function_quoteRow($fieldInfo,$row){
foreach($rowas$field_name=>$field_value){
$field_value=strval($field_value);
switch($fieldInfo[$field_name]){
case"blob":$row[$field_name]="'".mysql_escape_string($field_value)."'";break;
case"string":$row[$field_name]="'".mysql_escape_string($field_value)."'";break;
case"date":$row[$field_name]="'".mysql_escape_string($field_value)."'";break;
case"datetime":$row[$field_name]="'".mysql_escape_string($field_value)."'";break;
case"time":$row[$field_name]="'".mysql_escape_string($field_value)."'";break;
case"unknown":$row[$field_name]="'".mysql_escape_string($field_value)."'";break;
case"int":$row[$field_name]=intval($field_value);break;
case"real":$row[$field_name]=intval($field_value);break;
case"timestamp":$row[$field_name]=intval($field_value);break;
default:$row[$field_name]=intval($field_value);break;
}
}
return$row;
}
function_backupTable($tableName,$tableDir)
{
//取得表的字段类型：
$fieldInfo=$this->_getFieldInfo($tableName);
//step1:构造INSERT语句前半部分并写入文件：
$fields=array_keys($fieldInfo);
$fields=implode(',',$fields);
$sqltext="INSERTINTO$tableName($fields)VALUESrn";
$datafile=$tableDir.DIRECTORY_SEPARATOR.$tableName.'.sql';
(!$handle=fopen($datafile,'w'))&&die("cannotopenfile$datafile");
(!fwrite($handle,$sqltext))&&die("cannotwritedatatofile$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("cannotopenfile$datafile");
//逐条取得表记录并写入文件：
while($row=mysql_fetch_assoc($result)){
$row=$this->_quoteRow($fieldInfo,$row);
$record='('.implode(',',$row).");rn";
(!fwrite($handle,$record))&&die("cannotwritedatatofile$datafile");
}
mysql_free_result($result);
//关闭文件：
fclose($handle);
returntrue;
}
}
?>
备份mybbs数据库：
SQL代码
//example1backup:
require_once('DbBak.php');
require_once('TableBak.php');
$connectid=mysql_connect('localhost','root','123456');
$backupDir='data';
$DbBak=newDbBak($connectid,$backupDir);
$DbBak->backupDb('mybbs');
恢复mybbs数据库：
复制代码 代码如下:
require_once('DbBak.php');
require_once('TableBak.php');
$connectid=mysql_connect('localhost','root','123456');
$backupDir='data';
$DbBak=newDbBak($connectid,$backupDir);
$DbBak->restoreDb('mybbs');
