<?php

/*
 +-----------------------------------------------------------------------+
 | program/include/rcube_mysql.inc                                       |
 |                                                                       |
 | This file is part of the RoundCube Webmail client                     |
 | Copyright (C) 2005, RoundCube Dev. - Switzerland                      |
 | Licensed under the GNU GPL                                            |
 |                                                                       |
 | 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;
    }

  }


?>