Source for file class.database.php

Documentation is available at class.database.php

  1. <?php
  2.  
  3. /**
  4.  * AVE.cms
  5.  *
  6.  * @package AVE.cms
  7.  * @filesource
  8.  */
  9.  
  10. /**
  11.  * Класс работы с результатом выполнения MySQL-запроса
  12.  */
  13. class AVE_DB_Result
  14. {
  15.  
  16. /**
  17.  *    СВОЙСТВА
  18.  */
  19.  
  20.     /**
  21.      * Результат выполнения запроса
  22.      *
  23.      * @var resource 
  24.      * @access private
  25.      */
  26.     var $_result;
  27.  
  28. /**
  29.  *    ВНУТРЕННИЕ МЕТОДЫ
  30.  */
  31.  
  32. /**
  33.  *    ВНЕШНИЕ МЕТОДЫ
  34.  */
  35.  
  36.     /**
  37.      * Конструктор, возвращает объект с указателем на результат выполнения SQL-запроса
  38.      *
  39.      * @param resource $result    указателем на результат выполнения SQL-запроса
  40.      * @return object AVE_DB_Result 
  41.      * @access public
  42.      */
  43.     function AVE_DB_Result($result)
  44.     {
  45.         $this->_result = $result;
  46.     }
  47.  
  48.     /**
  49.      * Обрабатывает ряд результата запроса, возвращая ассоциативный массив и численный массив
  50.      *
  51.      * @return array 
  52.      * @access public
  53.      */
  54.     function FetchArray()
  55.     {
  56.         return @mysql_fetch_array($this->_result);
  57.     }
  58.  
  59.     /**
  60.      *  Обрабатывает ряд результата запроса и возвращает ассоциативный массив
  61.      *
  62.      * @return array 
  63.      * @access public
  64.      */
  65.     function FetchAssocArray()
  66.     {
  67.         return @mysql_fetch_array($this->_result, MYSQL_ASSOC);
  68.     }
  69.  
  70.     /**
  71.      * Обрабатывает ряд результата запроса и возвращает объект
  72.      *
  73.      * @return object 
  74.      * @access public
  75.      */
  76.     function FetchRow()
  77.     {
  78.         return @mysql_fetch_object($this->_result);
  79.     }
  80.  
  81.     /**
  82.      * Возвращает данные результата запроса
  83.      *
  84.      * @return mixed 
  85.      * @access public
  86.      */
  87.     function GetCell()
  88.     {
  89.         if ($this->NumRows())
  90.         {
  91.             return @mysql_result($this->_result, 0);
  92.         }
  93.         return false;
  94.     }
  95.  
  96.     /**
  97.      * Перемещает внутренний указатель в результате запроса
  98.      *
  99.      * @param int $id - номер ряда результатов запроса
  100.      * @return bool 
  101.      * @access public
  102.      */
  103.     function DataSeek($id = 0)
  104.     {
  105.         return @mysql_data_seek($this->_result, $id);
  106.     }
  107.  
  108.     /**
  109.      * Возвращает количество рядов результата запроса
  110.      *
  111.      * @return int 
  112.      * @access public
  113.      */
  114.     function NumRows()
  115.     {
  116.         return @mysql_num_rows($this->_result);
  117.     }
  118.  
  119.     /**
  120.      * Возвращает количество полей результата запроса
  121.      *
  122.      * @return int 
  123.      * @access public
  124.      */
  125.     function NumFields()
  126.     {
  127.         return mysql_num_fields($this->_result);
  128.     }
  129.  
  130.     /**
  131.      * Возвращает название указанной колонки результата запроса
  132.      *
  133.      * @param int $i - индекс колонки
  134.      * @return string 
  135.      * @access public
  136.      */
  137.     function FieldName($i)
  138.     {
  139.         return mysql_field_name($this->_result, $i);
  140.     }
  141.  
  142.     /**
  143.      * Освобождает память от результата запроса
  144.      *
  145.      * @return bool 
  146.      * @access public
  147.      */
  148.     function Close()
  149.     {
  150.         $r = @mysql_free_result($this->_result);
  151.         unset($this);
  152.         return $r;
  153.     }
  154. }
  155.  
  156. /**
  157.  * Класс работы с MySQL
  158.  */
  159. class AVE_DB
  160. {
  161.  
  162. /**
  163.  *    СВОЙСТВА
  164.  */
  165.  
  166.     /**
  167.      * Идентификатор соединения с БД
  168.      *
  169.      * @var DbStateHandler 
  170.      * @access private
  171.      */
  172.     var $_handle;
  173.  
  174.     /**
  175.      * Список выполненных запросов
  176.      *
  177.      * @var array 
  178.      * @access private
  179.      */
  180.     var $_query_list;
  181.  
  182.     /**
  183.      * Метки времени до и после выполнения SQL-запроса
  184.      *
  185.      * @var array 
  186.      * @access private
  187.      */
  188.     var $_time_exec;
  189.  
  190. /**
  191.  *    ВНУТРЕННИЕ МЕТОДЫ
  192.  */
  193.  
  194.     /**
  195.      * Конструктор
  196.      *
  197.      * @param string $host    адрес сервера
  198.      * @param string $user    имя пользователя
  199.      * @param string $pass    пароль
  200.      * @param string $db    имя БД
  201.      * @return object        AVE_DB - объект
  202.      * @access public
  203.      */
  204.     function AVE_DB($host, $user, $pass, $db)
  205.     {
  206.         if (! $this->_handle = @mysql_connect($host, $user, $pass))
  207.         {
  208.             $this->_error('connect');
  209.             return false;
  210.         }
  211.  
  212.         if (! @mysql_select_db($db, $this->_handle))
  213.         {
  214.             $this->_error('select');
  215.             return false;
  216.         }
  217.  
  218.         if (function_exists('mysql_set_charset'))
  219.         {
  220.             mysql_set_charset('cp1251', $this->_handle);
  221.         }
  222.         else
  223.         {
  224.             mysql_query("SET NAMES 'cp1251'");
  225.         }
  226.  
  227.         if (defined('PROFILING') && PROFILING)
  228.         {
  229. //            mysql_query("QUERY_CACHE_TYPE = OFF");
  230. //            mysql_query("FLUSH TABLES");
  231.             mysql_query("SET PROFILING_HISTORY_SIZE = 100");
  232.             mysql_query("SET PROFILING = 1");
  233.         }
  234.  
  235.         return true;
  236.     }
  237.  
  238.     /**
  239.      * Получить функцию из которой пришел запрос с ошибкой
  240.      *
  241.      * @return string 
  242.      */
  243.     function get_caller()
  244.     {
  245.         if (! function_exists('debug_backtrace')) return '';
  246.  
  247.         $stack = debug_backtrace();
  248.         $stack = array_reverse($stack);
  249.  
  250.         $caller = array();
  251.         foreach ((array)$stack as $call)
  252.         {
  253.             if (@$call['class'] == __CLASS__) continue;
  254.             $function = $call['function'];
  255.             if (isset($call['class']))
  256.             {
  257.                 $function = $call['class'] . "->$function";
  258.             }
  259.             $caller[] = (isset($call['file']) ? 'FILE: ' . $call['file'] . ' ' : '')
  260.                         . 'FUNCTION: ' . $function
  261.                         . (isset($call['line']) ? ' LINE: ' . $call['line'] : '');
  262.         }
  263.  
  264.         return implode(', ', $caller);
  265.     }
  266.  
  267.     /**
  268.      * Обработка ошибок
  269.      *
  270.      * @param string $type - тип ошибки
  271.      *          (при подключении к БД или при выполнении SQL-запроса)
  272.      * @param string $query - текст SQL запроса вызвавшего ошибку
  273.      * @access private
  274.      */
  275.     function _error($type, $query = '')
  276.     {
  277.         if ($type != 'query')
  278.         {
  279.             display_notice('Error ' . $type . ' MySQL database. <br />');
  280.         }
  281.         else
  282.         {
  283.             $my_error = mysql_error();
  284.  
  285.             reportLog('SQL ERROR: ' . $my_error . PHP_EOL
  286.                     . "\t\tQUERY: " . stripslashes($query) . PHP_EOL
  287.                     . "\t\t"        . $this->get_caller() . PHP_EOL
  288.                     . "\t\tURL: "   . HOST . $_SERVER['SCRIPT_NAME']
  289.                                     . '?' . $_SERVER['QUERY_STRING'] . PHP_EOL
  290.             );
  291.             if (SEND_SQL_ERROR)
  292.             {
  293.                 $mail_body = ('SQL ERROR: ' . $my_error . PHP_EOL
  294.                     . 'TIME: '  . date('d-m-Y, H:i:s') . PHP_EOL
  295.                     . 'URL: '   . HOST . $_SERVER['SCRIPT_NAME']
  296.                                 . '?' . $_SERVER['QUERY_STRING'] . PHP_EOL
  297.                     . $this->get_caller() . PHP_EOL
  298.                     . 'QUERY: ' . stripslashes($query) . PHP_EOL
  299.                 );
  300.                 send_mail(
  301.                     get_settings('mail_from'),
  302.                     $mail_body,
  303.                     'MySQL Error!',
  304.                     get_settings('mail_from'),
  305.                     get_settings('mail_from_name'),
  306.                     'text'
  307.                 );
  308.             }
  309.         }
  310.     }
  311.  
  312. /**
  313.  *    ВНЕШНИЕ МЕТОДЫ
  314.  */
  315.  
  316.     /**
  317.      * Посылает запрос MySQL
  318.      *
  319.      * @param string $query - текст SQL-запроса
  320.      * @return object - объект с указателем на результат выполнения запроса
  321.      * @access public
  322.      */
  323.     function Query($query)
  324.     {
  325. //        $this->_time_exec[] = microtime();
  326.         $res = @mysql_query($query, $this->_handle);
  327. //        $this->_time_exec[] = microtime();
  328. //        $this->_query_list[] = $query;
  329.         if (!$res) $this->_error('query', $query);
  330.  
  331.         return new AVE_DB_Result($res);
  332.     }
  333.  
  334.     /**
  335.      * Экранирует специальные символы в строках для использования в выражениях SQL
  336.      *
  337.      * @param mixed $value - обрабатываемое значение
  338.      * @return mixed 
  339.      * @access public
  340.      */
  341.     function Escape($value)
  342.     {
  343.         if (!is_numeric($value))
  344.         {
  345.             $value = function_exists('mysql_real_escape_string')
  346.                 ? mysql_real_escape_string($value, $this->_handle)
  347.                 : mysql_escape_string($value);
  348.         }
  349.  
  350.         return $value;
  351.     }
  352.  
  353.     /**
  354.      * Возвращает ID, сгенерированный при последнем INSERT-запросе
  355.      *
  356.      * @return int 
  357.      * @access public
  358.      */
  359.     function InsertId()
  360.     {
  361.         return mysql_insert_id($this->_handle);
  362.     }
  363.  
  364.     /**
  365.      * Статистика выполнения SQL-запросов
  366.      *
  367.      * @param string $type - тип запрашиваемой статистики
  368.      *  <pre>
  369.      *  Возможные значения:
  370.      *      list  - список выполненых зпаросов
  371.      *      time  - время исполнения зпросов
  372.      *      count - количество выполненных запросов
  373.      *  </pre>
  374.      * @return mixed 
  375.      * @access public
  376.      */
  377.     function DBStatisticGet($type = '')
  378.     {
  379.         switch ($type)
  380.         {
  381.             case 'list':
  382.                 list($s_dec, $s_sec) = explode(' ', $GLOBALS['start_time']);
  383.                 $query_list = '';
  384.                 $nq = 0;
  385.                 $time_exec = 0;
  386.                 $arr = $this->_time_exec;
  387.                 $co = sizeof($arr);
  388.                 for ($it=0;$it<$co;)
  389.                 {
  390.                     list($a_dec, $a_sec) = explode(' ', $arr[$it++]);
  391.                     list($b_dec, $b_sec) = explode(' ', $arr[$it++]);
  392.                     $time_main = ($a_sec - $s_sec + $a_dec - $s_dec)*1000;
  393.                     $time_exec = ($b_sec - $a_sec + $b_dec - $a_dec)*1000;
  394.                     $query = sizeof(array_keys($this->_query_list, $this->_query_list[$nq])) > 1
  395.                         ? "<span style=\"background-color:#ff9;\">" . $this->_query_list[$nq++] . "</span>"
  396.                         : $this->_query_list[$nq++];
  397.                     $query_list .= (($time_exec > 1) ? "<li style=\"color:#c00\">(" : "<li>(")
  398.                         . round($time_main) . " ms) " . $time_exec . " ms " . $query . "</li>\n";
  399.                 }
  400.  
  401.                 return $query_list;
  402.                 break;
  403.  
  404.             case 'time':
  405.                 $arr = $this->_time_exec;
  406.                 $time_exec = 0;
  407.                 $co = sizeof($arr);
  408.                 for ($it=0;$it<$co;) {
  409.                     list($a_dec, $a_sec) = explode(" ", $arr[$it++]);
  410.                     list($b_dec, $b_sec) = explode(" ", $arr[$it++]);
  411.                     $time_exec += $b_sec - $a_sec + $b_dec - $a_dec;
  412.                 }
  413.  
  414.                 return $time_exec;
  415.                 break;
  416.  
  417.             case 'count':
  418.                 return sizeof($this->_query_list);
  419.                 break;
  420.  
  421.             default:
  422.                 return '';
  423.                 break;
  424.         }
  425.     }
  426.  
  427.     /**
  428.      * Статистика выполнения SQL-запросов
  429.      *
  430.      * @param string $type - тип запрашиваемой статистики
  431.      *  <pre>
  432.      *  Возможные значения:
  433.      *      list  - список выполненых зпаросов
  434.      *      time  - время исполнения зпросов
  435.      *      count - количество выполненных запросов
  436.      *  </pre>
  437.      * @return mixed 
  438.      * @access public
  439.      */
  440.     function DBProfilesGet($type = '')
  441.     {
  442.         static $result, $list, $time, $count;
  443.  
  444.         if (!(defined('PROFILING') && PROFILING)) return false;
  445.  
  446.         if (!$result)
  447.         {
  448.             $list = "<table width=\"100%\">"
  449.                 . "\n\t<col width=\"20\">\n\t<col width=\"70\">";
  450.             $result = mysql_query("SHOW PROFILES");
  451.             while (list($qid, $qtime, $qstring) = mysql_fetch_row($result))
  452.             {
  453.                 $time += $qtime;
  454.                 $list .= "\n\t<tr>\n\t\t<td><strong>"
  455.                     . $qid
  456.                     . "</strong></td>\n\t\t<td><strong>"
  457.                     . number_format($qtime * 1, 6, ',', '')
  458.                     . "</strong></td>\n\t\t<td><strong>"
  459.                     . $qstring
  460.                     . "</strong></td>\n\t</tr>";
  461.                 $res = mysql_query("
  462.                     SELECT STATE, FORMAT(DURATION, 6) AS DURATION
  463.                     FROM INFORMATION_SCHEMA.PROFILING
  464.                     WHERE QUERY_ID = " . $qid
  465.                 );
  466.                 while (list($state, $duration) = mysql_fetch_row($res))
  467.                 {
  468.                     $list .= "\n\t<tr>\n\t\t<td>&nbsp;</td><td>"
  469.                         . number_format($duration * 1, 6, ',', '')
  470.                         . "</td>\n\t\t<td>" . $state . "</td>\n\t</tr>";
  471.                 }
  472.             }
  473.             $time = number_format($time * 1, 6, ',', '');
  474.             $list .= "\n</table>";
  475.             $count = mysql_num_rows($result);
  476.         }
  477.  
  478.         switch ($type)
  479.         {
  480.             case 'list':  return $list;  break;
  481.             case 'time':  return $time;  break;
  482.             case 'count': return $count; break;
  483.         }
  484.  
  485.         return false;
  486.     }
  487.  
  488.     /**
  489.      * Возвращает информацию о сервере MySQL
  490.      *
  491.      * @return string 
  492.      * @access public
  493.      */
  494.     function mysql_version()
  495.     {
  496.         return  mysql_get_server_info($this->_handle);
  497.     }
  498. }
  499.  
  500. global $AVE_DB;
  501.  
  502. if (! isset($AVE_DB))
  503. {
  504.     require(BASE_DIR . '/inc/db.config.php');
  505.  
  506.     if (! isset($config)) exit;
  507.  
  508.     if (! defined('PREFIX')) define('PREFIX', $config['dbpref']);
  509.  
  510.     $AVE_DB = new AVE_DB($config['dbhost'], $config['dbuser'], $config['dbpass'], $config['dbname']);
  511.  
  512.     unset($config);
  513. }
  514.  
  515. ?>

Documentation generated on Fri, 04 Jun 2010 18:01:33 +0400 by phpDocumentor 1.4.3