Sqlite3.php

Go to the documentation of this file.

<?php

namespace GetId3\Extension\Cache;

use GetId3\GetId3Core;

//  available at http://getid3.sourceforge.net                                 //
//            or http://www.getid3.org                                        ///
// extension.cache.sqlite3.php - part of GetId3()                              //
// Please see readme.txt for more information                                  //
//                                                                            ///
// MySQL extension written by Allan Hansen <ahØartemis*dk>                     //
// Table name mod by Carlo Capocasa <calroØcarlocapocasa*com>                  //
// MySQL extension was reworked for SQLite3 by Karl G. Holz <newaeonØmac*com>  //
//                                                                            ///

class Sqlite3 extends GetId3
{
    private $db;

    private $table;

    public function __construct($table = 'getid3_cache', $hide = false)
    {
        $this->table = $table; // Set table
        $file = dirname(__FILE__) . '/' . basename(__FILE__, 'php') . 'sqlite';
        if ($hide) {
            $file = dirname(__FILE__) . '/.ht.' . basename(__FILE__, 'php') . 'sqlite';
        }
        $this->db = new SQLite3($file);
        $db = $this->db;
        $this->create_table();   // Create cache table if not exists
        $version = '';
        $sql = $this->version_check;
        $stmt = $db->prepare($sql);
        $stmt->bindValue(':filename', GetId3Core::VERSION, SQLITE3_TEXT);
        $result = $stmt->execute();
        list($version) = $result->fetchArray();
        if ($version != GetId3Core::VERSION) { // Check version number and clear cache if changed
            $this->clear_cache();
        }

        return parent::__construct();
    }

    public function __destruct()
    {
        $db = $this->db;
        $db->close();
    }

    private function clear_cache()
    {
        $db = $this->db;
        $sql = $this->delete_cache;
        $db->exec($sql);
        $sql = $this->set_version;
        $stmt = $db->prepare($sql);
        $stmt->bindValue(':filename', GetId3Core::VERSION, SQLITE3_TEXT);
        $stmt->bindValue(':dirname', GetId3Core::VERSION, SQLITE3_TEXT);
        $stmt->bindValue(':val', GetId3Core::VERSION, SQLITE3_TEXT);

        return $stmt->execute();
    }

    public function analyze($filename)
    {
        if (!file_exists($filename)) {
            return false;
        }
        // items to track for caching
        $filetime = filemtime($filename);
        $filesize = filesize($filename);
        // this will be saved for a quick directory lookup of analized files
        // ... why do 50 seperate sql quries when you can do 1 for the same result
        $dirname = dirname($filename);
        // Lookup file
        $db = $this->db;
        $sql = $this->get_id3_data;
        $stmt = $db->prepare($sql);
        $stmt->bindValue(':filename', $filename, SQLITE3_TEXT);
        $stmt->bindValue(':filesize', $filesize, SQLITE3_INTEGER);
        $stmt->bindValue(':filetime', $filetime, SQLITE3_INTEGER);
        $res = $stmt->execute();
        list($result) = $res->fetchArray();
        if (count($result) > 0) {
            return unserialize(base64_decode($result));
        }
        // if it hasn't been analyzed before, then do it now
        $analysis = parent::analyze($filename);
        // Save result
        $sql = $this->cache_file;
        $stmt = $db->prepare($sql);
        $stmt->bindValue(':filename', $filename, SQLITE3_TEXT);
        $stmt->bindValue(':dirname', $dirname, SQLITE3_TEXT);
        $stmt->bindValue(':filesize', $filesize, SQLITE3_INTEGER);
        $stmt->bindValue(':filetime', $filetime, SQLITE3_INTEGER);
        $stmt->bindValue(':atime', time(), SQLITE3_INTEGER);
        $stmt->bindValue(':val', base64_encode(serialize($analysis)),
                                                         SQLITE3_TEXT);
        $res = $stmt->execute();

        return $analysis;
    }

    private function create_table()
    {
        $db = $this->db;
        $sql = $this->make_table;

        return $db->exec($sql);
    }

    public function get_cached_dir($dir)
    {
        $db = $this->db;
        $rows = array();
        $sql = $this->get_cached_dir;
        $stmt = $db->prepare($sql);
        $stmt->bindValue(':dirname', $dir, SQLITE3_TEXT);
        $res = $stmt->execute();
        while ($row = $res->fetchArray()) {
            $rows[] = unserialize(base64_decode($row));
        }

        return $rows;
    }

    public function __get($name)
    {
        switch ($name) {
            case 'version_check':
                return "SELECT val FROM $this->table WHERE filename = :filename AND filesize = '-1' AND filetime = '-1' AND analyzetime = '-1'";
                break;
            case 'delete_cache':
                return "DELETE FROM $this->table";
                break;
            case 'set_version':
                return "INSERT INTO $this->table (filename, dirname, filesize, filetime, analyzetime, val) VALUES (:filename, :dirname, -1, -1, -1, :val)";
                break;
            case 'get_id3_data':
                return "SELECT val FROM $this->table WHERE filename = :filename AND filesize = :filesize AND filetime = :filetime";
                break;
            case 'cache_file':
                return "INSERT INTO $this->table (filename, dirname, filesize, filetime, analyzetime, val) VALUES (:filename, :dirname, :filesize, :filetime, :atime, :val)";
                break;
            case 'make_table':
                return "CREATE TABLE IF NOT EXISTS $this->table (filename VARCHAR(255) NOT NULL DEFAULT '', dirname 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', val text not null, PRIMARY KEY (filename, filesize, filetime))";
                break;
            case 'get_cached_dir':
                return "SELECT val FROM $this->table WHERE dirname = :dirname";
                break;
        }
    }
}