php备份和恢复mysql数据库

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› PHP›PHP编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

//1、实例化DbBak需要告诉它两件事：数据服务器在哪里($connectid)、备份到哪个目录($backupDir)：
require_once(database_back.php); //把文件database_back.php包含进来

$connectid = mysql_connect('localhost','root','123');
$backupDir = 'data';    //设置要备份到的目录
$DbBak = new DbBak($connectid,$backupDir);

//2数据备份
//2.1如果你想备份test库中的所有表，只要这样：
//$DbBak->backupDb('test');

//2.2如果你只想备份test库中的admin 、test表，可以用一个一维数组指定：
//$DbBak->backupDb('test',array('admin','test'));

//2.3如果只想备份一个表，比如admin表：
//$DbBak->backupDb('test','admin');

//数据恢复：
//对于2.1、2.2、2.3三种情况，只要相应的修改下语句，把backupDb换成restoreDb就能实现数据恢复了：
//$DbBak->restoreDb('test');

//SQL代码
//$DbBak->restoreDb('test',array('admin','test'));

//PHP代码
//$DbBak->restoreDb('test','admin');

//下面是database_back.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 backupDb($dbName,$tableName=null)
{
( (!is_string($dbName)) || strlen($dbName)==0 ) && die('$dbName must be a string value');
//step1:选择数据库：
mysql_select_db($dbName);
//step2:创建数据库备份目录
$dbDir = $this->_dataDir.DIRECTORY_SEPARATOR.$dbName;
!is_dir($dbDir) && mkdir($dbDir);
//step3:得到数据库所有表名并开始备份表
$this->_TableBak = new TableBak($this->_mysql_link_id,$dbDir);
if(is_null($tableName)){//backup all table in the db
$this->_backupAllTable($dbName);
return;
}
if(is_string($tableName)){
(strlen($tableName)==0) && die('....');
$this->_backupOneTable($dbName,$tableName);
return;
}
if (is_array($tableName)){
foreach ($tableName as $table){
( (!is_string($table)) || strlen($table)==0 ) && die('....');
}
$this->_backupSomeTalbe($dbName,$tableName);
return;
}
}

//数据恢复
function restoreDb($dbName,$tableName=null){
( (!is_string($dbName)) || strlen($dbName)==0 ) && die('$dbName must be a string value');
//step1:检查是否存在数据库并连接：
@mysql_select_db($dbName) || die("the database $dbName dose not exists");
//step2:检查是否存在数据库备份目录
$dbDir = $this->_dataDir.DIRECTORY_SEPARATOR.$dbName;
!is_dir($dbDir) && die("$dbDir not exists");
//step3:start restore
$this->_TableBak = new TableBak($this->_mysql_link_id,$dbDir);
if(is_null($tableName)){//backup all table in the db
$this->_restoreAllTable($dbName);
return;
}
if(is_string($tableName)){
(strlen($tableName)==0) && die('....');
$this->_restoreOneTable($dbName,$tableName);
return;
}
if (is_array($tableName)){
foreach ($tableName as $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_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);
}
}
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("$tableBakFile not exists or unwirteable");
}
//step2:start restore
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("$tableBakFile not exists or unwirteable");
//step3:start restore
$this->_TableBak->restoreTable($tableName,$tableBakFile);
}
function _restoreSomeTalbe($dbName,$TableNameList)
{
//step1:检查是否存在数据表:
foreach ($TableNameList as $tableName){
!in_array($tableName,$this->_getTableList($dbName)) && die("指定的表名$tableName在数据库中不存在");
}
//step2:检查是否存在数据表备份文件以及是否可写：
foreach ($TableNameList as $tableName){
$tableBakFile = $this->_dataDir.DIRECTORY_SEPARATOR
 . $dbName.DIRECTORY_SEPARATOR
 . $tableName.DIRECTORY_SEPARATOR
 . $tableName.'.sql';
!is_writeable ($tableBakFile) && die("$tableBakFile not exists or unwirteable");
}
//step3:start restore:
foreach ($TableNameList as $tableName){
$tableBakFile = $this->_dataDir.DIRECTORY_SEPARATOR
 . $dbName.DIRECTORY_SEPARATOR
 . $tableName.DIRECTORY_SEPARATOR
 . $tableName.'.sql';
$this->_TableBak->restoreTable($tableName,$tableBakFile);
}
}
}

//只有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;
}
function _getFieldInfo($tableName){
$fieldInfo = array();
$sql="SELECT * FROM $tableName LIMIT 1";
$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 ($row as $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="INSERT INTO $tableName($fields)VALUES \r\n";
$datafile = $tableDir.DIRECTORY_SEPARATOR.$tableName.'.sql';
(!$handle = fopen($datafile,'w')) && die("can not open file $datafile");

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";

$record=$sqltext.$record;

(!fwrite($handle, $record)) && die("can not write data to file $datafile");
}

mysql_free_result($result);
//关闭文件：
fclose($handle);
return true;
}
}

?>

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

在windows平台上构建自己的PHP（仅适用于php5.2）发布时间：2022-07-10

PHP获取本周的每一天的时间发布时间：2022-07-10

krishnaik06/Machine-Learning-in-90-days

1 CVE-2022-22681

Session fixation vulnerability in access control management in Synology Photo St

阅读：945|2022-07-08

2 bluegill/katana:

bluegill/katana:

阅读：911|2022-08-18

3 NelsonUpenn/PMLS-MATLAB-Guide: MLguide1-

NelsonUpenn/PMLS-MATLAB-Guide: MLguide1-0.pdf: Nelson Dodson's Student'

阅读：324|2022-08-17

4 青岛中学艺术设计课程帮助学生树立全新思维

这几年，学校不仅关注学生的文化课知识，对于学生的艺术培养，也是非常重视的。毕竟，

阅读：351|2022-11-06

5 juleswhite/mobilecloud-15: Programming C

juleswhite/mobilecloud-15: Programming Cloud Services for Android Handheld Syste

阅读：461|2022-08-30

6 yosupo06/library-checker-problems: The p

yosupo06/library-checker-problems: The problem data (Test case generator, judge

阅读：531|2022-08-15

7 athos/Bigmouth: Clojure framework to bui

athos/Bigmouth: Clojure framework to build delivery-only Mastodon-compatible web

阅读：869|2022-08-17

8 开洗车店怎么样？20元洗一辆车有利润吗

现在汽车行业生意红火，当然，汽车的相关投资项目，市场前景都是很不错的，那么，开洗

阅读：231|2022-11-06

9 CVE-2022-36686

Ingredients Stock Management System v1.0 was discovered to contain a SQL injecti

阅读：506|2022-09-18

10 微信小程序|没有授权合法域名时如何操作

在使用微信小程序开发者工具进行开发需要使用数据库内的内容而发送网络请求却没有配置

阅读：820|2022-07-18

客服电话

电子邮件

php备份和恢复mysql数据库

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

juven/maven-bash-completion: Maven Bash

win7系统注册表编辑器打开的操作方法

route101/mastoinker: Quick image view as

openshift/library-go: Helpers for going

krishnaik06/Machine-Learning-in-90-days

微信小程序在components的properties属性

armancodv/building-energy-model-matlab:

美元符号为什么是“$”

CVE-2022-2280

FGRibreau/import-tweets-to-mastodon: How

关于我们

产品与服务

解决方案

139-2527-9053

客服电话

电子邮件

php备份和恢复mysql数据库

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

juven/maven-bash-completion: Maven Bash

win7系统注册表编辑器打开的操作方法

route101/mastoinker: Quick image view as

openshift/library-go: Helpers for going

krishnaik06/Machine-Learning-in-90-days

微信小程序 在components的properties属性

armancodv/building-energy-model-matlab:

美元符号为什么是“$”

CVE-2022-2280

FGRibreau/import-tweets-to-mastodon: How

关于我们

产品与服务

解决方案

139-2527-9053

微信小程序在components的properties属性