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

/**

• 初始化
• @param string $host
• @param string $username
• @param string $password
• @param string $database
• @param string $charset
  */
  function __construct($host = 'localhost',$username = 'root',$password = '',$database = 'test',$charset = 'utf8') {
  $this->host = $host;
  $this->username = $username;
  $this->password = $password;
  $this->database = $database;
  $this->charset = $charset;
  // 连接数据库
  $this->db = mysql_connect ( $this->host,$this->username,$this->password ) or die ( "数据库连接失败." );
  // 选择使用哪个数据库
  mysql_select_db ( $this->database,$this->db ) or die ( "无法打开数据库" );
  // 数据库编码方式
  mysql_query ( 'SET NAMES ' . $this->charset,$this->db );
  }

/**

• 导入备份数据
• 说明：分卷文件格式20120516211738_all_v1.sql
• @param string $sqlfile
• @param bool $single
  */
  function restore($sqlfile,$single = FALSE) {
  // 检测文件是否存在
  if (! file_exists ( $sqlfile )) {
  exit ( "文件不存在！请检查" );
  }
  $this->lock ( $this->database );
  // 获取数据库存储位置
  $sqlpath = pathinfo ( $sqlfile );
  $this->sqldir = $sqlpath ['dirname'];
  // 检测是否包含分卷，将类似20120516211738_all_v1.sql从_v分开,有则说明有分卷
  $volume = explode ( "_v",$sqlfile );
  $volume_path = $volume [0];
  echo "请勿刷新及关闭浏览器以防止程序被中止，如有不慎！将导致数据库结构受损
  ";
  echo "正在导入备份数据，请稍等！
  ";
  if (emptyempty ( $volume [1] ) || $single) {
  echo "正在导入sql：" . $sqlfile . '
  ';
  // 没有分卷
  if ($this->_import ( $sqlfile )) {
  echo "数据库导入成功！";
  } else {
  exit ( '数据库导入失败！' );
  }
  } else {
  // 存在分卷，则获取当前是第几分卷，循环执行余下分卷
  $volume_id = explode ( ".sq",$volume [1] );
  // 当前分卷为$volume_id
  $volume_id = intval ( $volume_id [0] );
  while ( $volume_id ) {
  $tmpfile = $volume_path . "_v" . $volume_id . ".sql";
  // 存在其他分卷，继续执行
  if (file_exists ( $tmpfile )) {
  // 执行导入方法
  echo "正在导入分卷$volume_id：" . $tmpfile . '
  ';
  if ($this->_import ( $tmpfile )) {

} else {
exit ( "导入分卷$volume_id：" . $tmpfile . '失败！可能是数据库结构已损坏！请尝试从分卷1开始导入' );
}
} else {
echo "此分卷备份全部导入成功！
";
return;
}
$volume_id ++;
}
}
}

/**

• 将sql导入到数据库（普通导入）
• @param string $sqlfile
• @return boolean
  */
  private function _import($sqlfile) {
  $name = basename ( $sqlfile );
  $sqls = file ( $sqlfile );
  foreach ( $sqls as $sql ) {
  str_replace ( "r","",$sql );
  str_replace ( "n",$sql );
  if (! mysql_query ( trim ( $sql ),$this->db ))
  return false;
  }
  return true;
  }

// 关闭数据库连接
private function close() {
mysql_close ( $this->db );
}

// 锁定数据库，以免备份或导入时出错
private function lock($tablename,$op = "WRITE") {
if (mysql_query ( "lock tables " . $tablename . " " . $op ))
return true;
else
return false;
}

// 解锁
private function unlock() {
if (mysql_query ( "unlock tables" ))
return true;
else
return false;
}

// 析构
function __destruct() {
mysql_query ( "unlock tables",$this->db );
mysql_close ( $this->db );
}
}
?>
mysql备份恢复分卷处理,调用简单.

分卷导入思路:

按行读取sql文件,将每一行当作完整的sql语句存到数组再循环执行插入数据库就可以了,但是在创建表语句分了多行,这个需要单独处理,就这个花了我好长时间的.感觉文章好长啊,主要是那个类文件给占用了.

更新说明:

1.去除sql导入的时候排除sql文件里面的注释'– ‘ 从而解决sql中单双引号不能导入

2.单行读取后的sql直接执行,避免重新将sql语句组合到数组中再从数组中读取导入sql,提高效率.

下载地址: https://github.com/yanue/Dbmanage

导出后的sql文件格式如下: 代码如下: