wtrmln/libs/db.php

   1 <?php
   2 /********************************************************************
   3
   4   Watermelon CMS
   5
   6 Copyright 2008-2009 Radosław Pietruszewski
   7
   8 This program is free software; you can redistribute it and/or
   9 modify it under the terms of the GNU General Public License
  10 version 2 as published by the Free Software Foundation.
  11
  12 This program is distributed in the hope that it will be useful,
  13 but WITHOUT ANY WARRANTY; without even the implied warranty of
  14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15 GNU General Public License for more details.
  16
  17 You should have received a copy of the GNU General Public License
  18 along with this program; if not, write to the Free Software
  19 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  20
  21 ********************************************************************/
  22
  23 /*
  24  * Lib DB
  25  * wersja 2.2.2
  26  *
  27  * Komunikacja z bazą danych
  28  *
  29  */
  30
  31 class DB
  32 {
  33    /*
  34     * public static uint $queriesCounter
  35     *
  36     * licznik zapytań (liczba wykonanych zapytań)
  37     */
  38    public static $queriesCounter = 0;
  39
  40    /*
  41     * public static array $errorList
  42     *
  43     * lista (log) błędów. Przydatne w debbugowaniu
  44     *
  45     * $errorList = array(string $error[, string $error[, ...]])
  46     *   $error = treść błędu
  47     */
  48
  49    public static $errorList = array();
  50
  51    /*
  52     * private static mysql_link $link
  53     *
  54     * resource bazy danych (zwracany przez mysql_connect)
  55     */
  56
  57    private static $link;
  58
  59    /*
  60     * private static string $prefix
  61     *
  62     * prefiks nazw tabel (np. tabela 'users' wraz z prefiksem 'wcms_' to 'wcms_users')
  63     */
  64
  65    private static $prefix;
  66
  67    /*
  68     * private static string[] $queriesList
  69     *
  70     * lista wykonanych zapytań
  71     */
  72
  73    public static $queriesList = array();
  74
  75    /*
  76     * public void connect(string $host, string $user, string $pass, string $name, string $prefix)
  77     *
  78     * Łączy z bazą danych $name na serwerze $host jako user $user o haśle $pass z prefisami tabel $prefix
  79     */
  80    public function connect($host, $user, $pass, $name, $prefix)
  81    {
  82       self::$link = @mysql_connect($host, $user, $pass);
  83
  84       self::$prefix = $prefix;
  85
  86       if(!self::$link)
  87       {
  88          panic('Lib DB: error 0<br>nie można połączyć z bazą danych');
  89       }
  90
  91       $dbselect = @mysql_select_db($name);
  92
  93       if(!$dbselect)
  94       {
  95          panic('Lib DB: error 1<br>nie można wybrać bazy danych');
  96       }
  97    }
  98
  99    /*
 100     * public static DBresult query(string $query[, string $arg1[, string $arg2[, ...]]])
 101     *
 102     * Zapytanie do bazy danych
 103     *
 104     * Nazwy tabel podajemy poprzedzając podwójnym podkreślnikeim
 105     *
 106     * Wszystkie dane wejściowe (znaczy te, które podajemy w apostrofach) oznaczamy
 107     * jako %(cyfra), a w $arg(cyfra) podajemy zawartość tej danej
 108     *
 109     * Zwraca FALSE w przypadku porażki
 110     *
 111     * Przykład:
 112     *
 113     * DB::query("SELECT `id`, `password` FROM `__users` WHERE `nick` = '%1' AND `salt` = '%2'", 'radex', '86fcf28678ebe8a0');
 114     *
 115     * zostanie zinterpretowane (gdy DB::$prefix == 'wcms_') jako:
 116     *
 117     * "SELECT `id`, `password` FROM `wcms_users` WHERE `nick` = 'radex' AND `salt` = '86fcf28678ebe8a0'"
 118     */
 119
 120    public static function query($query)
 121    {
 122       // jeśli jakaś nazwa tabeli w "panie kopniętym" zaczyna się od
 123       // podwójnego podkreślnika, zamienia na prefix
 124
 125       $query = str_replace('`__', '`' . self::$prefix, $query);
 126
 127       // podmieniamy argumenty
 128
 129       $numargs = func_num_args();
 130       $arg_list = func_get_args();
 131
 132       for($i = 1; $i < $numargs; $i++)
 133       {
 134          $query = str_replace('%' . $i, $arg_list[$i], $query);
 135       }
 136
 137       // inkrementujemy licznik zapytań
 138
 139       self::$queriesCounter++;
 140
 141       // zapisujemy zapytanie, jeśli tryb debug
 142
 143       if(defined('DEBUG'))
 144       {
 145          self::$queriesList[] = $query;
 146       }
 147
 148       // wykonujemy zapytanie
 149
 150       $queryResult = mysql_query($query);
 151
 152       if($queryResult)
 153       {
 154          return new DBresult($queryResult);
 155       }
 156       else
 157       {
 158          self::$errorList[] = mysql_error();
 159
 160          panic('Nieudane wykonanie zapytania. Błąd: ' . self::lastError());
 161
 162          return false;
 163       }
 164    }
 165
 166    /*
 167     * public static string[] errorList()
 168     *
 169     * Zwraca listę błędów
 170     */
 171
 172    public static function errorList()
 173    {
 174       return self::$errorList;
 175    }
 176
 177    /*
 178     * public static string lastError()
 179     *
 180     * Zwraca ostatni napotkany błąd
 181     */
 182
 183    public static function lastError()
 184    {
 185       return end(self::$errorList);
 186    }
 187
 188    /*
 189     * public static uint queries()
 190     *
 191     * Zwraca liczbę wykonanych zapytań
 192     */
 193
 194    public static function queries()
 195    {
 196       return self::$queriesCounter;
 197    }
 198
 199    /*
 200     * public static int insert_id()
 201     *
 202     * zwraca ID ostatnio dodanego elementu
 203     */
 204
 205    public static function insert_id()
 206    {
 207       return mysql_insert_id();
 208    }
 209
 210    /*
 211     * public static string[] queriesList()
 212     *
 213     * zwraca listę zapytań gdy włączony
 214     * tryb DEBUG, w przeciwnym wypadku
 215     * zwraca false
 216     */
 217
 218    public static function queriesList()
 219    {
 220       if(defined('DEBUG'))
 221       {
 222          return self::$queriesList;
 223       }
 224       else
 225       {
 226          return false;
 227       }
 228    }
 229 }
 230
 231 ############
 232 ############
 233 ############
 234
 235 class DBresult
 236 {
 237    /*
 238     * public mysql_result $res
 239     *
 240     * resource zwrócony przez DB::query()
 241     */
 242    public $res;
 243
 244    /*
 245     * public void DBresult(mysql_result $res)
 246     *
 247     * Ustawia $this->res
 248     */
 249    public function DBresult($res)
 250    {
 251       $this->res = $res;
 252    }
 253
 254    /*
 255     * public int num_rows()
 256     *
 257     * Zwraca ilość znalezionych wyników
 258     */
 259
 260    public function num_rows()
 261    {
 262       return mysql_num_rows($this->res);
 263    }
 264
 265    /*
 266     * public object to_obj()
 267     *
 268     * Zwraca dane w postaci obiektu
 269     */
 270
 271    public function to_obj()
 272    {
 273       return mysql_fetch_object($this->res);
 274    }
 275
 276    /*
 277     * public array to_array()
 278     *
 279     * Zwraca dane w postaci tablicy
 280     */
 281
 282    public function to_array()
 283    {
 284       return mysql_fetch_array($this->res);
 285    }
 286
 287    /*
 288     * public bool exists()
 289     *
 290     * Zwraca true, gdy element istnieje, false w przeciwnym wypadku
 291     */
 292
 293    public function exists()
 294    {
 295       return (mysql_num_rows($this->res) == 0) ? false : true;
 296    }
 297 }
 298
 299 ?>