From a403cdacf07656c0bbeb2c6bf00557070ef826ba Mon Sep 17 00:00:00 2001 From: thomascube <thomas@roundcube.net> Date: Tue, 04 Apr 2006 17:40:13 -0400 Subject: [PATCH] Added Lithuanian localization --- program/include/rcube_db.inc | 79 ++++++++++++++++++++++++++++++--------- 1 files changed, 60 insertions(+), 19 deletions(-) diff --git a/program/include/rcube_db.inc b/program/include/rcube_db.inc index e54dcc9..5731688 100755 --- a/program/include/rcube_db.inc +++ b/program/include/rcube_db.inc @@ -35,7 +35,7 @@ * @package RoundCube Webmail * @author David Saez Padros <david@ols.es> * @author Thomas Bruederli <roundcube@gmail.com> - * @version 1.14 + * @version 1.17 * @link http://pear.php.net/package/DB */ class rcube_db @@ -45,6 +45,9 @@ var $db_connected = false; // Already connected ? var $db_mode = ''; // Connection mode var $db_handle = 0; // Connection handle + var $db_pconn = false; // Use persistent connections + var $db_error = false; + var $db_error_msg = ''; var $a_query_results = array('dummy'); var $last_res_id = 0; @@ -56,13 +59,14 @@ * @param string DSN for read/write operations * @param string Optional DSN for read only operations */ - function __construct($db_dsnw, $db_dsnr='') + function __construct($db_dsnw, $db_dsnr='', $pconn=false) { if ($db_dsnr=='') $db_dsnr=$db_dsnw; $this->db_dsnw = $db_dsnw; $this->db_dsnr = $db_dsnr; + $this->db_pconn = $pconn; $dsn_array = DB::parseDSN($db_dsnw); $this->db_provider = $dsn_array['phptype']; @@ -74,20 +78,10 @@ * * @see rcube_db::__construct */ - function rcube_db($db_dsnw,$db_dsnr='') + function rcube_db($db_dsnw, $db_dsnr='', $pconn=false) { - $this->__construct($db_dsnw,$db_dsnr); + $this->__construct($db_dsnw, $db_dsnr); } - - - /** - * Object destructor - */ - function __destruct() - { - // before closing the database connection, write session data - session_write_close(); - } /** @@ -100,12 +94,17 @@ function dsn_connect($dsn) { // Use persistent connections if available - $dbh = DB::connect($dsn, array('persistent' => TRUE)); + $dbh = DB::connect($dsn, array('persistent' => $this->db_pconn)); if (DB::isError($dbh)) { + $this->db_error = TRUE; + $this->db_error_msg = $dbh->getMessage(); + raise_error(array('code' => 500, 'type' => 'db', 'line' => __LINE__, 'file' => __FILE__, - 'message' => $dbh->getMessage()), TRUE, FALSE); + 'message' => $this->db_error_msg), TRUE, FALSE); + + return FALSE; } else if ($this->db_provider=='sqlite') @@ -152,7 +151,18 @@ $dsn = $this->db_dsnw; $this->db_handle = $this->dsn_connect($dsn); - $this->db_connected = true; + $this->db_connected = $this->db_handle ? TRUE : FALSE; + } + + + /** + * Getter for error state + * + * @param boolean True on error + */ + function is_error() + { + return $this->db_error ? $this->db_error_msg : FALSE; } @@ -213,6 +223,9 @@ $mode='w'; $this->db_connect($mode); + + if (!$this->db_connected) + return FALSE; if ($this->db_provider == 'sqlite') $this->_sqlite_prepare(); @@ -314,7 +327,35 @@ function fetch_assoc($res_id=NULL) { $result = $this->_get_result($res_id); + return $this->_fetch_row($result, DB_FETCHMODE_ASSOC); + } + + /** + * Get an index array for one row + * If no query handle is specified, the last query will be taken as reference + * + * @param number Optional query handle identifier + * @return mixed Array with col values or FALSE on failure + * @access public + */ + function fetch_array($res_id=NULL) + { + $result = $this->_get_result($res_id); + return $this->_fetch_row($result, DB_FETCHMODE_ORDERED); + } + + + /** + * Get co values for a result row + * + * @param object Query result handle + * @param number Fetch mode identifier + * @return mixed Array with col values or FALSE on failure + * @access private + */ + function _fetch_row($result, $mode) + { if (DB::isError($result)) { raise_error(array('code' => 500, 'type' => 'db', 'line' => __LINE__, 'file' => __FILE__, @@ -322,9 +363,9 @@ return FALSE; } - return $result->fetchRow(DB_FETCHMODE_ASSOC); + return $result->fetchRow($mode); } - + /** * Formats input so it can be safely used in a query -- Gitblit v1.9.1