phpmysqlautobackup_extras.php

Go to the documentation of this file.

<?php
/*******************************************************************************************
    phpMySQLAutoBackup  -  Author:  http://www.DWalker.co.uk - released under GPL License
           For support and help please try the forum at: http://www.dwalker.co.uk/forum/
********************************************************************************************
Version    Date              Comment
0.2.0      7th July 2005     GPL release
0.3.0      June 2006  Upgrade - added ability to backup separate tables
0.4.0      Dec 2006   removed bugs/improved code
1.4.0      Dec 2007   improved faster version
1.5.0      Dec 2008   improved and added FTP backup to remote site
1.5.4      Nov 2009   Version printed in email
1.5.5      Feb 2011  more options for config added - email reports only and/or backup, save backup file to local and/or remote server.
                                Reporter added: email report of last 6 (or more) backup stats (date, total bytes exported, total lines exported) plus any errors
                                MySQL error reporting added  and Automated version checker added
1.6.0      Dec 2011  PDO version
1.6.1      April 2012 - CURLOPT_TRANSFERTEXT turned off (to stop garbaging zip file on transfer) and bug removed from write_back
********************************************************************************************/
$phpMySQLAutoBackup_version="1.6.1";
// ---------------------------------------------------------
function has_data($value)
{
 if (is_array($value)) return (sizeof($value) > 0)? true : false;
 else return (($value != '') && (strtolower($value) != 'null') && (strlen(trim($value)) > 0)) ? true : false;
}

function xmail ($to_emailaddress,$from_emailaddress, $subject, $content, $file_name, $backup_type, $newline, $ver)
{
 $mail_attached = "";
 $boundary = "----=_NextPart_000_01FB_010".md5($to_emailaddress);
 $mail_attached.="--".$boundary.$newline
                       ."Content-Type: application/octet-stream;$newline name=\"$file_name\"$newline"
                       ."Content-Transfer-Encoding: base64$newline"
                       ."Content-Disposition: attachment;$newline filename=\"$file_name\"$newline$newline"
                       .chunk_split(base64_encode($content)).$newline;
 $mail_attached .= "--".$boundary."--$newline";
 $add_header ="MIME-Version: 1.0".$newline."Content-Type: multipart/mixed;$newline boundary=\"$boundary\" $newline";
 $mail_content="--".$boundary.$newline."Content-Type: text/plain; $newline charset=\"iso-8859-1\"$newline"."Content-Transfer-Encoding: 7bit$newline $newline BACKUP Successful...$newline $newline Please see attached for your zipped Backup file; $backup_type $newline If this is the first backup then you should test it restores correctly to a test server.$newline $newline phpMySQLAutoBackup (version $ver) is developed by http://www.dwalker.co.uk/ $newline $newline Have a good day now you have a backup of your MySQL db  :-) $newline $newline Please consider making a donation at: $newline http://www.dwalker.co.uk/make_a_donation.php $newline (every penny or cent helps)$newline".$mail_attached;
 return mail($to_emailaddress, $subject, $mail_content, "From: $from_emailaddress".$newline."Reply-To:$from_emailaddress".$newline.$add_header);
}

function write_backup($gzdata, $backup_file_name)
{
 $fp = fopen(LOCATION."../backups/".$backup_file_name, "w");
 fwrite($fp, $gzdata);
 fclose($fp);
 //check folder is protected - stop HTTP access
 if (!file_exists(LOCATION."../backups/.htaccess"))
 {
  $fp = fopen(LOCATION."../backups/.htaccess", "w");
  fwrite($fp, "deny from all");
  fclose($fp);
 }
 delete_old_backups();
}

function delete_old_backups()
{
    $files=$keep=array();
    $prefix = 'mysql_'.DBNAME;
    $suffix = ".sql.gz";
    $dir = LOCATION."../backups/";
    if ($handle = opendir($dir))
      {
       while (false !== ($file = readdir($handle)))
        {
         if ((filetype($dir.$file) == "file") && (substr($file,0,strlen($prefix)) == $prefix) && (substr($file,-strlen($suffix)) == $suffix) && (filesize($dir.$file)>0))
          {
           $files[filemtime($dir.$file)]= $file;       
          }
         }
        closedir($handle);
        krsort($files);
        $slice = min(TOTAL_BACKUP_FILES_TO_RETAIN,sizeof($files));
        if ($slice)
         {
          $erase = array_slice($files,TOTAL_BACKUP_FILES_TO_RETAIN);
          foreach ($erase as $key=>$thisOne)
           {
            unlink($dir.$thisOne);
           }
         } 
      }
}



class transfer_backup
{
      public $error = "";
      public function transfer_data($ftp_username,$ftp_password,$ftp_server,$ftp_path,$filename)
      {
       if (function_exists('curl_exec'))
       {
        $file=LOCATION."../backups/".$filename;
        $fp = fopen($file, "r");
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, "ftp://$ftp_username:$ftp_password@$ftp_server.$ftp_path".$filename);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_UPLOAD, 1);
        curl_setopt($ch, CURLOPT_INFILE, $fp);
        curl_setopt($ch, CURLOPT_INFILESIZE, filesize($file));
        curl_setopt($ch, CURLOPT_TRANSFERTEXT, 0);
        curl_setopt($ch, CURLOPT_REFERER, $_SERVER['HTTP_HOST']." - via phpMySQLAutoBackup");
        $output = curl_exec($ch);
        $info = curl_getinfo($ch);
        if (empty($info['http_code'])) $this->error = "\n\nFTP ERROR - Failed to transfer backup file to remote ftp server";
        else
        {
         $http_codes = parse_ini_file(LOCATION."http_codes.ini");
         if ($info['http_code']!=226) $this->error = "\n\nFTP ERROR - server response: \n".$info['http_code']
                                            ." " . $http_codes[$info['http_code']]
                                            ."\nfor more detail please refer to: http://www.w3.org/Protocols/rfc959/4_FileTransfer.html"                                            ;
        }
        curl_close($ch);

       }
       else $this->error = "\n\nWARNING: FTP will not function as PHP CURL does not exist on your hosting account - try a new host:  http://www.seiretto.com";
       return $this->error;
      }
}


class record
{
      public function save($date, $bytes, $lines)
      {
       $dbc = dbc::instance();
       $result = $dbc->prepare("SHOW TABLES LIKE 'phpmysqlautobackup_log' ");
       $rows = $dbc->executeGetRows($result);
       if(count($rows)<1)
       {
        $q="CREATE TABLE IF NOT EXISTS `phpmysqlautobackup_log` (
            `date` int(11) NOT NULL,
            `bytes` int(11) NOT NULL,
            `lines` int(11) NOT NULL,
             PRIMARY KEY (`date`) )";
        $result = $dbc->prepare($q);
        $result = $dbc->execute($result);
       }
       $query="INSERT INTO `phpmysqlautobackup_log` (`date`, `bytes`, `lines`)
                 VALUES ('$date', '$bytes', '$lines')";
       $result = $dbc->prepare($query);
       $result = $dbc->execute($result);
       $query="SELECT date FROM `phpmysqlautobackup_log` ORDER BY `date` DESC LIMIT 0 , ".LOG_REPORTS_MAX;
       $result = $dbc->prepare($query);
       $rows = $dbc->executeGetRows($result);

       $search_date=$rows[count($rows)-1]['date'];
       $query="delete FROM `phpmysqlautobackup_log` where date<'$search_date' ";
       $result = $dbc->prepare($query);
       $result = $dbc->execute($result);
      }

      public function get()
      {
       $dbc = dbc::instance();
       $result = $dbc->prepare("SELECT * FROM `phpmysqlautobackup_log` ORDER BY `date` DESC ");
       $rows = $dbc->executeGetRows($result);
       $report="\nBelow are the records of the last ".LOG_REPORTS_MAX." backups.\nDATE and TIME (total bytes, Total lines exported)";
       foreach ($rows as $row)
       {
        $report.= "\n".strftime("%d %b %Y - %H:%M:%S",$row['date'])." (";
        $report.= number_format(($row['bytes']/1000), 2, '.', '') ." KB, ";
        $report.= number_format($row['lines'])." lines)";
       }
       return $report;
      }

}

class version
{
 public function check($version)
      {
       $newest_version=$version;
       if (function_exists('curl_exec'))
       {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, "http://www.dwalker.co.uk/versions/phpMySQLAutoBackup.php");
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
        $newest_version=curl_exec($ch);
        curl_close($ch);
       }
       /*elseif ($fp = fsockopen("www.dwalker.co.uk", 80, $errno, $errstr, 30));
       {
        $headers ="GET /versions/phpMySQLAutoBackup.php HTTP/1.0\r\nHost: dwalker.co.uk\r\n"
                . "Content-Type: application/x-www-form-urlencoded\r\n"
                . "\r\nConnection: close\r\n\r\n";
        fwrite($fp, $headers);
        while (!feof($fp))
        {
         $newest_version= fgets($fp, 128);
        }
        fclose($fp);
       } */
       if ($version!=$newest_version) return "*WARNING: upgrade required! Please visit: http://www.dwalker.co.uk/phpmysqlautobackup/ ";
      }
}

class dbc extends PDO
{
 protected static $instance;

 public function __construct()
 {   
   $options = array(PDO::ATTR_PERSISTENT => true,PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION);
   try {
        $this->dbconn = new PDO(DBDRIVER.":host=".DBHOST.";port=".DBPORT.";dbname=".DBNAME,DBUSER,DBPASS,$options);
        return $this->dbconn;
       }
    catch (PDOException $e){ $this->reportDBError($e->getMessage()); }   
 }
 
 public function reportDBError($msg)
 {
  if (DEBUG) print_r('<div style="padding:10%;"><h3>'.nl2br($msg).'</h3></div>');
  else
  {
   if(!session_id()) session_start();
   $_SESSION['pmab_mysql_errors'] = "\n\nMySQL error: ".$msg."\n";
  }

 }
 
 public static function instance()
 {
  if (!isset(self::$instance)) self::$instance = new self();
  return self::$instance;
 }

 public function prepare($query) {
  try { return $this->dbconn->prepare($query); }
   catch (PDOException $e){ $this->reportDBError($e->getMessage()); }   
 }      

 public function bindParam($query) {
  try { return $this->dbconn->bindParam($query); }
   catch (PDOException $e){ $this->reportDBError($e->getMessage()); }     
 }

 public function query($query) {
  try {
       if ($this->query($query)) return $this->fetchAll();
       else return 0;
      } 
   catch (PDOException $e){ $this->reportDBError($e->getMessage()."<hr>".$e->getTraceAsString()); } }

 public function execute($result) {//use for insert/update/delete
  try { if ($result->execute()) return $result; } 
   catch (PDOException $e){ $this->reportDBError($e->getMessage()."<hr>".$e->getTraceAsString()); }     
 }
 public function executeGetRows($result) {//use to retrieve rows of data
  try { 
       if ($result->execute()) return $result->fetchAll(PDO::FETCH_ASSOC);
       else return 0;
      }
    catch (PDOException $e){ $this->reportDBError($e->getMessage()."<hr>".$e->getTraceAsString()); }     
 }

 public function __clone()
 {  //not allowed
 }
 public function __destruct()
 {
  $this->dbconn = null;
 }
}