| | |
| | | | program/include/rcube_mdb2.php | |
| | | | | |
| | | | This file is part of the Roundcube Webmail client | |
| | | | Copyright (C) 2005-2009, Roundcube Dev. - Switzerland | |
| | | | Copyright (C) 2005-2009, The Roundcube Dev Team | |
| | | | Licensed under the GNU GPL | |
| | | | | |
| | | | PURPOSE: | |
| | |
| | | * @author David Saez Padros <david@ols.es> |
| | | * @author Thomas Bruederli <roundcube@gmail.com> |
| | | * @author Lukas Kahwe Smith <smith@pooteeweet.org> |
| | | * @version 1.17 |
| | | * @version 1.18 |
| | | * @link http://pear.php.net/package/MDB2 |
| | | */ |
| | | class rcube_mdb2 |
| | |
| | | var $db_error_msg = ''; |
| | | |
| | | private $debug_mode = false; |
| | | private $write_failure = false; |
| | | private $a_query_results = array('dummy'); |
| | | private $last_res_id = 0; |
| | | private $tables; |
| | |
| | | 'persistent' => $this->db_pconn, |
| | | 'emulate_prepared' => $this->debug_mode, |
| | | 'debug' => $this->debug_mode, |
| | | 'debug_handler' => 'mdb2_debug_handler', |
| | | 'debug_handler' => array($this, 'debug_handler'), |
| | | 'portability' => MDB2_PORTABILITY_ALL ^ MDB2_PORTABILITY_EMPTY_TO_NULL); |
| | | |
| | | if ($this->db_provider == 'pgsql') { |
| | |
| | | // Already connected |
| | | if ($this->db_connected) { |
| | | // connected to read-write db, current connection is ok |
| | | if ($this->db_mode == 'w') |
| | | if ($this->db_mode == 'w' && !$this->write_failure) |
| | | return; |
| | | |
| | | // no replication, current connection is ok for read and write |
| | |
| | | |
| | | $this->db_handle = $this->dsn_connect($dsn); |
| | | $this->db_connected = !PEAR::isError($this->db_handle); |
| | | $this->db_mode = $mode; |
| | | |
| | | if ($this->db_connected) |
| | | $this->db_mode = $mode; |
| | | } |
| | | |
| | | |
| | |
| | | |
| | | |
| | | /** |
| | | * Is database replication configured? |
| | | * This returns true if dsnw != dsnr |
| | | */ |
| | | function is_replicated() |
| | | { |
| | | return !empty($this->db_dsnr) && $this->db_dsnw != $this->db_dsnr; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Execute a SQL query |
| | | * |
| | | * @param string SQL query to execute |
| | |
| | | { |
| | | $params = func_get_args(); |
| | | $query = array_shift($params); |
| | | |
| | | // Support one argument of type array, instead of n arguments |
| | | if (count($params) == 1 && is_array($params[0])) |
| | | $params = $params[0]; |
| | | |
| | | return $this->_query($query, 0, 0, $params); |
| | | } |
| | |
| | | // Read or write ? |
| | | $mode = (strtolower(substr(trim($query),0,6)) == 'select') ? 'r' : 'w'; |
| | | |
| | | // don't event attempt to connect if previous write-operation failed |
| | | if ($this->write_failure && $mode == 'w') |
| | | return false; |
| | | |
| | | $this->db_connect($mode); |
| | | |
| | | // check connection before proceeding |
| | |
| | | |
| | | raise_error(array('code' => 500, 'type' => 'db', |
| | | 'line' => __LINE__, 'file' => __FILE__, |
| | | 'message' => $this->db_error_msg), true, true); |
| | | 'message' => $this->db_error_msg), true, false); |
| | | |
| | | $result = false; |
| | | } |
| | | else { |
| | | $result = $q->execute($params); |
| | | $q->free(); |
| | | } |
| | | } |
| | | |
| | | // remember that write-operation failed |
| | | if ($mode == 'w' && ($result === false || PEAR::isError($result))) |
| | | $this->write_failure = true; |
| | | |
| | | // add result, even if it's an error |
| | | return $this->_add_result($result); |
| | |
| | | */ |
| | | function num_rows($res_id=null) |
| | | { |
| | | if (!$this->db_handle) |
| | | if (!$this->db_connected) |
| | | return false; |
| | | |
| | | if ($result = $this->_get_result($res_id)) |
| | |
| | | */ |
| | | function affected_rows($res_id = null) |
| | | { |
| | | if (!$this->db_handle) |
| | | if (!$this->db_connected) |
| | | return false; |
| | | |
| | | return (int) $this->_get_result($res_id); |
| | | return $this->_get_result($res_id); |
| | | } |
| | | |
| | | |
| | |
| | | */ |
| | | function insert_id($table = '') |
| | | { |
| | | if (!$this->db_handle || $this->db_mode == 'r') |
| | | if (!$this->db_connected || $this->db_mode == 'r') |
| | | return false; |
| | | |
| | | if ($table) { |
| | |
| | | |
| | | |
| | | /** |
| | | * Wrapper for SHOW COLUMNS command |
| | | * |
| | | * @param string Table name |
| | | * @return array List of table cols |
| | | */ |
| | | function list_cols($table) |
| | | { |
| | | $this->db_handle->loadModule('Manager'); |
| | | if (!PEAR::isError($result = $this->db_handle->listTableFields($table))) { |
| | | return $result; |
| | | } |
| | | |
| | | return null; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Formats input so it can be safely used in a query |
| | | * |
| | | * @param mixed $input Value to quote |
| | |
| | | if (!$this->db_handle) |
| | | $this->db_connect('r'); |
| | | |
| | | return $this->db_handle->quote($input, $type); |
| | | return $this->db_connected ? $this->db_handle->quote($input, $type) : addslashes($input); |
| | | } |
| | | |
| | | |
| | |
| | | if (!$this->db_handle) |
| | | $this->db_connect('r'); |
| | | |
| | | return $this->db_handle->quoteIdentifier($str); |
| | | return $this->db_connected ? $this->db_handle->quoteIdentifier($str) : $str; |
| | | } |
| | | |
| | | |
| | |
| | | /** |
| | | * Return SQL statement to convert a field value into a unix timestamp |
| | | * |
| | | * This method is deprecated and should not be used anymore due to limitations |
| | | * of timestamp functions in Mysql (year 2038 problem) |
| | | * |
| | | * @param string $field Field name |
| | | * @return string SQL statement to use in query |
| | | * @access public |
| | | * @deprecated |
| | | */ |
| | | function unixtimestamp($field) |
| | | { |
| | |
| | | */ |
| | | function fromunixtime($timestamp) |
| | | { |
| | | switch($this->db_provider) { |
| | | case 'mysqli': |
| | | case 'mysql': |
| | | case 'sqlite': |
| | | return sprintf("FROM_UNIXTIME(%d)", $timestamp); |
| | | |
| | | default: |
| | | return date("'Y-m-d H:i:s'", $timestamp); |
| | | } |
| | | return date("'Y-m-d H:i:s'", $timestamp); |
| | | } |
| | | |
| | | |
| | |
| | | default: |
| | | return $this->quote_identifier($column).' LIKE '.$this->quote($value); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * Abstract SQL statement for value concatenation |
| | | * |
| | | * @return string SQL statement to be used in query |
| | | * @access public |
| | | */ |
| | | function concat(/* col1, col2, ... */) |
| | | { |
| | | $func = ''; |
| | | $args = func_get_args(); |
| | | |
| | | switch($this->db_provider) { |
| | | case 'mysql': |
| | | case 'mysqli': |
| | | $func = 'CONCAT'; |
| | | $delim = ', '; |
| | | break; |
| | | case 'mssql': |
| | | case 'sqlsrv': |
| | | $delim = ' + '; |
| | | break; |
| | | default: |
| | | $delim = ' || '; |
| | | } |
| | | |
| | | return $func . '(' . join($delim, $args) . ')'; |
| | | } |
| | | |
| | | |
| | |
| | | */ |
| | | private function _sqlite_prepare() |
| | | { |
| | | include_once('include/rcube_sqlite.inc'); |
| | | include_once(INSTALL_PATH . 'program/include/rcube_sqlite.inc'); |
| | | |
| | | // we emulate via callback some missing MySQL function |
| | | sqlite_create_function($this->db_handle->connection, |
| | |
| | | 'md5', 'rcube_sqlite_md5'); |
| | | } |
| | | |
| | | } // end class rcube_db |
| | | |
| | | |
| | | /* this is our own debug handler for the MDB2 connection */ |
| | | function mdb2_debug_handler(&$db, $scope, $message, $context = array()) |
| | | { |
| | | if ($scope != 'prepare') { |
| | | $debug_output = sprintf('%s(%d): %s;', |
| | | $scope, $db->db_index, rtrim($message, ';')); |
| | | write_log('sql', $debug_output); |
| | | /** |
| | | * Debug handler for the MDB2 |
| | | */ |
| | | function debug_handler(&$db, $scope, $message, $context = array()) |
| | | { |
| | | if ($scope != 'prepare') { |
| | | $debug_output = sprintf('%s(%d): %s;', |
| | | $scope, $db->db_index, rtrim($message, ';')); |
| | | write_log('sql', $debug_output); |
| | | } |
| | | } |
| | | } |
| | | |
| | | } // end class rcube_db |