Initial revision

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