/***************************************************************************
*
- * Copyright (c) by Andreas Unterkircher, unki@netshadow.at
- * All rights reserved
+ * 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
*
***************************************************************************/
+/**
+ * PHPFSPOT_DB class
+ *
+ * @package phpfspot
+ */
class PHPFSPOT_DB {
private $db;
private $parent;
private $is_connected;
private $last_error;
+ private $last_query;
/**
* PHPFSPOT_DB class constructor
*/
public function __construct($parent, $db_path)
{
- $this->parent = $parent;
+ global $phpfspot;
+
+ $this->parent = $phpfspot;
$this->db_path = $db_path;
/* We are starting disconnected */
$this->setConnStatus(false);
- /* Connect to MySQL Database */
+ /* Connect to database */
$this->db_connect();
} // __construct()
/**
* PHPFSPOT_DB database connect
*
- * This function will connect to the database via MDB2
+ * This function will connect to the database
*/
private function db_connect()
{
$this->setConnStatus(false);
}
else {
+ sqlite3_create_function($this->db, 'basename', 1, 'basename');
$this->setConnStatus(true);
}
break;
*/
public function db_query($query = "")
{
- if($this->getConnStatus()) {
-
- 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;
+ 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;
}
- else
- $this->ThrowError("Can't execute query - we are not connected!");
+
+ return $result;
} // db_query()
*/
public function db_exec($query = "")
{
- if($this->getConnStatus()) {
-
- switch($this->parent->cfg->db_access) {
- case 'native':
- if(($result = sqlite3_exec($this->db, $query)) === false)
- $this->ThrowError($this->getLastError());
- break;
- case 'pdo':
- try {
- $result = $this->db->query($query);
- }
- catch (Exception $e){
- $this->ThrowError($e->getLMessage());
- }
- break;
- }
+ 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;
}
- else
- $this->ThrowError("Can't execute query - we are not connected!");
+
+ return true;
} // db_exec()
*/
public function db_fetchSingleRow($query = "")
{
- if($this->getConnStatus()) {
-
- $result = $this->db_query($query);
- switch($this->parent->cfg->db_access) {
- case 'native':
- $row = $result->fetchRow();
- break;
- case 'pdo':
- $row = $result[0];
- break;
- }
- return $row;
+ 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;
}
- else
- $this->ThrowError("Can't fetch row - we are not connected!");
+ return $row;
} // db_fetchSingleRow()
} // db_getNumRows()
- /**
- * PHPFSPOT_DB get primary key
- *
- * This function returns the primary key of the last
- * operated insert SQL query.
- */
- public function db_getid()
- {
- /* Get the last primary key ID from execute query */
- return mysql_insert_id($this->db->connection);
-
- } // db_getid()
-
/**
* PHPFSPOT_DB check table exists
*
*/
public function db_check_table_exists($table_name = "")
{
- if($this->getConnStatus()) {
-
- $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;
- }
-
+ if(!$this->getConnStatus())
return false;
- }
- else
- $this->ThrowError("Can't check table - we are not connected!");
+
+ $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
*
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;
} // 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
?>
projects / phpfspot.git / blobdiff