php实现mysql备份恢复分卷处理的方法_PHP

本文实例讲述了php实现mysql备份恢复分卷处理的方法。分享给大家供大家参考。具体分析如下：

分卷处理就是把握们要处理的数据分成一个个小文件进行处理了,这里我来给大家介绍一个php mysql备份恢复分卷处理类,实现mysql数据库分卷备份,选择表进行备份,实现单个sql文件及分卷sql导入.

分卷导入类及思路详解

数据库导入导出是一个后台必要拥有的功能,网上一搜,有很多关于数据库导入导出的,但基本上一个大的系统,包含了许多我们并不需要的,而且他们都是自己的后台的形式,我并不喜欢的是拿人家的东西整合到自己的后台,我需要的是自己东西,于是参照了很多,自己写了一个关于分卷导入类,以方便调用,欢迎大家拍砖.

这里针对分卷文件是以‘_v1.sql’为结尾,实现单个sql文件及分卷sql导入,分卷导入可选择是否当前分卷导入余下分卷,我们只需要直接调用类即可完成.

分别是主机，用户名，密码，数据库名，数据库编码

$db = new DataManage ( 'localhost', 'root', 'root', 'test', 'utf8' );

sql文件,是否只导入单个sql(即如果有其他分卷也不导入).

$db->restore ( './backup/20120516211738_all_v1.sql', false );

对应如何去列出备份的sql文件或选择sql之类的,自己去实现,那个不在这个范畴了,也很简单的.

还有目前只实现了数据库导入,关于数据库导出的,正在编写功能,下面是完整的类代码,具体思路及实现代码里面都有说明,这里不在赘述,代码如下:

<?php <br />/** <br /> * @author yanue <br /> * 说明：分卷文件是以_v1.sql为结尾 <br /> * 功能：实现单个sql文件及分卷sql导入,分卷导入可选择是否当前分卷导入余下分卷 <br /> * 使用方法： <br /> * <br /> * <br /> * ------------------------------------------------------------------ <br />//分别是主机，用户名，密码，数据库名，数据库编码 <br />$db = new DataManage ( 'localhost', 'root', 'root', 'test', 'utf8' ); <br />//sql文件，是否只导入单个sql（即如果有其他分卷也不导入） <br />$db->restore ( './backup/20120516211738_all_v1.sql', false ); <br /> *---------------------------------------------------------------------- <br /> */ <br />class DataManage { <br /> var $db; // 数据库连接 <br /> var $database; // 所用数据库 <br /> var $sqldir; // 数据库备份文件夹 <br /> <br /> /** <br />  * 初始化 <br />  * <br />  * @param string $host <br />  * @param string $username <br />  * @param string $password <br />  * @param string $database <br />  * @param string $charset <br />  */ <br /> function __construct($host = 'localhost', $username = 'root', $password = '', $database = 'test', $charset = 'utf8') { <br />  $this->host = $host; <br />  $this->username = $username; <br />  $this->password = $password; <br />  $this->database = $database; <br />  $this->charset = $charset; <br />  // 连接数据库 <br />  $this->db = mysql_connect ( $this->host, $this->username, $this->password ) or die ( "数据库连接失败." ); <br />  // 选择使用哪个数据库 <br />  mysql_select_db ( $this->database, $this->db ) or die ( "无法打开数据库" ); <br />  // 数据库编码方式 <br />  mysql_query ( 'SET NAMES ' . $this->charset, $this->db ); <br /> } <br /> <br /> /** <br />  * 导入备份数据 <br />  * 说明：分卷文件格式20120516211738_all_v1.sql <br />  * <br />  * @param string $sqlfile <br />  * @param bool $single <br />  */ <br /> function restore($sqlfile, $single = FALSE) { <br />  // 检测文件是否存在 <br />  if (! file_exists ( $sqlfile )) { <br />   exit ( "文件不存在！请检查" ); <br />  } <br />  $this->lock ( $this->database ); <br />  // 获取数据库存储位置 <br />  $sqlpath = pathinfo ( $sqlfile ); <br />  $this->sqldir = $sqlpath ['dirname']; <br />  // 检测是否包含分卷，将类似20120516211738_all_v1.sql从_v分开,有则说明有分卷 <br />  $volume = explode ( "_v", $sqlfile ); <br />  $volume_path = $volume [0]; <br />  echo "请勿刷新及关闭浏览器以防止程序被中止，如有不慎！将导致数据库结构受损<br />"; <br />  echo "正在导入备份数据，请稍等！<br />"; <br />  if (emptyempty ( $volume [1] ) || $single) { <br />   echo "正在导入sql：<span style='color:#f00'>" . $sqlfile . '</span><br />'; <br />   // 没有分卷 <br />   if ($this->_import ( $sqlfile )) { <br />    echo "数据库导入成功！"; <br />   } else { <br />    exit ( '数据库导入失败！' ); <br />   } <br />  } else { <br />   // 存在分卷，则获取当前是第几分卷，循环执行余下分卷 <br />   $volume_id = explode ( ".sq", $volume [1] ); <br />   // 当前分卷为$volume_id <br />   $volume_id = intval ( $volume_id [0] ); <br />   while ( $volume_id ) { <br />    $tmpfile = $volume_path . "_v" . $volume_id . ".sql"; <br />    // 存在其他分卷，继续执行 <br />    if (file_exists ( $tmpfile )) { <br />     // 执行导入方法 <br />     echo "正在导入分卷$volume_id：<span style='color:#f00'>" . $tmpfile . '</span><br />'; <br />     if ($this->_import ( $tmpfile )) { <br /> <br />     } else { <br />      exit ( "导入分卷$volume_id：<span style='color:#f00'>" . $tmpfile . '</span>失败！可能是数据库结构已损坏！请尝试从分卷1开始导入' ); <br />     } <br />    } else { <br />     echo "此分卷备份全部导入成功！<br />"; <br />     return; <br />    } <br />    $volume_id ++; <br />   } <br />  } <br /> } <br /> <br /> /** <br />  * 将sql导入到数据库（普通导入） <br />  * <br />  * @param string $sqlfile <br />  * @return boolean <br />  */ <br /> private function _import($sqlfile) { <br />  $name = basename ( $sqlfile ); <br />  $sqls = file ( $sqlfile ); <br />  foreach ( $sqls as $sql ) { <br />   str_replace ( "r", "", $sql ); <br />   str_replace ( "n", "", $sql ); <br />   if (! mysql_query ( trim ( $sql ), $this->db )) <br />    return false; <br />  } <br />  return true; <br /> } <br /> <br /> // 关闭数据库连接 <br /> private function close() { <br />  mysql_close ( $this->db ); <br /> } <br /> <br /> // 锁定数据库，以免备份或导入时出错 <br /> private function lock($tablename, $op = "WRITE") { <br />  if (mysql_query ( "lock tables " . $tablename . " " . $op )) <br />   return true; <br />  else <br />   return false; <br /> } <br /> <br /> // 解锁 <br /> private function unlock() { <br />  if (mysql_query ( "unlock tables" )) <br />   return true; <br />  else <br />   r<mark style="color:transparent">来4源gaodaimacom搞#代%码*网</mark><code>搞代gaodaima码</code>eturn false; <br /> } <br /> <br /> // 析构 <br /> function __destruct() { <br />  mysql_query ( "unlock tables", $this->db ); <br />  mysql_close ( $this->db ); <br /> } <br />} <br />?>

mysql备份恢复分卷处理,调用简单.

喜欢 (0)赏

[搞代码]

分享 (0)