embient.db.php

Go to the documentation of this file.

<?php

require_once("embient.util.php");

class EmbientDatabase
{
  var $connection;

  var $result;

  // ---------------------------------

  var $_db_host;  

  var $_db_user;

  var $_db_pass;

  var $_db_name;

  var $_prefix;

  // ---------------------------------

  function EmbientDatabase()
  {
    $this->connection = false;
    $this->result     = NULL;

    $this->_db_host    = 'localhost';
    $this->_db_user    = 'root';
    $this->_db_pass    = '';
    $this->_db_name    = '';
    $this->_prefix     = '';
  }

  function Init($cfg)
  {
    if ( $this->connection != false )
    {
      $this->Disconnect();
    }

    $this->connection = false;
    $this->result     = false;

    $this->_db_host = $cfg['db_host'];
    $this->_db_user = $cfg['db_user'];
    $this->_db_pass = $cfg['db_passwd'];
    $this->_db_name = $cfg['db_name'];
    $this->_prefix  = $cfg['prefix'];

    // connect to database!
    return $this->Connect();
  }

  function Connect()
  {
    if ( $this->connection != false )
    {
      return $this->connection;
    }

    // Check if MySQL support is present in PHP
    if (!function_exists('mysql_connect'))
    {
      embient_error("mySQL extension for PHP is not installed in this system", __FILE__, __LINE__);
      return false;
    }

    // connnect to mySQL
    $this->connection = mysql_connect($this->_db_host, $this->_db_user, $this->_db_pass);

    if ( ! $this->connection )
    {
      embient_error(mysql_error(), __FILE__, __LINE__);
      return false;
    }

    // select the database
    if ( ! mysql_select_db($this->_db_name, $this->connection) )
    {
      embient_error(mysql_error($this->connection), __FILE__, __LINE__);
      return false;
    }

    return true;
  }

  function Disconnect()
  {
    if ( $this->connection == false )
    {
      return;
    }

    // Check if MySQL support is present in PHP
    if (!function_exists('mysql_close'))
    {
      embient_error("mySQL extension for PHP is not installed in this system", __FILE__, __LINE__);
      return;
    }

    // disconnnect from mySQL
    mysql_close($this->connection);
  }

  function Query($query, $file, $line)
  {
    $this->result = mysql_query($this->_prepare($query), $this->connection);

    if ( ! mysql_errno($this->connection) )
    {
      return true;
    }

    embient_error(mysql_error($this->connection) ." (query = ". $this->_prepare($query) .")", $file, $line);
    return false;
  }

  function GetRowsCount()
  {
    if ($this->result)
    {
      return mysql_num_rows($this->result);
    }

    embient_error("Previous query is failed - cannot get rows count", __FILE__, __LINE__);
    return false;
  }

  function FetchArray()
  {
    if ($this->result)
    {
      return mysql_fetch_array($this->result, MYSQL_ASSOC);
    }

    embient_error("Previous query is failed, cannot fetch array", __FILE__, __LINE__);
    return array();
  }

  function FetchAll()
  {
    $output = array();

    if (!$this->result)
    {
      embient_error("Previous query is failed, cannot fetch array", __FILE__, __LINE__);
    }
    else
    {
      while ($row = mysql_fetch_array($this->result, MYSQL_ASSOC))
      {
        array_push($output, $row);
      }
    }

    return $output;
  }

  function FetchRow()
  {
    if ($this->result)
    {
      return mysql_fetch_row($this->result);
    }

    embient_error("Previous query is failed, cannot fetch result", __FILE__, __LINE__);
    return NULL;
  }

  function GetNextID($tablename, $idname)
  {
    $query = "LOCK TABLES $tablename WRITE";
    $this->Query($query, __FILE__, __LINE__);

    $query = "SELECT id FROM $tablename "
           . "WHERE name = '". $idname ."'";
    $this->Query($query, __FILE__, __LINE__);

    $id = 0;

    if ( $this->result && $this->GetRowsCount() >= 1)
    {
      $id = mysql_result($this->result, 0) + 1;
    }

    $query = "REPLACE INTO $tablename VALUES ('". $idname ."', '". $id ."')";
    $this->Query($query, __FILE__, __LINE__);

    $query = 'UNLOCK TABLES';
    $this->Query($query, __FILE__, __LINE__);

    return $id;
  }
  
  function _prepare($sql)
  {
    return strtr($sql, array('{' => $this->_prefix, '}' => ''));
  }
}

---