From bc8c2c57880523472b30f475d566a8133e2d2e20 Mon Sep 17 00:00:00 2001 From: alecpl <alec@alec.pl> Date: Sat, 21 May 2011 14:04:51 -0400 Subject: [PATCH] - Fix s/pattern/prefix/ in clear_cache() --- program/include/rcube_mdb2.php | 58 ++++++++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 54 insertions(+), 4 deletions(-) diff --git a/program/include/rcube_mdb2.php b/program/include/rcube_mdb2.php index 707bce0..75764c4 100644 --- a/program/include/rcube_mdb2.php +++ b/program/include/rcube_mdb2.php @@ -44,6 +44,7 @@ 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; @@ -124,7 +125,7 @@ // 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 @@ -189,6 +190,16 @@ /** + * 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 @@ -245,6 +256,10 @@ // 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 @@ -277,6 +292,10 @@ $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); @@ -315,7 +334,7 @@ if (!$this->db_connected) return false; - return (int) $this->_get_result($res_id); + return $this->_get_result($res_id); } @@ -545,9 +564,12 @@ /** * 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) { @@ -595,6 +617,34 @@ 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) . ')'; } @@ -724,7 +774,7 @@ */ 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, -- Gitblit v1.9.1