php信息库备份类程序代码

发布时间：2022-02-18 13:09:03 所属栏目：PHP教程来源：互联网

导读：今天没事收集了两款php数据库备份程序,这里可以完成功能有:1.备份指定数据表、2.打包成zip文件、3.发送到指定邮箱地址,基本功能就这些了. 下面看下使用方法,代码如下: ?php error_reporting(0);//消灭万恶的php报警提示 //设定邮箱 $options = array(email

　　今天没事收集了两款php数据库备份程序,这里可以完成功能有:1.备份指定数据表、2.打包成zip文件、3.发送到指定邮箱地址,基本功能就这些了.

　　下面看下使用方法,代码如下:

　　<?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();
　　?>
　　具体类实现,代码如下:

　　<?php
　　
　　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(emptyempty($_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 (emptyempty($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']) && !emptyempty($this->config['email']))
　　{
　　$this->sendEmail();
　　}
　　
　　// output
　　echo '<h3 style="color:green;">备份完成啦</h3><a href="'.
　　$this->datei.'">下载备份</a>
　　<br />
　　<br />';
　　}
　　}
　　
　　/**
　　* 发送邮件函数
　　* @return
　　*/
　　protected function sendEmail()
　　{
　　// 读取邮箱地址
　　foreach($this->config['email'] AS $email)
　　{
　　$to = $email;
　　
　　$from = $this->config['email'][0];
　　
　　$message_body = "本邮件中包含的zip压缩包为数据库备份";
　　
　　$msep = strtoupper (md5 (uniqid (time ())));
　　
　　// 设置email头
　　$header =
　　"From: $fromrn" .
　　"MIME-Version: 1.0rn" .
　　"Content-Type: multipart/mixed; boundary=".$msep."rnrn" .
　　"--$mseprn" .
　　"Content-Type: text/plainrn" .
　　"Content-Transfer-Encoding: 8bitrnrn" .
　　$message_body . "rn";
　　
　　// 文件名
　　$dateiname = $this->datei;
　　
　　// 压缩包大小
　　$dateigroesse = filesize ($dateiname);
　　
　　// 读取压缩包
　　$f = fopen ($dateiname, "r");
　　// 保存到附件
　　$attached_file = fread ($f, $dateigroesse);
　　// 关闭压缩包
　　fclose ($f);
　　// 建立一个附件
　　$attachment = chunk_split (base64_encode ($attached_file));
　　
　　// 设置附件头
　　$header .=
　　"--" . $msep . "rn" .
　　"Content-Type: application/zip; name='Backup'rn" .
　　"Content-Transfer-Encoding: base64rn" .
　　"Content-Disposition: attachment; filename='Backup.zip'rn" .
　　"Content-Description: Mysql Datenbank Backup im Anhangrnrn" .
　　$attachment . "rn";
　　
　　// 标记附件结束未知
　　$header .= "--$msep--";
　　
　　// 邮件标题
　　$subject = "数据库备份";
　　
　　// 发送邮件需要开启php相应支持哦^^
　　if(mail($to, $subject, '', $header) == FALSE)
　　{
　　die("无法发送邮件，请检查邮箱地址");
　　}
　　
　　echo "<p><small>邮件发送成功</small></p>";
　　}
　　}
　　
　　/**
　　* 建立数据库备份的压缩包并保存到服务器指定目录中
　　* @return
　　*/
　　protected function createZIP()
　　{
　　
　　// 文件夹权限要够
　　chmod($this->config['folder'], 0777);
　　
　　// 建立压缩包
　　$zip = new ZipArchive();
　　// 设置压缩包文件名
　　$this->datei = $this->config['folder'].$this->config['mysql'][3]."_"
　　.date("j_F_Y_g_i_a").".zip";
　　
　　// 看看压缩包能不能打开
　　if ($zip->open($this->datei, ZIPARCHIVE::CREATE)!==TRUE) {
　　exit("无法打开 <".$this->datei.">n");
　　}
　　
　　// 把dump出来的数据放到压缩包里
　　$zip->addFromString("dump.sql", $this->dump);
　　// 关闭压缩包
　　$zip->close();
　　
　　// 看看压缩包有没有生成
　　if(!file_exists($this->datei))
　　{
　　die("无法生成压缩包");
　　}
　　
　　echo "<p><small>数据库备份压缩包成功生成</small></p>";
　　}
　　
　　/**
　　* mysql dump函数
　　* @param object $dump
　　* @return
　　*/
　　protected function createDUMP($dump)
　　{
　　$date = date("F j, Y, g:i a");
　　
　　$header = <<<HEADER
　　        -- SQL Dump
　　--
　　-- Host: {$_SERVER['HTTP_HOST']}
　　-- Erstellungszeit: {$date}
　　
　　--
　　-- Datenbank: `{$this->config['mysql'][3]}`
　　--
　　
　　-- --------------------------------------------------------
　　
　　HEADER;
　　foreach($dump AS $name => $value)
　　{
　　$sql .= $name.$value;
　　}
　　$this->dump = $header.$sql;
　　}
　　
　　/**
　　* 生成选择数据表的界面函数
　　* @return
　　*/
　　public function outputForm()
　　{
　　// 选择全部
　　$result = mysql_list_tables($this->config['mysql'][3]);
　　
　　$buffer = '
　　<fieldset>
　　<legend>选择需要备份的数据表</legend>
　　<form method="post" action="">
　　<select name="table[]" multiple="multiple" size="30">';
　　while($row = mysql_fetch_row($result))
　　{
　　$buffer .= '<option value="'.$row[0].'">'.$row[0].'</option>';
　　}
　　$buffer .= '</select>
　　<br /><br />
　　<input type="submit" name="backup" value="备份选定数据表" />
　　</form>
　　</fieldset>';
　　
　　echo $buffer;
　　}
　　}
　　
　　?>
　　通用数据库备份类,代码如下:

　　<?php
　　/*数据库备份: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<mysql_num_rows($result)){
　　$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.111cn.net /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<count($array_table);$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;//开源代码Cuoxin.com
　　}
　　//写入一个文件
　　function write_file($file_path,$file_contents){
　　if(@!$fp=fopen($file_path,'w')){
　　$status="<fontcolor=/"red/">ThisFileCouldNotOpenOrRead.</font>";
　　}else{
　　flock($fp,3);
　　fwrite($fp,$file_contents);
　　fclose($fp);
　　window.google_render_ad();
　　?>

（编辑：云计算网_泰州站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!

php批量命名文件技巧	php读取文件内容几种正
php中读取大文件实现方	php打开远程文件的方法