Mysql.php

Go to the documentation of this file.

<?php
 
namespace GetId3\Extension\Cache;
 
use GetId3\GetId3Core;
use GetId3\Exception\DefaultException;
 
//  available at http://getid3.sourceforge.net                 //
//            or http://www.getid3.org                         //
//                                                             //
// extension.cache.mysql.php - part of GetId3()                //
// Please see readme.txt for more information                  //
//                                                            ///
//                                                             //
// This extension written by Allan Hansen <ahØartemis*dk>      //
// Table name mod by Carlo Capocasa <calroØcarlocapocasa*com>  //
//                                                            ///
 
class Mysql extends GetId3
{
    private $cursor;
 
    private $connection;
 
    public function __construct($host, $database, $username, $password, $table='getid3_cache')
    {
        // Check for mysql support
        if (!function_exists('mysql_pconnect')) {
            throw new DefaultException('PHP not compiled with mysql support.');
        }
 
        // Connect to database
        $this->connection = mysql_pconnect($host, $username, $password);
        if (!$this->connection) {
            throw new DefaultException('mysql_pconnect() failed - check permissions and spelling.');
        }
 
        // Select database
        if (!mysql_select_db($database, $this->connection)) {
            throw new DefaultException('Cannot use database '.$database);
        }
 
        // Set table
        $this->table = $table;
 
        // Create cache table if not exists
        $this->create_table();
 
        // Check version number and clear cache if changed
        $version = '';
        if ($this->cursor = mysql_query("SELECT `value` FROM `".mysql_real_escape_string($this->table)."` WHERE (`filename` = '".mysql_real_escape_string(GetId3Core::VERSION)."') AND (`filesize` = '-1') AND (`filetime` = '-1') AND (`analyzetime` = '-1')", $this->connection)) {
            list($version) = mysql_fetch_array($this->cursor);
        }
        if ($version != GetId3Core::VERSION) {
            $this->clear_cache();
        }
 
        parent::__construct();
    }
 
    public function clear_cache()
    {
        $this->cursor = mysql_query("DELETE FROM `".mysql_real_escape_string($this->table)."`", $this->connection);
        $this->cursor = mysql_query("INSERT INTO `".mysql_real_escape_string($this->table)."` VALUES ('".GetId3Core::VERSION."', -1, -1, -1, '".GetId3Core::VERSION."')", $this->connection);
    }
 
    public function analyze($filename)
    {
        if (file_exists($filename)) {
 
            // Short-hands
            $filetime = filemtime($filename);
            $filesize = filesize($filename);
 
            // Lookup file
            $this->cursor = mysql_query("SELECT `value` FROM `".mysql_real_escape_string($this->table)."` WHERE (`filename` = '".mysql_real_escape_string($filename)."') AND (`filesize` = '".mysql_real_escape_string($filesize)."') AND (`filetime` = '".mysql_real_escape_string($filetime)."')", $this->connection);
            if (mysql_num_rows($this->cursor) > 0) {
                // Hit
                list($result) = mysql_fetch_array($this->cursor);
 
                return unserialize(base64_decode($result));
            }
        }
 
        // Miss
        $analysis = parent::analyze($filename);
 
        // Save result
        if (file_exists($filename)) {
            $this->cursor = mysql_query("INSERT INTO `".mysql_real_escape_string($this->table)."` (`filename`, `filesize`, `filetime`, `analyzetime`, `value`) VALUES ('".mysql_real_escape_string($filename)."', '".mysql_real_escape_string($filesize)."', '".mysql_real_escape_string($filetime)."', '".mysql_real_escape_string(time())."', '".mysql_real_escape_string(base64_encode(serialize($analysis)))."')", $this->connection);
        }
 
        return $analysis;
    }
 
    private function create_table($drop=false)
    {
        $this->cursor = mysql_query("CREATE TABLE IF NOT EXISTS `".mysql_real_escape_string($this->table)."` (
            `filename` VARCHAR(255) NOT NULL DEFAULT '',
            `filesize` INT(11) NOT NULL DEFAULT '0',
            `filetime` INT(11) NOT NULL DEFAULT '0',
            `analyzetime` INT(11) NOT NULL DEFAULT '0',
            `value` TEXT NOT NULL,
            PRIMARY KEY (`filename`,`filesize`,`filetime`)) ENGINE=MyISAM", $this->connection);
        echo mysql_error($this->connection);
    }
}