<?php
/**
 * Observium
 *
 *   This file is part of Observium.
 *
 * @package        observium
 * @subpackage     db
 * @copyright  (C) Adam Armstrong
 *
 */

print_error("MySQL extension is deprecated since PHP 5.5, we unsupported it anymore. Use mysqli extension instead!");

/*
This code based on original non-OO version of dbFacile version 0.4.3
written by Alan Szlosek from http://www.greaterscope.net/projects/dbFacile
and licensed by the MIT license http://en.wikipedia.org/wiki/MIT_License

Many part of code rewritten by Observium developers.

It's a bit simplistic, but gives you the really useful bits in non-class form.
*/

/* Specific mysql function calls. */

/**
 * Get MySQL client info
 *
 * @return string $info
 */
function dbClientInfo()
{
    return mysql_get_client_info();
}

/**
 * Returns a string representing the type of connection used
 *
 * @return string $info
 */
function dbHostInfo()
{
    return mysql_get_host_info();
}

/**
 * Open connection to mysql server
 *
 * @param string $host     Hostname for mysql server, default 'localhost'
 * @param string $user     Username for connect to mysql server
 * @param string $password Username password
 * @param string $database Database name
 * @param string $charset  Charset used for mysql connection, default 'utf8'
 *
 * @return resource $connection
 */
function dbOpen($host = 'localhost', $user, $password, $database, $charset = 'utf8')
{
    // Check host params
    $host_array = explode(':', $host);
    if (count($host_array) > 1) {
        if ($host_array[0] === 'p') {
            // This is for compatability with new style host option (from mysqli extension)
            // p:example.com
            // p:::1
            array_shift($host_array);
            $host                               = implode(':', $host_array);
            $GLOBALS['config']['db_persistent'] = TRUE;
        } elseif (count($host_array) === 2) {
            // IPv6 host not possible here
            $host = $host_array[0];
            if (is_numeric($host_array[1])) {
                // example.com:3306
                $port = $host_array[1];
            } else {
                // example.com:/tmp/mysql.sock
                $socket = $host_array[1];
            }
        }
    }

    switch ($host) {
        case 'localhost':
        case '127.0.0.1':
        case '::1':
        case '':
            // For localhost socket prefer
            if (strlen($GLOBALS['config']['db_socket'])) {
                $host .= ':' . $GLOBALS['config']['db_socket'];
            } elseif (strlen($socket)) {
                $host .= ':' . $socket;
            } elseif (is_numeric($GLOBALS['config']['db_port'])) {
                $host .= ':' . $GLOBALS['config']['db_port'];
            } elseif (is_numeric($port)) {
                $host .= ':' . $port;
            }
            break;
        default:
            // All other host uses only port
            if (is_numeric($GLOBALS['config']['db_port'])) {
                $host .= ':' . $GLOBALS['config']['db_port'];
            } elseif (is_numeric($port)) {
                $host .= ':' . $port;
            }
    }

    $client_flags = 0;
    // Optionally compress connection
    if ($GLOBALS['config']['db_compress'] && defined('MYSQL_CLIENT_COMPRESS')) {
        $client_flags |= MYSQL_CLIENT_COMPRESS;
    }

    if ($GLOBALS['config']['db_persistent'] && ini_get('mysql.allow_persistent')) {
        // Open a persistent connection
        $connection = mysql_pconnect($host, $user, $password, $client_flags);
    } else {
        // force opening a new link because we might be selecting a different database
        $connection = mysql_connect($host, $user, $password, TRUE, $client_flags);
    }

    if ($connection) {
        if (mysql_select_db($database, $connection)) {
            // Connected to DB
            if ($charset) {
                mysql_set_charset($charset, $connection);
            }
        } else {
            // DB not exist, reset $connection
            if (OBS_DEBUG) {
                echo('MySQL connection error ' . mysql_errno() . ': ' . mysql_error($connection) . PHP_EOL);
            }
            return NULL;
        }
    }

    return $connection;
}

/**
 * Closes a previously opened database connection
 *
 * @param resource $connection Link to resource with mysql connection, default last used connection
 *
 * @return bool Returns TRUE on success or FALSE on failure.
 */
function dbClose($connection = NULL)
{
    if (is_resource($connection)) {
        return mysql_close($connection);
    } else {
        return mysql_close();
    }
}

/**
 * Returns the text of the error message from last MySQL operation
 *
 * @param resource $connection Link to resource with mysql connection, default last used connection
 *
 * @return string $return
 */
function dbError($connection = NULL)
{
    if (is_resource($connection)) {
        return mysql_error($connection);
    } else {
        return mysql_error();
    }
}

/**
 * Returns the numerical value of the error message from last MySQL operation
 *
 * @param resource $connection Link to resource with mysql connection, default last used connection
 *
 * @return string $return
 */
function dbErrorNo($connection = NULL)
{
    if (is_resource($connection)) {
        return mysql_errno($connection);
    } else {
        return mysql_errno();
    }
}

function dbPing($connection = NULL)
{
    if (is_resource($connection)) {
        return mysql_ping($connection);
    } else {
        return mysql_ping();
    }
}

function dbAffectedRows($connection = NULL)
{
    if (is_resource($connection)) {
        return mysql_affected_rows($connection);
    } else {
        return mysql_affected_rows();
    }
}

function dbCallQuery($fullSql, $connection = NULL)
{
    if (is_resource($connection)) {
        return mysql_query($fullSql, $connection);
    } else {
        return mysql_query($fullSql);
    }
}

/**
 * Returns escaped string
 *
 * @param string $string Input string for escape in mysql query
 *
 * @return string
 */
function dbEscape($string, $connection = NULL)
{
    if (is_resource($connection)) {
        return mysql_real_escape_string($string, $connection);
    } else {
        return mysql_real_escape_string($string);
    }
}

/**
 * Returns the auto generated id used in the last query
 *
 * @param resource $connection Link to resource with mysql connection, default last used connection
 *
 * @return string
 */
function dbLastID($connection = NULL)
{
    if (is_resource($connection)) {
        return mysql_insert_id($connection);
    } else {
        return mysql_insert_id();
    }
}

/*
 * Fetches all of the rows (associatively) from the last performed query.
 * Most other retrieval functions build off this
 * */
function dbFetchRows($sql, $parameters = [], $print_query = FALSE)
{
    $time_start = utime();
    $result     = dbQuery($sql, $parameters, $print_query);

    $rows = [];
    if (mysql_num_rows($result) > 0) {
        while ($row = mysql_fetch_assoc($result)) {
            $rows[] = $row;
        }
        mysql_free_result($result);

        $time_end                             = utime();
        $GLOBALS['db_stats']['fetchrows_sec'] += $time_end - $time_start;
        $GLOBALS['db_stats']['fetchrows']++;
    }

    // no records, thus return empty array
    // which should evaluate to false, and will prevent foreach notices/warnings
    return $rows;
}

/*
 * Like fetch(), accepts any number of arguments
 * The first argument is an sprintf-ready query stringTypes
 * */
function dbFetchRow($sql = NULL, $parameters = [], $print_query = FALSE)
{
    $time_start = utime();
    $result     = dbQuery($sql, $parameters, $print_query);
    if ($result) {
        $row = mysql_fetch_assoc($result);
        mysql_free_result($result);
        $time_end = utime();

        $GLOBALS['db_stats']['fetchrow_sec'] += $time_end - $time_start;
        $GLOBALS['db_stats']['fetchrow']++;

        return $row;
    } else {
        return NULL;
    }

    //$time_start = utime();
}

/*
 * Fetches the first call from the first row returned by the query
 * */
function dbFetchCell($sql, $parameters = [], $print_query = FALSE)
{
    $time_start = utime();
    //$row = dbFetchRow($sql, $parameters);
    $result = dbQuery($sql, $parameters, $print_query);
    if ($result) {
        $row = mysql_fetch_assoc($result);
        mysql_free_result($result);
        $time_end = utime();

        $GLOBALS['db_stats']['fetchcell_sec'] += $time_end - $time_start;
        $GLOBALS['db_stats']['fetchcell']++;

        return array_shift($row); // shift first field off first row
    }

    return NULL;
}

function dbBeginTransaction()
{
    mysql_query('begin');
}

function dbCommitTransaction()
{
    mysql_query('commit');
}

function dbRollbackTransaction()
{
    mysql_query('rollback');
}

/*
class dbIterator implements Iterator {
  private $result;
  private $i;

  public function __construct($r) {
    $this->result = $r;
    $this->i = 0;
  }
  public function rewind() {
    mysql_data_seek($this->result, 0);
    $this->i = 0;
  }
  public function current() {
    $a = mysql_fetch_assoc($this->result);
    return $a;
  }
  public function key() {
    return $this->i;
  }
  public function next() {
    $this->i++;
    $a = mysql_data_seek($this->result, $this->i);
    if ($a === false) {
      $this->i = 0;
    }
    return $a;
  }
  public function valid() {
    return ($this->current() !== false);
  }
}
*/

// EOF