| | |
| | | | program/include/rcube_mdb2.php | |
| | | | | |
| | | | This file is part of the RoundCube Webmail client | |
| | | | Copyright (C) 2005-2008, RoundCube Dev. - Switzerland | |
| | | | Copyright (C) 2005-2009, RoundCube Dev. - Switzerland | |
| | | | Licensed under the GNU GPL | |
| | | | | |
| | | | PURPOSE: | |
| | |
| | | |
| | | |
| | | /** |
| | | * Connection state checker |
| | | * |
| | | * @param boolean True if in connected state |
| | | */ |
| | | function is_connected() |
| | | { |
| | | return PEAR::isError($this->db_handle) ? false : true; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Execute a SQL query |
| | | * |
| | | * @param string SQL query to execute |
| | |
| | | */ |
| | | function query() |
| | | { |
| | | if (!$this->is_connected()) |
| | | return NULL; |
| | | |
| | | $params = func_get_args(); |
| | | $query = array_shift($params); |
| | | |
| | |
| | | function _query($query, $offset, $numrows, $params) |
| | | { |
| | | // Read or write ? |
| | | if (strtolower(trim(substr($query,0,6)))=='select') |
| | | if (strtolower(substr(trim($query),0,6))=='select') |
| | | $mode='r'; |
| | | else |
| | | $mode='w'; |
| | |
| | | */ |
| | | function _fetch_row($result, $mode) |
| | | { |
| | | if ($result === FALSE || PEAR::isError($result)) |
| | | if ($result === FALSE || PEAR::isError($result) || !$this->is_connected()) |
| | | return FALSE; |
| | | |
| | | return $result->fetchRow($mode); |
| | |
| | | |
| | | |
| | | /** |
| | | * Return list of elements for use with SQL's IN clause |
| | | * |
| | | * @param string Input array |
| | | * @return string Elements list string |
| | | * @access public |
| | | */ |
| | | function array2list($arr, $type=null) |
| | | { |
| | | if (!is_array($arr)) |
| | | return $this->quote($arr, $type); |
| | | |
| | | $res = array(); |
| | | foreach ($arr as $item) |
| | | $res[] = $this->quote($item, $type); |
| | | |
| | | return implode(',', $res); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Return SQL statement to convert a field value into a unix timestamp |
| | | * |
| | | * @param string Field name |
| | |
| | | |
| | | |
| | | /** |
| | | * Encodes non-UTF-8 characters in string/array/object (recursive) |
| | | * |
| | | * @param mixed Data to fix |
| | | * @return mixed Properly UTF-8 encoded data |
| | | * @access public |
| | | */ |
| | | function encode($input) |
| | | { |
| | | if (is_object($input)) { |
| | | foreach (get_object_vars($input) as $idx => $value) |
| | | $input->$idx = $this->encode($value); |
| | | return $input; |
| | | } |
| | | else if (is_array($input)) { |
| | | foreach ($input as $idx => $value) |
| | | $input[$idx] = $this->encode($value); |
| | | return $input; |
| | | } |
| | | |
| | | return utf8_encode($input); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Decodes encoded UTF-8 string/object/array (recursive) |
| | | * |
| | | * @param mixed Input data |
| | | * @return mixed Decoded data |
| | | * @access public |
| | | */ |
| | | function decode($input) |
| | | { |
| | | if (is_object($input)) { |
| | | foreach (get_object_vars($input) as $idx => $value) |
| | | $input->$idx = $this->decode($value); |
| | | return $input; |
| | | } |
| | | else if (is_array($input)) { |
| | | foreach ($input as $idx => $value) |
| | | $input[$idx] = $this->decode($value); |
| | | return $input; |
| | | } |
| | | |
| | | return utf8_decode($input); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Adds a query result and returns a handle ID |
| | | * |
| | | * @param object Query handle |
| | |
| | | $data = file_get_contents($file_name); |
| | | |
| | | if (strlen($data)) |
| | | sqlite_exec($dbh->connection, $data); |
| | | if (!sqlite_exec($dbh->connection, $data, $error) || MDB2::isError($dbh)) |
| | | raise_error(array('code' => 500, 'type' => 'db', |
| | | 'line' => __LINE__, 'file' => __FILE__, 'message' => $error), TRUE, FALSE); |
| | | } |
| | | |
| | | |