当前位置:首页 > Mysql教程 > 列表

php备份mysql数据库程序代码

发布:smiling 来源: PHP粉丝网  添加日期:2014-10-09 14:19:52 浏览: 评论:0 

在我们开发中数据库备份是很重要的环节,下面我们来分享两个php备份mysql数据库类,有需要的朋友可稍加修改即可使用.

先看备份的类文件backdata.class.php,代码如下:

  1. <?php 
  2. /* 
  3. * 
  4. *简单的一个Mysql备份数据类  
  5. * 
  6. */ 
  7. class backupData{ 
  8.     private    $mysql_link;//链接标识 
  9.     private    $dbName;    //数据库名 
  10.     private    $dataDir;     //数据所要存放的目录 
  11.     private    $tableNames;//表名 
  12.  
  13.     public function __construct($mysql_link){ 
  14.          $this->mysql_link = $mysql_link
  15.     } 
  16.     public function backupTables($dbName,$dataDir,$tableNames){//开始备份 
  17.         $this->dbName  = $dbName
  18.         $this->dataDir  = $dataDir
  19.         $this->tableNames = $tableNames
  20.         $tables=$this->delarray($this->tableNames); 
  21.         $sqls=''
  22.         foreach($tables as $tablename){ 
  23.             if($tablename==''){//表不存在时 
  24.                 continue
  25.             } 
  26.              
  27.             //************************以下是形成SQL的前半部分************** 
  28.             //如果存在表,就先删除 
  29.             $sqls .= "DROP TABLE IF EXISTS $tablename;n"
  30.             //读取表结构 
  31.             $rs = mysql_query("SHOW CREATE TABLE $tablename",$this->mysql_link);   
  32.             $row=mysql_fetch_row($rs); 
  33.             //获得表结构组成SQL 
  34.             $sqls.=$row['1'].";nn"
  35.             unset($rs); 
  36.             unset($row); 
  37.              
  38.             //************************以下是形成SQL的后半部分************** 
  39.             //查寻出表中的所有数据 
  40.             $rs=mysql_query("select * from $tablename",$this->mysql_link); 
  41.             //表的字段个数 
  42.             $field=mysql_num_fields($rs); 
  43.             //形成此种SQL语句:"INSERT INTO `groups` VALUES('1499e0ca25988d','主任','','0');" 
  44.             while($rows=mysql_fetch_row($rs)){ 
  45.                 $comma='';//逗号 
  46.                 $sqls.="INSERT INTO `$tablename` VALUES("
  47.                 for($i=0;$i<$field;$i++){ 
  48.                     $sqls.=$comma."'".$rows[$i]."'"
  49.                     $comma=','
  50.                 } 
  51.                 $sqls.=");nnn"
  52.             } 
  53.         } 
  54.         $backfilepath=$this->dataDir.date("Ymdhis",time()).'.sql'
  55.          
  56.         //写入文件 
  57.         $filehandle = fopen($backfilepath"w"); 
  58.         fwrite($filehandle$sqls); 
  59.         fclose($filehandle); 
  60.     } 
  61.     private function delarray($array){    //处理传入进来的数组 
  62.         foreach($array as $tables){ 
  63.             if($tables=='*'){    //所有的表(获得表名时不能按常规方式来组成一个数组) 
  64.                 $newtables=mysql_list_tables($this->dbName,$this->mysql_link); 
  65.                 $tableList = array(); 
  66.                 for ($i = 0; $i < mysql_numrows($newtables); $i++){ 
  67.                     array_push($tableList,mysql_tablename($newtables$i)); 
  68.                 } 
  69.                 $tableList=$tableList
  70.             }else
  71.                 $tableList=$array
  72.                 break
  73.             } 
  74.         } 
  75.         return $tableList
  76.     } 
  77.  
  78. ?> 

数据库备份用法,代码如下:

  1. require_once("backdata.class.php"); 
  2. $link = @mysql_connect("localhost","数据库名","密码"or die ('Could not connect to server.'); 
  3. mysql_query("use cms",$link); 
  4. mysql_query("set names utf8",$link); 
  5. $dbbck=new backupData($link);//实例化它,只要一个链接标识就行了  
  6. //备份数据时,如想备份一个数据库中的所有表,你可这样写:  
  7. $dbbck->backupTables("cms","./",array('*')); 
  8. //备份数据时,如想备份一个数据库中的仅一个表时,你可这样写:  
  9. $dbbck->backupTables("cms","./",array('user')); 
  10. //备份数据时,如想备份一个数据库中的多个表时,你可这样写:  
  11. $dbbck->backupTables("cms","./",array('user','acl','informatoin')); 
  12. //注解:$dbbck->backupTables("参1","参2",array());中,  

参1为:数据库名.

参2为:要存放备份数据的位置,即目录地址.

第三个为:你要保存那些表.

再来分享一个数据库备份类,代码如下:

  1. /** 
  2.   * 说明,该类适用于小型的网站的数据库备份,内置mysql连接,只需要简单配置数据连接 
  3.   * 及存贮备份的位置即可。 
  4.   * 类实列化并且连接数据库以后可执行以下操作 
  5.   * get_db_table($database)    取得所有数据表 
  6.   * export_sql($table,$subsection=0))   生成sql文件,注意生成sql文件只保存到服务器目录,不提供下载 
  7.   * import_sql($dir)     恢复数据只导入服务器目录下的sql文件 
  8.   * 该类制作简单,可任意传播,如何您对该类有什么提议,请发送邮件给小虾 
  9.   * @author 赵红健[游天小虾] 
  10.   * email:328742379@qq.com 
  11.   * qq交流群:69574955 聚义堂-网页制作交 
  12.   */ 
  13.  
  14. class data { 
  15.  public   $data_dir    = "class/"//备份文件存放的路径 
  16.  public   $transfer     ="";   //临时存放sql[切勿不要对该属性赋值,否则会生成错误的sql语句] 
  17.  
  18. /** 
  19.  *数据库连接 
  20.  *@param string $host 数据库主机名 
  21.  *@param string $user 用户名 
  22.  *@param string $pwd  密码 
  23.  *@param string $db   选择数据库名 
  24.  *@param string $charset 编码方式 
  25.  */ 
  26.  function connect_db($host,$user,$pwd,$db,$charset='gbk'){ 
  27.   if(!$conn = mysql_connect($host,$user,$pwd)){ 
  28.    return false; 
  29.   } 
  30.   mysql_select_db($db); 
  31.   mysql_query("set names $charset"); 
  32.   return true; 
  33.  } 
  34.  
  35. /** 
  36.  * 生成sql语句 
  37.  * @param   $table     要备份的表 
  38.  * @return  $tabledump 生成的sql语句 
  39.  */ 
  40.  public function set_sql($table,$subsection=0,&$tabledom=''){ 
  41.   $tabledom .= "drop table if exists $tablen"
  42.   $createtable = mysql_query("show create table $table"); 
  43.   $create = mysql_fetch_row($createtable); 
  44.   $create[1] = str_replace("n","",$create[1]); 
  45.   $create[1] = str_replace("t","",$create[1]); 
  46.  
  47.   $tabledom  .= $create[1].";n"
  48.  
  49.   $rows = mysql_query("select * from $table"); 
  50.   $numfields = mysql_num_fields($rows); 
  51.   $numrows = mysql_num_rows($rows); 
  52.   $n = 1; 
  53.   $sqlarry = array(); 
  54.   while ($row = mysql_fetch_row($rows)){ 
  55.      $comma = ""
  56.      $tabledom  .= "insert into $table values("
  57.      for($i = 0; $i < $numfields$i++) 
  58.      { 
  59.     $tabledom  .= $comma."'".mysql_escape_string($row[$i])."'"
  60.     $comma = ","
  61.      } 
  62.     $tabledom  .= ")n"
  63.      if($subsection != 0 && strlen($this->transfer )>=$subsection*1000){ 
  64.        $sqlarry[$n]= $tabledom
  65.        $tabledom = ''$n++; 
  66.      } 
  67.   } 
  68.   return $sqlarry
  69.    } 
  70.  
  71. /** 
  72.  *列表数据库中的表 
  73.  *@param  database $database 要操作的数据库名 
  74.  *@return array    $dbarray  所列表的数据库表 
  75.  */ 
  76.  public function get_db_table($database){ 
  77.   $result = mysql_list_tables($database); 
  78.   while($tmparry = mysql_fetch_row($result)){ 
  79.    $dbarry[]  = $tmparry[0]; 
  80.   } 
  81.   return $dbarry
  82.  } 
  83.  
  84. /** 
  85.  *验证目录是否有效 
  86.  *@param diretory $dir 
  87.  *@return booln 
  88.  */ 
  89.  function check_write_dir($dir){ 
  90.   if(!is_dir($dir)) {@mkdir($dir, 0777);} 
  91.   if(is_dir($dir)){ 
  92.    if($link = opendir($dir)){ 
  93.     $filearry = scandir($dir); 
  94.     for($i=0;$i<count($filearry);$i++){ 
  95.      if($filearry[$i]!='.' || $filearry != '..'){ 
  96.       @unlink($dir.$filearry[$i]); 
  97.      } 
  98.     } 
  99.    } 
  100.   } 
  101.   return true; 
  102.  } 
  103. /** 
  104.  *将数据写入到文件中 
  105.  *@param file $filename 文件名 
  106.  *@param string $str   要写入的信息 
  107.  *@return booln 写入成功则返回true,否则false 
  108.  */ 
  109.  private function write_sql($filename,$str){ 
  110.   $re= true; 
  111.   if(!@$fp=fopen($filename,"w+")) {$re=false; echo "在打开文件时遇到错误,备份失败!";} 
  112.   if(!@fwrite($fp,$str)) {$re=false; echo "在写入信息时遇到错误,备份失败!";} 
  113.   if(!@fclose($fp)) {$re=false; echo "在关闭文件 时遇到错误,备份失败!";} 
  114.   return $re
  115.  } 
  116.  
  117. /** 
  118.  *生成sql文件 
  119.  *@param string $sql sql    语句 
  120.  *@param number $subsection 分卷大小,以kb为单位,为0表示不分卷 
  121.  */ 
  122.      public function export_sql($table,$subsection=0){ 
  123.       if(!$this->check_write_dir($this->data_dir)){echo '您没有权限操作目录,备份失败';return false;} 
  124.       if($subsection == 0){ 
  125.        if(!is_array($table)){ 
  126.     $this->set_sql($table,0,$this->transfer); 
  127.    }else
  128.     for($i=0;$i<count($table);$i++){ 
  129.      $this->set_sql($table[$i],0,$this->transfer); 
  130.     } 
  131.    } 
  132.        $filename = $this->data_dir.date("ymd",time()).'_all.sql'
  133.        if(!$this->write_sql($filename,$this->transfer)){return false;} 
  134.       }else
  135.        if(!is_array($table)){ 
  136.     $sqlarry = $this->set_sql($table,$subsection,$this->transfer); 
  137.     $sqlarry[] = $this->transfer; 
  138.    }else
  139.     $sqlarry = array(); 
  140.     for($i=0;$i<count($table);$i++){ 
  141.      $tmparry = $this->set_sql($table[$i],$subsection,$this->transfer); 
  142.      $sqlarry = array_merge($sqlarry,$tmparry); 
  143.     } 
  144.     $sqlarry[] = $this->transfer; 
  145.    } 
  146.        for($i=0;$i<count($sqlarry);$i++){ 
  147.         $filename = $this->data_dir.date("ymd",time()).'_part'.$i.'.sql'
  148.         if(!$this->write_sql($filename,$sqlarry[$i])){return false;} 
  149.        } 
  150.       } 
  151.       return true; 
  152.     } 
  153. /** 
  154.  *载入sql文件 
  155.  *@param diretory $dir 
  156.  *@return booln 
  157.  *注意:请不在目录下面存放其它文件,或者目录 
  158.  *以节省恢复时间 
  159.  */ 
  160.     public function import_sql($dir){ 
  161.   if($link = opendir($dir)){ 
  162.    $filearry = scandir($dir); 
  163.     $pattern = "_part[0-9]+.sql$|_all.sql$"
  164.    for($i=0;$i<count($filearry);$i++){ 
  165.     if(eregi($pattern,$filearry[$i])){ 
  166.      $sqls=file($dir.$filearry[$i]); 
  167.      foreach($sqls as $sql){ 
  168.       str_replace("r","",$sql); 
  169.       str_replace("n","",$sql); 
  170.       if(!mysql_query(trim($sql))) return false; 
  171.      }  //phpfensi.com 
  172.     } 
  173.    } 
  174.    return true; 
  175.   } 
  176.     } 
  177.  

应用方法,代码如下:

  1. //$d = new data(); 
  2.  
  3. //连接数据库 
  4. //if(!$d->connect_db('localhost','root','','guestbook','gbk')){ 
  5. // echo '数据库连接失败'; 
  6. //} 
  7.  
  8. //查找数据库内所有数据表 
  9. //$tablearry = $d->get_db_table('guestbook'); 
  10.  
  11. //备份并生成sql文件 
  12. //if(!$d->export_sql($tablearry)){ 
  13. // echo '备份失败'; 
  14. //}else{ 
  15. // echo '备份成功'; 
  16. //} 
  17.  
  18. //恢复导入sql文件夹 
  19. //if($d->import_sql($d->data_dir)){ 
  20. // echo '恢复成功'; 
  21. //}else{ 
  22. // echo '恢复失败'; 
  23. //}

Tags: php备份数据库 mysql备份

分享到: