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);
    }
}