支持SAE的数据库备份Thinkphp3.2.3

数据库备份是一个好看的功能，支持SAE的数据库备份的类库
// +----------------------------------------------------------------------
// | Author: 左边 （加群：366504956(刚建，欢迎) 交流thinkphp下微信开发）
// +----------------------------------------------------------------------



//类库放在Application\Common\Libs目录下
use \Common\Libs\MySQLReback;



//数据备份
public function sqlback(){
$DataDir = "Databak";
if(!file_exists($DataDir))mkdir($DataDir) ;

$opt = trim(I('get.opt'));
$file = trim(I('get.file'));
$mr = new MySQLReback();
$mr->setDBName(C('DB_NAME'));
$mr->setPath($DataDir);

if ($opt) {
if ($opt == 'backup') {
$mr->backup()?$alert = '数据库备份成功！':$alert = $mr->error();
}
if($opt == 'optimize'){
$mr->optimize()?$alert = '数据库优化成功！':$alert = $mr->error();
}
if ($opt == 'redo' && $file) {
$r = $mr->recover($file);
$alert = '数据库还原成功'.$r['qty'] ."条";
}
if ($opt== 'del' && $file) {
$mr->remove($file)?$alert = '数据库删除成功！':$alert = $mr->error();
}
if ($opt == 'download' && $file ) $mr->DownloadFile($file);
}
$lists = $mr->dataList($DataDir);
$this->assign("list", $lists);
if($alert)
$this->assign('alert',"alert('".$alert."');");
$this->display();
}页面






系统管理 > 数据库管理

编号	文件名	备份时间	文件大小	操作
{$key+1}	{$vo.filename}	{$vo.filetime}	{:$vo['filesize']/1000} KB

类文件
// +----------------------------------------------------------------------
// | Author: 左边 （加群：366504956(刚建，欢迎) 交流thinkphp下微信开发）
// +----------------------------------------------------------------------


namespace Common\Libs;
use Think\Db;
use sinacloud\sae\Storage as Storage;

class MySQLReback {

private $path;
private $isCompress;
private $content;
private $dbName;
private $error;
private $sign = '/*++$*/';

const DIR_SEP = DIRECTORY_SEPARATOR;

public function __construct() {
$this->path = 'Databak';

}

public function setDBName($dbName) {
$this->dbName = $dbName;
}

public function setPath($path) {
$this->path = $path;
}

public function setIsCompress($isCompress){
$this->isCompress = $isCompress;
}

private function getFile($fileName) {

if(strtolower(STORAGE_TYPE) == 'sae'){
$s = new Storage();
$r = json_encode($s -> getObject(strtolower( $this->path ), $fileName) );
$r = json_decode($r,true);
return $r['body'];

}
$fileName = $this->path . self::DIR_SEP . $fileName;
if (is_file($fileName)) {
$ext = strrchr($fileName, '.');
if ($ext == '.sql') {
return file_get_contents($fileName);
} elseif ($ext == '.gz') {
return implode('', gzfile($fileName));
} else {
$this->error = '_无法识别的文件格式!';
return;
}
} else {
$this->error = '文件不存在!';
return;
}
}


private function setFile($content) {

$recognize = $this->dbName;
$fileName = $recognize . '_' . date('YmdHis') . '_' . mt_rand(100000000, 999999999) . '.sql';

if(strtolower(STORAGE_TYPE) == 'sae'){
$s = new Storage();

$root_path = strtolower($this->$path);
//不存在就创建
$pathArr = $s->listBuckets();
if(!in_array($root_path,$pathArr) ){
$s->putBucket($root_path,'.r:*');
}
//写入
$path = $s->putObject($content, $root_path, $fileName);
if($path !== true){
$this->error = "写入文件失败";
return;
}
return $path;
}

$fileName = $this->path . self::DIR_SEP .$fileName;
$path = $this->cetPath($fileName);
if ($path !== true) {
$this->error = "无法创建备份目录,目录 '$path'";
return;
}
if ($this->isCompress == 0) {
if (!file_put_contents($fileName, $content, LOCK_EX)) {
$this->error = '写入文件失败,请检查磁盘空间或者权限!';
return;
}
} else {
if (function_exists('gzwrite')) {
$fileName .= '.gz';
$gz = gzopen($fileName, 'wb');
if ($gz) {
$gw = gzwrite($gz, $content);
gzclose($gz);
return $gw;
} else {
$this->error = '写入文件失败,请检查磁盘空间或者权限!';
return;
}
} else {
$this->error = '没有开启gzip扩展!';
return;
}
}
}

private function cetPath($fileName) {
$dirs = explode(self::DIR_SEP, dirname($fileName));
$tmp = '';
foreach ($dirs as $dir) {
$tmp .= $dir . self::DIR_SEP;
if (!file_exists($tmp) && !@mkdir($tmp, 0777))
return;
}
return true;
}


//备份
public function backup(){
$db = Db::getInstance();
$tables = $db->query('SHOW TABLE STATUS');
$tables = array_map('array_change_key_case', $tables);
$sql = '/* This file is created by MySQLReback ' . date('Y-m-d H:i:s') . ' */';
foreach ($tables as $value) {
$table = $value['name'];
$result = $db->query("SHOW CREATE TABLE `{$table}`");
$create = $result[0]['create table'];
$sql .= "\r\n /* 创建表结构 {$table} */";
$sql .= "\r\n DROP TABLE IF EXISTS {$table};". $this->sign ." {$create};" . $this->sign;

$result = $db->query("SELECT COUNT(*) AS count FROM `{$table}`");
$count = $result['0']['count'];
if($count){
$sql .= "\r\n /* 插入数据 {$table} */";

$result = $db->query("SELECT * FROM {$table}");

foreach ($result as $row) {
$row = array_map('addslashes', $row);
$sql .= "\r\n INSERT INTO {$table} VALUES ( '" . str_replace( array("\r","\n") , array('\r','\n') ,implode("', '", $row) ) . "' );".$this->sign;
}
}

}

if ($sql) {
return $this->setFile($sql);
}else{
$this->error = '数据为空';
}
return;

}

//删除备份
public function remove($fileName){
if(strtolower(STORAGE_TYPE) == 'sae'){
$s = new Storage();
$r = $s->deleteObject(strtolower($this->path), $fileName);
if(!$r){
$this->error = '删除失败';
return;
}
return true;
}
if(!@unlink($this->path . self::DIR_SEP . $fileName)){
$this->error = '删除失败';
return;
}
return true;
}

//表优化
public function optimize(){
if(strtolower(STORAGE_TYPE) == 'sae'){
$this->error='SAE数据库不支持表优化';
return ;
}
$db = Db::getInstance();
$list = $db->query('SHOW TABLE STATUS');
$list = array_map('array_change_key_case', $list);
foreach ($list as $key => $value) {
$tables[] = $value['name'];
}

if($tables) {
if(is_array($tables)){
$tables = implode('`,`', $tables);
$list[] = $db->execute("OPTIMIZE TABLE `{$tables}`");
}
}
return $list;
}

//恢复
public function recover($fileName) {
$content = $this->getFile($fileName);
if (!$content) {
if($this->error)return;
return '数据为空';
}
$content = explode($this->sign, $content);
$db = Db::getInstance();
foreach ($content as $i => $sql) {
$sql = trim($sql);
if (!empty($sql)){

$res = $db->execute($sql);

if($res){
$rs['qty']++;
}else{
$rt[] = $sql;
}
}
}
$rs['error'] = $rt;
return $rs;
}

public function DownloadFile($fileName) {
ob_end_clean();
header("Cache-Control: must-revalidate, post-check=0, pre-check=0");
header('Content-Description: File Transfer');
header('Content-Type: application/octet-stream');

if(strtolower(STORAGE_TYPE) == 'sae'){
$s = new Storage();
$r = json_encode($s -> getObject(strtolower( $this->path ), $fileName) );
$r = json_decode($r,true);
header('Content-Disposition: attachment; filename="' . $fileName . '"');
echo $r['body'];

}else{
$fileName = $this->path . self::DIR_SEP . $fileName;
$stat = stat($this->path . self::DIR_SEP . $filename);
header('Content-Disposition: attachment; filename="' . $fileName . '"');
header('Content-Length: ' . $stat['size']);
readfile($fileName);
}

}

public function dataList() {

if(strtolower(STORAGE_TYPE) == 'sae'){
$s = new Storage();
$f = $s->getBucket( strtolower($this->path) );
foreach ($f as $v) {
$rt['filename'] = $v['name'];
$rt['filetime'] = date('Y-m-d H:i:s',strtotime($v['last_modified']) );
$rt['filesize'] = $v['bytes'];
$FileAndFolderAyy[] = $rt;
}

}else{
$FilePath = opendir($this->path);
while (false !== ($filename = readdir($FilePath))) {
if ($filename!="." && $filename!=".."){
$stat = stat($this->path .'/'. $filename);
$rt['filename'] = $filename;
$rt['filetime'] = date('Y-m-d H:i:s', $stat['mtime'] );
$rt['filesize'] = $stat['size'];
$FileAndFolderAyy[] = $rt;
}
}
}
$Order == 0 ? sort($FileAndFolderAyy) : rsort($FileAndFolderAyy);
return $FileAndFolderAyy;
}




public function error(){
return $this->error;
}


}

?>

MySQLReback.class.zip ( 2.71 KB 下载：14 次 )

AD：真正免费，域名+虚机+企业邮箱=0元