二款php数据库备份类程序代码_PHP教程

error_reporting(0);//消灭万恶的php报警提示
//设定邮箱
$options = array('email' => array('email1', 'email2'),
'folder' => './backup/',
'mysql' => array('localhost', 'user', 'password', 'db'));

$b = new Backup($options);

// 提交备份命令
if(isset($_POST['backup']))
{
// 开始备份
$b->backupDB();
}
// 显示备份表
$b->outputForm();
?>

class Backup
{
/**
* @var 用于保存配置参数
*/
var $config;

/**
* @var 用于保存mysql dump的数据
*/
var $dump;

/**
* @var 用于数据库结果数据以及insert指令
*/
var $struktur = array();

/**
* @var 压缩文件名zip
*/
var $datei;

/**
* 结构函数
* 连接数据库
* @return
*/
public function Backup($options)
{
// 从形参中读取配置
foreach($options AS $name => $value)
{
$this->config[$name] = $value;
}

// 连接数据库
mysql_connect($this->config['mysql'][0], $this->config['mysql'][1],
$this->config['mysql'][2]) or die(mysql_error());
mysql_select_db($this->config['mysql'][3]) or die(mysql_error());
}

/**
* 执行备份数据库流程的函数
* @return
*/
public function backupDB()
{
// 开始备份的命令
if(isset($_POST['backup']))
{
// 检测是否选择了数据表
if(empty($_POST['table']))
{
die("请选择一个数据表。");
}

/** 开始备份 **/
$tables = array();
$insert = array();
$sql_statement = '';

// 锁定需要备份的数据库，防止读脏数据
foreach($_POST['table'] AS $table)
{
mysql_query("LOCK TABLE $table WRITE");

// 获取数据库结构
$res = mysql_query('SHOW CREATE TABLE '.$table.'');
$createtable = mysql_result($res, 0, 1);
$str = "nn".$createtable."nn";

array_push($tables, $str);

// 查询数据表中的所有数据行
$sql = 'SELECT * FROM '.$table;
$query = mysql_query($sql) or die(mysql_error());
$feld_anzahl = mysql_num_fields($query);

$sql_statement = '--
-- Data Table `$table`
--
';

// 开始读数据，并将其转换为insert命令
while($ds = mysql_fetch_object($query)){
$sql_statement .= 'INSERT INTO `'.$table.'` (';

for ($i = 0;$i <$feld_anzahl;$i++){
if ($i ==$feld_anzahl-1){
$sql_statement .= mysql_field_name($query,$i);
} else {
$sql_statement .= mysql_field_name($query,$i).', ';
}
}

$sql_statement .= ') VALUES (';

for ($i = 0;$i <$feld_anzahl;$i++){
$name = mysql_field_name($query,$i);
if (empty($ds->$name)){
$ds->$name = 'NULL';
}
if ($i ==$feld_anzahl-1){
$sql_statement .= '"'.$ds->$name.'"';
} else {
$sql_statement .= '"'.$ds->$name.'", ';
}
}
$sql_statement .= ");n";
}

// 将insert数据放在数组中，去重
if(!in_array($sql_statement, $insert))
{
array_push($insert, $sql_statement);
unset($sql_statement);
}

unset($sql_statement);

}

// 将数据库结构与insert命令放在一起啦
$this->struktur = array_combine($tables, $insert);

// 执行dump函数
$this->createDUMP($this->struktur);

// 生成zip压缩包
$this->createZIP();

/** 备份结束 **/

// 发一封邮件到指定邮箱，附件包含sql备份，如果你设置了的话^_^
if(isset($this->config['email']) && !empty($this->config['email']))
{
$this->sendEmail();
}

// output
echo '

备份完成啦

邮件发送成功

数据库备份压缩包成功生成

/*数据库备份:NOTICE:此类要添加数据库连接才能正常工作*/
Class Back_up_databaseextendsdbstuff{
//类开始
var $HOST;
var $USERNAME;
var $PASSWORD;
var $DATABASE;
function Back_up_database($host,$username,$password,$database){
//初始化数据库连接
$this->HOST=$host;
$this->USERNAME=$username;
$this->ASSWORD=$password;
$this->DATABASE=$database;
$Connection=$this->connect($this->HOST,$this->USERNAME,$this->ASSWORD,$this->DATABASE,$pconnect);
$this->Connection=$Connection;
}
//取得数据库中的表
function get_table_name($database){
$this->Connection;
$result=mysql_list_tables($database);
$i=0;
while($i $tb_name[$i]=mysql_tablename($result,$i);
$table_name.=$tb_name[$i].",";
$i++;
}
$this->table_name=substr($table_name,0,-1);
return$this->table_name;
}
//取得每个表中的FIELDS和属性并生成CREATETABLE语句
function get_table_fields($table_name){
$this->Connection;
$createtable=dbstuff::query("SHOWCREATETABLE$table_name");
$create=dbstuff::fetch_row($createtable);
$tabledump.="DROPTABLEIFEXISTS$table_name;\n";
$tabledump.=$create[1].";\n\n";
$this->$table_name=$tabledump;
return$this->$table_name;
}
//取得表中的数据并生成ISERTINTO语句
function get_insert($table_insert_name){
$this->Connection;
$rows=dbstuff::query("SELECT*FROM$table_insert_name");
$numfields=dbstuff::num_fields($rows);
$numrows=dbstuff::num_rows($rows);
while($row=dbstuff::fetch_row($rows)){
$comma="";
$tabledump.="INSERTINTO$table_insert_nameVALUES(";
for($i=0;$i<$numfields;$i++){
$tabledump.=$comma."'".mysql_escape_string($row[$i])."'";
$comma=",";
}
$tabledump.=");\n";
}
$this->tabledump=$tabledump;
return$this->tabledump;
}
//获取所有数据并连接成新的字符串并将它写入文件中.sql
function get_string($database_name,$file_path_name){
$time=date("Y-m-dH:j");
$date_time=date("YmdHis");
$file_path_name=$file_path_name.$date_time.".sql";
$version="Antsent_Web_StudioDatabaseBackUpV1.01";
$idstring='#Identify:'.base64_encode("$time,$version")."\n";
$head_info="$idstring".
"#\n".
"#Antsnet_Web!TheBasicClassOfBackUpDataBase\n".
"#Version:AntsnetWeb!$version\n".
"#Timetime\n".
"#Type:ClassOfBackUpDataBase\n".
"#Antsnet_Web_Studio!Home:http://www.bKjia.c0m \n".
"#PleasevisitourwebsitefornewestinfomationaboutAntsnet_Web_Studio!\n".
"#--------------------------------------------------------\n\n\n";
$table_name=$this->get_table_name($database_name);
$array_table=explode(",",$table_name);
for($i=0;$i $table_string.=$this->get_table_fields($array_table[$i]);
$table_insert.=$this->get_insert($array_table[$i]);
}
$count_string=$head_info.$table_string.$table_insert;
//return$count_string;
$write_status=$this->write_file($file_path_name,$count_string);
return$write_status;
}
//写入一个文件
function write_file($file_path,$file_contents){
if(@!$fp=fopen($file_path,'w')){
$status="ThisFileCouldNotOpenOrRead.";
}else{
flock($fp,3);
fwrite($fp,$file_contents);
fclose($fp);
window.google_render_ad();
?>