summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorthomascube <thomas@roundcube.net>2011-05-20 18:35:08 +0000
committerthomascube <thomas@roundcube.net>2011-05-20 18:35:08 +0000
commit10ea10a3177fb59caac13adc44cfbc4b5e6ff8dd (patch)
tree6cc5d73143415137bfc77ed30750d5fe8f85cbae
parentccc059fd70ea4eb5a279d0603b21a54328bf9251 (diff)
Catch write-errors on database (yet untested)
-rw-r--r--program/include/rcube_mdb2.php21
1 files changed, 20 insertions, 1 deletions
diff --git a/program/include/rcube_mdb2.php b/program/include/rcube_mdb2.php
index 691c75de9..75764c497 100644
--- a/program/include/rcube_mdb2.php
+++ b/program/include/rcube_mdb2.php
@@ -44,6 +44,7 @@ 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;
@@ -124,7 +125,7 @@ class rcube_mdb2
// 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 @@ class rcube_mdb2
/**
+ * 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 @@ class rcube_mdb2
// 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
@@ -278,6 +293,10 @@ class rcube_mdb2
}
}
+ // 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);
}