phpfspot

 <?php

 /***************************************************************************

  *

  * phpfspot, presents your F-Spot photo collection in Web browsers.

  *

  * Copyright (c) by Andreas Unterkircher

  *

  *  This program is free software; you can redistribute it and/or modify

  *  it under the terms of the GNU General Public License as published by

  *  the Free Software Foundation; either version 2 of the License, or

  *  any later version.

  *

  *  This program is distributed in the hope that it will be useful,

  *  but WITHOUT ANY WARRANTY; without even the implied warranty of

  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

  *  GNU General Public License for more details.

  *

  *  You should have received a copy of the GNU General Public License

  *  along with this program; if not, write to the Free Software

  *  Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.

  *

  ***************************************************************************/

 /**

  * PHPFSPOT_DB class

  *

  * @package phpfspot

  */

 class PHPFSPOT_DB {

    private $db;

    private $db_path;

    private $parent;

    private $is_connected;

    private $last_error;

    private $last_query;

    /**

     * PHPFSPOT_DB class constructor

     *

     * This constructor initially connect to the database.

     */

    public function __construct($parent, $db_path)

    {

       global $phpfspot;

       $this->parent = $phpfspot;

       $this->db_path = $db_path;

       /* We are starting disconnected */

       $this->setConnStatus(false);

       /* Connect to database */

       $this->db_connect();

    } // __construct()

    /**

     * PHPFSPOT_DB class deconstructor

     *

     * This destructor will close the current database connection.

     */

    public function __destruct()

    {

       $this->db_disconnect();

    } // _destruct()

    /**

     * PHPFSPOT_DB database connect

     *

     * This function will connect to the database

     */

    private function db_connect()

    {

       switch($this->parent->cfg->db_access) {

          case 'native':

             if(($this->db = sqlite3_open($this->db_path)) === false) {

                $this->throwError("Unable to connect to database:" . $this->getLastError());

                $this->setConnStatus(false);

             }

             else {

                sqlite3_create_function($this->db, 'basename', 1, 'basename');

                $this->setConnStatus(true);

             }

             break;

          case 'pdo':

             try {

                $this->db =  new PDO("sqlite:".$this->db_path);

                $this->setConnStatus(true);

             }

             catch (Exception $e) {

                $this->throwError("Unable to connect to database:" . $e->getMessage());

                $this->setConnStatus(false);

             }

             break;

       }

    } // db_connect()

    /**

     * PHPFSPOT_DB database disconnect

     *

     * This function will disconnected an established database connection.

     */

    private function db_disconnect()

    {

       switch($this->parent->cfg->db_access) {

          case 'native':

             if($this->getConnStatus())

                sqlite3_close($this->db);

             break;

          case 'pdo':

             $this->db = NULL;

             break;

       }

    } // db_disconnect()

    /**

     * PHPFSPOT_DB database query

     *

     * This function will execute a SQL query and return the result as

     * object.

     */

    public function db_query($query = "")

    {

       if(!$this->getConnStatus())

          return false;

       $this->last_query = $query;

       switch($this->parent->cfg->db_access) {

          case 'native':

             if(($result = sqlite3_query($this->db, $query)) === false)

                $this->ThrowError($this->getLastError());

             break;

          case 'pdo':

             try{

                $result = $this->db->query($query);

                return $result;

             }

             catch (Exception $e) {

                $this->ThrowError($e->getMessage());

                $result= NULL;

             }

             break;

       }

       return $result;

    } // db_query()

    /**

     * PHPFSPOT_DB database query & execute

     *

     * This function will execute a SQL query and return nothing.

     */

    public function db_exec($query = "")

    {

       if(!$this->getConnStatus())

          return false;

       $this->last_query = $query;

       switch($this->parent->cfg->db_access) {

          case 'native':

             if(($result = sqlite3_exec($this->db, $query)) === false) {

                $this->ThrowError($this->getLastError());

                return false;

             }

             break;

          case 'pdo':

             try {

                $result = $this->db->query($query);

             }

             catch (Exception $e){

                $this->ThrowError($e->getLMessage());

                return false;

             }

             break;

       }

       return true;

    } // db_exec()

    public function db_fetch_object($resource)

    {

       switch($this->parent->cfg->db_access) {

          case 'native':

             return sqlite3_fetch_array($resource);

          case 'pdo':

             return $resource->fetch();

       }

    } // db_fetch_object

    /**

     * PHPFSPOT_DB fetch ONE row

     *

     * This function will execute the given but only return the

     * first result.

     */

    public function db_fetchSingleRow($query = "")

    {

       if(!$this->getConnStatus())

          return false;

       $result = $this->db_query($query);

       switch($this->parent->cfg->db_access) {

          case 'native':

             $row = $this->db_fetch_object($result);

             break;

          case 'pdo':

             $row = $result->fetch();

             break;

       }

       return $row;

    } // db_fetchSingleRow()

    /**

     * PHPFSPOT_DB number of affected rows

     *

     * This functions returns the number of affected rows but the

     * given SQL query.

     */

    public function db_getNumRows($query = "")

    {

       /* Execute query */

       $result = $this->db_query($query);

       /* Errors? */

       if(PEAR::isError($result))

          $this->throwError($result->getMessage());

       return $result->numRows();

    } // db_getNumRows()

    /**

     * PHPFSPOT_DB check table exists

     *

     * This function checks if the given table exists in the

     * database

     * @param string, table name

     * @return true if table found otherwise false

     */

    public function db_check_table_exists($table_name = "")

    {

       if(!$this->getConnStatus())

          return false;

       $result = $this->db_query("SELECT name FROM sqlite_master WHERE type='table'");

       switch($this->parent->cfg->db_access) {

          case 'native':

             while($table = $this->db_fetch_object($result)) {

                if($table['name'] == $table_name)

                   return true;

             }

             break;

          case 'pdo':

             foreach($result as $table ){

                if($table['name'] == $table_name)

                   return true;

             }

             break;

       }

       return false;

    } // db_check_table_exists()

    /**

     * PHPFSPOT_DB check column exist

     *

     * This function checks if the given column exists within

     * the specified table.

     */

    public function db_check_column_exists($table_name, $column)

    {

       if(!$this->getConnStatus())

          return false;

       $result = $this->db_query("

          SELECT sql

          FROM

             (SELECT * FROM sqlite_master UNION ALL

              SELECT * FROM sqlite_temp_master)

          WHERE

             tbl_name LIKE '". $table_name ."'

          AND type!='meta'

          AND sql NOT NULL

          AND name NOT LIKE 'sqlite_%'

          ORDER BY substr(type,2,1), name

       ");

       while($row = $this->db_fetch_object($result)) {

          /* CREATE TABLE xx ( col1 int, col2 bool, col3 ...) */

          if(strstr($row['sql'], " ". $column ." ") !== false)

                return true;

       }

       return false;

    } // db_check_column_exists()

    /**

     * PHPFSPOT_DB get connection status

     *

     * This function checks the internal state variable if already

     * connected to database.

     */

    private function setConnStatus($status)

    {

       $this->is_connected = $status;

    } // setConnStatus()

    /**

     * PHPFSPOT_DB set connection status

     * This function sets the internal state variable to indicate

     * current database connection status.

     */

    private function getConnStatus()

    {

       return $this->is_connected;

    } // getConnStatus()

    /**

     * PHPFSPOT_DB throw error

     *

     * This function shows up error messages and afterwards through exceptions.

     */

    private function ThrowError($string)

    {

       if(!defined('DB_NOERROR'))  {

          print "Error during query: ". $this->last_query ."<br /><br />\n";

          print "<br /><br />". $string ."<br /><br />\n";

          try {

             throw new Exception;

          }

          catch(Exectpion $e) {

          }

       }

       $this->last_error = $string;

    } // ThrowError()

    private function getLastError()

    {

       switch($this->parent->cfg->db_access) {

          case 'native':

             return sqlite3_error($this->db);

          case 'pdo':

             return "". $this->db->errorInfo();

       }

    } // getLastError()

    /**

     * start transaction

     *

     * this will start a transaction on ACID-supporting database

     * systems.

     *

     * @return bool

     */

    public function db_start_transaction()

    {

       if(!$this->getConnStatus())

          return false;

       $result = $this->db_exec("BEGIN");

       /* Errors? */

       if(PEAR::isError($result))

          $this->throwError($result->getMessage() .' - '. $result->getUserInfo());

       return true;

    } // db_start_transaction()

    /**

     * commit transaction

     *

     * this will commit an ongoing transaction on ACID-supporting

     * database systems

     *

     * @return bool

     */

    public function db_commit_transaction()

    {

       if(!$this->getConnStatus())

          return false;

       $result = $this->db_exec("COMMIT");

       /* Errors? */

       if(PEAR::isError($result))

          $this->throwError($result->getMessage() .' - '. $result->getUserInfo());

       return true;

    } // db_commit_transaction()

    /**

     * rollback transaction()

     *

     * this function aborts a on going transaction

     *

     * @return bool

     */

    public function db_rollback_transaction()

    {

       if(!$this->getConnStatus())

          return false;

       $result = $this->db_exec("ROLLBACK");

       /* Errors? */

       if(PEAR::isError($result))

          $this->throwError($result->getMessage() .' - '. $result->getUserInfo());

       return true;

    } // db_rollback_transaction()

 } // PHPFSPOT_DB

 ?>