summaryrefslogtreecommitdiff
path: root/program/include/rcube_mysql.inc
diff options
context:
space:
mode:
authorthomascube <thomas@roundcube.net>2005-09-25 14:18:03 +0000
committerthomascube <thomas@roundcube.net>2005-09-25 14:18:03 +0000
commit4e17e6c9dbac8991ee8b302cb2581241247dc8bc (patch)
treed877546f6bd334b041734498e81f6299e005b01c /program/include/rcube_mysql.inc
Initial revision
Diffstat (limited to 'program/include/rcube_mysql.inc')
-rw-r--r--program/include/rcube_mysql.inc186
1 files changed, 186 insertions, 0 deletions
diff --git a/program/include/rcube_mysql.inc b/program/include/rcube_mysql.inc
new file mode 100644
index 000000000..bcffe5e2b
--- /dev/null
+++ b/program/include/rcube_mysql.inc
@@ -0,0 +1,186 @@
+<?php
+
+/*
+ +-----------------------------------------------------------------------+
+ | program/include/rcube_mysql.inc |
+ | |
+ | This file is part of the RoundCube Webmail client |
+ | Copyright (C) 2005, RoundCube Dev. - Switzerland |
+ | All rights reserved. |
+ | |
+ | PURPOSE: |
+ | MySQL wrapper class that implements PHP MySQL functions |
+ | See http://www.php.net/manual/en/ref.mysql.php |
+ | |
+ +-----------------------------------------------------------------------+
+ | Author: Thomas Bruederli <roundcube@gmail.com> |
+ +-----------------------------------------------------------------------+
+
+ $Id$
+
+*/
+
+
+class rcube_mysql
+ {
+ var $db_link;
+ var $db_host = 'localhost';
+ var $db_name = '';
+ var $db_user = '';
+ var $db_pass = '';
+ var $a_query_results = array('dummy');
+ var $last_res_id = 0;
+
+
+ // PHP 5 constructor
+ function __construct($db_name='', $user='', $pass='', $host='localhost')
+ {
+ $this->db_host = $host;
+ $this->db_name = $db_name;
+ $this->db_user = $user;
+ $this->db_pass = $pass;
+ }
+
+ // PHP 4 compatibility
+ function rcube_mysql($db_name='', $user='', $pass='', $host='localhost')
+ {
+ $this->__construct($db_name, $user, $pass, $host);
+ }
+
+
+ function connect()
+ {
+ $this->db_link = mysql_connect($this->db_host, $this->db_user, $this->db_pass);
+
+ if (!$this->db_link)
+ {
+ raise_error(array('code' => 500,
+ 'type' => 'mysql',
+ 'line' => __LINE__,
+ 'file' => __FILE__,
+ 'message' => "Can't connect to database"), TRUE, FALSE);
+ return FALSE;
+ }
+
+ return TRUE;
+ }
+
+
+ function select_db($name)
+ {
+ $this->db_name = $name;
+
+ if ($this->db_link)
+ mysql_select_db($name, $this->db_link);
+ }
+
+
+ function query($query)
+ {
+ // establish a connection
+ if (!$this->db_link)
+ {
+ if (!$this->connect())
+ return FALSE;
+ }
+
+ $sql_result = mysql_db_query($this->db_name, $query, $this->db_link);
+ return $this->_add_result($sql_result, $query);
+ }
+
+
+ function num_rows($res_id=NULL)
+ {
+ if (!$this->db_link)
+ return FALSE;
+
+ $sql_result = $this->_get_result($res_id);
+
+ if ($sql_result)
+ return mysql_num_rows($sql_result);
+ else
+ return FALSE;
+ }
+
+
+ function affected_rows()
+ {
+ if (!$this->db_link)
+ return FALSE;
+
+ return mysql_affected_rows($this->db_link);
+ }
+
+
+ function insert_id()
+ {
+ if (!$this->db_link)
+ return FALSE;
+
+ return mysql_insert_id($this->db_link);
+ }
+
+
+ function fetch_assoc($res_id=NULL)
+ {
+ $sql_result = $this->_get_result($res_id);
+
+ if ($sql_result)
+ return mysql_fetch_assoc($sql_result);
+ else
+ return FALSE;
+ }
+
+
+ function seek($res_id=NULL, $row=0)
+ {
+ $sql_result = $this->_get_result($res_id);
+
+ if ($sql_result)
+ return mysql_data_seek($sql_result, $row);
+ else
+ return FALSE;
+ }
+
+
+
+ function _add_result($res, $query)
+ {
+ // sql error occured
+ if ($res===FALSE)
+ {
+ $sql_error = mysql_error($this->db_link);
+ raise_error(array('code' => 500,
+ 'type' => 'mysql',
+ 'line' => __LINE__,
+ 'file' => __FILE__,
+ 'message' => $sql_error."; QUERY: ".preg_replace('/[\r\n]+\s*/', ' ', $query)), TRUE, FALSE);
+
+ return FALSE;
+ }
+ else
+ {
+ $res_id = sizeof($this->a_query_results);
+ $this->a_query_results[$res_id] = $res;
+ $this->last_res_id = $res_id;
+
+ return $res_id;
+ }
+ }
+
+
+ function _get_result($res_id)
+ {
+ if ($res_id===NULL)
+ $res_id = $this->last_res_id;
+
+ if ($res_id && isset($this->a_query_results[$res_id]))
+ return $this->a_query_results[$res_id];
+ else
+ return FALSE;
+ }
+
+ }
+
+
+?> \ No newline at end of file